beamdb 0.18.0

BEAM — distributed graph database syncing over WebSocket, WebRTC, and multicast. Successor to rod.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59

/**
 * Headless Gun.js + SEA bootstrap for PANIC Node clients.
 *
 * Loads Gun + SEA via dynamic import() (the only import form that
 * parses inside PANIC's eval'd .run() callbacks), wires the Node
 * WebSocket implementation, connects to the BEAM relay, and forces
 * mesh.hi() (Gun's ESM/Node mode does not auto-open peer sockets).
 *
 * Idempotent: sets globalThis.gun / globalThis.user once per client
 * process; subsequent calls are no-ops. Returns { gun, user }.
 *
 * Usage inside a .run() callback:
 *   if (!globalThis.user) {
 *     await require('./helpers/gunboot').bootGun(test.props.relayPort);
 *   }
 *
 * @module helpers/gunboot
 */

/** Track in-flight boot to avoid double-init on concurrent steps. */
let booting = null;

async function bootGun(relayPort) {
  if (globalThis.user && globalThis.gun) {
    return { gun: globalThis.gun, user: globalThis.user };
  }
  if (booting) return booting;

  booting = (async () => {
    const Gun = (await import('gun')).default;
    await import('gun/sea.js');
    const { default: WebSocket } = await import('ws');

    Gun.window = Gun.window || {};
    Gun.window.WebSocket = WebSocket;

    const gun = Gun({
      peers: ['ws://localhost:' + relayPort + '/gun'],
      localStorage: false,
      radisk: false,
    });

    // Gun's ESM/Node mode does not auto-open peer sockets — force mesh.hi.
    const mesh = gun._.opt.mesh;
    if (mesh) {
      for (const url of Object.keys(gun._.opt.peers)) {
        mesh.hi(gun._.opt.peers[url]);
      }
    }

    globalThis.gun = gun;
    globalThis.user = gun.user();
    return { gun, user: globalThis.user };
  })();

  return booting;
}

module.exports = { bootGun };