113 lines
3.1 KiB
TypeScript
113 lines
3.1 KiB
TypeScript
import { validate } from "uuid";
|
|
import { SAction } from "../actions";
|
|
import { docs } from "../entity/docs";
|
|
import { gunzipAsync } from "../entity/zlib";
|
|
import { SyncConnection } from "../type";
|
|
import { gzipAsync } from "utils/diff/diff";
|
|
|
|
const history = {} as Record<string, string>;
|
|
|
|
export const yjs_diff_local: SAction["yjs"]["diff_local"] = async function (
|
|
this: SyncConnection,
|
|
mode,
|
|
id,
|
|
bin
|
|
) {
|
|
if (!docs[mode][id]) {
|
|
console.log(`diff_local not found`, mode, id);
|
|
return;
|
|
}
|
|
if (mode === "page" || mode === "comp") {
|
|
const doc = docs[mode][id].doc as YJS.Doc;
|
|
const diff = await gunzipAsync(bin);
|
|
const um = docs[mode][id].um;
|
|
um.addTrackedOrigin(this.client_id);
|
|
Y.applyUpdate(doc, diff, this.client_id);
|
|
|
|
const root = doc.getMap("map").get("root") as any;
|
|
if (root) {
|
|
if (mode === "page") {
|
|
if (validate(id) && id) {
|
|
let mode = "create" as "create" | "update";
|
|
const cur = Math.round(Date.now() / 5000) + "";
|
|
if (history[id] && history[id] === cur) {
|
|
mode = "update";
|
|
}
|
|
history[id] = cur;
|
|
if (mode === "create") {
|
|
await _db.page_history.create({
|
|
data: {
|
|
id_page: id,
|
|
content_tree: await gzipAsync(JSON.stringify(root.toJSON())),
|
|
ts: history[id],
|
|
},
|
|
});
|
|
setTimeout(async () => {
|
|
const res = await _db.page_history.findMany({
|
|
where: {
|
|
id_page: id,
|
|
},
|
|
select: {
|
|
id: true,
|
|
ts: true,
|
|
},
|
|
orderBy: {
|
|
ts: "desc",
|
|
},
|
|
});
|
|
const ids: string[] = [];
|
|
|
|
let last_ts = 0;
|
|
let last_stacked = false;
|
|
for (let i = 0; i < res.length; i++) {
|
|
const ts = parseInt(res[i].ts);
|
|
|
|
if (!last_ts) last_ts = ts;
|
|
|
|
if (i > 25) {
|
|
if (!last_stacked) {
|
|
if (((last_ts - ts) / 1000) * 60 < 10) {
|
|
last_stacked = true;
|
|
ids.push(res[i].id);
|
|
}
|
|
} else {
|
|
last_stacked = false;
|
|
}
|
|
}
|
|
last_ts = ts;
|
|
}
|
|
_db.page_history.deleteMany({
|
|
where: { id: { in: ids } },
|
|
});
|
|
});
|
|
} else {
|
|
_db.page_history.updateMany({
|
|
data: {
|
|
content_tree: await gzipAsync(JSON.stringify(root.toJSON())),
|
|
},
|
|
where: {
|
|
id_page: id,
|
|
ts: history[id],
|
|
},
|
|
});
|
|
}
|
|
|
|
await _db.page.update({
|
|
where: { id },
|
|
data: {
|
|
content_tree: root.toJSON(),
|
|
},
|
|
});
|
|
}
|
|
} else if (mode === "comp") {
|
|
await _db.component.update({
|
|
where: { id },
|
|
data: {
|
|
content_tree: root.toJSON(),
|
|
},
|
|
});
|
|
}
|
|
}
|
|
}
|
|
};
|