feat: srvx fetch (#169)

Co-authored-by: pi0::agent <[email protected]>

Author: pi0

README.md

@@ -60,6 +60,7 @@ $ bunx --bun srvx
 | `jsx`            | [examples/jsx](https://github.com/h3js/srvx/tree/main/examples/jsx/)                       | `npx giget gh:h3js/srvx/examples/jsx srvx-jsx`                       |
 | `node-handler`   | [examples/node-handler](https://github.com/h3js/srvx/tree/main/examples/node-handler/)     | `npx giget gh:h3js/srvx/examples/node-handler srvx-node-handler`     |
 | `service-worker` | [examples/service-worker](https://github.com/h3js/srvx/tree/main/examples/service-worker/) | `npx giget gh:h3js/srvx/examples/service-worker srvx-service-worker` |
+| `streaming`      | [examples/streaming](https://github.com/h3js/srvx/tree/main/examples/streaming/)           | `npx giget gh:h3js/srvx/examples/streaming srvx-streaming`           |
 | `tracing`        | [examples/tracing](https://github.com/h3js/srvx/tree/main/examples/tracing/)               | `npx giget gh:h3js/srvx/examples/tracing srvx-tracing`               |
 | `websocket`      | [examples/websocket](https://github.com/h3js/srvx/tree/main/examples/websocket/)           | `npx giget gh:h3js/srvx/examples/websocket srvx-websocket`           |
 

docs/1.guide/1.index.md

@@ -98,6 +98,7 @@ bun run server.mjs
 | `jsx`            | [examples/jsx](https://github.com/h3js/srvx/tree/main/examples/jsx/)                       | `npx giget gh:h3js/srvx/examples/jsx srvx-jsx`                       |
 | `node-handler`   | [examples/node-handler](https://github.com/h3js/srvx/tree/main/examples/node-handler/)     | `npx giget gh:h3js/srvx/examples/node-handler srvx-node-handler`     |
 | `service-worker` | [examples/service-worker](https://github.com/h3js/srvx/tree/main/examples/service-worker/) | `npx giget gh:h3js/srvx/examples/service-worker srvx-service-worker` |
+| `streaming`      | [examples/streaming](https://github.com/h3js/srvx/tree/main/examples/streaming/)           | `npx giget gh:h3js/srvx/examples/streaming srvx-streaming`           |
 | `tracing`        | [examples/tracing](https://github.com/h3js/srvx/tree/main/examples/tracing/)               | `npx giget gh:h3js/srvx/examples/tracing srvx-tracing`               |
 | `websocket`      | [examples/websocket](https://github.com/h3js/srvx/tree/main/examples/websocket/)           | `npx giget gh:h3js/srvx/examples/websocket srvx-websocket`           |
 

docs/1.guide/8.cli.md

@@ -52,6 +52,17 @@ $ srvx --host=localhost       # Bind to localhost only
 $ srvx --import=jiti/register # Enable [jiti](https://github.com/unjs/jiti) loader
 $ srvx --tls --cert=cert.pem --key=key.pem  # Enable TLS (HTTPS/HTTP2)
 
+FETCH MODE
+
+# srvx fetch [options] [url]
+$ srvx fetch                  # Fetch from default entry
+$ srvx fetch /api/users       # Fetch a specific URL/path
+$ srvx fetch --entry ./server.ts /api/users # Fetch using a specific entry
+$ srvx fetch -X POST /api/users # POST request
+$ srvx fetch -H "Content-Type: application/json" /api # With headers
+$ srvx fetch -d '{"name":"foo"}' /api # With request body
+$ echo '{"name":"foo"}' | srvx fetch -d @- /api # Body from stdin
+$ srvx fetch -v /api/users    # Verbose output (show headers)
 
 ARGUMENTS
 
@@ -69,7 +80,14 @@ OPTIONS
   --cert <file>            TLS certificate file
   --key  <file>            TLS private key file
   -h, --help               Show this help message
-  -v, --version            Show server and runtime versions
+  --version                Show server and runtime versions
+
+FETCH OPTIONS
+
+  -X, --request <method>   HTTP method (default: GET, or POST if body is provided)
+  -H, --header <header>    Add header (format: "Name: Value", can be used multiple times)
+  -d, --data <data>        Request body (use @- for stdin, @file for file)
+  -v, --verbose            Show request and response headers
 
 ENVIRONMENT
 

examples/streaming/package.json

@@ -0,0 +1,12 @@
+{
+  "name": "srvx-examples-hello-world",
+  "version": "0.0.0",
+  "type": "module",
+  "scripts": {
+    "start": "srvx --prod",
+    "dev": "srvx"
+  },
+  "devDependencies": {
+    "srvx": "latest"
+  }
+}

examples/streaming/server.ts

@@ -0,0 +1,31 @@
+// Fixture: Streaming lorem ipsum text word by word
+const loremIpsum =
+  "Lorem ipsum dolor sit amet consectetur adipiscing elit sed do eiusmod tempor incididunt ut labore et dolore magna aliqua";
+
+export default {
+  fetch: (): Response => {
+    const words = loremIpsum.split(" ");
+    let index = 0;
+
+    const stream = new ReadableStream({
+      async pull(controller) {
+        if (index < words.length) {
+          const word = words[index] + (index < words.length - 1 ? " " : "");
+          controller.enqueue(new TextEncoder().encode(word));
+          index++;
+          await new Promise((resolve) => setTimeout(resolve, 100));
+        } else {
+          controller.close();
+        }
+      },
+    });
+
+    return new Response(stream, {
+      headers: {
+        "Content-Type": "text/plain",
+        "Cache-Control": "no-cache",
+        "X-Content-Type-Options": "nosniff",
+      },
+    });
+  },
+};