refactor: 🔊 Fix duplicate logs

api/well-known/webfinger/index.ts

@@ -108,7 +108,7 @@ export default apiRoute((app) =>
             } catch (e) {
                 const error = e as ResponseError;
 
-                getLogger("federation")
+                getLogger(["federation", "bridge"])
                     .error`Error from bridge: ${await error.response.data}`;
             }
         }

classes/database/instance.ts

@@ -144,7 +144,7 @@ export class Instance extends BaseInterface<typeof Instances> {
     } | null> {
         const origin = new URL(url).origin;
         const wellKnownUrl = new URL("/.well-known/versia", origin);
-        const logger = getLogger("federation");
+        const logger = getLogger(["federation", "resolvers"]);
 
         const requester = await User.getFederationRequester();
 
@@ -201,7 +201,7 @@ export class Instance extends BaseInterface<typeof Instances> {
 
         // Go to endpoint, then follow the links to the actual metadata
 
-        const logger = getLogger("federation");
+        const logger = getLogger(["federation", "resolvers"]);
         const requester = await User.getFederationRequester();
 
         try {
@@ -332,7 +332,7 @@ export class Instance extends BaseInterface<typeof Instances> {
     }
 
     public static async resolve(url: string): Promise<Instance> {
-        const logger = getLogger("federation");
+        const logger = getLogger(["federation", "resolvers"]);
         const host = new URL(url).host;
 
         const existingInstance = await Instance.fromSql(
@@ -363,7 +363,7 @@ export class Instance extends BaseInterface<typeof Instances> {
     }
 
     public async updateFromRemote(): Promise<Instance> {
-        const logger = getLogger("federation");
+        const logger = getLogger(["federation", "resolvers"]);
 
         const output = await Instance.fetchMetadata(
             `https://${this.data.baseUrl}`,

classes/database/note.ts

@@ -747,7 +747,7 @@ export class Note extends BaseInterface<typeof Notes, NoteTypeWithRelations> {
         author: User,
     ): Promise<Note> {
         const emojis: Emoji[] = [];
-        const logger = getLogger("federation");
+        const logger = getLogger(["federation", "resolvers"]);
 
         for (const emoji of note.extensions?.["pub.versia:custom_emojis"]
             ?.emojis ?? []) {

classes/database/user.ts

@@ -716,7 +716,8 @@ export class User extends BaseInterface<typeof Users, UserWithRelations> {
     }
 
     public static async resolve(uri: string): Promise<User | null> {
-        getLogger("federation").debug`Resolving user ${chalk.gray(uri)}`;
+        getLogger(["federation", "resolvers"])
+            .debug`Resolving user ${chalk.gray(uri)}`;
         // Check if user not already in database
         const foundUser = await User.fromSql(eq(Users.uri, uri));
 
@@ -737,7 +738,7 @@ export class User extends BaseInterface<typeof Users, UserWithRelations> {
             return await User.fromId(uuid[0]);
         }
 
-        getLogger("federation")
+        getLogger(["federation", "resolvers"])
             .debug`User not found in database, fetching from remote`;
 
         return await User.saveFromRemote(uri);
@@ -1014,9 +1015,9 @@ export class User extends BaseInterface<typeof Users, UserWithRelations> {
                 },
             );
         } catch (e) {
-            getLogger("federation")
+            getLogger(["federation", "outbox"])
                 .error`Federating ${chalk.gray(entity.type)} to ${user.getUri()} ${chalk.bold.red("failed")}`;
-            getLogger("federation").error`${e}`;
+            getLogger(["federation", "outbox"]).error`${e}`;
             sentry?.captureException(e);
 
             return { ok: false };

utils/loggers.ts

@@ -175,12 +175,22 @@ export const configureLoggers = (silent = false): Promise<void> =>
                 filters: ["configFilter"],
             },
             {
-                category: "federation",
+                category: ["federation", "inbox"],
                 sinks: ["console", "file"],
                 filters: ["configFilter"],
             },
             {
-                category: ["federation", "inbox"],
+                category: ["federation", "outbox"],
+                sinks: ["console", "file"],
+                filters: ["configFilter"],
+            },
+            {
+                category: ["federation", "bridge"],
+                sinks: ["console", "file"],
+                filters: ["configFilter"],
+            },
+            {
+                category: ["federation", "resolvers"],
                 sinks: ["console", "file"],
                 filters: ["configFilter"],
             },