slon-project/slon
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Slon/Modules/ActivityPub: Propagate create/delete statuses to followers

Browse source
This commit is contained in:
Alec Murphy 2025-02-17 18:21:59 -05:00
parent 16d65c88ee
commit 591bd3ecbb
1 changed files with 30 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

36
Slon/Modules/ActivityPub.HC
View file

@ -367,12 +367,11 @@ U0 @slon_activitypub_async_accept_request(JsonObject* o)
Free(fetch_buffer); Free(fetch_buffer);
} }
U0 @slon_activitypub_async_create_status(JsonObject* status) U0 @slon_activitypub_async_create_status_to(JsonObject* status, U8* dest)
{ {
Sleep(2000); Sleep(2000);
U8 scratch_buffer[2048]; U8 scratch_buffer[2048];
U8* dest = "https://techhub.social/users/ryeucrvtexw3/inbox";
U8* this_actor = StrNew(status->@("uri"), adam_task); U8* this_actor = StrNew(status->@("uri"), adam_task);
StrFind("/statuses/", this_actor)[0] = NULL; StrFind("/statuses/", this_actor)[0] = NULL;
@ -421,7 +420,8 @@ U0 @slon_activitypub_async_create_status(JsonObject* status)
JsonObject* http_headers = Json.CreateObject(); JsonObject* http_headers = Json.CreateObject();
HttpUrl* url = @http_parse_url(dest); StrPrint(scratch_buffer, "%s/inbox", dest);
HttpUrl* url = @http_parse_url(scratch_buffer);
CDateStruct ds; CDateStruct ds;
Date2Struct(&ds, Now + 1043910000); Date2Struct(&ds, Now + 1043910000);
@ -493,12 +493,23 @@ U0 @slon_activitypub_async_create_status(JsonObject* status)
Free(fetch_buffer); Free(fetch_buffer);
} }
U0 @slon_activitypub_async_delete_status(JsonObject* status) U0 @slon_activitypub_async_create_status(JsonObject* status)
{
I64 i;
JsonArray* followers = db->o("followers")->a(status->o("account")->@("username"));
if (!followers) {
return;
}
for (i = 0; i < followers->length; i++) {
@slon_activitypub_async_create_status_to(status, followers->@(i));
}
}
U0 @slon_activitypub_async_delete_status_to(JsonObject* status, U8* dest)
{ {
Sleep(2000); Sleep(2000);
U8 scratch_buffer[2048]; U8 scratch_buffer[2048];
U8* dest = "https://techhub.social/users/ryeucrvtexw3/inbox";
U8* this_actor = StrNew(status->@("uri"), adam_task); U8* this_actor = StrNew(status->@("uri"), adam_task);
StrFind("/statuses/", this_actor)[0] = NULL; StrFind("/statuses/", this_actor)[0] = NULL;
@ -525,7 +536,8 @@ U0 @slon_activitypub_async_delete_status(JsonObject* status)
JsonObject* http_headers = Json.CreateObject(); JsonObject* http_headers = Json.CreateObject();
HttpUrl* url = @http_parse_url(dest); StrPrint(scratch_buffer, "%s/inbox", dest);
HttpUrl* url = @http_parse_url(scratch_buffer);
CDateStruct ds; CDateStruct ds;
Date2Struct(&ds, Now + 1043910000); Date2Struct(&ds, Now + 1043910000);
@ -597,6 +609,18 @@ U0 @slon_activitypub_async_delete_status(JsonObject* status)
Free(fetch_buffer); Free(fetch_buffer);
} }
U0 @slon_activitypub_async_delete_status(JsonObject* status)
{
I64 i;
JsonArray* followers = db->o("followers")->a(status->o("account")->@("username"));
if (!followers) {
return;
}
for (i = 0; i < followers->length; i++) {
@slon_activitypub_async_delete_status_to(status, followers->@(i));
}
}
U0 @slon_activitypub_create_status_fedi(JsonObject* status) U0 @slon_activitypub_create_status_fedi(JsonObject* status)
{ {
Spawn(&@slon_activitypub_async_create_status, status, "SlonAsyncCreateTask"); Spawn(&@slon_activitypub_async_create_status, status, "SlonAsyncCreateTask");