let5see/clawdbot
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: resolve ReadableStream cast in skills install

Browse Source
This commit is contained in:
Peter Steinberger
2026-01-21 00:33:10 +00:00
parent dd38185e6c
commit 48b0d08493
1 changed files with 6 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
src/agents/skills-install.ts
View File

@@ -1,6 +1,7 @@
import fs from "node:fs"; import fs from "node:fs";
import path from "node:path"; import path from "node:path";
import { Readable } from "node:stream"; import { Readable } from "node:stream";
import type { ReadableStream as NodeReadableStream } from "node:stream/web";
import { pipeline } from "node:stream/promises"; import { pipeline } from "node:stream/promises";
import type { ClawdbotConfig } from "../config/config.js"; import type { ClawdbotConfig } from "../config/config.js";
@@ -154,10 +155,12 @@ async function downloadFile(
await ensureDir(path.dirname(destPath)); await ensureDir(path.dirname(destPath));
const file = fs.createWriteStream(destPath); const file = fs.createWriteStream(destPath);
const body = response.body; const body = response.body;
// Node's Readable.fromWeb expects the node:stream/web type; cast through unknown for DOM streams.
const nodeStream = body as unknown as NodeJS.ReadableStream;
const readable = const readable =
typeof (body as NodeJS.ReadableStream).pipe === "function" typeof nodeStream.pipe === "function"
? (body as NodeJS.ReadableStream) ? nodeStream
: Readable.fromWeb(body as Parameters<typeof Readable.fromWeb>[0]); : Readable.fromWeb(body as unknown as NodeReadableStream);
await pipeline(readable, file); await pipeline(readable, file);
const stat = await fs.promises.stat(destPath); const stat = await fs.promises.stat(destPath);
return { bytes: stat.size }; return { bytes: stat.size };