refactor(entries): simplify stdin reading with node:stream/consumers

This commit is contained in:
mitchell 2026-06-17 12:22:32 -04:00
parent 19272bc0b4
commit 7652e62d47
2 changed files with 6 additions and 9 deletions

View file

@ -1,4 +1,5 @@
#!/usr/bin/env node #!/usr/bin/env node
import consumers from "node:stream/consumers";
import util from "node:util"; import util from "node:util";
import { createOpenAICompatible } from "@ai-sdk/openai-compatible"; import { createOpenAICompatible } from "@ai-sdk/openai-compatible";
import { streamText } from "ai"; import { streamText } from "ai";
@ -72,8 +73,10 @@ async function main() {
if (modelFlag) convo.model = modelFlag; if (modelFlag) convo.model = modelFlag;
} }
let input = positionals.join(" ").trim();
if (input === "-") input = await consumers.text(process.stdin);
let prompt = "Introduce yourself."; let prompt = "Introduce yourself.";
const input = positionals.join(" ").trim();
if (messageFlag) prompt = Prompts.commit(input); if (messageFlag) prompt = Prompts.commit(input);
else if (reviewFlag) prompt = Prompts.review(input); else if (reviewFlag) prompt = Prompts.review(input);
else if (input) prompt = input; else if (input) prompt = input;

View file

@ -1,10 +1,10 @@
#!/usr/bin/env node #!/usr/bin/env node
import events from "node:events";
import fs from "node:fs/promises"; import fs from "node:fs/promises";
import os from "node:os"; import os from "node:os";
import path from "node:path"; import path from "node:path";
import process from "node:process"; import process from "node:process";
import readline from "node:readline"; import readline from "node:readline";
import consumers from "node:stream/consumers";
import util from "node:util"; import util from "node:util";
import { Readability } from "@mozilla/readability"; import { Readability } from "@mozilla/readability";
import chalk from "chalk"; import chalk from "chalk";
@ -36,13 +36,7 @@ async function main() {
let input = positionals.join(" ").trim(); let input = positionals.join(" ").trim();
if (!input) { if (!input) input = await consumers.text(process.stdin);
process.stdin.setEncoding("utf8");
process.stdin.on("data", (data) => {
input += data;
});
await events.once(process.stdin, "end");
}
if (!input) { if (!input) {
throw new Error("No input was given. Use positional arguments or stdin."); throw new Error("No input was given. Use positional arguments or stdin.");