@@ -21,56 +21,6 @@ beforeAll(async () => {
21
21
} ) ;
22
22
await server . listen ( 0 ) ; // 0 for random port
23
23
} ) ;
24
- /*
25
- it("should sync user data via yjs", async () => {
26
- const ydoc = new Y.Doc();
27
-
28
- let pResolve = () => {};
29
- const p = new Promise<void>((resolve) => {
30
- pResolve = resolve;
31
- });
32
- const wsProvider = new HocuspocusProviderWebsocket({
33
- url: "ws://localhost:1234",
34
- WebSocketPolyfill: ws,
35
- });
36
-
37
- const provider = new HocuspocusProvider({
38
- name: generateId(),
39
- document: ydoc,
40
- token: alice.session?.access_token,
41
- onAuthenticated: () => {
42
- console.log("onAuthenticated");
43
- },
44
- onAuthenticationFailed(data) {
45
- console.log("onAuthenticationFailed", data);
46
- },
47
- onStatus: (data) => {
48
- console.log("onStatus", data);
49
- },
50
- onSynced: () => {
51
- console.log("onSynced");
52
- pResolve();
53
- },
54
- onConnect() {
55
- console.log("onConnect");
56
- },
57
- websocketProvider: wsProvider,
58
- broadcast: false,
59
- });
60
-
61
- provider.on("awarenessUpdate", () => {
62
- console.log("awareness");
63
- });
64
- await p;
65
- ydoc.getMap("hello").set("world", "hello");
66
- await new Promise((resolve) => setTimeout(resolve, 3000));
67
- console.log("next change");
68
- ydoc.getMap("hello").set("world", "hello2");
69
- await new Promise((resolve) => setTimeout(resolve, 1000));
70
- // await provider.connect();
71
- // await p;
72
- // provider.on("synced", () => {});
73
- });*/
74
24
75
25
describe ( "SupabaseHocuspocus" , ( ) => {
76
26
let alice : Awaited < ReturnType < typeof createRandomUser > > ;
0 commit comments