From 7f322302e5b5cf0345de110afe78767bfb03ae51 Mon Sep 17 00:00:00 2001 From: default Date: Mon, 29 Apr 2024 09:50:22 +0200 Subject: [PATCH] New function list_distribute(). --- data.c | 28 ++++++++++++++++++++++++++++ snac.h | 1 + 2 files changed, 29 insertions(+) diff --git a/data.c b/data.c index ed65d32..07b38ec 100644 --- a/data.c +++ b/data.c @@ -1154,6 +1154,8 @@ int timeline_add(snac *snac, const char *id, const xs_dict *o_msg) tag_index(id, o_msg); + list_distribute(snac, o_msg); + snac_debug(snac, 1, xs_fmt("timeline_add %s", id)); return ret; @@ -1859,6 +1861,32 @@ xs_val *list_content(snac *user, const char *list, const char *actor_md5, int op } +void list_distribute(snac *user, const xs_dict *post) +/* distributes the post to all appropriate lists */ +{ + char *atto = get_atto(post); + char *id = xs_dict_get(post, "id"); + + if (xs_type(atto) == XSTYPE_STRING && xs_type(id) == XSTYPE_STRING) { + xs *a_md5 = xs_md5_hex(atto, strlen(atto)); + xs *i_md5 = xs_md5_hex(id, strlen(id)); + xs *spec = xs_fmt("%s/list/" "*.lst", user->basedir); + xs *ls = xs_glob(spec, 0, 0); + int c = 0; + char *v; + + while (xs_list_next(ls, &v, &c)) { + /* is the actor in this list? */ + if (index_in_md5(v, a_md5)) { + /* it is; add post md5 to its timeline */ + xs *idx = xs_replace(v, ".lst", ".idx"); + index_add(idx, i_md5); + } + } + } +} + + /** static data **/ static int _load_raw_file(const char *fn, xs_val **data, int *size, diff --git a/snac.h b/snac.h index da8b6f9..b478c7e 100644 --- a/snac.h +++ b/snac.h @@ -176,6 +176,7 @@ xs_list *tag_search(char *tag, int skip, int show); xs_val *list_maint(snac *user, const char *list, int op); xs_val *list_content(snac *user, const char *list_id, const char *actor_md5, int op); +void list_distribute(snac *user, const xs_dict *post); int actor_add(const char *actor, xs_dict *msg); int actor_get(const char *actor, xs_dict **data);