mirror of
https://github.com/openclaw/openclaw.git
synced 2026-06-06 05:51:15 +08:00
build(deps): refresh workspace dependency pins
This commit is contained in:
@@ -1,8 +1,8 @@
|
||||
diff --git a/dist/acp-agent.js b/dist/acp-agent.js
|
||||
index e1d9aa9f0815f57ea2fd299a7f2b8ef0917ca191..875fdfb25fbfa905ca80728355d25a17e6d89148 100644
|
||||
index d0af13a..0f84309 100644
|
||||
--- a/dist/acp-agent.js
|
||||
+++ b/dist/acp-agent.js
|
||||
@@ -436,6 +436,7 @@ export class ClaudeAcpAgent {
|
||||
@@ -441,6 +441,7 @@ export class ClaudeAcpAgent {
|
||||
session.promptRunning = true;
|
||||
let handedOff = false;
|
||||
let stopReason = "end_turn";
|
||||
@@ -10,7 +10,7 @@ index e1d9aa9f0815f57ea2fd299a7f2b8ef0917ca191..875fdfb25fbfa905ca80728355d25a17
|
||||
try {
|
||||
while (true) {
|
||||
const { value: message, done } = await session.query.next();
|
||||
@@ -443,6 +444,9 @@ export class ClaudeAcpAgent {
|
||||
@@ -448,6 +449,9 @@ export class ClaudeAcpAgent {
|
||||
if (session.cancelled) {
|
||||
return { stopReason: "cancelled" };
|
||||
}
|
||||
@@ -20,7 +20,7 @@ index e1d9aa9f0815f57ea2fd299a7f2b8ef0917ca191..875fdfb25fbfa905ca80728355d25a17
|
||||
break;
|
||||
}
|
||||
if (session.emitRawSDKMessages &&
|
||||
@@ -499,7 +503,7 @@ export class ClaudeAcpAgent {
|
||||
@@ -518,7 +522,7 @@ export class ClaudeAcpAgent {
|
||||
break;
|
||||
}
|
||||
case "session_state_changed": {
|
||||
@@ -29,11 +29,13 @@ index e1d9aa9f0815f57ea2fd299a7f2b8ef0917ca191..875fdfb25fbfa905ca80728355d25a17
|
||||
return { stopReason, usage: sessionUsage(session) };
|
||||
}
|
||||
break;
|
||||
@@ -621,6 +625,7 @@ export class ClaudeAcpAgent {
|
||||
@@ -637,6 +641,9 @@ export class ClaudeAcpAgent {
|
||||
unreachable(message, this.logger);
|
||||
break;
|
||||
}
|
||||
+ sawResult = true;
|
||||
+ if (!isTaskNotification) {
|
||||
+ sawResult = true;
|
||||
+ }
|
||||
break;
|
||||
}
|
||||
case "stream_event": {
|
||||
@@ -1,46 +0,0 @@
|
||||
diff --git a/lib/Utils/messages-media.js b/lib/Utils/messages-media.js
|
||||
index 0d32dfb4882dfe029ba8804772d7d89404b08e76..73809fcd1d52362aef0c35cb7416c29d86482df0 100644
|
||||
--- a/lib/Utils/messages-media.js
|
||||
+++ b/lib/Utils/messages-media.js
|
||||
@@ -353,9 +353,17 @@
|
||||
const fileSha256 = sha256Plain.digest();
|
||||
const fileEncSha256 = sha256Enc.digest();
|
||||
encFileWriteStream.write(mac);
|
||||
+ // Create finish promises before calling end() to avoid missing the event
|
||||
+ const encFinishPromise = once(encFileWriteStream, 'finish');
|
||||
+ const originalFinishPromise = originalFileStream ? once(originalFileStream, 'finish') : Promise.resolve();
|
||||
encFileWriteStream.end();
|
||||
originalFileStream?.end?.();
|
||||
stream.destroy();
|
||||
+ // Wait for write streams to fully flush to disk before returning encFilePath.
|
||||
+ // Without this await, the caller may open a read stream on the file before
|
||||
+ // the OS has created it, causing a race-condition ENOENT crash.
|
||||
+ await encFinishPromise;
|
||||
+ await originalFinishPromise;
|
||||
logger?.debug('encrypted data successfully');
|
||||
return {
|
||||
mediaKey,
|
||||
@@ -520,11 +528,10 @@
|
||||
// eslint-disable-next-line @typescript-eslint/no-explicit-any
|
||||
let result;
|
||||
try {
|
||||
const stream = createReadStream(filePath);
|
||||
const response = await fetch(url, {
|
||||
- dispatcher: fetchAgent,
|
||||
method: 'POST',
|
||||
body: stream,
|
||||
headers: {
|
||||
...(() => {
|
||||
const hdrs = options?.headers;
|
||||
@@ -535,6 +542,11 @@
|
||||
'Content-Type': 'application/octet-stream',
|
||||
Origin: DEFAULT_ORIGIN
|
||||
},
|
||||
+ // Baileys passes a generic agent here in some runtimes. Undici's
|
||||
+ // `dispatcher` only works with Dispatcher-compatible implementations,
|
||||
+ // so only wire it through when the object actually implements
|
||||
+ // `dispatch`.
|
||||
+ ...(typeof fetchAgent?.dispatch === 'function' ? { dispatcher: fetchAgent } : {}),
|
||||
duplex: 'half',
|
||||
// Note: custom agents/proxy require undici Agent; omitted here.
|
||||
signal: timeoutMs ? AbortSignal.timeout(timeoutMs) : undefined
|
||||
28
patches/@whiskeysockets__baileys@7.0.0-rc10.patch
Normal file
28
patches/@whiskeysockets__baileys@7.0.0-rc10.patch
Normal file
@@ -0,0 +1,28 @@
|
||||
diff --git a/lib/Utils/messages-media.js b/lib/Utils/messages-media.js
|
||||
index 95f8c63..612b7fb 100644
|
||||
--- a/lib/Utils/messages-media.js
|
||||
+++ b/lib/Utils/messages-media.js
|
||||
@@ -596,7 +596,10 @@ const uploadWithFetch = async ({ url, filePath, headers, timeoutMs, agent }) =>
|
||||
const nodeStream = createReadStream(filePath);
|
||||
const webStream = Readable.toWeb(nodeStream);
|
||||
const response = await fetch(url, {
|
||||
- dispatcher: agent,
|
||||
+ // Baileys may pass a generic agent in some runtimes. Undici's dispatcher
|
||||
+ // option only accepts Dispatcher-compatible implementations, so only wire
|
||||
+ // it through when the object actually implements dispatch.
|
||||
+ ...(typeof agent?.dispatch === 'function' ? { dispatcher: agent } : {}),
|
||||
method: 'POST',
|
||||
body: webStream,
|
||||
headers,
|
||||
diff --git a/lib/Utils/logger.d.ts b/lib/Utils/logger.d.ts
|
||||
index 4d78996..059f58f 100644
|
||||
--- a/lib/Utils/logger.d.ts
|
||||
+++ b/lib/Utils/logger.d.ts
|
||||
@@ -7,6 +7,6 @@ export interface ILogger {
|
||||
info(obj: unknown, msg?: string): void;
|
||||
warn(obj: unknown, msg?: string): void;
|
||||
error(obj: unknown, msg?: string): void;
|
||||
}
|
||||
-declare const _default: import("pino").Logger<never, boolean>;
|
||||
+declare const _default: ILogger;
|
||||
export default _default;
|
||||
Reference in New Issue
Block a user