test: add e2e tests for streaming, session continuity, user-id, and deploy --plan

Author: Hweinstock

e2e-tests/e2e-helper.ts

@@ -261,6 +261,94 @@ export function createE2ESuite(cfg: E2EConfig) {
       },
       120000
     );
+
+    it.skipIf(!canRun)(
+      'invoke supports streaming',
+      async () => {
+        const result = await run(['invoke', '--prompt', 'Say hello', '--agent', agentName, '--stream', '--json']);
+
+        expect(result.exitCode, `Stream invoke failed: ${result.stderr}`).toBe(0);
+        expect(result.stdout.length, 'Streaming invoke should produce output').toBeGreaterThan(0);
+      },
+      120000
+    );
+
+    it.skipIf(!canRun)(
+      'invoke maintains conversation continuity with session ID',
+      async () => {
+        const sessionId = `e2e-session-${randomUUID()}`;
+
+        // First turn: say something memorable
+        await retry(
+          async () => {
+            const r1 = await run([
+              'invoke',
+              '--prompt',
+              'Remember this word: pineapple',
+              '--agent',
+              agentName,
+              '--session-id',
+              sessionId,
+              '--json',
+            ]);
+            expect(r1.exitCode, `First turn failed (stdout: ${r1.stdout}, stderr: ${r1.stderr})`).toBe(0);
+          },
+          3,
+          10000
+        );
+
+        // Second turn: ask for it back
+        const r2 = await run([
+          'invoke',
+          '--prompt',
+          'What word did I ask you to remember?',
+          '--agent',
+          agentName,
+          '--session-id',
+          sessionId,
+          '--json',
+        ]);
+        expect(r2.exitCode, `Second turn failed: ${r2.stderr}`).toBe(0);
+
+        const json = parseJsonOutput(r2.stdout) as { success: boolean; response?: string };
+        expect(json.success).toBe(true);
+        expect(json.response?.toLowerCase(), 'Response should reference the word from the first turn').toContain(
+          'pineapple'
+        );
+      },
+      180000
+    );
+
+    it.skipIf(!canRun)(
+      'invoke accepts a user ID',
+      async () => {
+        const result = await run([
+          'invoke',
+          '--prompt',
+          'Say hello',
+          '--agent',
+          agentName,
+          '--user-id',
+          'test-user-e2e',
+          '--json',
+        ]);
+
+        expect(result.exitCode, `Invoke with user-id failed: ${result.stderr}`).toBe(0);
+        const json = parseJsonOutput(result.stdout) as { success: boolean };
+        expect(json.success).toBe(true);
+      },
+      120000
+    );
+
+    it.skipIf(!canRun)(
+      'deploy --plan previews without modifying infrastructure',
+      async () => {
+        const result = await run(['deploy', '--plan', '--json']);
+
+        expect(result.exitCode, `Deploy --plan failed: ${result.stderr}`).toBe(0);
+      },
+      120000
+    );
   });
 }