2.78
snac.h
1/* snac - A simple, minimalistic ActivityPub instance */
2/* copyright (c) 2022 - 2025 grunfink et al. / MIT license */
3
4#define VERSION "2.78"
5
6#define USER_AGENT "snac/" VERSION
7
8#define WHAT_IS_SNAC_URL "https:/" "/comam.es/what-is-snac"
9
10#define DIR_PERM 00770
11#define DIR_PERM_ADD 02770
12
13#define ISO_DATE_SPEC "%Y-%m-%dT%H:%M:%SZ"
14
15#ifndef MAX_THREADS
16#define MAX_THREADS 256
17#endif
18
19#ifndef MAX_JSON_DEPTH
20#define MAX_JSON_DEPTH 8
21#endif
22
23#ifndef MAX_CONVERSATION_LEVELS
24#define MAX_CONVERSATION_LEVELS 48
25#endif
26
27#define MD5_HEX_SIZE 33
28
29#define MD5_ALREADY_SEEN_MARK "00000000000000000000000000000000"
30
31extern double disk_layout;
32extern xs_str *srv_basedir;
33extern xs_dict *srv_config;
34extern xs_str *srv_baseurl;
35extern xs_str *srv_proxy_token_seed;
36extern xs_dict *srv_langs;
37
38extern int dbglevel;
39
40#define L(s) lang_str((s), user)
41
42#define POSTLIKE_OBJECT_TYPE "Note|Question|Page|Article|Video|Audio|Event"
43
44int mkdirx(const char *pathname);
45
46int valid_status(int status);
47xs_str *tid(int offset);
48double ftime(void);
49
50void srv_log(xs_str *str);
51#define srv_debug(level, str) do { if (dbglevel >= (level)) \
52 { srv_log((str)); } } while (0)
53
54typedef struct {
55 xs_str *uid; /* uid */
56 xs_str *basedir; /* user base directory */
57 xs_dict *config; /* user configuration */
58 xs_dict *config_o; /* user configuration admin override */
59 xs_dict *key; /* keypair */
60 xs_dict *links; /* validated links */
61 xs_str *actor; /* actor url */
62 xs_str *md5; /* actor url md5 */
63 const xs_dict *lang;/* string translation dict */
64 const char *tz; /* configured timezone */
65} snac;
66
67typedef struct {
68 int s_size; /* struct size (for double checking) */
69 int srv_running; /* server running on/off */
70 int use_fcgi; /* FastCGI use on/off */
71 time_t srv_start_time; /* start time */
72 int job_fifo_size; /* job fifo size */
73 int peak_job_fifo_size; /* maximum job fifo size seen */
74 int n_threads; /* number of configured threads */
75 enum { THST_STOP, THST_WAIT, THST_IN, THST_QUEUE } th_state[MAX_THREADS];
76} srv_state;
77
78extern srv_state *p_state;
79
80void snac_log(snac *user, xs_str *str);
81#define snac_debug(user, level, str) do { if (dbglevel >= (level)) \
82 { snac_log((user), (str)); } } while (0)
83
84int srv_open(const char *basedir, int auto_upgrade);
85void srv_free(void);
86
87void sbox_enter(const char *basedir);
88
89int user_open(snac *snac, const char *uid);
90void user_free(snac *snac);
91xs_list *user_list(void);
92int user_open_by_md5(snac *snac, const char *md5);
93int user_persist(snac *snac, int publish);
94
95int validate_uid(const char *uid);
96
97xs_str *hash_password(const char *uid, const char *passwd, const char *nonce);
98int check_password(const char *uid, const char *passwd, const char *hash);
99
100void srv_archive(const char *direction, const char *url, xs_dict *req,
101 const char *payload, int p_size,
102 int status, xs_dict *headers,
103 const char *body, int b_size);
104void srv_archive_error(const char *prefix, const xs_str *err,
105 const xs_dict *req, const xs_val *data);
106void srv_archive_qitem(const char *prefix, xs_dict *q_item);
107
108double mtime_nl(const char *fn, int *n_link);
109#define mtime(fn) mtime_nl(fn, NULL)
110double f_ctime(const char *fn);
111
112int index_add_md5(const char *fn, const char *md5);
113int index_add(const char *fn, const char *id);
114int index_gc(const char *fn);
115int index_first(const char *fn, char md5[MD5_HEX_SIZE]);
116int index_len(const char *fn);
117xs_list *index_list(const char *fn, int max);
118int index_desc_next(FILE *f, char md5[MD5_HEX_SIZE]);
119int index_desc_first(FILE *f, char md5[MD5_HEX_SIZE], int skip);
120int index_asc_next(FILE *f, char md5[MD5_HEX_SIZE]);
121int index_asc_first(FILE *f, char md5[MD5_HEX_SIZE], const char *seek_md5);
122xs_list *index_list_desc(const char *fn, int skip, int show);
123
124int object_add(const char *id, const xs_dict *obj);
125int object_add_ow(const char *id, const xs_dict *obj);
126int object_here_by_md5(const char *id);
127int object_here(const char *id);
128int object_get_by_md5(const char *md5, xs_dict **obj);
129int object_get(const char *id, xs_dict **obj);
130int object_del(const char *id);
131int object_del_if_unref(const char *id);
132double object_ctime_by_md5(const char *md5);
133double object_ctime(const char *id);
134double object_mtime_by_md5(const char *md5);
135double object_mtime(const char *id);
136void object_touch(const char *id);
137
138int object_admire(const char *id, const char *actor, int like);
139int object_unadmire(const char *id, const char *actor, int like);
140
141int object_likes_len(const char *id);
142int object_announces_len(const char *id);
143
144xs_list *object_children(const char *id);
145xs_list *object_likes(const char *id);
146xs_list *object_announces(const char *id);
147int object_parent(const char *md5, char parent[MD5_HEX_SIZE]);
148
149int object_user_cache_add(snac *snac, const char *id, const char *cachedir);
150int object_user_cache_del(snac *snac, const char *id, const char *cachedir);
151
152int follower_add(snac *snac, const char *actor);
153int follower_del(snac *snac, const char *actor);
154int follower_check(snac *snac, const char *actor);
155xs_list *follower_list(snac *snac);
156int follower_list_len(snac *snac);
157
158int pending_add(snac *user, const char *actor, const xs_dict *msg);
159int pending_check(snac *user, const char *actor);
160xs_dict *pending_get(snac *user, const char *actor);
161void pending_del(snac *user, const char *actor);
162xs_list *pending_list(snac *user);
163int pending_count(snac *user);
164
165double timeline_mtime(snac *snac);
166int timeline_touch(snac *snac);
167int timeline_here_by_md5(snac *snac, const char *md5);
168int timeline_here(snac *snac, const char *id);
169int timeline_get_by_md5(snac *snac, const char *md5, xs_dict **msg);
170int timeline_del(snac *snac, const char *id);
171xs_str *user_index_fn(snac *user, const char *idx_name);
172xs_list *timeline_simple_list(snac *user, const char *idx_name, int skip, int show, int *more);
173xs_list *timeline_list(snac *snac, const char *idx_name, int skip, int show, int *more);
174int timeline_add(snac *snac, const char *id, const xs_dict *o_msg);
175int timeline_admire(snac *snac, const char *id, const char *admirer, int like);
176
177xs_list *timeline_top_level(snac *snac, const xs_list *list);
178void timeline_add_mark(snac *user);
179
180xs_list *local_list(snac *snac, int max);
181xs_str *instance_index_fn(void);
182xs_list *timeline_instance_list(int skip, int show);
183
184int following_add(snac *snac, const char *actor, const xs_dict *msg);
185int following_del(snac *snac, const char *actor);
186int following_check(snac *snac, const char *actor);
187int following_get(snac *snac, const char *actor, xs_dict **data);
188xs_list *following_list(snac *snac);
189int following_list_len(snac *snac);
190
191void mute(snac *snac, const char *actor);
192void unmute(snac *snac, const char *actor);
193int is_muted(snac *snac, const char *actor);
194xs_list *muted_list(snac *user);
195
196int is_bookmarked(snac *user, const char *id);
197int bookmark(snac *user, const char *id);
198int unbookmark(snac *user, const char *id);
199xs_list *bookmark_list(snac *user);
200xs_str *bookmark_index_fn(snac *user);
201
202int pin(snac *user, const char *id);
203int unpin(snac *user, const char *id);
204int is_pinned(snac *user, const char *id);
205int is_pinned_by_md5(snac *user, const char *md5);
206xs_list *pinned_list(snac *user);
207
208int is_draft(snac *user, const char *id);
209void draft_del(snac *user, const char *id);
210void draft_add(snac *user, const char *id, const xs_dict *msg);
211xs_list *draft_list(snac *user);
212
213int is_scheduled(snac *user, const char *id);
214void schedule_del(snac *user, const char *id);
215void schedule_add(snac *user, const char *id, const xs_dict *msg);
216xs_list *scheduled_list(snac *user);
217void scheduled_process(snac *user);
218
219int limited(snac *user, const char *id, int cmd);
220#define is_limited(user, id) limited((user), (id), 0)
221#define limit(user, id) limited((user), (id), 1)
222#define unlimit(user, id) limited((user), (id), 2)
223
224void hide(snac *snac, const char *id);
225int is_hidden(snac *snac, const char *id);
226
227void tag_index(const char *id, const xs_dict *obj);
228xs_str *tag_fn(const char *tag);
229xs_list *tag_search(const char *tag, int skip, int show);
230
231xs_val *list_maint(snac *user, const char *list, int op);
232xs_str *list_timeline_fn(snac *user, const char *list);
233xs_list *list_timeline(snac *user, const char *list, int skip, int show);
234xs_val *list_content(snac *user, const char *list_id, const char *actor_md5, int op);
235void list_distribute(snac *user, const char *who, const xs_dict *post);
236
237int actor_add(const char *actor, const xs_dict *msg);
238int actor_get(const char *actor, xs_dict **data);
239int actor_get_refresh(snac *user, const char *actor, xs_dict **data);
240
241int static_get(snac *snac, const char *id, xs_val **data, int *size, const char *inm, xs_str **etag);
242void static_put(snac *snac, const char *id, const char *data, int size);
243void static_put_meta(snac *snac, const char *id, const char *str);
244xs_str *static_get_meta(snac *snac, const char *id);
245
246double history_mtime(snac *snac, const char *id);
247void history_add(snac *snac, const char *id, const char *content, int size,
248 xs_str **etag);
249int history_get(snac *snac, const char *id, xs_str **content, int *size,
250 const char *inm, xs_str **etag);
251int history_del(snac *snac, const char *id);
252xs_list *history_list(snac *snac);
253
254void lastlog_write(snac *snac, const char *source);
255
256xs_str *notify_check_time(snac *snac, int reset);
257void notify_add(snac *snac, const char *type, const char *utype,
258 const char *actor, const char *objid, const xs_dict *msg);
259xs_dict *notify_get(snac *snac, const char *id);
260int notify_new_num(snac *snac);
261xs_list *notify_list(snac *snac, int skip, int show);
262void notify_clear(snac *snac);
263
264xs_dict *markers_get(snac *snac, const xs_list *markers);
265xs_dict *markers_set(snac *snac, const char *home_marker, const char *notify_marker);
266
267void inbox_add(const char *inbox);
268void inbox_add_by_actor(const xs_dict *actor);
269xs_list *inbox_list(void);
270
271int is_instance_blocked(const char *instance);
272int instance_block(const char *instance);
273int instance_unblock(const char *instance);
274
275int content_match(const char *file, const xs_dict *msg);
276xs_list *content_search(snac *user, const char *regex,
277 int priv, int skip, int show, int max_secs, int *timeout);
278
279void enqueue_input(snac *snac, const xs_dict *msg, const xs_dict *req, int retries);
280void enqueue_shared_input(const xs_dict *msg, const xs_dict *req, int retries);
281void enqueue_output_raw(const char *keyid, const char *seckey,
282 const xs_dict *msg, const xs_str *inbox,
283 int retries, int p_status);
284void enqueue_output(snac *snac, const xs_dict *msg,
285 const xs_str *inbox, int retries, int p_status);
286void enqueue_output_by_actor(snac *snac, const xs_dict *msg,
287 const xs_str *actor, int retries);
288void enqueue_email(const xs_str *msg, int retries);
289void enqueue_telegram(const xs_str *msg, const char *bot, const char *chat_id);
290void enqueue_ntfy(const xs_str *msg, const char *ntfy_server, const char *ntfy_token);
291void enqueue_message(snac *snac, const xs_dict *msg);
292void enqueue_close_question(snac *user, const char *id, int end_secs);
293void enqueue_object_request(snac *user, const char *id, int forward_secs);
294void enqueue_verify_links(snac *user);
295void enqueue_actor_refresh(snac *user, const char *actor, int forward_secs);
296void enqueue_webmention(const xs_dict *msg);
297void enqueue_notify_webhook(snac *user, const xs_dict *noti, int retries);
298
299int was_question_voted(snac *user, const char *id);
300
301xs_list *user_queue(snac *snac);
302xs_list *queue(void);
303xs_dict *queue_get(const char *fn);
304xs_dict *dequeue(const char *fn);
305
306void purge(snac *snac);
307void purge_all(void);
308
309xs_dict *http_signed_request_raw(const char *keyid, const char *seckey,
310 const char *method, const char *url,
311 const xs_dict *headers,
312 const char *body, int b_size,
313 int *status, xs_str **payload, int *p_size,
314 int timeout);
315xs_dict *http_signed_request(snac *snac, const char *method, const char *url,
316 const xs_dict *headers,
317 const char *body, int b_size,
318 int *status, xs_str **payload, int *p_size,
319 int timeout);
320int check_signature(const xs_dict *req, xs_str **err);
321
322srv_state *srv_state_op(xs_str **fname, int op);
323void httpd(void);
324
325int webfinger_request_signed(snac *snac, const char *qs, xs_str **actor, xs_str **user);
326int webfinger_request(const char *qs, xs_str **actor, xs_str **user);
327int webfinger_request_fake(const char *qs, xs_str **actor, xs_str **user);
328int webfinger_get_handler(xs_dict *req, const char *q_path,
329 xs_val **body, int *b_size, char **ctype);
330
331const char *default_avatar_base64(void);
332
333xs_str *process_tags(snac *snac, const char *content, xs_list **tag);
334
335const char *get_atto(const xs_dict *msg);
336const char *get_in_reply_to(const xs_dict *msg);
337xs_list *get_attachments(const xs_dict *msg);
338
339xs_dict *msg_admiration(snac *snac, const char *object, const char *type);
340xs_dict *msg_repulsion(snac *user, const char *id, const char *type);
341xs_dict *msg_create(snac *snac, const xs_dict *object);
342xs_dict *msg_follow(snac *snac, const char *actor);
343
344xs_dict *msg_note(snac *snac, const xs_str *content, const xs_val *rcpts,
345 const xs_str *in_reply_to, const xs_list *attach,
346 int scope, const char *lang_str, const char *msg_date);
347
348xs_dict *msg_undo(snac *snac, const xs_val *object);
349xs_dict *msg_delete(snac *snac, const char *id);
350xs_dict *msg_actor(snac *snac);
351xs_dict *msg_update(snac *snac, const xs_dict *object);
352xs_dict *msg_ping(snac *user, const char *rcpt);
353xs_dict *msg_pong(snac *user, const char *rcpt, const char *object);
354xs_dict *msg_move(snac *user, const char *new_account);
355xs_dict *msg_accept(snac *snac, const xs_val *object, const char *to);
356xs_dict *msg_question(snac *user, const char *content, xs_list *attach,
357 const xs_list *opts, int multiple, int end_secs);
358
359int activitypub_request(snac *snac, const char *url, xs_dict **data);
360int actor_request(snac *user, const char *actor, xs_dict **data);
361int send_to_inbox_raw(const char *keyid, const char *seckey,
362 const xs_str *inbox, const xs_dict *msg,
363 xs_val **payload, int *p_size, int timeout);
364int send_to_inbox(snac *snac, const xs_str *inbox, const xs_dict *msg,
365 xs_val **payload, int *p_size, int timeout);
366xs_str *get_actor_inbox(const char *actor, int shared);
367int send_to_actor(snac *snac, const char *actor, const xs_dict *msg,
368 xs_val **payload, int *p_size, int timeout);
369int is_msg_public(const xs_dict *msg);
370int is_msg_from_private_user(const xs_dict *msg);
371int is_msg_for_me(snac *snac, const xs_dict *msg);
372
373int process_user_queue(snac *snac);
374void process_queue_item(xs_dict *q_item);
375int process_queue(void);
376
377int activitypub_get_handler(const xs_dict *req, const char *q_path,
378 char **body, int *b_size, char **ctype);
379int activitypub_post_handler(const xs_dict *req, const char *q_path,
380 char *payload, int p_size,
381 char **body, int *b_size, char **ctype);
382
383xs_dict *emojis(void);
384xs_str *format_text_with_emoji(snac *user, const char *text, int ems, const char *proxy);
385xs_str *not_really_markdown(const char *content, xs_list **attach, xs_list **tag);
386xs_str *sanitize(const char *content);
387xs_str *encode_html(const char *str);
388
389xs_str *html_timeline(snac *user, const xs_list *list, int read_only,
390 int skip, int show, int show_more,
391 const char *title, const char *page, int utl, const char *error);
392
393int html_get_handler(const xs_dict *req, const char *q_path,
394 char **body, int *b_size, char **ctype,
395 xs_str **etag, xs_str **last_modified);
396
397int html_post_handler(const xs_dict *req, const char *q_path,
398 char *payload, int p_size,
399 char **body, int *b_size, char **ctype);
400
401int write_default_css(void);
402int snac_init(const char *_basedir);
403int adduser(const char *uid);
404int resetpwd(snac *snac);
405int deluser(snac *user);
406
407extern const char *snac_blurb;
408
409void job_post(const xs_val *job, int urgent);
410void job_wait(xs_val **job);
411
412int oauth_get_handler(const xs_dict *req, const char *q_path,
413 char **body, int *b_size, char **ctype);
414int oauth_post_handler(const xs_dict *req, const char *q_path,
415 const char *payload, int p_size,
416 char **body, int *b_size, char **ctype);
417int mastoapi_get_handler(const xs_dict *req, const char *q_path,
418 char **body, int *b_size, char **ctype, xs_str **link);
419int mastoapi_post_handler(const xs_dict *req, const char *q_path,
420 const char *payload, int p_size,
421 char **body, int *b_size, char **ctype);
422int mastoapi_delete_handler(const xs_dict *req, const char *q_path,
423 const char *payload, int p_size,
424 char **body, int *b_size, char **ctype);
425int mastoapi_put_handler(const xs_dict *req, const char *q_path,
426 const char *payload, int p_size,
427 char **body, int *b_size, char **ctype);
428void persist_image(const char *key, const xs_val *data, const char *payload, snac *snac);
429int mastoapi_patch_handler(const xs_dict *req, const char *q_path,
430 const char *payload, int p_size,
431 char **body, int *b_size, char **ctype);
432void mastoapi_purge(void);
433
434void verify_links(snac *user);
435
436void export_csv(snac *user);
437int migrate_account(snac *user);
438
439void import_blocked_accounts_csv(snac *user, const char *fn);
440void import_following_accounts_csv(snac *user, const char *fn);
441void import_list_csv(snac *user, const char *fn);
442void import_csv(snac *user);
443int parse_port(const char *url, const char **errstr);
444
445typedef enum {
446#define HTTP_STATUS(code, name, text) HTTP_STATUS_ ## name = code,
447#include "http_codes.h"
448#undef HTTP_STATUS
449} http_status;
450
451const char *http_status_text(int status);
452
453typedef struct {
454 double timestamp;
455 char *text;
456} t_announcement;
457t_announcement *announcement(double after);
458
459xs_str *make_url(const char *href, const char *proxy, int by_token);
460
461int badlogin_check(const char *user, const char *addr);
462void badlogin_inc(const char *user, const char *addr);
463
464const char *lang_str(const char *str, const snac *user);
465
466xs_str *rss_from_timeline(snac *user, const xs_list *timeline,
467 const char *title, const char *link, const char *desc);
468void rss_to_timeline(snac *user, const char *url);
469void rss_poll_hashtags(void);
