.windsurf/workflows/mr-summary.md

@@ -1,7 +0,0 @@
----
-description: Generate a merge request summary
----
-
-- fetch origin/main
-- compare the current branch to origin/main
-- generate a merge request summary as an untracked file called merge-${branch}.md

__tests__/run/002-two-nodes.ts

@@ -17,7 +17,7 @@ describe('Run', () => {
     apps[0].config.seedPeers.push(apps[1].myRequestAddr);
     apps[1].config.seedPeers.push(apps[0].myRequestAddr);
 
-    await Promise.all(apps.map((app) => app.start()));
+    await Promise.all(apps.map((app) => app.start({ waitForReady: false })));
   });
 
   afterAll(async () => {

__tests__/run/004-simple-docker-test.ts

@@ -0,0 +1,13 @@
+import Docker from 'dockerode';
+import { describe, it, beforeAll, afterAll, expect } from '@jest/globals';
+import Debug from 'debug';
+
+const debug = Debug('rz:test:docker-smoke');
+
+// Simple test to verify Docker is working
+describe('Docker Smoke Test', () => {
+  let docker: Docker;
+  let container: any;
+
+  
+});

src/node.ts

@@ -83,13 +83,16 @@ export class RhizomeNode {
 
   /**
    * Start the node components
+   * @param options.startupOptions Options for node startup
+   * @param options.waitForReady Whether to wait for all components to be fully ready (default: false)
    * @param options.syncOnStart Whether to sync with peers on startup (default: false)
-   * @returns Promise that resolves when the node is fully started and ready
+   * @returns Promise that resolves when the node is started (and ready if waitForReady is true)
    */
   async start({
+    waitForReady = false,
     syncOnStart = false
-  }: { syncOnStart?: boolean } = {}): Promise<void> {
-    debug(`[${this.config.peerId}]`, 'Starting node (waiting for ready)...');
+  }: { waitForReady?: boolean; syncOnStart?: boolean } = {}): Promise<void> {
+    debug(`[${this.config.peerId}]`, `Starting node${waitForReady ? ' (waiting for ready)' : ''}...`);
     
     // Connect our lossless view to the delta stream
     this.deltaStream.subscribeDeltas(async (delta) => {
@@ -112,7 +115,11 @@ export class RhizomeNode {
     
     // Start HTTP server if enabled
     if (this.config.httpEnable && this.httpServer) {
-      await this.httpServer.startAndWait();
+      if (waitForReady) {
+        await this.httpServer.startAndWait();
+      } else {
+        this.httpServer.start();
+      }
     }
 
     // Initialize network components
@@ -125,7 +132,7 @@ export class RhizomeNode {
       await new Promise((resolve) => setTimeout(resolve, 1000));
     }
     
-    debug(`[${this.config.peerId}]`, 'Node started and ready');
+    debug(`[${this.config.peerId}]`, `Node started${waitForReady ? ' and ready' : ''}`);
   }
 
   async stop() {

src/orchestration/test-orchestrator/index.ts

@@ -61,7 +61,7 @@ export class TestOrchestrator extends BaseOrchestrator {
     // Start the node and wait for all components to be ready
     debug(`[${nodeId}] Starting node and waiting for it to be fully ready...`);
     try {
-      await node.start();
+      await node.start({ waitForReady: true });
       debug(`[${nodeId}] Node is fully started and ready`);
     } catch (error) {
       debug(`[${nodeId}] Error starting node:`, error);

src/views/lossless.ts

@@ -172,6 +172,7 @@ export class Lossless {
   viewSpecific(entityId: DomainEntityID, deltaIds: DeltaID[], deltaFilter?: DeltaFilter): LosslessViewOne | undefined {
     const combinedFilter = (delta: Delta) => {
       if (!deltaIds.includes(delta.id)) {
+        debug(`[${this.rhizomeNode.config.peerId}]`, `Excluding delta ${delta.id} because it's not in the requested list of deltas`);
         return false;
       }
       if (!deltaFilter) return true;