added periodic rebroadcasting

Signed-off-by: Robert Gogete <[email protected]>

Author: gogeterobert

README.md

@@ -76,8 +76,10 @@ The package includes a complete example that automatically shares and discovers
 The example will:
 - Seed all `*.dig` files from `~/.dig` directory
 - Share their magnet URIs via Gun.js registry
-- Periodically discover magnet URIs from other peers
-- Download files that you don't already have
+- **Every 30 seconds:**
+  - Rebroadcast all seeded magnet URIs (to keep them fresh in the registry)
+  - Discover magnet URIs from other peers
+  - Download files that you don't already have
 - Automatically seed downloaded files
 
 You can create test files:

examples/nat-tools-example.js

@@ -96,6 +96,28 @@ async function seedAllDigFiles(natTools) {
   return seededFiles;
 }
 
+/**
+ * Rebroadcast all currently seeded magnet URIs
+ */
+async function rebroadcastMagnetUris(natTools) {
+  try {
+    const seededFiles = natTools.getSeededFiles();
+    
+    if (seededFiles.size === 0) {
+      logger.debug('No files to rebroadcast');
+      return;
+    }
+
+    logger.info(`📡 Rebroadcasting ${seededFiles.size} magnet URIs...`);
+
+    const count = await natTools.rebroadcastMagnetUris();
+    
+    logger.info(`✅ Rebroadcast ${count} magnet URIs successfully`);
+  } catch (error) {
+    logger.error('❌ Error during rebroadcast:', error.message);
+  }
+}
+
 /**
  * Discover and download new files
  */
@@ -238,12 +260,16 @@ async function main() {
     await seedAllDigFiles(natTools);
 
     logger.info('='.repeat(60));
-    logger.info('🔄 Starting periodic discovery...');
+    logger.info('🔄 Starting periodic discovery and rebroadcast...');
     logger.info('   Press Ctrl+C to stop');
     logger.info('='.repeat(60));
 
-    // Start periodic discovery and download
-    const discoveryInterval = setInterval(async () => {
+    // Start periodic discovery, download, and rebroadcast
+    const periodicInterval = setInterval(async () => {
+      // Rebroadcast magnet URIs to keep them fresh
+      await rebroadcastMagnetUris(natTools);
+      
+      // Discover and download new files
       await discoverAndDownload(natTools);
     }, CONFIG.discoveryIntervalMs);
 
@@ -253,7 +279,7 @@ async function main() {
     // Handle graceful shutdown
     process.on('SIGINT', async () => {
       logger.info('\n\n🛑 Shutting down gracefully...');
-      clearInterval(discoveryInterval);
+      clearInterval(periodicInterval);
 
       try {
         await natTools.destroy();

src/nat-tools.ts

@@ -214,6 +214,41 @@ export class NatTools {
     return this.registry.isAvailable();
   }
 
+  /**
+   * Rebroadcast all currently seeded magnet URIs to refresh their timestamps
+   * This should be called periodically to keep magnet URIs fresh in the registry
+   * @returns Number of magnet URIs successfully rebroadcast
+   */
+  public async rebroadcastMagnetUris(): Promise<number> {
+    if (!this.isInitialized) {
+      throw new Error("NatTools not initialized. Call initialize() first.");
+    }
+
+    if (this.seededMagnetUris.size === 0) {
+      this.logger.debug("No magnet URIs to rebroadcast");
+      return 0;
+    }
+
+    this.logger.debug(`📡 Rebroadcasting ${this.seededMagnetUris.size} magnet URIs...`);
+
+    let successCount = 0;
+
+    for (const [filePath, magnetUri] of this.seededMagnetUris) {
+      try {
+        // Re-share the magnet URI to update its timestamp in the registry
+        await this.registry.shareMagnetUri(magnetUri);
+        successCount++;
+        this.logger.debug(`  ✅ Rebroadcast: ${path.basename(filePath)}`);
+      } catch (error) {
+        this.logger.warn(`  ⚠️ Failed to rebroadcast ${path.basename(filePath)}:`, error);
+      }
+    }
+
+    this.logger.debug(`✅ Rebroadcast ${successCount}/${this.seededMagnetUris.size} magnet URIs`);
+
+    return successCount;
+  }
+
   /**
    * Clean up resources
    */