2.52
snac.h
1/* snac - A simple, minimalistic ActivityPub instance */
2/* copyright (c) 2022 - 2024 grunfink et al. / MIT license */
3
4#define VERSION "2.52"
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_CONVERSATION_LEVELS
20#define MAX_CONVERSATION_LEVELS 48
21#endif
22
23extern double disk_layout;
24extern xs_str *srv_basedir;
25extern xs_dict *srv_config;
26extern xs_str *srv_baseurl;
27
28extern int dbglevel;
29
30#define L(s) (s)
31
32int mkdirx(const char *pathname);
33
34int valid_status(int status);
35xs_str *tid(int offset);
36double ftime(void);
37
38void srv_log(xs_str *str);
39#define srv_debug(level, str) do { if (dbglevel >= (level)) \
40 { srv_log((str)); } } while (0)
41
42typedef struct {
43 xs_str *uid; /* uid */
44 xs_str *basedir; /* user base directory */
45 xs_dict *config; /* user configuration */
46 xs_dict *config_o; /* user configuration admin override */
47 xs_dict *key; /* keypair */
48 xs_dict *links; /* validated links */
49 xs_str *actor; /* actor url */
50 xs_str *md5; /* actor url md5 */
51} snac;
52
53typedef struct {
54 int s_size; /* struct size (for double checking) */
55 int srv_running; /* server running on/off */
56 int use_fcgi; /* FastCGI use on/off */
57 time_t srv_start_time; /* start time */
58 int job_fifo_size; /* job fifo size */
59 int peak_job_fifo_size; /* maximum job fifo size seen */
60 int n_threads; /* number of configured threads */
61 enum { THST_STOP, THST_WAIT, THST_IN, THST_QUEUE } th_state[MAX_THREADS];
62} srv_state;
63
64extern srv_state *p_state;
65
66void snac_log(snac *user, xs_str *str);
67#define snac_debug(user, level, str) do { if (dbglevel >= (level)) \
68 { snac_log((user), (str)); } } while (0)
69
70int srv_open(char *basedir, int auto_upgrade);
71void srv_free(void);
72
73int user_open(snac *snac, const char *uid);
74void user_free(snac *snac);
75xs_list *user_list(void);
76int user_open_by_md5(snac *snac, const char *md5);
77
78int validate_uid(const char *uid);
79
80xs_str *hash_password(const char *uid, const char *passwd, const char *nonce);
81int check_password(const char *uid, const char *passwd, const char *hash);
82
83void srv_archive(const char *direction, const char *url, xs_dict *req,
84 const char *payload, int p_size,
85 int status, xs_dict *headers,
86 const char *body, int b_size);
87void srv_archive_error(const char *prefix, const xs_str *err,
88 const xs_dict *req, const xs_val *data);
89void srv_archive_qitem(char *prefix, xs_dict *q_item);
90
91double mtime_nl(const char *fn, int *n_link);
92#define mtime(fn) mtime_nl(fn, NULL)
93double f_ctime(const char *fn);
94
95int index_add_md5(const char *fn, const char *md5);
96int index_add(const char *fn, const char *id);
97int index_gc(const char *fn);
98int index_first(const char *fn, char *buf, int size);
99int index_len(const char *fn);
100xs_list *index_list(const char *fn, int max);
101xs_list *index_list_desc(const char *fn, int skip, int show);
102
103int object_add(const char *id, const xs_dict *obj);
104int object_add_ow(const char *id, const xs_dict *obj);
105int object_here_by_md5(const char *id);
106int object_here(const char *id);
107int object_get_by_md5(const char *md5, xs_dict **obj);
108int object_get(const char *id, xs_dict **obj);
109int object_del(const char *id);
110int object_del_if_unref(const char *id);
111double object_ctime_by_md5(const char *md5);
112double object_ctime(const char *id);
113double object_mtime_by_md5(const char *md5);
114double object_mtime(const char *id);
115void object_touch(const char *id);
116
117int object_admire(const char *id, const char *actor, int like);
118int object_unadmire(const char *id, const char *actor, int like);
119
120int object_likes_len(const char *id);
121int object_announces_len(const char *id);
122
123xs_list *object_children(const char *id);
124xs_list *object_likes(const char *id);
125xs_list *object_announces(const char *id);
126int object_parent(const char *id, char *buf, int size);
127
128int object_user_cache_add(snac *snac, const char *id, const char *cachedir);
129int object_user_cache_del(snac *snac, const char *id, const char *cachedir);
130
131int follower_add(snac *snac, const char *actor);
132int follower_del(snac *snac, const char *actor);
133int follower_check(snac *snac, const char *actor);
134xs_list *follower_list(snac *snac);
135
136double timeline_mtime(snac *snac);
137int timeline_touch(snac *snac);
138int timeline_here(snac *snac, const char *md5);
139int timeline_get_by_md5(snac *snac, const char *md5, xs_dict **msg);
140int timeline_del(snac *snac, char *id);
141xs_list *timeline_simple_list(snac *snac, const char *idx_name, int skip, int show);
142xs_list *timeline_list(snac *snac, const char *idx_name, int skip, int show);
143int timeline_add(snac *snac, const char *id, const xs_dict *o_msg);
144int timeline_admire(snac *snac, const char *id, const char *admirer, int like);
145
146xs_list *timeline_top_level(snac *snac, xs_list *list);
147xs_list *local_list(snac *snac, int max);
148xs_list *timeline_instance_list(int skip, int show);
149
150int following_add(snac *snac, const char *actor, const xs_dict *msg);
151int following_del(snac *snac, const char *actor);
152int following_check(snac *snac, const char *actor);
153int following_get(snac *snac, const char *actor, xs_dict **data);
154xs_list *following_list(snac *snac);
155
156void mute(snac *snac, const char *actor);
157void unmute(snac *snac, const char *actor);
158int is_muted(snac *snac, const char *actor);
159
160int pin(snac *user, const char *id);
161int unpin(snac *user, const char *id);
162int is_pinned(snac *user, const char *id);
163int is_pinned_by_md5(snac *user, const char *md5);
164xs_list *pinned_list(snac *user);
165
166int limited(snac *user, const char *id, int cmd);
167#define is_limited(user, id) limited((user), (id), 0)
168#define limit(user, id) limited((user), (id), 1)
169#define unlimit(user, id) limited((user), (id), 2)
170
171void hide(snac *snac, const char *id);
172int is_hidden(snac *snac, const char *id);
173
174void tag_index(const char *id, const xs_dict *obj);
175xs_list *tag_search(char *tag, int skip, int show);
176
177xs_val *list_maint(snac *user, const char *list, int op);
178xs_val *list_content(snac *user, const char *list_id, const char *actor_md5, int op);
179void list_distribute(snac *user, const char *who, const xs_dict *post);
180
181int actor_add(const char *actor, xs_dict *msg);
182int actor_get(const char *actor, xs_dict **data);
183int actor_get_refresh(snac *user, const char *actor, xs_dict **data);
184
185int static_get(snac *snac, const char *id, xs_val **data, int *size, const char *inm, xs_str **etag);
186void static_put(snac *snac, const char *id, const char *data, int size);
187void static_put_meta(snac *snac, const char *id, const char *str);
188xs_str *static_get_meta(snac *snac, const char *id);
189
190double history_mtime(snac *snac, const char *id);
191void history_add(snac *snac, const char *id, const char *content, int size,
192 xs_str **etag);
193int history_get(snac *snac, const char *id, xs_str **content, int *size,
194 const char *inm, xs_str **etag);
195int history_del(snac *snac, const char *id);
196xs_list *history_list(snac *snac);
197
198void lastlog_write(snac *snac, const char *source);
199
200xs_str *notify_check_time(snac *snac, int reset);
201void notify_add(snac *snac, const char *type, const char *utype,
202 const char *actor, const char *objid);
203xs_dict *notify_get(snac *snac, const char *id);
204int notify_new_num(snac *snac);
205xs_list *notify_list(snac *snac, int skip, int show);
206void notify_clear(snac *snac);
207
208void inbox_add(const char *inbox);
209void inbox_add_by_actor(const xs_dict *actor);
210xs_list *inbox_list(void);
211
212int is_instance_blocked(const char *instance);
213int instance_block(const char *instance);
214int instance_unblock(const char *instance);
215
216int content_check(const char *file, const xs_dict *msg);
217
218void enqueue_input(snac *snac, const xs_dict *msg, const xs_dict *req, int retries);
219void enqueue_shared_input(const xs_dict *msg, const xs_dict *req, int retries);
220void enqueue_output_raw(const char *keyid, const char *seckey,
221 xs_dict *msg, xs_str *inbox, int retries, int p_status);
222void enqueue_output(snac *snac, xs_dict *msg, xs_str *inbox, int retries, int p_status);
223void enqueue_output_by_actor(snac *snac, xs_dict *msg, const xs_str *actor, int retries);
224void enqueue_email(xs_str *msg, int retries);
225void enqueue_telegram(const xs_str *msg, const char *bot, const char *chat_id);
226void enqueue_ntfy(const xs_str *msg, const char *ntfy_server, const char *ntfy_token);
227void enqueue_message(snac *snac, const xs_dict *msg);
228void enqueue_close_question(snac *user, const char *id, int end_secs);
229void enqueue_object_request(snac *user, const char *id, int forward_secs);
230void enqueue_verify_links(snac *user);
231void enqueue_actor_refresh(snac *user, const char *actor);
232void enqueue_request_replies(snac *user, const char *id);
233int was_question_voted(snac *user, const char *id);
234
235xs_list *user_queue(snac *snac);
236xs_list *queue(void);
237xs_dict *queue_get(const char *fn);
238xs_dict *dequeue(const char *fn);
239
240void purge(snac *snac);
241void purge_all(void);
242
243xs_dict *http_signed_request_raw(const char *keyid, const char *seckey,
244 const char *method, const char *url,
245 xs_dict *headers,
246 const char *body, int b_size,
247 int *status, xs_str **payload, int *p_size,
248 int timeout);
249xs_dict *http_signed_request(snac *snac, const char *method, const char *url,
250 xs_dict *headers,
251 const char *body, int b_size,
252 int *status, xs_str **payload, int *p_size,
253 int timeout);
254int check_signature(xs_dict *req, xs_str **err);
255
256srv_state *srv_state_op(xs_str **fname, int op);
257void httpd(void);
258
259int webfinger_request_signed(snac *snac, const char *qs, char **actor, char **user);
260int webfinger_request(const char *qs, char **actor, char **user);
261int webfinger_get_handler(xs_dict *req, char *q_path,
262 char **body, int *b_size, char **ctype);
263
264const char *default_avatar_base64(void);
265
266xs_str *process_tags(snac *snac, const char *content, xs_list **tag);
267
268char *get_atto(const xs_dict *msg);
269xs_list *get_attachments(const xs_dict *msg);
270
271xs_dict *msg_admiration(snac *snac, char *object, char *type);
272xs_dict *msg_repulsion(snac *user, char *id, char *type);
273xs_dict *msg_create(snac *snac, const xs_dict *object);
274xs_dict *msg_follow(snac *snac, const char *actor);
275
276xs_dict *msg_note(snac *snac, const xs_str *content, const xs_val *rcpts,
277 xs_str *in_reply_to, xs_list *attach, int priv);
278
279xs_dict *msg_undo(snac *snac, char *object);
280xs_dict *msg_delete(snac *snac, char *id);
281xs_dict *msg_actor(snac *snac);
282xs_dict *msg_update(snac *snac, xs_dict *object);
283xs_dict *msg_ping(snac *user, const char *rcpt);
284xs_dict *msg_pong(snac *user, const char *rcpt, const char *object);
285xs_dict *msg_question(snac *user, const char *content, xs_list *attach,
286 const xs_list *opts, int multiple, int end_secs);
287
288int activitypub_request(snac *snac, const char *url, xs_dict **data);
289int actor_request(snac *user, const char *actor, xs_dict **data);
290void timeline_request_replies(snac *user, const char *id);
291int send_to_inbox_raw(const char *keyid, const char *seckey,
292 const xs_str *inbox, const xs_dict *msg,
293 xs_val **payload, int *p_size, int timeout);
294int send_to_inbox(snac *snac, const xs_str *inbox, const xs_dict *msg,
295 xs_val **payload, int *p_size, int timeout);
296xs_str *get_actor_inbox(const char *actor);
297int send_to_actor(snac *snac, const char *actor, const xs_dict *msg,
298 xs_val **payload, int *p_size, int timeout);
299int is_msg_public(const xs_dict *msg);
300int is_msg_from_private_user(const xs_dict *msg);
301int is_msg_for_me(snac *snac, const xs_dict *msg);
302
303int process_user_queue(snac *snac);
304void process_queue_item(xs_dict *q_item);
305int process_queue(void);
306
307int activitypub_get_handler(const xs_dict *req, const char *q_path,
308 char **body, int *b_size, char **ctype);
309int activitypub_post_handler(const xs_dict *req, const char *q_path,
310 char *payload, int p_size,
311 char **body, int *b_size, char **ctype);
312
313xs_dict *emojis(void);
314xs_str *not_really_markdown(const char *content, xs_list **attach, xs_list **tag);
315xs_str *sanitize(const char *content);
316xs_str *encode_html(const char *str);
317
318xs_str *html_timeline(snac *user, const xs_list *list, int read_only,
319 int skip, int show, int show_more,
320 char *tag, char *page, int utl);
321
322int html_get_handler(const xs_dict *req, const char *q_path,
323 char **body, int *b_size, char **ctype, xs_str **etag);
324int html_post_handler(const xs_dict *req, const char *q_path,
325 char *payload, int p_size,
326 char **body, int *b_size, char **ctype);
327xs_str *timeline_to_rss(snac *user, const xs_list *timeline, char *title, char *link, char *desc);
328
329int snac_init(const char *_basedir);
330int adduser(const char *uid);
331int resetpwd(snac *snac);
332int deluser(snac *user);
333
334extern const char *snac_blurb;
335
336void job_post(const xs_val *job, int urgent);
337void job_wait(xs_val **job);
338
339int oauth_get_handler(const xs_dict *req, const char *q_path,
340 char **body, int *b_size, char **ctype);
341int oauth_post_handler(const xs_dict *req, const char *q_path,
342 const char *payload, int p_size,
343 char **body, int *b_size, char **ctype);
344int mastoapi_get_handler(const xs_dict *req, const char *q_path,
345 char **body, int *b_size, char **ctype);
346int mastoapi_post_handler(const xs_dict *req, const char *q_path,
347 const char *payload, int p_size,
348 char **body, int *b_size, char **ctype);
349int mastoapi_delete_handler(const xs_dict *req, const char *q_path,
350 const char *payload, int p_size,
351 char **body, int *b_size, char **ctype);
352int mastoapi_put_handler(const xs_dict *req, const char *q_path,
353 const char *payload, int p_size,
354 char **body, int *b_size, char **ctype);
355void mastoapi_purge(void);
356
357void verify_links(snac *user);
