\n"); /** **/
else
s = xs_str_cat(s, "
", "\n"); xs *title = xs_str_new(NULL); int i; for (i = 0; es_title[i] && es_title[i] != '\n' && es_title[i] != '&' && i < 50; i++) title = xs_append_m(title, &es_title[i], 1); xs_html_add(channel, xs_html_tag("item", xs_html_tag("title", xs_html_text(title)), xs_html_tag("link", xs_html_text(id)), xs_html_tag("description", xs_html_text(content)))); } *body = xs_html_render_s(rss, "\n"); *b_size = strlen(*body); *ctype = "application/rss+xml; charset=utf-8"; status = 200; snac_debug(&snac, 1, xs_fmt("serving RSS")); } else status = 404; user_free(&snac); if (valid_status(status) && *ctype == NULL) { *ctype = "text/html; charset=utf-8"; } return status; } int html_post_handler(const xs_dict *req, const char *q_path, char *payload, int p_size, char **body, int *b_size, char **ctype) { (void)p_size; (void)ctype; int status = 0; snac snac; char *uid, *p_path; xs_dict *p_vars; xs *l = xs_split_n(q_path, "/", 2); uid = xs_list_get(l, 1); if (!uid || !user_open(&snac, uid)) { /* invalid user */ srv_debug(1, xs_fmt("html_post_handler bad user %s", uid)); return 404; } p_path = xs_list_get(l, 2); /* all posts must be authenticated */ if (!login(&snac, req)) { user_free(&snac); *body = xs_dup(uid); return 401; } p_vars = xs_dict_get(req, "p_vars"); #if 0 xs_json_dump(p_vars, 4, stdout); #endif if (p_path && strcmp(p_path, "admin/note") == 0) { /** **/ /* post note */ xs_str *content = xs_dict_get(p_vars, "content"); xs_str *in_reply_to = xs_dict_get(p_vars, "in_reply_to"); xs_str *attach_url = xs_dict_get(p_vars, "attach_url"); xs_list *attach_file = xs_dict_get(p_vars, "attach"); xs_str *to = xs_dict_get(p_vars, "to"); xs_str *sensitive = xs_dict_get(p_vars, "sensitive"); xs_str *summary = xs_dict_get(p_vars, "summary"); xs_str *edit_id = xs_dict_get(p_vars, "edit_id"); xs_str *alt_text = xs_dict_get(p_vars, "alt_text"); int priv = !xs_is_null(xs_dict_get(p_vars, "mentioned_only")); xs *attach_list = xs_list_new(); /* default alt text */ if (xs_is_null(alt_text)) alt_text = ""; /* is attach_url set? */ if (!xs_is_null(attach_url) && *attach_url != '\0') { xs *l = xs_list_new(); l = xs_list_append(l, attach_url); l = xs_list_append(l, alt_text); attach_list = xs_list_append(attach_list, l); } /* is attach_file set? */ if (!xs_is_null(attach_file) && xs_type(attach_file) == XSTYPE_LIST) { char *fn = xs_list_get(attach_file, 0); if (*fn != '\0') { char *ext = strrchr(fn, '.'); xs *hash = xs_md5_hex(fn, strlen(fn)); xs *id = xs_fmt("%s%s", hash, ext); xs *url = xs_fmt("%s/s/%s", snac.actor, id); int fo = xs_number_get(xs_list_get(attach_file, 1)); int fs = xs_number_get(xs_list_get(attach_file, 2)); /* store */ static_put(&snac, id, payload + fo, fs); xs *l = xs_list_new(); l = xs_list_append(l, url); l = xs_list_append(l, alt_text); attach_list = xs_list_append(attach_list, l); } } if (content != NULL) { xs *msg = NULL; xs *c_msg = NULL; xs *content_2 = xs_replace(content, "\r", ""); xs *poll_opts = NULL; /* is there a valid set of poll options? */ const char *v = xs_dict_get(p_vars, "poll_options"); if (!xs_is_null(v) && *v) { xs *v2 = xs_strip_i(xs_replace(v, "\r", "")); poll_opts = xs_split(v2, "\n"); } if (!xs_is_null(poll_opts) && xs_list_len(poll_opts)) { /* get the rest of poll configuration */ const char *p_multiple = xs_dict_get(p_vars, "poll_multiple"); const char *p_end_secs = xs_dict_get(p_vars, "poll_end_secs"); int multiple = 0; int end_secs = atoi(!xs_is_null(p_end_secs) ? p_end_secs : "60"); if (!xs_is_null(p_multiple) && strcmp(p_multiple, "on") == 0) multiple = 1; msg = msg_question(&snac, content_2, attach_list, poll_opts, multiple, end_secs); enqueue_close_question(&snac, xs_dict_get(msg, "id"), end_secs); } else msg = msg_note(&snac, content_2, to, in_reply_to, attach_list, priv); if (sensitive != NULL) { msg = xs_dict_set(msg, "sensitive", xs_stock_true); msg = xs_dict_set(msg, "summary", xs_is_null(summary) ? "..." : summary); } if (xs_is_null(edit_id)) { /* new message */ c_msg = msg_create(&snac, msg); timeline_add(&snac, xs_dict_get(msg, "id"), msg); } else { /* an edition of a previous message */ xs *p_msg = NULL; if (valid_status(object_get(edit_id, &p_msg))) { /* copy relevant fields from previous version */ char *fields[] = { "id", "context", "url", "published", "to", "inReplyTo", NULL }; int n; for (n = 0; fields[n]; n++) { char *v = xs_dict_get(p_msg, fields[n]); msg = xs_dict_set(msg, fields[n], v); } /* set the updated field */ xs *updated = xs_str_utctime(0, ISO_DATE_SPEC); msg = xs_dict_set(msg, "updated", updated); /* overwrite object, not updating the indexes */ object_add_ow(edit_id, msg); /* update message */ c_msg = msg_update(&snac, msg); } else snac_log(&snac, xs_fmt("cannot get object '%s' for editing", edit_id)); } if (c_msg != NULL) enqueue_message(&snac, c_msg); history_del(&snac, "timeline.html_"); } status = 303; } else if (p_path && strcmp(p_path, "admin/action") == 0) { /** **/ /* action on an entry */ char *id = xs_dict_get(p_vars, "id"); char *actor = xs_dict_get(p_vars, "actor"); char *action = xs_dict_get(p_vars, "action"); char *group = xs_dict_get(p_vars, "group"); if (action == NULL) return 404; snac_debug(&snac, 1, xs_fmt("web action '%s' received", action)); status = 303; if (strcmp(action, L("Like")) == 0) { /** **/ xs *msg = msg_admiration(&snac, id, "Like"); if (msg != NULL) { enqueue_message(&snac, msg); timeline_admire(&snac, xs_dict_get(msg, "object"), snac.actor, 1); } } else if (strcmp(action, L("Boost")) == 0) { /** **/ xs *msg = msg_admiration(&snac, id, "Announce"); if (msg != NULL) { enqueue_message(&snac, msg); timeline_admire(&snac, xs_dict_get(msg, "object"), snac.actor, 0); } } else if (strcmp(action, L("MUTE")) == 0) { /** **/ mute(&snac, actor); } else if (strcmp(action, L("Unmute")) == 0) { /** **/ unmute(&snac, actor); } else if (strcmp(action, L("Hide")) == 0) { /** **/ hide(&snac, id); } else if (strcmp(action, L("Limit")) == 0) { /** **/ limit(&snac, actor); } else if (strcmp(action, L("Unlimit")) == 0) { /** **/ unlimit(&snac, actor); } else if (strcmp(action, L("Follow")) == 0) { /** **/ xs *msg = msg_follow(&snac, actor); if (msg != NULL) { /* reload the actor from the message, in may be different */ actor = xs_dict_get(msg, "object"); following_add(&snac, actor, msg); enqueue_output_by_actor(&snac, msg, actor, 0); } } else if (strcmp(action, L("Unfollow")) == 0) { /** **/ /* get the following object */ xs *object = NULL; if (valid_status(following_get(&snac, actor, &object))) { xs *msg = msg_undo(&snac, xs_dict_get(object, "object")); following_del(&snac, actor); enqueue_output_by_actor(&snac, msg, actor, 0); snac_log(&snac, xs_fmt("unfollowed actor %s", actor)); } else snac_log(&snac, xs_fmt("actor is not being followed %s", actor)); } else if (strcmp(action, L("Follow Group")) == 0) { /** **/ xs *msg = msg_follow(&snac, group); if (msg != NULL) { /* reload the group from the message, in may be different */ group = xs_dict_get(msg, "object"); following_add(&snac, group, msg); enqueue_output_by_actor(&snac, msg, group, 0); } } else if (strcmp(action, L("Unfollow Group")) == 0) { /** **/ /* get the following object */ xs *object = NULL; if (valid_status(following_get(&snac, group, &object))) { xs *msg = msg_undo(&snac, xs_dict_get(object, "object")); following_del(&snac, group); enqueue_output_by_actor(&snac, msg, group, 0); snac_log(&snac, xs_fmt("unfollowed group %s", group)); } else snac_log(&snac, xs_fmt("actor is not being followed %s", actor)); } else if (strcmp(action, L("Delete")) == 0) { /** **/ char *actor_form = xs_dict_get(p_vars, "actor-form"); if (actor_form != NULL) { /* delete follower */ if (valid_status(follower_del(&snac, actor))) snac_log(&snac, xs_fmt("deleted follower %s", actor)); else snac_log(&snac, xs_fmt("error deleting follower %s", actor)); } else { /* delete an entry */ if (xs_startswith(id, snac.actor)) { /* it's a post by us: generate a delete */ xs *msg = msg_delete(&snac, id); enqueue_message(&snac, msg); snac_log(&snac, xs_fmt("posted tombstone for %s", id)); } timeline_del(&snac, id); snac_log(&snac, xs_fmt("deleted entry %s", id)); } } else if (strcmp(action, L("Pin")) == 0) { /** **/ pin(&snac, id); timeline_touch(&snac); } else if (strcmp(action, L("Unpin")) == 0) { /** **/ unpin(&snac, id); timeline_touch(&snac); } else status = 404; /* delete the cached timeline */ if (status == 303) history_del(&snac, "timeline.html_"); } else if (p_path && strcmp(p_path, "admin/user-setup") == 0) { /** **/ /* change of user data */ char *v; char *p1, *p2; if ((v = xs_dict_get(p_vars, "name")) != NULL) snac.config = xs_dict_set(snac.config, "name", v); if ((v = xs_dict_get(p_vars, "avatar")) != NULL) snac.config = xs_dict_set(snac.config, "avatar", v); if ((v = xs_dict_get(p_vars, "bio")) != NULL) snac.config = xs_dict_set(snac.config, "bio", v); if ((v = xs_dict_get(p_vars, "cw")) != NULL && strcmp(v, "on") == 0) { snac.config = xs_dict_set(snac.config, "cw", "open"); } else { /* if the checkbox is not set, the parameter is missing */ snac.config = xs_dict_set(snac.config, "cw", ""); } if ((v = xs_dict_get(p_vars, "email")) != NULL) snac.config = xs_dict_set(snac.config, "email", v); if ((v = xs_dict_get(p_vars, "telegram_bot")) != NULL) snac.config = xs_dict_set(snac.config, "telegram_bot", v); if ((v = xs_dict_get(p_vars, "telegram_chat_id")) != NULL) snac.config = xs_dict_set(snac.config, "telegram_chat_id", v); if ((v = xs_dict_get(p_vars, "purge_days")) != NULL) { xs *days = xs_number_new(atof(v)); snac.config = xs_dict_set(snac.config, "purge_days", days); } if ((v = xs_dict_get(p_vars, "drop_dm_from_unknown")) != NULL && strcmp(v, "on") == 0) snac.config = xs_dict_set(snac.config, "drop_dm_from_unknown", xs_stock_true); else snac.config = xs_dict_set(snac.config, "drop_dm_from_unknown", xs_stock_false); if ((v = xs_dict_get(p_vars, "bot")) != NULL && strcmp(v, "on") == 0) snac.config = xs_dict_set(snac.config, "bot", xs_stock_true); else snac.config = xs_dict_set(snac.config, "bot", xs_stock_false); if ((v = xs_dict_get(p_vars, "private")) != NULL && strcmp(v, "on") == 0) snac.config = xs_dict_set(snac.config, "private", xs_stock_true); else snac.config = xs_dict_set(snac.config, "private", xs_stock_false); if ((v = xs_dict_get(p_vars, "metadata")) != NULL) { /* split the metadata and store it as a dict */ xs_dict *md = xs_dict_new(); xs *l = xs_split(v, "\n"); xs_list *p = l; xs_str *kp; while (xs_list_iter(&p, &kp)) { xs *kpl = xs_split_n(kp, "=", 1); if (xs_list_len(kpl) == 2) { xs *k2 = xs_strip_i(xs_dup(xs_list_get(kpl, 0))); xs *v2 = xs_strip_i(xs_dup(xs_list_get(kpl, 1))); md = xs_dict_set(md, k2, v2); } } snac.config = xs_dict_set(snac.config, "metadata", md); } /* uploads */ const char *uploads[] = { "avatar", "header", NULL }; int n; for (n = 0; uploads[n]; n++) { xs *var_name = xs_fmt("%s_file", uploads[n]); xs_list *uploaded_file = xs_dict_get(p_vars, var_name); if (xs_type(uploaded_file) == XSTYPE_LIST) { const char *fn = xs_list_get(uploaded_file, 0); if (fn && *fn) { const char *mimetype = xs_mime_by_ext(fn); if (xs_startswith(mimetype, "image/")) { const char *ext = strrchr(fn, '.'); xs *hash = xs_md5_hex(fn, strlen(fn)); xs *id = xs_fmt("%s%s", hash, ext); xs *url = xs_fmt("%s/s/%s", snac.actor, id); int fo = xs_number_get(xs_list_get(uploaded_file, 1)); int fs = xs_number_get(xs_list_get(uploaded_file, 2)); /* store */ static_put(&snac, id, payload + fo, fs); snac.config = xs_dict_set(snac.config, uploads[n], url); } } } } /* password change? */ if ((p1 = xs_dict_get(p_vars, "passwd1")) != NULL && (p2 = xs_dict_get(p_vars, "passwd2")) != NULL && *p1 && strcmp(p1, p2) == 0) { xs *pw = hash_password(snac.uid, p1, NULL); snac.config = xs_dict_set(snac.config, "passwd", pw); } xs *fn = xs_fmt("%s/user.json", snac.basedir); xs *bfn = xs_fmt("%s.bak", fn); FILE *f; rename(fn, bfn); if ((f = fopen(fn, "w")) != NULL) { xs_json_dump(snac.config, 4, f); fclose(f); } else rename(bfn, fn); history_del(&snac, "timeline.html_"); xs *a_msg = msg_actor(&snac); xs *u_msg = msg_update(&snac, a_msg); enqueue_message(&snac, u_msg); status = 303; } else if (p_path && strcmp(p_path, "admin/clear-notifications") == 0) { /** **/ notify_clear(&snac); timeline_touch(&snac); status = 303; } else if (p_path && strcmp(p_path, "admin/vote") == 0) { /** **/ char *irt = xs_dict_get(p_vars, "irt"); const char *opt = xs_dict_get(p_vars, "question"); const char *actor = xs_dict_get(p_vars, "actor"); xs *ls = NULL; /* multiple choices? */ if (xs_type(opt) == XSTYPE_LIST) ls = xs_dup(opt); else { ls = xs_list_new(); ls = xs_list_append(ls, opt); } xs_list *p = ls; xs_str *v; while (xs_list_iter(&p, &v)) { xs *msg = msg_note(&snac, "", actor, irt, NULL, 1); /* set the option */ msg = xs_dict_append(msg, "name", v); xs *c_msg = msg_create(&snac, msg); enqueue_message(&snac, c_msg); timeline_add(&snac, xs_dict_get(msg, "id"), msg); } status = 303; } if (status == 303) { char *redir = xs_dict_get(p_vars, "redir"); if (xs_is_null(redir)) redir = "top"; *body = xs_fmt("%s/admin#%s", snac.actor, redir); *b_size = strlen(*body); } user_free(&snac); return status; }
\n"); /** **/
/** post header **/
xs_html *score;
xs_html *post_header = xs_html_tag("div",
xs_html_attr("class", "snac-post-header"),
score = xs_html_tag("div",
xs_html_attr("class", "snac-score")));
if (user && is_pinned(user, id)) {
/* add a pin emoji */
xs_html_add(score,
xs_html_tag("span",
xs_html_attr("title", L("Pinned")),
xs_html_raw(" 📌 ")));
}
if (strcmp(type, "Question") == 0) {
/* add the ballot box emoji */
xs_html_add(score,
xs_html_tag("span",
xs_html_attr("title", L("Poll")),
xs_html_raw(" 🗳 ")));
if (user && was_question_voted(user, id)) {
/* add a check to show this poll was voted */
xs_html_add(score,
xs_html_tag("span",
xs_html_attr("title", L("Voted")),
xs_html_raw(" ✓ ")));
}
}
/* if it's a user from this same instance, add the score */
if (xs_startswith(id, srv_baseurl)) {
int n_likes = object_likes_len(id);
int n_boosts = object_announces_len(id);
/* alternate emojis: %d 👍 %d 🔁 */
xs *s1 = xs_fmt("%d ★ %d ↺\n", n_likes, n_boosts);
xs_html_add(score,
xs_html_raw(s1));
}
if (boosts == NULL)
boosts = object_announces(id);
if (xs_list_len(boosts)) {
/* if somebody boosted this, show as origin */
char *p = xs_list_get(boosts, -1);
xs *actor_r = NULL;
if (user && xs_list_in(boosts, user->md5) != -1) {
/* we boosted this */
xs_html_add(post_header,
xs_html_tag("div",
xs_html_attr("class", "snac-origin"),
xs_html_tag("a",
xs_html_attr("href", user->actor),
xs_html_text(xs_dict_get(user->config, "name"))),
xs_html_text(" "),
xs_html_text(L("boosted"))));
}
else
if (valid_status(object_get_by_md5(p, &actor_r))) {
xs *name = actor_name(actor_r);
if (!xs_is_null(name)) {
xs_html_add(post_header,
xs_html_tag("div",
xs_html_attr("class", "snac-origin"),
xs_html_tag("a",
xs_html_attr("href", xs_dict_get(actor_r, "id")),
xs_html_raw(name)), /* already sanitized */
xs_html_text(" "),
xs_html_text(L("boosted"))));
}
}
}
else
if (strcmp(type, "Note") == 0) {
if (level == 0) {
/* is the parent not here? */
char *parent = xs_dict_get(msg, "inReplyTo");
if (user && !xs_is_null(parent) && *parent && !timeline_here(user, parent)) {
xs_html_add(post_header,
xs_html_tag("div",
xs_html_attr("class", "snac-origin"),
xs_html_text(L("in reply to")),
xs_html_text(" "),
xs_html_tag("a",
xs_html_attr("href", parent),
xs_html_text("»"))));
}
}
}
xs_html_add(post_header,
html_msg_icon(msg));
{
xs *s1 = xs_html_render(post_header);
s = xs_str_cat(s, s1);
}
/** post content **/
s = xs_str_cat(s, "\n
\n");
return xs_str_cat(os, s);
}
xs_html *html_footer(void)
{
return xs_html_tag("div",
xs_html_attr("class", "snac-footer"),
xs_html_tag("a",
xs_html_attr("href", srv_baseurl),
xs_html_text(L("about this site"))),
xs_html_text(" - "),
xs_html_text(L("powered by ")),
xs_html_tag("a",
xs_html_attr("href", WHAT_IS_SNAC_URL),
xs_html_tag("abbr",
xs_html_attr("title", "Social Network Are Crap"),
xs_html_text("snac"))));
}
xs_str *html_timeline(snac *user, const xs_list *list, int local,
int skip, int show, int show_more, char *tag)
/* returns the HTML for the timeline */
{
xs_str *s = xs_str_new(NULL);
xs_list *p = (xs_list *)list;
char *v;
double t = ftime();
if (user)
s = html_user_header(user, s, local);
else
s = html_instance_header(s, tag);
if (user && !local) {
xs_html *h = html_top_controls(user);
xs *s1 = xs_html_render(h);
s = xs_str_cat(s, s1);
}
s = xs_str_cat(s, "\n");
s = xs_str_cat(s, "\n"); /** **/
if (!xs_is_null(v = xs_dict_get(msg, "name"))) {
xs *es1 = encode_html(v);
xs *s1 = xs_fmt("
")) c = xs_crop_i(c, 0, -4); c = xs_replace_i(c, "
", "![](\"%s\")
", u, n);
c = xs_replace_i(c, n, img);
}
}
}
}
if (strcmp(type, "Question") == 0) { /** question content **/
xs_list *oo = xs_dict_get(msg, "oneOf");
xs_list *ao = xs_dict_get(msg, "anyOf");
xs_list *p;
xs_dict *v;
int closed = 0;
xs_html *poll = xs_html_tag("div", NULL);
if (xs_dict_get(msg, "closed"))
closed = 2;
else
if (user && xs_startswith(id, user->actor))
closed = 1; /* we questioned; closed for us */
else
if (user && was_question_voted(user, id))
closed = 1; /* we already voted; closed for us */
/* get the appropriate list of options */
p = oo != NULL ? oo : ao;
if (closed || user == NULL) {
/* closed poll */
xs_html *poll_result = xs_html_tag("table",
xs_html_attr("class", "snac-poll-result"));
while (xs_list_iter(&p, &v)) {
char *name = xs_dict_get(v, "name");
xs_dict *replies = xs_dict_get(v, "replies");
if (name && replies) {
char *ti = (char *)xs_number_str(xs_dict_get(replies, "totalItems"));
xs_html_add(poll_result,
xs_html_tag("tr",
xs_html_tag("td",
xs_html_text(name),
xs_html_text(":")),
xs_html_tag("td",
xs_html_text(ti))));
}
}
xs_html_add(poll,
poll_result);
}
else {
/* poll still active */
xs *vote_action = xs_fmt("%s/admin/vote", user->actor);
xs_html *form;
xs_html *poll_form = xs_html_tag("div",
xs_html_attr("class", "snac-poll-form"),
form = xs_html_tag("form",
xs_html_attr("autocomplete", "off"),
xs_html_attr("method", "post"),
xs_html_attr("action", vote_action),
xs_html_sctag("input",
xs_html_attr("type", "hidden"),
xs_html_attr("name", "actor"),
xs_html_attr("value", actor)),
xs_html_sctag("input",
xs_html_attr("type", "hidden"),
xs_html_attr("name", "irt"),
xs_html_attr("value", id))));
while (xs_list_iter(&p, &v)) {
char *name = xs_dict_get(v, "name");
xs_dict *replies = xs_dict_get(v, "replies");
if (name) {
char *ti = (char *)xs_number_str(xs_dict_get(replies, "totalItems"));
xs_html_add(form,
xs_html_sctag("input",
xs_html_attr("type", !xs_is_null(oo) ? "radio" : "checkbox"),
xs_html_attr("id", name),
xs_html_attr("value", name),
xs_html_attr("name", "question")),
xs_html_text(" "),
xs_html_tag("span",
xs_html_attr("title", ti),
xs_html_text(name)),
xs_html_sctag("br", NULL));
}
}
xs_html_add(form,
xs_html_tag("p", NULL),
xs_html_sctag("input",
xs_html_attr("type", "submit"),
xs_html_attr("class", "button"),
xs_html_attr("value", L("Vote"))));
xs_html_add(poll,
poll_form);
}
/* if it's *really* closed, say it */
if (closed == 2) {
xs_html_add(poll,
xs_html_tag("p",
xs_html_text(L("Closed"))));
}
else {
/* show when the poll closes */
char *end_time = xs_dict_get(msg, "endTime");
if (!xs_is_null(end_time)) {
time_t t0 = time(NULL);
time_t t1 = xs_parse_iso_date(end_time, 0);
if (t1 > 0 && t1 > t0) {
time_t diff_time = t1 - t0;
xs *tf = xs_str_time_diff(diff_time);
char *p = tf;
/* skip leading zeros */
for (; *p == '0' || *p == ':'; p++);
xs_html_add(poll,
xs_html_tag("p",
xs_html_text(L("Closes in")),
xs_html_text(" "),
xs_html_text(p)));
}
}
}
xs *s1 = xs_html_render(poll);
c = xs_str_cat(c, s1);
}
s = xs_str_cat(s, c);
}
s = xs_str_cat(s, "\n");
/* add the attachments */
v = xs_dict_get(msg, "attachment");
if (!xs_is_null(v)) { /** attachments **/
xs *attach = NULL;
/* ensure it's a list */
if (xs_type(v) == XSTYPE_DICT) {
attach = xs_list_new();
attach = xs_list_append(attach, v);
}
else
if (xs_type(v) == XSTYPE_LIST)
attach = xs_dup(v);
else
attach = xs_list_new();
/* does the message have an image? */
if (xs_type(v = xs_dict_get(msg, "image")) == XSTYPE_DICT) {
/* add it to the attachment list */
attach = xs_list_append(attach, v);
}
/* make custom css for attachments easier */
xs_html *content_attachments = xs_html_tag("div",
xs_html_attr("class", "snac-content-attachments"));
xs_list *p = attach;
while (xs_list_iter(&p, &v)) {
char *t = xs_dict_get(v, "mediaType");
if (xs_is_null(t))
t = xs_dict_get(v, "type");
if (xs_is_null(t))
continue;
char *url = xs_dict_get(v, "url");
if (xs_is_null(url))
url = xs_dict_get(v, "href");
if (xs_is_null(url))
continue;
/* infer MIME type from non-specific attachments */
if (xs_list_len(attach) < 2 && xs_match(t, "Link|Document")) {
char *mt = (char *)xs_mime_by_ext(url);
if (xs_match(mt, "image/*|audio/*|video/*")) /* */
t = mt;
}
char *name = xs_dict_get(v, "name");
if (xs_is_null(name))
name = xs_dict_get(msg, "name");
if (xs_is_null(name))
name = L("No description");
if (xs_startswith(t, "image/") || strcmp(t, "Image") == 0) {
xs_html_add(content_attachments,
xs_html_tag("a",
xs_html_attr("href", url),
xs_html_attr("target", "_blank"),
xs_html_sctag("img",
xs_html_attr("loading", "lazy"),
xs_html_attr("src", url),
xs_html_attr("alt", name),
xs_html_attr("title", name))));
}
else
if (xs_startswith(t, "video/")) {
xs_html_add(content_attachments,
xs_html_tag("video",
xs_html_attr("style", "width: 100%"),
xs_html_attr("class", "snac-embedded-video"),
xs_html_attr("controls", NULL),
xs_html_attr("src", url),
xs_html_text(L("Video")),
xs_html_text(": "),
xs_html_tag("a",
xs_html_attr("href", url),
xs_html_text(name))));
}
else
if (xs_startswith(t, "audio/")) {
xs_html_add(content_attachments,
xs_html_tag("audio",
xs_html_attr("style", "width: 100%"),
xs_html_attr("class", "snac-embedded-audio"),
xs_html_attr("controls", NULL),
xs_html_attr("src", url),
xs_html_text(L("Audio")),
xs_html_text(": "),
xs_html_tag("a",
xs_html_attr("href", url),
xs_html_text(name))));
}
else
if (strcmp(t, "Link") == 0) {
xs_html_add(content_attachments,
xs_html_tag("p",
xs_html_tag("a",
xs_html_attr("href", url),
xs_html_text(url))));
}
else {
xs_html_add(content_attachments,
xs_html_tag("p",
xs_html_tag("a",
xs_html_attr("href", url),
xs_html_text(L("Attachment")),
xs_html_text(": "),
xs_html_text(url))));
}
}
{
xs *s1 = xs_html_render(content_attachments);
s = xs_str_cat(s, s1);
}
}
/* has this message an audience (i.e., comes from a channel or community)? */
const char *audience = xs_dict_get(msg, "audience");
if (strcmp(type, "Page") == 0 && !xs_is_null(audience)) {
xs *es1 = encode_html(audience);
xs *s1 = xs_fmt("
\n");
/** controls **/
if (!local && user) {
xs_html *h = html_entry_controls(user, msg, md5);
xs *s1 = xs_html_render(h);
s = xs_str_cat(s, s1);
}
/** children **/
if (!hide_children) {
xs *children = object_children(id);
int left = xs_list_len(children);
if (left) {
char *p, *cmd5;
int older_open = 0;
xs *ss = xs_str_new(NULL);
int n_children = 0;
ss = xs_str_cat(ss, "%s
\n", es1); s = xs_str_cat(s, s1); } /* is it sensitive? */ if (user && xs_type(xs_dict_get(msg, "sensitive")) == XSTYPE_TRUE) { if (xs_is_null(v = xs_dict_get(msg, "summary")) || *v == '\0') v = "..."; /* only show it when not in the public timeline and the config setting is "open" */ char *cw = xs_dict_get(user->config, "cw"); if (xs_is_null(cw) || local) cw = ""; xs *es1 = encode_html(v); xs *s1 = xs_fmt("%s [%s]
\n", cw, es1, L("SENSITIVE CONTENT")); s = xs_str_cat(s, s1); sensitive = 1; } #if 0 { xs *md5 = xs_md5_hex(id, strlen(id)); xs *s1 = xs_fmt("%s
")) c = xs_crop_i(c, 0, -4); c = xs_replace_i(c, "
", "
"); if (!xs_startswith(c, "
")) { xs *s1 = c; c = xs_fmt("
%s
", s1); } /* replace the :shortnames: */ if (!xs_is_null(p = xs_dict_get(msg, "tag"))) { xs *tag = NULL; if (xs_type(p) == XSTYPE_DICT) { /* not a list */ tag = xs_list_new(); tag = xs_list_append(tag, p); } else if (xs_type(p) == XSTYPE_LIST) tag = xs_dup(p); else tag = xs_list_new(); xs_list *tags = tag; /* iterate the tags */ while (xs_list_iter(&tags, &v)) { char *t = xs_dict_get(v, "type"); if (t && strcmp(t, "Emoji") == 0) { char *n = xs_dict_get(v, "name"); char *i = xs_dict_get(v, "icon"); if (n && i) { char *u = xs_dict_get(i, "url"); xs *img = xs_fmt("(%s)
\n", audience, L("Source channel or community"), es1); s = xs_str_cat(s, s1); } if (sensitive) s = xs_str_cat(s, "\n"); s = xs_str_cat(s, "
...
\n"); if (level < 4) ss = xs_str_cat(ss, "
\n");
else
ss = xs_str_cat(ss, "
\n\n");
if (left > 3) {
xs *s1 = xs_fmt("\n");
older_open = 0;
}
if (chd != NULL && xs_is_null(xs_dict_get(chd, "name"))) {
ss = html_entry(user, ss, chd, local, level + 1, cmd5, hide_children);
n_children++;
}
else
srv_debug(2, xs_fmt("cannot read child %s", cmd5));
left--;
}
if (older_open)
ss = xs_str_cat(ss, "\n");
ss = xs_str_cat(ss, "
\n");
ss = xs_str_cat(ss, "\n");
if (n_children)
s = xs_str_cat(s, ss);
}
}
s = xs_str_cat(s, "%s
\n", L("Older...")); ss = xs_str_cat(ss, s1); older_open = 1; } p = children; while (xs_list_iter(&p, &cmd5)) { xs *chd = NULL; if (user) timeline_get_by_md5(user, cmd5, &chd); else object_get_by_md5(cmd5, &chd); if (older_open && left <= 3) { ss = xs_str_cat(ss, "\n");
while (xs_list_iter(&p, &v)) {
xs *msg = NULL;
int status;
if (user && !is_pinned_by_md5(user, v))
status = timeline_get_by_md5(user, v, &msg);
else
status = object_get_by_md5(v, &msg);
if (!valid_status(status))
continue;
/* if it's an instance page, discard private users */
if (user == NULL && xs_startswith(xs_dict_get(msg, "id"), srv_baseurl)) {
const char *atto = xs_dict_get(msg, "attributedTo");
xs *l = xs_split(atto, "/");
const char *uid = xs_list_get(l, -1);
snac user;
int skip = 1;
if (uid && user_open(&user, uid)) {
if (xs_type(xs_dict_get(user.config, "private")) != XSTYPE_TRUE)
skip = 0;
user_free(&user);
}
if (skip)
continue;
}
s = html_entry(user, s, msg, local, 0, v, user ? 0 : 1);
}
s = xs_str_cat(s, "
\n");
if (list && user && local) {
if (xs_type(xs_dict_get(srv_config, "disable_history")) == XSTYPE_TRUE) {
s = xs_str_cat(s, "\n");
}
else {
xs *s1 = xs_fmt(
"\n"
"
\n");
}
}
{
xs *s1 = xs_fmt("\n", ftime() - t);
s = xs_str_cat(s, s1);
}
if (show_more) {
xs *t = NULL;
xs *m = NULL;
xs *ss = xs_fmt("skip=%d&show=%d", skip + show, show);
if (tag) {
t = xs_fmt("%s?t=%s", srv_baseurl, tag);
m = xs_fmt("%s&%s", t, ss);
}
else {
t = xs_fmt("%s%s", user ? user->actor : srv_baseurl, local ? "" : "/admin");
m = xs_fmt("%s?%s", t, ss);
}
xs *s1 = xs_fmt(
"\n",
t, L("Back to top"),
m, L("More...")
);
s = xs_str_cat(s, s1);
}
{
xs_html *h = html_footer();
xs *s1 = xs_html_render(h);
s = xs_str_cat(s, s1);
}
s = xs_str_cat(s, "\n\n");
return s;
}
xs_html *html_people_list(snac *snac, xs_list *list, char *header, char *t)
{
xs_html *snac_posts;
xs_html *people = xs_html_tag("div",
xs_html_tag("h2",
xs_html_attr("class", "snac-header"),
xs_html_text(header)),
snac_posts = xs_html_tag("div",
xs_html_attr("class", "snac-posts")));
xs_list *p = list;
char *actor_id;
while (xs_list_iter(&p, &actor_id)) {
xs *md5 = xs_md5_hex(actor_id, strlen(actor_id));
xs *actor = NULL;
if (valid_status(actor_get(actor_id, &actor))) {
xs_html *snac_post = xs_html_tag("div",
xs_html_attr("class", "snac-post"),
xs_html_tag("div",
xs_html_attr("class", "snac-post-header"),
html_actor_icon(actor, xs_dict_get(actor, "published"), NULL, NULL, 0)));
/* content (user bio) */
char *c = xs_dict_get(actor, "summary");
if (!xs_is_null(c)) {
xs *sc = sanitize(c);
xs_html *snac_content = xs_html_tag("div",
xs_html_attr("class", "snac-content"));
if (xs_startswith(sc, "%s
- \n",
L("History")
);
s = xs_str_cat(s, s1);
xs *list = history_list(user);
char *p, *v;
p = list;
while (xs_list_iter(&p, &v)) {
xs *fn = xs_replace(v, ".html", "");
xs *s1 = xs_fmt(
"
- %s \n", user->actor, v, fn); s = xs_str_cat(s, s1); } s = xs_str_cat(s, "
")) xs_html_add(snac_content, xs_html_raw(sc)); /* already sanitized */ else xs_html_add(snac_content, xs_html_tag("p", xs_html_raw(sc))); /* already sanitized */ xs_html_add(snac_post, snac_content); } /* buttons */ xs *btn_form_action = xs_fmt("%s/admin/action", snac->actor); xs_html *snac_controls = xs_html_tag("div", xs_html_attr("class", "snac-controls")); xs_html *form = xs_html_tag("form", xs_html_attr("autocomplete", "off"), xs_html_attr("method", "post"), xs_html_attr("action", btn_form_action), xs_html_sctag("input", xs_html_attr("type", "hidden"), xs_html_attr("name", "actor"), xs_html_attr("value", actor_id)), xs_html_sctag("input", xs_html_attr("type", "hidden"), xs_html_attr("name", "actor-form"), xs_html_attr("value", "yes"))); xs_html_add(snac_controls, form); if (following_check(snac, actor_id)) { xs_html_add(form, html_button("unfollow", L("Unfollow"), L("Stop following this user's activity"))); if (is_limited(snac, actor_id)) xs_html_add(form, html_button("unlimit", L("Unlimit"), L("Allow announces (boosts) from this user"))); else xs_html_add(form, html_button("limit", L("Limit"), L("Block announces (boosts) from this user"))); } else { xs_html_add(form, html_button("follow", L("Follow"), L("Start following this user's activity"))); if (follower_check(snac, actor_id)) xs_html_add(form, html_button("delete", L("Delete"), L("Delete this user"))); } if (is_muted(snac, actor_id)) xs_html_add(form, html_button("unmute", L("Unmute"), L("Stop blocking activities from this user"))); else xs_html_add(form, html_button("mute", L("MUTE"), L("Block any activity from this user"))); /* the post textarea */ xs *dm_div_id = xs_fmt("%s_%s_dm", md5, t); xs *dm_form_id = xs_fmt("%s_reply_form", md5); xs_html_add(snac_controls, xs_html_tag("p", NULL), html_note(snac, L("Direct Message..."), dm_div_id, dm_form_id, "", "", NULL, actor_id, xs_stock_false, "", xs_stock_false, NULL, NULL, 0), xs_html_tag("p", NULL)); xs_html_add(snac_post, snac_controls); xs_html_add(snac_posts, snac_post); } } return people; } xs_str *html_people(snac *user) { xs *wing = following_list(user); xs *wers = follower_list(user); xs_html *html = xs_html_tag("html", html_user_head(user), xs_html_add(html_user_body(user, 0), html_people_list(user, wing, L("People you follow"), "i"), html_people_list(user, wers, L("People that follow you"), "e"), html_footer())); return xs_html_render_s(html, "\n"); } xs_str *html_notifications(snac *snac) { xs_str *s = xs_str_new(NULL); xs *n_list = notify_list(snac, 0); xs *n_time = notify_check_time(snac, 0); xs_list *p = n_list; xs_str *v; enum { NHDR_NONE, NHDR_NEW, NHDR_OLD } stage = NHDR_NONE; s = html_user_header(snac, s, 0); xs *clear_all_action = xs_fmt("%s/admin/clear-notifications", snac->actor); xs_html *clear_all_form = xs_html_tag("form", xs_html_attr("autocomplete", "off"), xs_html_attr("method", "post"), xs_html_attr("action", clear_all_action), xs_html_attr("id", "clear"), xs_html_sctag("input", xs_html_attr("type", "submit"), xs_html_attr("class", "snac-btn-like"), xs_html_attr("value", L("Clear all")))); { xs *s1 = xs_html_render(clear_all_form); s = xs_str_cat(s, s1); } while (xs_list_iter(&p, &v)) { xs *noti = notify_get(snac, v); if (noti == NULL) continue; xs *obj = NULL; const char *type = xs_dict_get(noti, "type"); const char *utype = xs_dict_get(noti, "utype"); const char *id = xs_dict_get(noti, "objid"); if (xs_is_null(id) || !valid_status(object_get(id, &obj))) continue; if (is_hidden(snac, id)) continue; const char *actor_id = xs_dict_get(noti, "actor"); xs *actor = NULL; if (!valid_status(actor_get(actor_id, &actor))) continue; xs *a_name = actor_name(actor); if (strcmp(v, n_time) > 0) { /* unseen notification */ if (stage == NHDR_NONE) { xs *s1 = xs_fmt("
%s
\n", L("New")); s = xs_str_cat(s, s1); s = xs_str_cat(s, "\n");
stage = NHDR_NEW;
}
}
else {
/* already seen notification */
if (stage != NHDR_OLD) {
if (stage == NHDR_NEW)
s = xs_str_cat(s, "
\n");
xs *s1 = xs_fmt("%s
\n", L("Already seen")); s = xs_str_cat(s, s1); s = xs_str_cat(s, "\n");
stage = NHDR_OLD;
}
}
const char *label = type;
if (strcmp(type, "Create") == 0)
label = L("Mention");
else
if (strcmp(type, "Update") == 0 && strcmp(utype, "Question") == 0)
label = L("Finished poll");
else
if (strcmp(type, "Undo") == 0 && strcmp(utype, "Follow") == 0)
label = L("Unfollow");
xs *es1 = encode_html(label);
xs *s1 = xs_fmt("
\n");
{
xs_html *h = html_footer();
xs *s1 = xs_html_render(h);
s = xs_str_cat(s, s1);
}
s = xs_str_cat(s, "\n\n");
/* set the check time to now */
xs *dummy = notify_check_time(snac, 1);
dummy = xs_free(dummy);
timeline_touch(snac);
return s;
}
int html_get_handler(const xs_dict *req, const char *q_path,
char **body, int *b_size, char **ctype, xs_str **etag)
{
char *accept = xs_dict_get(req, "accept");
int status = 404;
snac snac;
xs *uid = NULL;
char *p_path;
int cache = 1;
int save = 1;
char *v;
xs *l = xs_split_n(q_path, "/", 2);
v = xs_list_get(l, 1);
if (xs_is_null(v)) {
srv_log(xs_fmt("html_get_handler bad query '%s'", q_path));
return 404;
}
uid = xs_dup(v);
/* rss extension? */
if (xs_endswith(uid, ".rss")) {
uid = xs_crop_i(uid, 0, -4);
p_path = ".rss";
}
else
p_path = xs_list_get(l, 2);
if (!uid || !user_open(&snac, uid)) {
/* invalid user */
srv_debug(1, xs_fmt("html_get_handler bad user %s", uid));
return 404;
}
/* return the RSS if requested by Accept header */
if (accept != NULL) {
if (xs_str_in(accept, "text/xml") != -1 ||
xs_str_in(accept, "application/rss+xml") != -1)
p_path = ".rss";
}
/* check if server config variable 'disable_cache' is set */
if ((v = xs_dict_get(srv_config, "disable_cache")) && xs_type(v) == XSTYPE_TRUE)
cache = 0;
int skip = 0;
int show = xs_number_get(xs_dict_get(srv_config, "max_timeline_entries"));
char *q_vars = xs_dict_get(req, "q_vars");
if ((v = xs_dict_get(q_vars, "skip")) != NULL)
skip = atoi(v), cache = 0, save = 0;
if ((v = xs_dict_get(q_vars, "show")) != NULL)
show = atoi(v), cache = 0, save = 0;
if (p_path == NULL) { /** public timeline **/
xs *h = xs_str_localtime(0, "%Y-%m.html");
if (xs_type(xs_dict_get(snac.config, "private")) == XSTYPE_TRUE) {
*body = html_timeline(&snac, NULL, 1, 0, 0, 0, NULL);
*b_size = strlen(*body);
status = 200;
}
else
if (cache && history_mtime(&snac, h) > timeline_mtime(&snac)) {
snac_debug(&snac, 1, xs_fmt("serving cached local timeline"));
status = history_get(&snac, h, body, b_size,
xs_dict_get(req, "if-none-match"), etag);
}
else {
xs *list = timeline_list(&snac, "public", skip, show);
xs *next = timeline_list(&snac, "public", skip + show, 1);
xs *pins = pinned_list(&snac);
pins = xs_list_cat(pins, list);
*body = html_timeline(&snac, pins, 1, skip, show, xs_list_len(next), NULL);
*b_size = strlen(*body);
status = 200;
if (save)
history_add(&snac, h, *body, *b_size, etag);
}
}
else
if (strcmp(p_path, "admin") == 0) { /** private timeline **/
if (!login(&snac, req)) {
*body = xs_dup(uid);
status = 401;
}
else {
if (cache && history_mtime(&snac, "timeline.html_") > timeline_mtime(&snac)) {
snac_debug(&snac, 1, xs_fmt("serving cached timeline"));
status = history_get(&snac, "timeline.html_", body, b_size,
xs_dict_get(req, "if-none-match"), etag);
}
else {
snac_debug(&snac, 1, xs_fmt("building timeline"));
xs *list = timeline_list(&snac, "private", skip, show);
xs *next = timeline_list(&snac, "private", skip + show, 1);
xs *pins = pinned_list(&snac);
pins = xs_list_cat(pins, list);
*body = html_timeline(&snac, pins, 0, skip, show, xs_list_len(next), NULL);
*b_size = strlen(*body);
status = 200;
if (save)
history_add(&snac, "timeline.html_", *body, *b_size, etag);
}
}
}
else
if (strcmp(p_path, "people") == 0) { /** the list of people **/
if (!login(&snac, req)) {
*body = xs_dup(uid);
status = 401;
}
else {
*body = html_people(&snac);
*b_size = strlen(*body);
status = 200;
}
}
else
if (strcmp(p_path, "notifications") == 0) { /** the list of notifications **/
if (!login(&snac, req)) {
*body = xs_dup(uid);
status = 401;
}
else {
*body = html_notifications(&snac);
*b_size = strlen(*body);
status = 200;
}
}
else
if (xs_startswith(p_path, "p/")) { /** a timeline with just one entry **/
if (xs_type(xs_dict_get(snac.config, "private")) == XSTYPE_TRUE)
return 403;
xs *id = xs_fmt("%s/%s", snac.actor, p_path);
xs *msg = NULL;
if (valid_status(object_get(id, &msg))) {
xs *md5 = xs_md5_hex(id, strlen(id));
xs *list = xs_list_new();
list = xs_list_append(list, md5);
*body = html_timeline(&snac, list, 1, 0, 0, 0, NULL);
*b_size = strlen(*body);
status = 200;
}
}
else
if (xs_startswith(p_path, "s/")) { /** a static file **/
xs *l = xs_split(p_path, "/");
char *id = xs_list_get(l, 1);
int sz;
if (id && *id) {
status = static_get(&snac, id, body, &sz,
xs_dict_get(req, "if-none-match"), etag);
if (valid_status(status)) {
*b_size = sz;
*ctype = (char *)xs_mime_by_ext(id);
}
}
}
else
if (xs_startswith(p_path, "h/")) { /** an entry from the history **/
if (xs_type(xs_dict_get(snac.config, "private")) == XSTYPE_TRUE)
return 403;
if (xs_type(xs_dict_get(srv_config, "disable_history")) == XSTYPE_TRUE)
return 403;
xs *l = xs_split(p_path, "/");
char *id = xs_list_get(l, 1);
if (id && *id) {
if (xs_endswith(id, "timeline.html_")) {
/* Don't let them in */
*b_size = 0;
status = 404;
}
else
status = history_get(&snac, id, body, b_size,
xs_dict_get(req, "if-none-match"), etag);
}
}
else
if (strcmp(p_path, ".rss") == 0) { /** public timeline in RSS format **/
if (xs_type(xs_dict_get(snac.config, "private")) == XSTYPE_TRUE)
return 403;
xs *elems = timeline_simple_list(&snac, "public", 0, 20);
xs *bio = not_really_markdown(xs_dict_get(snac.config, "bio"), NULL);
xs *rss_title = xs_fmt("%s (@%s@%s)",
xs_dict_get(snac.config, "name"),
snac.uid,
xs_dict_get(srv_config, "host"));
xs *rss_link = xs_fmt("%s.rss", snac.actor);
xs_html *rss = xs_html_tag("rss",
xs_html_attr("version", "0.91"));
xs_html *channel = xs_html_tag("channel",
xs_html_tag("title",
xs_html_text(rss_title)),
xs_html_tag("language",
xs_html_text("en")),
xs_html_tag("link",
xs_html_text(rss_link)),
xs_html_tag("description",
xs_html_text(bio)));
xs_html_add(rss, channel);
xs_list *p = elems;
char *v;
while (xs_list_iter(&p, &v)) {
xs *msg = NULL;
if (!valid_status(timeline_get_by_md5(&snac, v, &msg)))
continue;
char *id = xs_dict_get(msg, "id");
char *content = xs_dict_get(msg, "content");
if (!xs_startswith(id, snac.actor))
continue;
/* create a title with the first line of the content */
xs *es_title = xs_replace(content, "\n"
"
\n");
}
if (stage == NHDR_NONE) {
xs *s1 = xs_fmt("%s by %s:
\n", es1, actor_id, a_name); s = xs_str_cat(s, s1); if (strcmp(type, "Follow") == 0 || strcmp(utype, "Follow") == 0) { xs_html *div = xs_html_tag("div", xs_html_attr("class", "snac-post"), html_actor_icon(actor, NULL, NULL, NULL, 0)); xs *s1 = xs_html_render(div); s = xs_str_cat(s, s1); } else { xs *md5 = xs_md5_hex(id, strlen(id)); s = html_entry(snac, s, obj, 0, 0, md5, 1); } s = xs_str_cat(s, "%s
\n", L("None")); s = xs_str_cat(s, s1); } else s = xs_str_cat(s, "", "\n"); xs *title = xs_str_new(NULL); int i; for (i = 0; es_title[i] && es_title[i] != '\n' && es_title[i] != '&' && i < 50; i++) title = xs_append_m(title, &es_title[i], 1); xs_html_add(channel, xs_html_tag("item", xs_html_tag("title", xs_html_text(title)), xs_html_tag("link", xs_html_text(id)), xs_html_tag("description", xs_html_text(content)))); } *body = xs_html_render_s(rss, "\n"); *b_size = strlen(*body); *ctype = "application/rss+xml; charset=utf-8"; status = 200; snac_debug(&snac, 1, xs_fmt("serving RSS")); } else status = 404; user_free(&snac); if (valid_status(status) && *ctype == NULL) { *ctype = "text/html; charset=utf-8"; } return status; } int html_post_handler(const xs_dict *req, const char *q_path, char *payload, int p_size, char **body, int *b_size, char **ctype) { (void)p_size; (void)ctype; int status = 0; snac snac; char *uid, *p_path; xs_dict *p_vars; xs *l = xs_split_n(q_path, "/", 2); uid = xs_list_get(l, 1); if (!uid || !user_open(&snac, uid)) { /* invalid user */ srv_debug(1, xs_fmt("html_post_handler bad user %s", uid)); return 404; } p_path = xs_list_get(l, 2); /* all posts must be authenticated */ if (!login(&snac, req)) { user_free(&snac); *body = xs_dup(uid); return 401; } p_vars = xs_dict_get(req, "p_vars"); #if 0 xs_json_dump(p_vars, 4, stdout); #endif if (p_path && strcmp(p_path, "admin/note") == 0) { /** **/ /* post note */ xs_str *content = xs_dict_get(p_vars, "content"); xs_str *in_reply_to = xs_dict_get(p_vars, "in_reply_to"); xs_str *attach_url = xs_dict_get(p_vars, "attach_url"); xs_list *attach_file = xs_dict_get(p_vars, "attach"); xs_str *to = xs_dict_get(p_vars, "to"); xs_str *sensitive = xs_dict_get(p_vars, "sensitive"); xs_str *summary = xs_dict_get(p_vars, "summary"); xs_str *edit_id = xs_dict_get(p_vars, "edit_id"); xs_str *alt_text = xs_dict_get(p_vars, "alt_text"); int priv = !xs_is_null(xs_dict_get(p_vars, "mentioned_only")); xs *attach_list = xs_list_new(); /* default alt text */ if (xs_is_null(alt_text)) alt_text = ""; /* is attach_url set? */ if (!xs_is_null(attach_url) && *attach_url != '\0') { xs *l = xs_list_new(); l = xs_list_append(l, attach_url); l = xs_list_append(l, alt_text); attach_list = xs_list_append(attach_list, l); } /* is attach_file set? */ if (!xs_is_null(attach_file) && xs_type(attach_file) == XSTYPE_LIST) { char *fn = xs_list_get(attach_file, 0); if (*fn != '\0') { char *ext = strrchr(fn, '.'); xs *hash = xs_md5_hex(fn, strlen(fn)); xs *id = xs_fmt("%s%s", hash, ext); xs *url = xs_fmt("%s/s/%s", snac.actor, id); int fo = xs_number_get(xs_list_get(attach_file, 1)); int fs = xs_number_get(xs_list_get(attach_file, 2)); /* store */ static_put(&snac, id, payload + fo, fs); xs *l = xs_list_new(); l = xs_list_append(l, url); l = xs_list_append(l, alt_text); attach_list = xs_list_append(attach_list, l); } } if (content != NULL) { xs *msg = NULL; xs *c_msg = NULL; xs *content_2 = xs_replace(content, "\r", ""); xs *poll_opts = NULL; /* is there a valid set of poll options? */ const char *v = xs_dict_get(p_vars, "poll_options"); if (!xs_is_null(v) && *v) { xs *v2 = xs_strip_i(xs_replace(v, "\r", "")); poll_opts = xs_split(v2, "\n"); } if (!xs_is_null(poll_opts) && xs_list_len(poll_opts)) { /* get the rest of poll configuration */ const char *p_multiple = xs_dict_get(p_vars, "poll_multiple"); const char *p_end_secs = xs_dict_get(p_vars, "poll_end_secs"); int multiple = 0; int end_secs = atoi(!xs_is_null(p_end_secs) ? p_end_secs : "60"); if (!xs_is_null(p_multiple) && strcmp(p_multiple, "on") == 0) multiple = 1; msg = msg_question(&snac, content_2, attach_list, poll_opts, multiple, end_secs); enqueue_close_question(&snac, xs_dict_get(msg, "id"), end_secs); } else msg = msg_note(&snac, content_2, to, in_reply_to, attach_list, priv); if (sensitive != NULL) { msg = xs_dict_set(msg, "sensitive", xs_stock_true); msg = xs_dict_set(msg, "summary", xs_is_null(summary) ? "..." : summary); } if (xs_is_null(edit_id)) { /* new message */ c_msg = msg_create(&snac, msg); timeline_add(&snac, xs_dict_get(msg, "id"), msg); } else { /* an edition of a previous message */ xs *p_msg = NULL; if (valid_status(object_get(edit_id, &p_msg))) { /* copy relevant fields from previous version */ char *fields[] = { "id", "context", "url", "published", "to", "inReplyTo", NULL }; int n; for (n = 0; fields[n]; n++) { char *v = xs_dict_get(p_msg, fields[n]); msg = xs_dict_set(msg, fields[n], v); } /* set the updated field */ xs *updated = xs_str_utctime(0, ISO_DATE_SPEC); msg = xs_dict_set(msg, "updated", updated); /* overwrite object, not updating the indexes */ object_add_ow(edit_id, msg); /* update message */ c_msg = msg_update(&snac, msg); } else snac_log(&snac, xs_fmt("cannot get object '%s' for editing", edit_id)); } if (c_msg != NULL) enqueue_message(&snac, c_msg); history_del(&snac, "timeline.html_"); } status = 303; } else if (p_path && strcmp(p_path, "admin/action") == 0) { /** **/ /* action on an entry */ char *id = xs_dict_get(p_vars, "id"); char *actor = xs_dict_get(p_vars, "actor"); char *action = xs_dict_get(p_vars, "action"); char *group = xs_dict_get(p_vars, "group"); if (action == NULL) return 404; snac_debug(&snac, 1, xs_fmt("web action '%s' received", action)); status = 303; if (strcmp(action, L("Like")) == 0) { /** **/ xs *msg = msg_admiration(&snac, id, "Like"); if (msg != NULL) { enqueue_message(&snac, msg); timeline_admire(&snac, xs_dict_get(msg, "object"), snac.actor, 1); } } else if (strcmp(action, L("Boost")) == 0) { /** **/ xs *msg = msg_admiration(&snac, id, "Announce"); if (msg != NULL) { enqueue_message(&snac, msg); timeline_admire(&snac, xs_dict_get(msg, "object"), snac.actor, 0); } } else if (strcmp(action, L("MUTE")) == 0) { /** **/ mute(&snac, actor); } else if (strcmp(action, L("Unmute")) == 0) { /** **/ unmute(&snac, actor); } else if (strcmp(action, L("Hide")) == 0) { /** **/ hide(&snac, id); } else if (strcmp(action, L("Limit")) == 0) { /** **/ limit(&snac, actor); } else if (strcmp(action, L("Unlimit")) == 0) { /** **/ unlimit(&snac, actor); } else if (strcmp(action, L("Follow")) == 0) { /** **/ xs *msg = msg_follow(&snac, actor); if (msg != NULL) { /* reload the actor from the message, in may be different */ actor = xs_dict_get(msg, "object"); following_add(&snac, actor, msg); enqueue_output_by_actor(&snac, msg, actor, 0); } } else if (strcmp(action, L("Unfollow")) == 0) { /** **/ /* get the following object */ xs *object = NULL; if (valid_status(following_get(&snac, actor, &object))) { xs *msg = msg_undo(&snac, xs_dict_get(object, "object")); following_del(&snac, actor); enqueue_output_by_actor(&snac, msg, actor, 0); snac_log(&snac, xs_fmt("unfollowed actor %s", actor)); } else snac_log(&snac, xs_fmt("actor is not being followed %s", actor)); } else if (strcmp(action, L("Follow Group")) == 0) { /** **/ xs *msg = msg_follow(&snac, group); if (msg != NULL) { /* reload the group from the message, in may be different */ group = xs_dict_get(msg, "object"); following_add(&snac, group, msg); enqueue_output_by_actor(&snac, msg, group, 0); } } else if (strcmp(action, L("Unfollow Group")) == 0) { /** **/ /* get the following object */ xs *object = NULL; if (valid_status(following_get(&snac, group, &object))) { xs *msg = msg_undo(&snac, xs_dict_get(object, "object")); following_del(&snac, group); enqueue_output_by_actor(&snac, msg, group, 0); snac_log(&snac, xs_fmt("unfollowed group %s", group)); } else snac_log(&snac, xs_fmt("actor is not being followed %s", actor)); } else if (strcmp(action, L("Delete")) == 0) { /** **/ char *actor_form = xs_dict_get(p_vars, "actor-form"); if (actor_form != NULL) { /* delete follower */ if (valid_status(follower_del(&snac, actor))) snac_log(&snac, xs_fmt("deleted follower %s", actor)); else snac_log(&snac, xs_fmt("error deleting follower %s", actor)); } else { /* delete an entry */ if (xs_startswith(id, snac.actor)) { /* it's a post by us: generate a delete */ xs *msg = msg_delete(&snac, id); enqueue_message(&snac, msg); snac_log(&snac, xs_fmt("posted tombstone for %s", id)); } timeline_del(&snac, id); snac_log(&snac, xs_fmt("deleted entry %s", id)); } } else if (strcmp(action, L("Pin")) == 0) { /** **/ pin(&snac, id); timeline_touch(&snac); } else if (strcmp(action, L("Unpin")) == 0) { /** **/ unpin(&snac, id); timeline_touch(&snac); } else status = 404; /* delete the cached timeline */ if (status == 303) history_del(&snac, "timeline.html_"); } else if (p_path && strcmp(p_path, "admin/user-setup") == 0) { /** **/ /* change of user data */ char *v; char *p1, *p2; if ((v = xs_dict_get(p_vars, "name")) != NULL) snac.config = xs_dict_set(snac.config, "name", v); if ((v = xs_dict_get(p_vars, "avatar")) != NULL) snac.config = xs_dict_set(snac.config, "avatar", v); if ((v = xs_dict_get(p_vars, "bio")) != NULL) snac.config = xs_dict_set(snac.config, "bio", v); if ((v = xs_dict_get(p_vars, "cw")) != NULL && strcmp(v, "on") == 0) { snac.config = xs_dict_set(snac.config, "cw", "open"); } else { /* if the checkbox is not set, the parameter is missing */ snac.config = xs_dict_set(snac.config, "cw", ""); } if ((v = xs_dict_get(p_vars, "email")) != NULL) snac.config = xs_dict_set(snac.config, "email", v); if ((v = xs_dict_get(p_vars, "telegram_bot")) != NULL) snac.config = xs_dict_set(snac.config, "telegram_bot", v); if ((v = xs_dict_get(p_vars, "telegram_chat_id")) != NULL) snac.config = xs_dict_set(snac.config, "telegram_chat_id", v); if ((v = xs_dict_get(p_vars, "purge_days")) != NULL) { xs *days = xs_number_new(atof(v)); snac.config = xs_dict_set(snac.config, "purge_days", days); } if ((v = xs_dict_get(p_vars, "drop_dm_from_unknown")) != NULL && strcmp(v, "on") == 0) snac.config = xs_dict_set(snac.config, "drop_dm_from_unknown", xs_stock_true); else snac.config = xs_dict_set(snac.config, "drop_dm_from_unknown", xs_stock_false); if ((v = xs_dict_get(p_vars, "bot")) != NULL && strcmp(v, "on") == 0) snac.config = xs_dict_set(snac.config, "bot", xs_stock_true); else snac.config = xs_dict_set(snac.config, "bot", xs_stock_false); if ((v = xs_dict_get(p_vars, "private")) != NULL && strcmp(v, "on") == 0) snac.config = xs_dict_set(snac.config, "private", xs_stock_true); else snac.config = xs_dict_set(snac.config, "private", xs_stock_false); if ((v = xs_dict_get(p_vars, "metadata")) != NULL) { /* split the metadata and store it as a dict */ xs_dict *md = xs_dict_new(); xs *l = xs_split(v, "\n"); xs_list *p = l; xs_str *kp; while (xs_list_iter(&p, &kp)) { xs *kpl = xs_split_n(kp, "=", 1); if (xs_list_len(kpl) == 2) { xs *k2 = xs_strip_i(xs_dup(xs_list_get(kpl, 0))); xs *v2 = xs_strip_i(xs_dup(xs_list_get(kpl, 1))); md = xs_dict_set(md, k2, v2); } } snac.config = xs_dict_set(snac.config, "metadata", md); } /* uploads */ const char *uploads[] = { "avatar", "header", NULL }; int n; for (n = 0; uploads[n]; n++) { xs *var_name = xs_fmt("%s_file", uploads[n]); xs_list *uploaded_file = xs_dict_get(p_vars, var_name); if (xs_type(uploaded_file) == XSTYPE_LIST) { const char *fn = xs_list_get(uploaded_file, 0); if (fn && *fn) { const char *mimetype = xs_mime_by_ext(fn); if (xs_startswith(mimetype, "image/")) { const char *ext = strrchr(fn, '.'); xs *hash = xs_md5_hex(fn, strlen(fn)); xs *id = xs_fmt("%s%s", hash, ext); xs *url = xs_fmt("%s/s/%s", snac.actor, id); int fo = xs_number_get(xs_list_get(uploaded_file, 1)); int fs = xs_number_get(xs_list_get(uploaded_file, 2)); /* store */ static_put(&snac, id, payload + fo, fs); snac.config = xs_dict_set(snac.config, uploads[n], url); } } } } /* password change? */ if ((p1 = xs_dict_get(p_vars, "passwd1")) != NULL && (p2 = xs_dict_get(p_vars, "passwd2")) != NULL && *p1 && strcmp(p1, p2) == 0) { xs *pw = hash_password(snac.uid, p1, NULL); snac.config = xs_dict_set(snac.config, "passwd", pw); } xs *fn = xs_fmt("%s/user.json", snac.basedir); xs *bfn = xs_fmt("%s.bak", fn); FILE *f; rename(fn, bfn); if ((f = fopen(fn, "w")) != NULL) { xs_json_dump(snac.config, 4, f); fclose(f); } else rename(bfn, fn); history_del(&snac, "timeline.html_"); xs *a_msg = msg_actor(&snac); xs *u_msg = msg_update(&snac, a_msg); enqueue_message(&snac, u_msg); status = 303; } else if (p_path && strcmp(p_path, "admin/clear-notifications") == 0) { /** **/ notify_clear(&snac); timeline_touch(&snac); status = 303; } else if (p_path && strcmp(p_path, "admin/vote") == 0) { /** **/ char *irt = xs_dict_get(p_vars, "irt"); const char *opt = xs_dict_get(p_vars, "question"); const char *actor = xs_dict_get(p_vars, "actor"); xs *ls = NULL; /* multiple choices? */ if (xs_type(opt) == XSTYPE_LIST) ls = xs_dup(opt); else { ls = xs_list_new(); ls = xs_list_append(ls, opt); } xs_list *p = ls; xs_str *v; while (xs_list_iter(&p, &v)) { xs *msg = msg_note(&snac, "", actor, irt, NULL, 1); /* set the option */ msg = xs_dict_append(msg, "name", v); xs *c_msg = msg_create(&snac, msg); enqueue_message(&snac, c_msg); timeline_add(&snac, xs_dict_get(msg, "id"), msg); } status = 303; } if (status == 303) { char *redir = xs_dict_get(p_vars, "redir"); if (xs_is_null(redir)) redir = "top"; *body = xs_fmt("%s/admin#%s", snac.actor, redir); *b_size = strlen(*body); } user_free(&snac); return status; }