fix(federation): uploads not working properly

ee/packages/federation-matrix/src/FederationMatrix.ts

@@ -428,7 +428,7 @@ export class FederationMatrix extends ServiceClass implements IFederationMatrixS
 			let lastEventId: { eventId: string } | null = null;
 
 			for await (const file of message.files) {
-				const mxcUri = await MatrixMediaService.prepareLocalFileForMatrix(file._id, matrixDomain);
+				const mxcUri = await MatrixMediaService.prepareLocalFileForMatrix(file._id, matrixDomain, matrixRoomId);
 
 				const msgtype = this.getMatrixMessageType(file.type);
 				const fileContent = {

ee/packages/federation-matrix/src/events/message.ts

@@ -29,6 +29,7 @@ async function handleMediaMessage(
 	messageBody: string,
 	user: IUser,
 	room: IRoom,
+	matrixRoomId: string,
 	eventId: EventID,
 	tmid?: string,
 ): Promise<{
@@ -42,7 +43,7 @@ async function handleMediaMessage(
 	const mimeType = fileInfo?.mimetype;
 	const fileName = messageBody;
 
-	const fileRefId = await MatrixMediaService.downloadAndStoreRemoteFile(url, {
+	const fileRefId = await MatrixMediaService.downloadAndStoreRemoteFile(url, matrixRoomId, {
 		name: messageBody,
 		size: fileInfo?.size,
 		type: mimeType,
@@ -226,7 +227,17 @@ export function message(emitter: Emitter<HomeserverEventSignatures>, serverName:
 
 			const isMediaMessage = Object.values(fileTypes).includes(msgtype as FileMessageType);
 			if (isMediaMessage && content.url) {
-				const result = await handleMediaMessage(content.url, content.info, msgtype, messageBody, user, room, data.event_id, thread?.tmid);
+				const result = await handleMediaMessage(
+					content.url,
+					content.info,
+					msgtype,
+					messageBody,
+					user,
+					room,
+					data.room_id,
+					data.event_id,
+					thread?.tmid,
+				);
 				await Message.saveMessageFromFederation(result);
 			} else {
 				const formatted = toInternalMessageFormat({

ee/packages/federation-matrix/src/services/MatrixMediaService.ts

@@ -38,7 +38,7 @@ export class MatrixMediaService {
 		};
 	}
 
-	static async prepareLocalFileForMatrix(fileId: string, serverName: string): Promise<string> {
+	static async prepareLocalFileForMatrix(fileId: string, serverName: string, matrixRoomId: string): Promise<string> {
 		try {
 			const file = await Uploads.findOneById(fileId);
 			if (!file) {
@@ -53,6 +53,7 @@ export class MatrixMediaService {
 			const mxcUri = this.generateMXCUri(fileId, serverName);
 
 			await Uploads.setFederationInfo(fileId, {
+				mrid: matrixRoomId,
 				mxcUri,
 				serverName,
 				mediaId: fileId,
@@ -86,6 +87,7 @@ export class MatrixMediaService {
 
 	static async downloadAndStoreRemoteFile(
 		mxcUri: string,
+		matrixRoomId: string,
 		metadata: {
 			name: string;
 			size?: number;
@@ -131,6 +133,7 @@ export class MatrixMediaService {
 
 			await Uploads.setFederationInfo(uploadedFile._id, {
 				mxcUri,
+				mrid: matrixRoomId,
 				serverName: parts.serverName,
 				mediaId: parts.mediaId,
 			});

packages/core-typings/src/IUpload.ts

@@ -61,6 +61,7 @@ export interface IUpload {
 	};
 	federation?: {
 		mxcUri: string;
+		mrid: string;
 		serverName: string;
 		mediaId: string;
 	};