-
-
- Exported Data
+
+
+
+
+
${room.name}
+ protected wrapHTML(content: string, room: Room) {
+ return `
+
+
+
+
+
+
-
+
+
+
+ ${room.name}
+
+
+ ${content}
+
-
- ${content}
-
+
+
+ `
+ }
+
+ protected isEdit(event: MatrixEvent) {
+ if (event.getType() === "m.room.message" && event.getContent().hasOwnProperty("m.new_content")) return true;
+ return false;
+ }
+
+ protected async getUserAvatar(event: MatrixEvent) {
+ const member = event.sender;
+ if (!member.getMxcAvatarUrl()) {
+ return `
+
+ }.png)
- `;
- const blob = await this.getImageData(event);
- this.zip.file(`images/${event.getId()}.png`, blob);
- }
- break;
- default:
- break;
- }
-
- return `
-
- `;
-}
-
-protected async createHTML(events: MatrixEvent[], room: Room) {
- let content = "";
- let prevEvent = null;
- for (const event of events) {
- // As the getContent of the edited event fetches the latest edit, there is no need to process edit events
- if (this.isEdit(event)) continue;
- content += this.dateSeparator(event, prevEvent);
-
- if (event.getType() === "m.room.message") {
- const replyTo = this.getBaseEventId(event);
- const shouldBeJoined = prevEvent && prevEvent.getContent().msgtype === "m.text"
- && event.sender.userId === prevEvent.sender.userId && !this.dateSeparator(event, prevEvent) && !replyTo;
-
- const body = await this.createMessageBody(event, shouldBeJoined, !!replyTo, replyTo);
- content += body;
} else {
- const eventText = textForEvent(event);
- content += eventText ? `
-
+
-
-
-`
-}
-
-
-protected isEdit(event: MatrixEvent) {
- if (event.getType() === "m.room.message" && event.getContent().hasOwnProperty("m.new_content")) return true;
- return false;
-}
-
-protected async getUserAvatar(event: MatrixEvent) {
- const member = event.sender;
- if (!member.getMxcAvatarUrl()) {
- return `
-
+ ${event.sender.name[0]}
-
- `;
- } else {
- const imageUrl = mediaFromMxc(member.getMxcAvatarUrl()).getThumbnailOfSourceHttp(42, 42, "crop");
-
- if (!this.avatars.has(member.userId)) {
- this.avatars.set(member.userId, true);
- const image = await fetch(imageUrl);
- const blob = await image.blob();
- this.zip.file(`users/${member.userId}`, blob);
- }
-
- return `
-
-
-
- ${event.sender.name[0]}
-
-
-
- `;
- }
-}
-
-
-protected async getImageData(event: MatrixEvent) {
- let blob: Blob;
- try {
- const isEncrypted = event.isEncrypted();
- const content = event.getContent();
- if (isEncrypted) {
- blob = await decryptFile(content.file);
- } else {
- const media = mediaFromContent(event.getContent());
- const image = await fetch(media.srcHttp);
- blob = await image.blob();
- }
- } catch (err) {
- console.log("Error decrypting image");
- }
- return blob;
-}
-
-//Gets the event_id of an event to which an event is replied
-protected getBaseEventId = (event: MatrixEvent) => {
- const isEncrypted = event.isEncrypted();
-
- // If encrypted, in_reply_to lies in event.event.content
- const content = isEncrypted ? event.event.content : event.getContent();
- const relatesTo = content["m.relates_to"];
- return (relatesTo && relatesTo["m.in_reply_to"]) ? relatesTo["m.in_reply_to"]["event_id"] : null;
-};
-
-protected dateSeparator(event: MatrixEvent, prevEvent: MatrixEvent) {
- const prevDate = prevEvent ? new Date(prevEvent.getTs()) : null;
- const currDate = new Date(event.getTs());
- if (!prevDate || currDate.setHours(0, 0, 0, 0) !== prevDate.setHours(0, 0, 0, 0)) {
- return `
-
`;
- }
- return "";
-}
-
-protected async createMessageBody(event: MatrixEvent, joined = false, isReply = false, replyId = null) {
- const userPic = await this.getUserAvatar(event);
- let messageBody = "";
- switch (event.getContent().msgtype) {
- case "m.text":
- messageBody = `
- 
-
- ${event.getContent().body}
`;
- break;
- case "m.image": {
- messageBody = `
-
-
- `;
- const blob = await this.getImageData(event);
- this.zip.file(`images/${event.getId()}.png`, blob);
- }
- break;
- default:
- break;
- }
-
- return `
-
- `;
-}
-
-protected async createHTML(events: MatrixEvent[], room: Room) {
- let content = "";
- let prevEvent = null;
- for (const event of events) {
- // As the getContent of the edited event fetches the latest edit, there is no need to process edit events
- if (this.isEdit(event)) continue;
- content += this.dateSeparator(event, prevEvent);
-
- if (event.getType() === "m.room.message") {
- const replyTo = this.getBaseEventId(event);
- const shouldBeJoined = prevEvent && prevEvent.getContent().msgtype === "m.text"
- && event.sender.userId === prevEvent.sender.userId && !this.dateSeparator(event, prevEvent) && !replyTo;
-
- const body = await this.createMessageBody(event, shouldBeJoined, !!replyTo, replyTo);
- content += body;
} else {
- const eventText = textForEvent(event);
- content += eventText ? `
-
-
- ${textForEvent(event)}
+ const imageUrl = mediaFromMxc(member.getMxcAvatarUrl()).getThumbnailOfSourceHttp(42, 42, "crop");
+
+ if (!this.avatars.has(member.userId)) {
+ this.avatars.set(member.userId, true);
+ const image = await fetch(imageUrl);
+ const blob = await image.blob();
+ this.zip.file(`users/${member.userId}`, blob);
+ }
+
+ return `
+ ((resolve, reject) => {
- reader.onloadend = evt => {
- const arrayBufferNew: any = evt.target.result;
- const uint8ArrayNew = new Uint8Array(arrayBufferNew);
- writer.write(uint8ArrayNew);
- resolve();
- };
- reader.readAsArrayBuffer(blobPiece);
- });
- await waiter;
+ protected async getImageData(event: MatrixEvent) {
+ let blob: Blob;
+ try {
+ const isEncrypted = event.isEncrypted();
+ const content = event.getContent();
+ if (isEncrypted) {
+ blob = await decryptFile(content.file);
+ } else {
+ const media = mediaFromContent(event.getContent());
+ const image = await fetch(media.srcHttp);
+ blob = await image.blob();
+ }
+ } catch (err) {
+ console.log("Error decrypting image");
+ }
+ return blob;
}
- writer.close();
- return blob;
-}
+ //Gets the event_id of an event to which an event is replied
+ protected getBaseEventId = (event: MatrixEvent) => {
+ const isEncrypted = event.isEncrypted();
+
+ // If encrypted, in_reply_to lies in event.event.content
+ const content = isEncrypted ? event.event.content : event.getContent();
+ const relatesTo = content["m.relates_to"];
+ return (relatesTo && relatesTo["m.in_reply_to"]) ? relatesTo["m.in_reply_to"]["event_id"] : null;
+ };
+
+ protected dateSeparator(event: MatrixEvent, prevEvent: MatrixEvent) {
+ const prevDate = prevEvent ? new Date(prevEvent.getTs()) : null;
+ const currDate = new Date(event.getTs());
+ if (!prevDate || currDate.setHours(0, 0, 0, 0) !== prevDate.setHours(0, 0, 0, 0)) {
+ return `
+
+ `;
+ }
+ return "";
+ }
+
+ protected async createMessageBody(event: MatrixEvent, joined = false, isReply = false, replyId = null) {
+ const userPic = await this.getUserAvatar(event);
+ let messageBody = "";
+ switch (event.getContent().msgtype) {
+ case "m.text":
+ messageBody = `
+ `;
+ const blob = await this.getImageData(event);
+ this.zip.file(`images/${event.getId()}.png`, blob);
+ }
+ break;
+ default:
+ break;
+ }
+
+ return `
+
+ `;
+ }
+
+ protected async createHTML(events: MatrixEvent[], room: Room) {
+ let content = "";
+ let prevEvent = null;
+ for (const event of events) {
+ // As the getContent of the edited event fetches the latest edit, there is no need to process edit events
+ if (this.isEdit(event)) continue;
+ content += this.dateSeparator(event, prevEvent);
+
+ if (event.getType() === "m.room.message") {
+ const replyTo = this.getBaseEventId(event);
+ const shouldBeJoined = prevEvent && prevEvent.getContent().msgtype === "m.text"
+ && event.sender.userId === prevEvent.sender.userId && !this.dateSeparator(event, prevEvent) && !replyTo;
+
+ const body = await this.createMessageBody(event, shouldBeJoined, !!replyTo, replyTo);
+ content += body;
+ } else {
+ const eventText = textForEvent(event);
+ content += eventText ? `
+
+ ` : "";
+ }
+ prevEvent = event;
+ }
+ return this.wrapHTML(content, room);
+ }
+
+ public async export() {
+ const html = await this.createHTML(this.res, this.room);
+
+ this.zip.file("index.html", html);
+ this.zip.file("css/style.css", css);
+
+ const filename = `matrix-export-${new Date().toISOString()}.zip`;
+
+ //Generate the zip file asynchronously
+ const blob = await this.zip.generateAsync({ type: "blob" });
+
+ //Create a writable stream to the directory
+ const fileStream = streamSaver.createWriteStream(filename, { size: blob.size });
+ const writer = fileStream.getWriter();
+
+ // Here we chunk the blob into pieces of 10 MB, the size might be dynamically generated.
+ // This can be used to keep track of the progress
+ const sliceSize = 10 * 1e6;
+ for (let fPointer = 0; fPointer < blob.size; fPointer += sliceSize) {
+ const blobPiece = blob.slice(fPointer, fPointer + sliceSize);
+ const reader = new FileReader();
+
+ const waiter = new Promise((resolve, reject) => {
+ reader.onloadend = evt => {
+ const arrayBufferNew: any = evt.target.result;
+ const uint8ArrayNew = new Uint8Array(arrayBufferNew);
+ writer.write(uint8ArrayNew);
+ resolve();
+ };
+ reader.readAsArrayBuffer(blobPiece);
+ });
+ await waiter;
+ }
+ writer.close();
+
+ return blob;
+ }
}
+
- ` : "";
+ `;
}
- prevEvent = event;
}
- return this.wrapHTML(content, room);
-}
-
-public async export() {
- const html = await this.createHTML(this.res, this.room);
-
- this.zip.file("index.html", html);
- this.zip.file("css/style.css", css);
-
- const filename = `matrix-export-${new Date().toISOString()}.zip`;
-
- //Generate the zip file asynchronously
- const blob = await this.zip.generateAsync({ type: "blob" });
-
- //Create a writable stream to the directory
- const fileStream = streamSaver.createWriteStream(filename, { size: blob.size });
- const writer = fileStream.getWriter();
-
- // Here we chunk the blob into pieces of 10 MB, the size might be dynamically generated.
- // This can be used to keep track of the progress
- const sliceSize = 10 * 1e6;
- for (let fPointer = 0; fPointer < blob.size; fPointer += sliceSize) {
- const blobPiece = blob.slice(fPointer, fPointer + sliceSize);
- const reader = new FileReader();
-
- const waiter = new Promise
+
${event.getContent().body}
`;
+ break;
+ case "m.image": {
+ messageBody = `
+
+
+ `;
+ const blob = await this.getImageData(event);
+ this.zip.file(`images/${event.getId()}.png`, blob);
+ }
+ break;
+ default:
+ break;
+ }
+
+ return `
+
+ `;
+ }
+
+ protected async createHTML(events: MatrixEvent[], room: Room) {
+ let content = "";
+ let prevEvent = null;
+ for (const event of events) {
+ // As the getContent of the edited event fetches the latest edit, there is no need to process edit events
+ if (this.isEdit(event)) continue;
+ content += this.dateSeparator(event, prevEvent);
+
+ if (event.getType() === "m.room.message") {
+ const replyTo = this.getBaseEventId(event);
+ const shouldBeJoined = prevEvent && prevEvent.getContent().msgtype === "m.text"
+ && event.sender.userId === prevEvent.sender.userId && !this.dateSeparator(event, prevEvent) && !replyTo;
+
+ const body = await this.createMessageBody(event, shouldBeJoined, !!replyTo, replyTo);
+ content += body;
+ } else {
+ const eventText = textForEvent(event);
+ content += eventText ? `
+
+ ` : "";
+ }
+ prevEvent = event;
+ }
+ return this.wrapHTML(content, room);
+ }
+
+ public async export() {
+ const html = await this.createHTML(this.res, this.room);
+
+ this.zip.file("index.html", html);
+ this.zip.file("css/style.css", css);
+
+ const filename = `matrix-export-${new Date().toISOString()}.zip`;
+
+ //Generate the zip file asynchronously
+ const blob = await this.zip.generateAsync({ type: "blob" });
+
+ //Create a writable stream to the directory
+ const fileStream = streamSaver.createWriteStream(filename, { size: blob.size });
+ const writer = fileStream.getWriter();
+
+ // Here we chunk the blob into pieces of 10 MB, the size might be dynamically generated.
+ // This can be used to keep track of the progress
+ const sliceSize = 10 * 1e6;
+ for (let fPointer = 0; fPointer < blob.size; fPointer += sliceSize) {
+ const blobPiece = blob.slice(fPointer, fPointer + sliceSize);
+ const reader = new FileReader();
+
+ const waiter = new Promise