devsyncwrld/backspace
1
0
Fork 0
Code Issues Pull Requests Actions 23 Packages Projects Releases 1 Wiki Activity

feat(server): wire onPeerDeactivated on performHandshake 403 rejection

Browse Source
This commit is contained in:
Jannis Braun
2026-04-24 00:43:32 +02:00
parent 743fdcac97
commit 8e6639648e
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
packages/server/src/utils/federationPeering.ts
+4 -1
View File
@@ -4,7 +4,7 @@ import { eq } from 'drizzle-orm';
import { generateSnowflake } from './snowflake.js'; import { generateSnowflake } from './snowflake.js';
import { getOurOrigin, generateHmacSecret } from './federationAuth.js'; import { getOurOrigin, generateHmacSecret } from './federationAuth.js';
import { validateOrigin } from '../routes/federation.js'; import { validateOrigin } from '../routes/federation.js';
import { onPeerActivated } from './federationPeerActivation.js'; import { onPeerActivated, onPeerDeactivated } from './federationPeerActivation.js';
// ─── Types ─────────────────────────────────────────────────────────────────── // ─── Types ───────────────────────────────────────────────────────────────────
@@ -187,6 +187,9 @@ async function performHandshake(
.run(); .run();
const { connectionManager } = await import('../ws/handler.js'); const { connectionManager } = await import('../ws/handler.js');
connectionManager.sendToAdmins({ type: 'federation_peers_changed' as const }); connectionManager.sendToAdmins({ type: 'federation_peers_changed' as const });
onPeerDeactivated(peerId, 'remote_rejected').catch(err =>
console.error('[federation] onPeerDeactivated from performHandshake rejected failed:', err)
);
return { status: 'rejected', error: errorMessage }; return { status: 'rejected', error: errorMessage };
} }