From ade46f0b8fdda21424d7dfa55a744e8fcf48105b Mon Sep 17 00:00:00 2001
From: Hong Minhee <hong@minhee.org>
Date: Mon, 23 Dec 2024 17:08:26 +0900
Subject: [PATCH] Logging for followers dispatcher

---
 src/federation/index.ts | 15 +++++++++++++--
 1 file changed, 13 insertions(+), 2 deletions(-)

diff --git a/src/federation/index.ts b/src/federation/index.ts
index 1776144..7e8504d 100644
--- a/src/federation/index.ts
+++ b/src/federation/index.ts
@@ -173,6 +173,8 @@ federation
     ];
   });
 
+const followersLogger = getLogger(["hollo", "federation", "followers"]);
+
 federation
   .setFollowersDispatcher(
     "/@{identifier}/followers",
@@ -181,6 +183,10 @@ federation
         where: eq(accountOwners.handle, identifier),
       });
       if (owner == null) return null;
+      followersLogger.debug(
+        "Gathering followers for {identifier} with cursor {cursor} and filter {filter}...",
+        { identifier, cursor, filter },
+      );
       const offset = cursor == null ? undefined : Number.parseInt(cursor);
       if (offset != null && !Number.isInteger(offset)) return null;
       const followers = await db.query.accounts.findMany({
@@ -206,7 +212,7 @@ federation
         limit: offset == null ? undefined : 41,
       });
       const items = offset == null ? followers : followers.slice(0, 40);
-      return {
+      const result = {
         items: items.map((f) => ({
           id: new URL(f.iri),
           inboxId: new URL(f.inboxUrl),
@@ -217,6 +223,11 @@ federation
         nextCursor:
           offset != null && followers.length > 40 ? `${offset + 40}` : null,
       };
+      followersLogger.debug(
+        "Gathered {followers} followers for {identifier} with cursor {cursor} and filter {filter}.",
+        { followers: result.items.length, identifier, cursor, filter },
+      );
+      return result;
     },
   )
   .setFirstCursor(async (_ctx, _identifier) => "0")
@@ -421,7 +432,7 @@ federation.setFeaturedTagsDispatcher(
   },
 );
 
-const inboxLogger = getLogger(["hollo", "inbox"]);
+const inboxLogger = getLogger(["hollo", "federation", "inbox"]);
 
 federation
   .setInboxListeners("/@{identifier}/inbox", "/inbox")