sy-dynamic.ts

import { Server } from '@hocuspocus/server';
import { TiptapTransformer } from '@hocuspocus/transformer';
import * as Y from 'yjs';
import 'dotenv/config';

console.log('[Synapse] Starting engine (sy-dynamic.ts)...');

const server = new Server({
    port: 1234,
    address: '0.0.0.0',

    async onAuthenticate(data) {
        return { user: { id: '1', name: 'Collaborateur' } };
    },

    async onLoadDocument(data) {
        const { documentName } = data;
        console.log(`[Synapse] 📥 Loading: ${documentName}`);
        try {
            // Dynamic import of Prisma to avoid startup collision
            const { default: prisma } = await import('./src/lib/prisma');

            if (documentName.startsWith('notion-')) {
                const notionId = documentName.replace('notion-', '');
                const notion = await prisma.notion.findUnique({ where: { notion_id: notionId } });
                if (notion) return TiptapTransformer.toYdoc(notion.notion_content || '', 'prosemirror');
            } else if (documentName.startsWith('part-')) {
                const partId = documentName.replace('part-', '');
                const part = await prisma.part.findUnique({ where: { part_id: partId } });
                if (part) return TiptapTransformer.toYdoc(part.part_intro || '', 'prosemirror');
            }
        } catch (e) {
            console.error('[Synapse] ❌ Prisma Load Error:', e);
        }
        return new Y.Doc();
    },

    async onStoreDocument(data) {
        const { documentName, document } = data;
        console.log(`[Synapse] 💾 Storing: ${documentName}`);
        try {
            const { default: prisma } = await import('./src/lib/prisma');
            const html = TiptapTransformer.fromYdoc(document, 'prosemirror');

            if (documentName.startsWith('notion-')) {
                const notionId = documentName.replace('notion-', '');
                await prisma.notion.update({ where: { notion_id: notionId }, data: { notion_content: html } });
            } else if (documentName.startsWith('part-')) {
                const partId = documentName.replace('part-', '');
                await prisma.part.update({ where: { part_id: partId }, data: { part_intro: html } });
            }
        } catch (e) {
            console.error('[Synapse] ❌ Prisma Store Error:', e);
        }
    },

    async onConnect() { console.log('[Synapse] 🚀 Connect'); },
});

server.listen();
console.log('[Synapse] 🛰️ Running on ws://192.168.1.160:1234');