diff options
| author | default <nobody@localhost> | 2023-07-13 20:19:50 +0200 |
|---|---|---|
| committer | default <nobody@localhost> | 2023-07-13 20:19:50 +0200 |
| commit | a05aa969d0cd2efbd08bbeda69544ceb8f26a388 (patch) | |
| tree | 7e3df96a9075f4316d4372b2807cf8ba87dd3a37 | |
| parent | 0bdd1f04203c57661d7b2ee9cdd52e564b3f98c6 (diff) | |
Added a maximum level of recursion to timeline_request().
| -rw-r--r-- | activitypub.c | 15 |
1 files changed, 8 insertions, 7 deletions
diff --git a/activitypub.c b/activitypub.c index 2566ba4..4843067 100644 --- a/activitypub.c +++ b/activitypub.c @@ -146,7 +146,7 @@ int actor_request(snac *snac, const char *actor, xs_dict **data) } -int timeline_request(snac *snac, char **id, xs_str **wrk) +int timeline_request(snac *snac, char **id, xs_str **wrk, int level) /* ensures that an entry and its ancestors are in the timeline */ { int status = 0; @@ -187,7 +187,8 @@ int timeline_request(snac *snac, char **id, xs_str **wrk) timeline_add(snac, *id, object); /* recurse! */ - timeline_request(snac, &in_reply_to, NULL); + if (level < 32) + timeline_request(snac, &in_reply_to, NULL, level + 1); } } } @@ -255,7 +256,7 @@ void timeline_request_replies(snac *user, const char *id) } else { snac_debug(user, 0, xs_fmt("request reply %s", v)); - timeline_request(user, &v, NULL); + timeline_request(user, &v, NULL, 0); } } } @@ -830,7 +831,7 @@ xs_dict *msg_admiration(snac *snac, char *object, char *type) xs *wrk = NULL; /* call the object */ - timeline_request(snac, &object, &wrk); + timeline_request(snac, &object, &wrk, 0); if (valid_status(object_get(object, &a_msg))) { xs *rcpts = xs_list_new(); @@ -1039,7 +1040,7 @@ xs_dict *msg_note(snac *snac, const xs_str *content, const xs_val *rcpts, xs *wrk = NULL; /* demand this thing */ - timeline_request(snac, &in_reply_to, &wrk); + timeline_request(snac, &in_reply_to, &wrk, 0); if (valid_status(object_get(in_reply_to, &p_msg))) { /* add this author as recipient */ @@ -1468,7 +1469,7 @@ int process_input_message(snac *snac, xs_dict *msg, xs_dict *req) char *in_reply_to = xs_dict_get(object, "inReplyTo"); xs *wrk = NULL; - timeline_request(snac, &in_reply_to, &wrk); + timeline_request(snac, &in_reply_to, &wrk, 0); if (timeline_add(snac, id, object)) { snac_log(snac, xs_fmt("new 'Note' %s %s", actor, id)); @@ -1521,7 +1522,7 @@ int process_input_message(snac *snac, xs_dict *msg, xs_dict *req) if (xs_type(object) == XSTYPE_DICT) object = xs_dict_get(object, "id"); - timeline_request(snac, &object, &wrk); + timeline_request(snac, &object, &wrk, 0); /* Note: implementations like lemmy send announces about objects that are not of the 'Note' type; these objects are not stored, |