-
${new Date(event.getTs()).toLocaleTimeString().slice(0, -3)}
+
+ ${new Date(event.getTs()).toLocaleTimeString().slice(0, -3)}
+
;
${!joined ? `
${event.sender.name}
`: ``}
@@ -430,7 +401,7 @@ const createMessageBody = async (event, joined = false, isReply = false, replyId
};
-const createHTML = async (events, room) => {
+const createHTML = async (events: MatrixEvent[], room: Room) => {
let content = "";
let prevEvent = null;
for (const event of events) {
@@ -458,19 +429,19 @@ const createHTML = async (events, room) => {
return wrapHTML(content, room);
};
-
const avatars = new Map();
let zip;
-const exportConversationalHistory = async (room) => {
- const res = getTimelineConversation(room);
+
+const exportAsHTML = async (res: MatrixEvent[], room: Room) => {
zip = new JSZip();
- const html = await createHTML(res, room, avatars);
+ const html = await createHTML(res, room);
zip.file("index.html", html);
zip.file("css/style.css", css);
avatars.clear();
+
const filename = `matrix-export-${new Date().toISOString()}.zip`;
//Generate the zip file asynchronously
@@ -480,16 +451,17 @@ const exportConversationalHistory = async (room) => {
const fileStream = streamSaver.createWriteStream(filename, blob.size);
const writer = fileStream.getWriter();
- // Here we chunk the blob into pieces of 10 MiB
+ // 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) {
// console.log(fPointer);
const blobPiece = blob.slice(fPointer, fPointer + sliceSize);
const reader = new FileReader();
- const waiter = new Promise((resolve, reject) => {
+ const waiter = new Promise
((resolve, reject) => {
reader.onloadend = evt => {
- const arrayBufferNew = evt.target.result;
+ const arrayBufferNew: any = evt.target.result;
const uint8ArrayNew = new Uint8Array(arrayBufferNew);
// Buffer.from(reader.result)
writer.write(uint8ArrayNew);
@@ -500,6 +472,6 @@ const exportConversationalHistory = async (room) => {
await waiter;
}
writer.close();
-};
+}
-export default exportConversationalHistory;
+export default exportAsHTML;
diff --git a/src/utils/exportUtils/exportUtils.js b/src/utils/exportUtils/exportUtils.js
new file mode 100644
index 0000000000..38abe62d74
--- /dev/null
+++ b/src/utils/exportUtils/exportUtils.js
@@ -0,0 +1,56 @@
+import { MatrixClientPeg } from "../../MatrixClientPeg";
+import { arrayFastClone } from "../arrays";
+import { TimelineWindow } from "matrix-js-sdk/src/timeline-window";
+import exportAsHTML from "./HtmlExport";
+
+export const exportFormats = Object.freeze({
+ "HTML": "HTML",
+ "JSON": "JSON",
+ "LOGS": "LOGS",
+});
+
+export const exportOptions = Object.freeze({
+ "TIMELINE": "TIMELINE",
+});
+
+const getTimelineConversation = (room) => {
+ if (!room) return;
+
+ const cli = MatrixClientPeg.get();
+
+ const timelineSet = room.getUnfilteredTimelineSet();
+
+ const timelineWindow = new TimelineWindow(
+ cli, timelineSet,
+ {windowLimit: Number.MAX_VALUE});
+
+ timelineWindow.load(null, 20);
+
+ const events = timelineWindow.getEvents();
+
+ // Clone and reverse the events so that we preserve the order
+ arrayFastClone(events)
+ .reverse()
+ .forEach(event => {
+ cli.decryptEventIfNeeded(event);
+ });
+
+ console.log(events);
+ return events;
+};
+
+
+const exportConversationalHistory = async (room, format, options) => {
+ const res = getTimelineConversation(room);
+ switch (format) {
+ case exportFormats.HTML:
+ await exportAsHTML(res, room);
+ break;
+ case exportFormats.JSON:
+ break;
+ case exportFormats.LOGS:
+ break;
+ }
+};
+
+export default exportConversationalHistory;
}.png)
-