import test from "node:test";import assert from "node:assert/strict";import { createDefaultRegistry } from "../src/commands/registry.js"; function streamOf(items) { return (async function* () { for (const item of items) yield item; })();} test("exec --stdin jsonl feeds pipeline input to subprocess", async () => { const registry = createDefaultRegistry(); const cmd = registry.get("exec"); const nodeScript = [ "let d='';", "process.stdin.on('data',c=>d+=c);", "process.stdin.on('end',()=>{", " const lines=d.trim().split('\\n').filter(Boolean);", " console.log(JSON.stringify(lines));", "});", ].join(""); const result = await cmd.run({ input: streamOf([{ a: 1 }, { a: 2 }]), args: { _: ["node", "-e", nodeScript], stdin: "jsonl", json: true, }, ctx: { stdin: process.stdin, stdout: process.stdout, stderr: process.stderr, env: process.env, registry, mode: "human", render: { json() {}, lines() {} }, }, }); const items = []; for await (const item of result.output) items.push(item); assert.deepEqual(items, ['{"a":1}', '{"a":2}']);});
import test from "node:test";
import assert from "node:assert/strict";
import { createDefaultRegistry } from "../src/commands/registry.js";
function streamOf(items) {
return (async function* () {
for (const item of items) yield item;
})();
}
test("exec --stdin jsonl feeds pipeline input to subprocess", async () => {
const registry = createDefaultRegistry();
const cmd = registry.get("exec");
const nodeScript = [
"let d='';",
"process.stdin.on('data',c=>d+=c);",
"process.stdin.on('end',()=>{",
" const lines=d.trim().split('\\n').filter(Boolean);",
" console.log(JSON.stringify(lines));",
"});",
].join("");
const result = await cmd.run({
input: streamOf([{ a: 1 }, { a: 2 }]),
args: {
_: ["node", "-e", nodeScript],
stdin: "jsonl",
json: true,
},
ctx: {
stdin: process.stdin,
stdout: process.stdout,
stderr: process.stderr,
env: process.env,
registry,
mode: "human",
render: { json() {}, lines() {} },
},
});
const items = [];
for await (const item of result.output) items.push(item);
assert.deepEqual(items, ['{"a":1}', '{"a":2}']);
});