claudia.keller/openclaw-matrix-multiaccounts
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

fix: handle downloadContent response format correctly

Browse source 
client.downloadContent() returns {data: Buffer, contentType: string},
not a raw Buffer. This was causing media downloads to fail with
ERR_INVALID_ARG_TYPE.
This commit is contained in:
Claudia 2026-02-01 20:01:09 +01:00
parent 68ebaf5014
commit 73713a574d
2 changed files with 10 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
src/matrix/monitor/handler.ts
View file

@ -358,6 +358,7 @@ export function createMatrixRoomMessageHandler(params: MatrixMonitorHandlerParam
const contentSize = const contentSize =
typeof contentInfo?.size === "number" ? contentInfo.size : undefined; typeof contentInfo?.size === "number" ? contentInfo.size : undefined;
if (mediaUrl?.startsWith("mxc://")) { if (mediaUrl?.startsWith("mxc://")) {
debugWrite(`HANDLER: attempting media download url=${mediaUrl} size=${contentSize ?? "unknown"} maxBytes=${mediaMaxBytes}`);
logVerboseMessage(`matrix: attempting media download url=${mediaUrl} size=${contentSize ?? "unknown"} maxBytes=${mediaMaxBytes}`); logVerboseMessage(`matrix: attempting media download url=${mediaUrl} size=${contentSize ?? "unknown"} maxBytes=${mediaMaxBytes}`);
try { try {
media = await downloadMatrixMedia({ media = await downloadMatrixMedia({
@ -368,11 +369,14 @@ export function createMatrixRoomMessageHandler(params: MatrixMonitorHandlerParam
maxBytes: mediaMaxBytes, maxBytes: mediaMaxBytes,
file: contentFile, file: contentFile,
}); });
debugWrite(`HANDLER: media download SUCCESS path=${media?.path ?? "none"}`);
logVerboseMessage(`matrix: media download success path=${media?.path ?? "none"}`); logVerboseMessage(`matrix: media download success path=${media?.path ?? "none"}`);
} catch (err) { } catch (err) {
debugWrite(`HANDLER: media download FAILED: ${String(err)}`);
logVerboseMessage(`matrix: media download failed: ${String(err)}`); logVerboseMessage(`matrix: media download failed: ${String(err)}`);
} }
} else if (mediaUrl) { } else if (mediaUrl) {
debugWrite(`HANDLER: skipping non-mxc url=${mediaUrl}`);
logVerboseMessage(`matrix: skipping non-mxc media url=${mediaUrl}`); logVerboseMessage(`matrix: skipping non-mxc media url=${mediaUrl}`);
} }

8
src/matrix/monitor/media.ts
View file

@ -28,11 +28,15 @@ async function fetchMatrixMediaBuffer(params: {
// Use the client's download method which handles auth // Use the client's download method which handles auth
try { try {
const buffer = await params.client.downloadContent(params.mxcUrl); // downloadContent returns {data: Buffer, contentType: string}
const response = await params.client.downloadContent(params.mxcUrl);
const buffer = response.data;
const contentType = response.contentType;
if (buffer.byteLength > params.maxBytes) { if (buffer.byteLength > params.maxBytes) {
throw new Error("Matrix media exceeds configured size limit"); throw new Error("Matrix media exceeds configured size limit");
} }
return { buffer: Buffer.from(buffer) }; return { buffer: Buffer.from(buffer), headerType: contentType };
} catch (err) { } catch (err) {
throw new Error(`Matrix media download failed: ${String(err)}`); throw new Error(`Matrix media download failed: ${String(err)}`);
} }