till/managarten
1
0
Fork 0
mirror of https://github.com/Memo-2023/mana-monorepo.git synced 2026-05-14 20:21:09 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions 4

fix(matrix-bot-common): use authenticated media API for downloads

Browse source 
Newer Synapse versions (1.98+) require authenticated downloads via
/_matrix/client/v1/media/download/ endpoint. Falls back to legacy
API for older servers.

Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
This commit is contained in:
Till-JS 2026-02-01 04:07:38 +01:00
parent 582f7435f1
commit 793b6d8e17
1 changed files with 33 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

36
packages/matrix-bot-common/src/base/base-matrix.service.ts
View file

@ -221,11 +221,41 @@ export abstract class BaseMatrixService implements OnModuleInit, OnModuleDestroy
}
/**
* Download media from Matrix
* Download media from Matrix using authenticated media API (v1)
* Newer Synapse versions require authenticated downloads via /_matrix/client/v1/media/download/
*/
protected async downloadMedia(mxcUrl: string): Promise<Buffer> {
const result = await this.client.downloadContent(mxcUrl);
return result.data;
// Parse mxc:// URL -> mxc://server/mediaId
const match = mxcUrl.match(/^mxc:\/\/([^/]+)\/(.+)$/);
if (!match) {
throw new Error(`Invalid mxc URL: ${mxcUrl}`);
}
const [, serverName, mediaId] = match;
const config = this.getConfig();
// Use the new authenticated media API (Matrix spec v1.11+)
const downloadUrl = `${config.homeserverUrl}/_matrix/client/v1/media/download/${serverName}/${mediaId}`;
const response = await fetch(downloadUrl, {
headers: {
Authorization: `Bearer ${config.accessToken}`,
},
});
if (!response.ok) {
// Fallback to old API for older servers
this.logger.debug(`v1 media API failed (${response.status}), trying legacy API...`);
try {
const result = await this.client.downloadContent(mxcUrl);
return result.data;
} catch {
throw new Error(`Failed to download media: ${response.status} ${response.statusText}`);
}
}
const arrayBuffer = await response.arrayBuffer();
return Buffer.from(arrayBuffer);
}
/**