Unverified Commit e80555bb authored by Hong Minhee's avatar Hong Minhee
Browse files

Enqueue incoming activities

parent 1411a55e

CHANGES.md

+3 −0
Original line number Diff line number Diff line
@@ -8,6 +8,9 @@ Version 0.12.2 


To be released.



 -  Fixed a bug where incoming activities had not been enqueued even

    if the `queue` option was provided to the `createFederation()` function.





Version 0.12.1

--------------

src/federation/handler.ts

+4 −0
Original line number Diff line number Diff line
@@ -490,6 +490,10 @@ export async function handleInbox<TContextData>( 
        started: new Date().toISOString(),

      } satisfies InboxMessage,

    );

    logger.info(

      "Activity {activityId} is eunqueued.",

      { activityId: activity.id?.href, activity: json },

    );

    return new Response("Activity is enqueued.", {

      status: 202,

      headers: { "Content-Type": "text/plain; charset=utf-8" },

src/federation/middleware.ts

+1 −0
Original line number Diff line number Diff line
@@ -1860,6 +1860,7 @@ export class Federation<TContextData> { 
          context,

          kv: this.#kv,

          kvPrefixes: this.#kvPrefixes,

          queue: this.#queue,

          actorDispatcher: this.#actorCallbacks?.dispatcher,

          inboxListeners: this.#inboxListeners,

          inboxErrorHandler: this.#inboxErrorHandler,