summaryrefslogtreecommitdiff
path: root/data.c
diff options
context:
space:
mode:
authordefault <nobody@localhost>2024-05-11 19:16:54 +0200
committerdefault <nobody@localhost>2024-05-11 19:16:54 +0200
commit4d53a7b6f7f45f524313980461f5d2a6ef965949 (patch)
tree0341b6146258f89d8488f9e01270d34b412c87c1 /data.c
parent3954361785c1384272b0e9fc7262bb25441101de (diff)
In timeline_request(), call enqueue_actor_request on actor errors.
Diffstat (limited to 'data.c')
-rw-r--r--data.c11
1 files changed, 6 insertions, 5 deletions
diff --git a/data.c b/data.c
index d037af0..8016ce1 100644
--- a/data.c
+++ b/data.c
@@ -1632,7 +1632,7 @@ int actor_get_refresh(snac *user, const char *actor, xs_dict **data)
int status = actor_get(actor, data);
if (status == 205 && user && !xs_startswith(actor, srv_baseurl))
- enqueue_actor_refresh(user, actor);
+ enqueue_actor_refresh(user, actor, 0);
return status;
}
@@ -2830,13 +2830,14 @@ void enqueue_verify_links(snac *user)
}
-void enqueue_actor_refresh(snac *user, const char *actor)
+void enqueue_actor_refresh(snac *user, const char *actor, int forward_secs)
/* enqueues an actor refresh */
{
- xs *qmsg = _new_qmsg("actor_refresh", "", 0);
- char *ntid = xs_dict_get(qmsg, "ntid");
- xs *fn = xs_fmt("%s/queue/%s.json", user->basedir, ntid);
+ xs *qmsg = _new_qmsg("actor_refresh", "", 0);
+ xs *ntid = tid(forward_secs);
+ xs *fn = xs_fmt("%s/queue/%s.json", user->basedir, ntid);
+ qmsg = xs_dict_set(qmsg, "ntid", ntid);
qmsg = xs_dict_append(qmsg, "actor", actor);
qmsg = _enqueue_put(fn, qmsg);