explorer: implement chunk syncing with all clients (#22)

client/src/api/GameManager.ts

@@ -383,13 +383,28 @@ class GameManager extends EventEmitter implements AbstractGameManager {
 
       this.explorerIPs.forEach((ip) => {
         const explorer = new window.Primus(ip);
+        const syncChunk = (chunk) => {
+          this.explorers.forEach((otherExplorer, otherIp) => {
+            if (ip !== otherIp) {
+              otherExplorer.emit('sync-chunk', chunk);
+            }
+          });
+        };
+
         explorer.on('sync-map', (chunks) => {
-          chunks.forEach((chunk) => this.addNewChunk(chunk));
+          chunks.forEach((chunk) => {
+            this.addNewChunk(chunk);
+            syncChunk(chunk);
+          });
         });
         explorer.on('new-chunk', (chunk) => {
           this.lastChunkPerExplorer.set(ip, chunk.chunkFootprint);
           this.addNewChunk(chunk);
           this.emit(GameManagerEvent.DiscoveredNewChunk, chunk);
+          syncChunk(chunk);
+        });
+        explorer.on('new-sync-chunk', (chunk) => {
+          this.addNewChunk(chunk);
         });
         explorer.on('hash-rate', (hashRate) => {
           this.hashRatePerExplorer.set(ip, hashRate);

index.mjs

@@ -43,7 +43,7 @@ const answers = await inquirer.prompt([
   {
     type: 'input',
     name: 'initCoords',
-    message: `Which x,y coords do you want to start mining at? (comma-separated)`,
+    message: `Which x,y coords do you want to start exploring at? (comma-separated)`,
     default: '0,0',
     filter: (coords) => {
       const [x = 0, y = 0] = coords.split(',').map((i) => i.trim());
@@ -176,6 +176,15 @@ if (isWebsocketServer) {
     spark.on('set-radius', (radius) => {
       minerManager.setRadius(radius);
     });
+
+    spark.on('sync-chunk', (chunk) => {
+      localStorageManager.updateChunk(chunk, false);
+      primus.forEach((otherSpark, otherId) => {
+        if (otherId !== spark.id) {
+          otherSpark.emit('new-sync-chunk', chunk);
+        }
+      });
+    });
   });
 }