chore: update devcontainer

Author: sinedied

.devcontainer/devcontainer.json

@@ -8,10 +8,7 @@
   "features": {
     "ghcr.io/devcontainers/features/azure-cli:1": {},
     "ghcr.io/devcontainers/features/github-cli:1": {},
-    "ghcr.io/azure/azure-dev/azd:latest": {},
-    "ghcr.io/devcontainers/features/docker-in-docker:2": {
-      "moby": "false"
-    }
+    "ghcr.io/azure/azure-dev/azd:latest": {}
   },
   // Use 'forwardPorts' to make a list of ports inside the container available locally.
   "forwardPorts": [7071, 7072, 4280, 3000],

packages/agent-api/src/functions/stream-get.ts

@@ -0,0 +1,24 @@
+import { app, HttpRequest, HttpResponseInit, InvocationContext } from '@azure/functions';
+import { createWriteStream } from 'fs';
+import { Writable } from 'stream';
+
+app.setup({ enableHttpStream: true });
+
+app.http('test', {
+  methods: ['POST'],
+  authLevel: 'anonymous',
+  handler: async function (request: HttpRequest, context: InvocationContext): Promise<HttpResponseInit> {
+    const writeStream = createWriteStream('test.txt');
+    await request.body?.pipeTo(Writable.toWeb(writeStream));
+
+    for (let i = 0; i < 10; i++) {
+      context.log(`Processing chunk ${i + 1}/10`);
+      writeStream.write(`Chunk ${i + 1}\n`);
+      await new Promise((resolve) => setTimeout(resolve, 500));
+    }
+
+    context.log('Processing complete');
+
+    return { body: 'Done!' };
+  },
+});