fix(federation): address code review findings for FED-009

- Resolve homeUserId from DB in sendFederatedCallStart/End (not raw userId)
- Clear existing timeout in createFederatedCall before overwriting
- Clear federatedCallToken/Url in leaveVoice and handleForceDisconnect
- Remove unnecessary `as any` cast in relay processor

packages/server/src/routes/federation.ts

@@ -3092,7 +3092,7 @@ function processDmCallStartEvent(
       callerName: callerStub.displayName ?? callerStub.username,
       livekitUrl: event.call!.livekitUrl,
       livekitToken: token,
-    } as any);
+    });
   }
 
   accepted.push(event.messageId);

packages/server/src/ws/events.ts

@@ -1765,7 +1765,7 @@ async function sendFederatedCallStart(
         livekitUrl,
         tokens,
         caller: {
-          homeUserId: callerId,
+          homeUserId: members.find(m => m.userId === callerId)?.homeUserId || callerId,
           homeInstance: ourOrigin,
           displayName: callerName,
         },
@@ -1852,6 +1852,13 @@ async function sendFederatedCallEnd(dmChannelId: string, endedByUserId: string):
   }
   if (targets.size === 0) return;
 
+  // Resolve actual homeUserId from DB
+  const endUser = db.select({ homeUserId: schema.users.homeUserId })
+    .from(schema.users)
+    .where(eq(schema.users.id, endedByUserId))
+    .get();
+  const resolvedHomeUserId = endUser?.homeUserId || endedByUserId;
+
   const event = {
     eventType: 'dm_call_end' as const,
     messageId: generateSnowflake(),
@@ -1859,7 +1866,7 @@ async function sendFederatedCallEnd(dmChannelId: string, endedByUserId: string):
     timestamp: Date.now(),
     federatedId: channel.federatedId,
     call: {
-      endedBy: { homeUserId: endedByUserId, homeInstance: ourOrigin },
+      endedBy: { homeUserId: resolvedHomeUserId, homeInstance: ourOrigin },
     },
   };
 

packages/server/src/ws/handler.ts

@@ -445,6 +445,8 @@ class ConnectionManager {
 
   /** Register a federated call received via S2S. Adds 60s ringing timeout. */
   createFederatedCall(entry: FederatedCallEntry): void {
+    // Clear any existing entry + timeout to avoid leaked timers
+    this.clearFederatedCall(entry.dmChannelId);
     this.federatedCalls.set(entry.dmChannelId, entry);
 
     // 60s ringing timeout — mirrors host behavior

packages/web/src/stores/voiceStore.ts

@@ -482,6 +482,8 @@ export const useVoiceStore = create<VoiceState>()(
             focusedParticipantId: null,
             activeDmCall: null,
             outgoingCall: null,
+            federatedCallToken: null,
+            federatedCallUrl: null,
             deafenedUserIds: new Set(),
             participantMutes: new Map(),
             streamVolumes: new Map(),
@@ -517,6 +519,8 @@ export const useVoiceStore = create<VoiceState>()(
           focusedParticipantId: null,
           activeDmCall: null,
           outgoingCall: null,
+          federatedCallToken: null,
+          federatedCallUrl: null,
           deafenedUserIds: new Set(),
           participantMutes: new Map(),
           streamVolumes: new Map(),