mirrors/snac2
3
0
Fork 0
mirror of https://codeberg.org/grunfink/snac2.git synced 2024-11-10 03:50:38 +03:00
Code Issues Packages Projects Releases Wiki Activity

Function object_add() also update the parent's children index.

Browse Source
This commit is contained in:
default 2022-11-24 08:09:57 +01:00
parent 9d7b35940f
commit ecea10e11c
1 changed files with 23 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
data.c
View File

@ -193,7 +193,7 @@ double mtime(char *fn)
/** database 2.1+ **/ /** database 2.1+ **/
int index_add(const char *fn, const char *md5) int index_add_md5(const char *fn, const char *md5)
/* adds an md5 to an index */ /* adds an md5 to an index */
{ {
int status = 200; int status = 200;
@ -212,6 +212,15 @@ int index_add(const char *fn, const char *md5)
} }
int index_add(const char *fn, const char *id)
/* adds an id to an index */
{
xs *md5 = xs_md5_hex(id, strlen(id));
return index_add_md5(fn, md5);
}
int index_del(const char *fn, const char *md5) int index_del(const char *fn, const char *md5)
/* deletes an md5 from an index */ /* deletes an md5 from an index */
{ {
@ -386,6 +395,19 @@ int object_add(const char *id, d_char *obj)
fwrite(j, strlen(j), 1, f); fwrite(j, strlen(j), 1, f);
fclose(f); fclose(f);
/* does this object has a parent? */
char *in_reply_to = xs_dict_get(obj, "inReplyTo");
if (!xs_is_null(in_reply_to)) {
/* update the children index of the parent */
xs *pfn = _object_fn(in_reply_to);
if (mtime(pfn) > 0.0) {
pfn = xs_replace_i(pfn, ".json", "_c.idx");
index_add(pfn, id);
}
}
} }
else else
status = 500; status = 500;