"); if (!xs_startswith(c, "
")) { xs *s1 = c; c = xs_fmt("
%s
", s1); } /* replace the :shortnames: */ c = replace_shortnames(c, xs_dict_get(msg, "tag")); /* c contains sanitized HTML */ xs_html_add(snac_content, xs_html_raw(c)); } 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_html_add(snac_content_wrap, poll); } /* 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_html_add(snac_content_wrap, 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)))); } } } /* has this message an audience (i.e., comes from a channel or community)? */ char *audience = xs_dict_get(msg, "audience"); if (strcmp(type, "Page") == 0 && !xs_is_null(audience)) { xs_html *au_tag = xs_html_tag("p", xs_html_text("("), xs_html_tag("a", xs_html_attr("href", audience), xs_html_attr("title", L("Source channel or community")), xs_html_text(audience)), xs_html_text(")")); xs_html_add(snac_content_wrap, au_tag); } /** controls **/ if (!local && user) { xs_html_add(entry, html_entry_controls(user, msg, md5)); } /** children **/ if (!hide_children) { xs *children = object_children(id); int left = xs_list_len(children); if (left) { xs_html *ch_details = xs_html_tag("details", xs_html_attr("open", NULL), xs_html_tag("summary", xs_html_text("..."))); xs_html_add(entry, ch_details); xs_html *ch_container = xs_html_tag("div", xs_html_attr("class", level < 4 ? "snac-children" : "snac-children-too-deep")); xs_html_add(ch_details, ch_container); xs_html *ch_older = NULL; if (left > 3) { xs_html_add(ch_container, ch_older = xs_html_tag("details", xs_html_tag("summary", xs_html_text(L("Older..."))))); } xs_list *p = children; char *cmd5; 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 (chd != NULL && xs_is_null(xs_dict_get(chd, "name"))) { xs_html *che = html_entry(user, chd, local, level + 1, cmd5, hide_children); if (che != NULL) { if (left > 3) xs_html_add(ch_older, che); else xs_html_add(ch_container, che); } } else srv_debug(2, xs_fmt("cannot read child %s", cmd5)); left--; } } } return entry_top; } 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_list *p = (xs_list *)list; char *v; double t = ftime(); xs_html *head; xs_html *body; if (user) { head = html_user_head(user); body = html_user_body(user, local); } else { head = html_instance_head(); body = html_instance_body(tag); } xs_html *html = xs_html_tag("html", head, body); if (user && !local) xs_html_add(body, html_top_controls(user)); xs_html_add(body, xs_html_tag("a", xs_html_attr("name", "snac-posts"))); xs_html *posts = xs_html_tag("div", xs_html_attr("class", "snac-posts")); xs_html_add(body, posts); 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; } xs_html *entry = html_entry(user, msg, local, 0, v, user ? 0 : 1); if (entry != NULL) xs_html_add(posts, entry); } if (list && user && local) { if (xs_type(xs_dict_get(srv_config, "disable_history")) != XSTYPE_TRUE) { xs_html *ul = xs_html_tag("ul", NULL); xs_html *history = xs_html_tag("div", xs_html_attr("class", "snac-history"), xs_html_tag("p", xs_html_attr("class", "snac-history-title"), xs_html_text(L("History"))), ul); xs *list = history_list(user); xs_list *p = list; char *v; while (xs_list_iter(&p, &v)) { xs *fn = xs_replace(v, ".html", ""); xs *url = xs_fmt("%s/h/%s", user->actor, v); xs_html_add(ul, xs_html_tag("li", xs_html_tag("a", xs_html_attr("href", url), xs_html_text(fn)))); } xs_html_add(body, history); } } { xs *s1 = xs_fmt("\n\n", ftime() - t); xs_html_add(body, xs_html_raw(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_html *more_links = xs_html_tag("p", xs_html_tag("a", xs_html_attr("href", t), xs_html_attr("name", "snac-more"), xs_html_text(L("Back to top"))), xs_html_text(" - "), xs_html_tag("a", xs_html_attr("href", m), xs_html_attr("name", "snac-more"), xs_html_text(L("More...")))); xs_html_add(body, more_links); } xs_html_add(body, html_footer()); return xs_html_render_s(html, "\n"); } 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, ""))
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 *user)
{
xs *n_list = notify_list(user, 0);
xs *n_time = notify_check_time(user, 0);
xs_html *body = html_user_body(user, 0);
xs_html *html = xs_html_tag("html",
html_user_head(user),
body);
xs *clear_all_action = xs_fmt("%s/admin/clear-notifications", user->actor);
xs_html_add(body,
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_html *noti_new = NULL;
xs_html *noti_seen = NULL;
xs_list *p = n_list;
xs_str *v;
while (xs_list_iter(&p, &v)) {
xs *noti = notify_get(user, v);
if (noti == NULL)
continue;
xs *obj = NULL;
char *type = xs_dict_get(noti, "type");
char *utype = xs_dict_get(noti, "utype");
char *id = xs_dict_get(noti, "objid");
if (xs_is_null(id) || !valid_status(object_get(id, &obj)))
continue;
if (is_hidden(user, id))
continue;
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);
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_html *entry = xs_html_tag("div",
xs_html_attr("class", "snac-post-with-desc"),
xs_html_tag("p",
xs_html_tag("b",
xs_html_text(label),
xs_html_text(" by "),
xs_html_tag("a",
xs_html_attr("href", actor_id),
xs_html_raw(a_name))))); /* a_name is already sanitized */
if (strcmp(type, "Follow") == 0 || strcmp(utype, "Follow") == 0) {
xs_html_add(entry,
xs_html_tag("div",
xs_html_attr("class", "snac-post"),
html_actor_icon(actor, NULL, NULL, NULL, 0)));
}
else {
xs *md5 = xs_md5_hex(id, strlen(id));
xs_html *h = html_entry(user, obj, 0, 0, md5, 1);
if (h != NULL) {
xs_html_add(entry,
h);
}
}
if (strcmp(v, n_time) > 0) {
/* unseen notification */
if (noti_new == NULL) {
noti_new = xs_html_tag("div",
xs_html_tag("h2",
xs_html_attr("class", "snac-header"),
xs_html_text(L("New"))));
xs_html_add(body,
noti_new);
}
xs_html_add(noti_new,
entry);
}
else {
/* already seen notification */
if (noti_seen == NULL) {
noti_seen = xs_html_tag("div",
xs_html_tag("h2",
xs_html_attr("class", "snac-header"),
xs_html_text(L("Already seen"))));
xs_html_add(body,
noti_seen);
}
xs_html_add(noti_seen,
entry);
}
}
if (noti_new == NULL && noti_seen == NULL)
xs_html_add(body,
xs_html_tag("h2",
xs_html_attr("class", "snac-header"),
xs_html_text(L("None"))));
xs_html_add(body,
html_footer());
/* set the check time to now */
xs *dummy = notify_check_time(user, 1);
dummy = xs_free(dummy);
timeline_touch(user);
return xs_html_render_s(html, "\n");
}
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");
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;
}