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