43 lines
1.1 KiB
TypeScript
43 lines
1.1 KiB
TypeScript
import { SAction } from "../actions";
|
|
import { docs } from "../entity/docs";
|
|
import { gunzipAsync } from "../entity/zlib";
|
|
import { SyncConnection } from "../type";
|
|
|
|
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;
|
|
}
|
|
const doc = docs[mode][id].doc as Y.Doc;
|
|
const diff = await gunzipAsync(bin);
|
|
const um = docs[mode][id].um;
|
|
um.addTrackedOrigin(this.client_id);
|
|
Y.applyUpdate(doc, diff, this.client_id);
|
|
|
|
if (mode === "page" || mode === "comp") {
|
|
const root = doc.getMap("map").get("root") as any;
|
|
if (root) {
|
|
if (mode === "page") {
|
|
// 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(),
|
|
// },
|
|
// });
|
|
}
|
|
}
|
|
}
|
|
};
|