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