diff --git a/packages/server/src/routes/dm.ts b/packages/server/src/routes/dm.ts index f6be4a02..afe8d684 100644 --- a/packages/server/src/routes/dm.ts +++ b/packages/server/src/routes/dm.ts @@ -26,6 +26,7 @@ import { appendMutationLog, queueOutboxEvent, queueDmRelay, + queueDmCloseRelay, getDmParticipants, getGroupDmTargetOrigins, isFederationRelayEnabled, @@ -445,6 +446,9 @@ export async function dmRoutes(app: FastifyInstance): Promise { eq(schema.dmMembers.userId, request.userId), )) .run(); + + // Relay reopen to federated peers + queueDmCloseRelay(myDm.dmChannelId, request.userId, 'dm_reopen'); } const dmMemberRows = db.select() @@ -854,6 +858,9 @@ export async function dmRoutes(app: FastifyInstance): Promise { dmChannelId: id, }); + // Relay close to federated peers + queueDmCloseRelay(id, request.userId, 'dm_close'); + return reply.code(200).send({ success: true }); });