diff --git a/classes/database/user.ts b/classes/database/user.ts index 8bf9daa2..74ddbfb5 100644 --- a/classes/database/user.ts +++ b/classes/database/user.ts @@ -716,6 +716,7 @@ export class User extends BaseInterface { } public static async resolve(uri: string): Promise { + getLogger("federation").debug`Resolving user ${chalk.bold(uri)}`; // Check if user not already in database const foundUser = await User.fromSql(eq(Users.uri, uri)); @@ -736,6 +737,9 @@ export class User extends BaseInterface { return await User.fromId(uuid[0]); } + getLogger("federation") + .debug`User not found in database, fetching from remote`; + return await User.saveFromRemote(uri); } diff --git a/worker.ts b/worker.ts index b346095a..e8539a1a 100644 --- a/worker.ts +++ b/worker.ts @@ -3,6 +3,7 @@ import type { Entity } from "@versia/federation/types"; import { Instance, Note, User } from "@versia/kit/db"; import { Queue, Worker } from "bullmq"; import type { SocketAddress } from "bun"; +import chalk from "chalk"; import IORedis from "ioredis"; import { InboxProcessor } from "./classes/inbox/processor.ts"; import { config } from "./packages/config-manager/index.ts"; @@ -98,6 +99,12 @@ export const inboxWorker = new Worker( const logger = getLogger(["federation", "inbox"]); + logger.debug( + `Processing entity ${chalk.bold( + data.id, + )} from ${chalk.bold(signedBy)}`, + ); + if (authorization) { const processor = new InboxProcessor( request, @@ -112,6 +119,12 @@ export const inboxWorker = new Worker( ip, ); + logger.debug( + `Entity ${chalk.bold( + data.id, + )} is potentially from a bridge`, + ); + return await processor.process(); }