snxraven/p2ns
2
1
Fork 1
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Caching

Browse Source
This commit is contained in:
Raven Scott
2026-05-27 20:19:51 -04:00
parent b000e34016
commit f60de776a0
1 changed files with 61 additions and 19 deletions
Download Patch File Download Diff File Expand all files Collapse all files
p2ns.js
+61 -19
View File
@@ -337,6 +337,7 @@ async function main() {
let processingInvite = false;
let currentInvitePromise = null;
let currentPairOperation = null; // Track active pairing operation for cleanup
let cachedMasterInviteWire = null;
// Helper function to safely get dnsPass and ensure state consistency
function getDnsPass() {
@@ -382,6 +383,26 @@ async function main() {
}
}
async function prepareMasterInvite(reason = 'startup') {
if (!isMaster) return null;
const pass = getDnsPass();
if (!pass) return null;
if (cachedMasterInviteWire) return cachedMasterInviteWire;
const { createInvite, inviteToWire, invitePreview } = require('./includes/core/dns-pass-queue');
logInfo('Swarm', `Preparing cached Autopass invite (${reason})...`);
const inv = await createInvite(pass);
cachedMasterInviteWire = inviteToWire(inv);
logInfo('Swarm', `Cached Autopass invite ready (${invitePreview(inv)})`);
return cachedMasterInviteWire;
}
function clearCachedMasterInvite(reason = 'unknown') {
if (!cachedMasterInviteWire) return;
cachedMasterInviteWire = null;
logDebug('Swarm', `Cleared cached Autopass invite (${reason})`);
}
// Helper functions for invite processing mutex
function isProcessingInvite() {
return processingInvite;
@@ -453,10 +474,10 @@ async function main() {
logInfo('Swarm', `Processing pending invite request from ${peerId} (queued for ${Math.round(age/1000)}s)`);
try {
const { createInvite, inviteToWire, invitePreview } = require('./includes/core/dns-pass-queue');
const inv = await createInvite(state.dnsPass);
const invWire = inviteToWire(inv);
logInfo('Swarm', `Created invite for pending request from ${peerId}: ${invitePreview(inv)}`);
const invWire = await prepareMasterInvite(`pending request from ${peerId.substring(0, 16)}...`);
if (!invWire) {
throw new Error('cached master invite unavailable');
}
const sent = channelManager.sendToPeer(CORE_DOMAIN, 'invite', peerId, invWire);
if (sent) {
logInfo('Swarm', `Successfully sent pending invite to ${peerId}`);
@@ -780,6 +801,14 @@ async function main() {
// Handle invite acknowledgment from joiner
if (message === 'invite_ack') {
logInfo('Swarm', `Received invite_ack from peer ${peerId}`);
clearCachedMasterInvite(`ack from ${peerId.substring(0, 16)}...`);
if (isMaster) {
setTimeout(() => {
prepareMasterInvite('post-ack refresh').catch((err) => {
logWarn('Swarm', `Could not refresh cached invite after ack: ${err.message}`);
});
}, 3000);
}
// Clear pending ack timeout for this peer
const pending = pendingInviteAcks.get(peerId);
if (pending) {
@@ -871,8 +900,7 @@ async function main() {
channelManager.sendToPeer(CORE_DOMAIN, 'request', peerId, 'invite_unavailable:creation_failed');
return;
}
logInfo('Swarm', `Creating Autopass invite for peer ${peerId}...`);
const { createInvite, inviteToWire, invitePreview } = require('./includes/core/dns-pass-queue');
logInfo('Swarm', `Sending cached Autopass invite to peer ${peerId}...`);
const inviteChannelInfo = channelManager.getChannelInfo(CORE_DOMAIN, 'invite');
const invitePeerChannel = inviteChannelInfo?.peerChannels?.get(peerId);
if (invitePeerChannel) {
@@ -881,9 +909,11 @@ async function main() {
logWarn('Swarm', `Invite channel not fully open for ${peerId}, sending invite anyway (protomux may queue)`);
}
}
const inv = await createInvite(pass);
const invWire = inviteToWire(inv);
logInfo('Swarm', `Created invite for requesting peer ${peerId}: ${invitePreview(inv)}`);
const invWire = await prepareMasterInvite(`request from ${peerId.substring(0, 16)}...`);
if (!invWire) {
throw new Error('cached master invite unavailable');
}
logInfo('Swarm', `Cached invite ready for requesting peer ${peerId}`);
try {
const sent = channelManager.sendToPeer(CORE_DOMAIN, 'invite', peerId, invWire);
if (!sent) {
@@ -921,14 +951,15 @@ async function main() {
setTimeout(async () => {
const retryPass = getDnsPass();
const { isDnsPassUsable } = require('./includes/core/core');
const { createInvite, inviteToWire, whenDnsPassIdle, ensureDnsPassOpen } = require('./includes/core/dns-pass-queue');
const { whenDnsPassIdle, ensureDnsPassOpen } = require('./includes/core/dns-pass-queue');
if (!connectedPeers.has(peerId) || !retryPass) return;
await whenDnsPassIdle();
await ensureDnsPassOpen(retryPass);
if (!isDnsPassUsable(retryPass)) return;
try {
const inv = await createInvite(retryPass);
channelManager.sendToPeer(CORE_DOMAIN, 'invite', peerId, inviteToWire(inv));
const invWire = await prepareMasterInvite(`retry for ${peerId.substring(0, 16)}...`);
if (!invWire) return;
channelManager.sendToPeer(CORE_DOMAIN, 'invite', peerId, invWire);
logInfo('Swarm', `Sent invite to ${peerId} after dnsPass busy retry`);
} catch (retryErr) {
logWarn('Swarm', `Invite retry failed for ${peerId}: ${retryErr.message}`);
@@ -964,10 +995,14 @@ async function main() {
if (pass && isDnsPassUsable(pass) && (isMaster || process.env.ALLOW_ANY_WRITER_INVITES === 'true')) {
// We can create an invite - send it back through the relay chain
try {
const { createInvite, inviteToWire, whenDnsPassIdle } = require('./includes/core/dns-pass-queue');
const { whenDnsPassIdle } = require('./includes/core/dns-pass-queue');
await whenDnsPassIdle();
const inv = await createInvite(pass);
const invWire = inviteToWire(inv);
const invWire = isMaster
? await prepareMasterInvite(`relay for ${originPeerId.substring(0, 16)}...`)
: null;
if (!invWire) {
throw new Error('cached relay invite unavailable');
}
logInfo('Swarm', `Created relay invite for origin ${originPeerId.substring(0, 16)}...`);
channelManager.sendToPeer(CORE_DOMAIN, 'request', peerId, `relay_invite_response:${originPeerId}:${invWire}`);
} catch (err) {
@@ -1310,10 +1345,11 @@ async function main() {
pendingInviteAcks.delete(peerId);
return;
}
const { createInvite, inviteToWire, invitePreview } = require('./includes/core/dns-pass-queue');
const inv = await createInvite(pass);
const invWire = inviteToWire(inv);
logInfo('Swarm', `Created proactive invite for peer ${peerId} (attempt ${retryCount}/${maxRetries}): ${invitePreview(inv)}`);
const invWire = await prepareMasterInvite(`proactive send to ${peerId.substring(0, 16)}...`);
if (!invWire) {
throw new Error('cached master invite unavailable');
}
logInfo('Swarm', `Using cached proactive invite for peer ${peerId} (attempt ${retryCount}/${maxRetries})`);
const success = channelManager.sendToPeer(CORE_DOMAIN, 'invite', peerId, invWire);
if (success) {
@@ -1756,6 +1792,12 @@ async function main() {
}
logInfo('Main', `Core retrieved. Writable: ${core.writable}, Key: ${core.key.toString('hex')}`);
try {
await prepareMasterInvite('master startup before p2ns swarm join');
} catch (err) {
logError('Main', `Failed to prepare initial Autopass invite before swarm join: ${err.message}`);
logError('Main', 'Restart with --clean --master if this persists; invite requests will fail until an invite can be cached.');
}
// Setup domains watcher for master
setupDomainsWatcher();
setupListeners();