OmniP2P v2
すべてを内包する P2P エンジン

<script src="https://cdn.jsdelivr.net/gh/2chkakinie-arch/OmniP2P@main/v2.js"></script>

const OmniP2P = require('./v2.js');

<script src="https://cdn.jsdelivr.net/gh/2chkakinie-arch/OmniP2P@main/v2.js"></script>
<script>
(async () => {
  // 1) インスタンス生成 (鍵は自動生成 or 既存の nsec/hex を渡す)
  const omni = new OmniP2P({
    relays: [
      'wss://relay.damus.io',
      'wss://nos.lol',
      'wss://relay.nostr.band',
      'wss://nostr.wine'
    ],
    // secretKey: '<64-hex or nsec...>'   // 省略で新規生成
  });

  await omni.start();               // リレー接続 + heartbeat 開始

  // 2) ルームに参加 (合言葉ベース、E2EE 自動)
  const room = await omni.join('my-secret-room', { password: 'p@ss' });

  // 3) メッセージ (WebRTC 優先、ダメなら Nostr で必ず届く)
  room.on('message', (msg, peer) => console.log('recv', msg, 'from', peer));
  room.send({ hello: 'world' });

  // 4) 音声/動画通話
  const call = await room.startCall({ audio: true, video: true });
  call.on('track', (stream, peer) => {
    const v = document.createElement('video');
    v.srcObject = stream; v.autoplay = true; document.body.appendChild(v);
  });
  // 画面共有に差し替え:
  // await call.shareScreen();
  // 録画して暗号化保存:
  // const rec = call.record(); ... const url = await rec.stopAndStore();

  // 5) 永続保存 (暗号化 KV / Blob DB)
  const ref = await omni.storage.put('note:1', { text: 'hi' }); // -> 参照
  const val = await omni.storage.get('note:1');                 // -> {text:'hi'}
  const url = await omni.storage.putBlob(fileBlob);             // -> 公開URL

  // 6) CRDT 共同編集
  const doc = room.doc('shared');       // MiniCRDT (Yjs 互換 API)
  const ymap = doc.getMap('state');
  ymap.set('count', 1);
  doc.on('update', () => console.log(ymap.toJSON()));
})();
</script>

omni.start()          // リレー接続 + heartbeat 開始
omni.stop()           // 全接続を優雅にクローズ
omni.join(roomId, { password?, e2ee? })  // -> Room

omni.pubkey           // string (hex) 自分の公開鍵
omni.storage          // Storage (put/get/del/putBlob/getBlob/list)

omni.on(evt, cb)      // 'ready' | 'relay:open' | 'relay:close' | 'error'
omni.off(evt, cb)
omni.emit(evt, ...args)

room.send(data, { reliable?, to? })   // to 省略で全員へ
room.on('message' | 'peer:join' | 'peer:leave' | 'state', cb)
room.peers()                          // -> string[] (pubkey hex)
room.startCall(constraints)           // -> Call
room.doc(name)                        // -> CRDT Doc
room.leave()

call.localStream                      // 自分の MediaStream
call.on('track', (stream, peer) => {}) // 相手のトラック受信
call.shareScreen()                    // 画面共有へ差し替え
call.stopScreen()
call.replaceTrack(kind, track)        // 'audio' | 'video'
call.mute(kind, bool)
call.record()                         // -> Recorder
//   recorder.stopAndStore()          // -> url (暗号化アップロード済み URL)
call.hangup()

storage.put(key, jsonable, { encrypt? })  // -> ref
storage.get(key)                          // -> value
storage.del(key)
storage.putBlob(blob|file, { encrypt?, name? })   // -> url
storage.getBlob(url, { key? })            // -> Blob
storage.list(prefix?)                     // -> [{key, ref, ts}]

const doc = room.doc('shared');
const map = doc.getMap('state');
const arr = doc.getArray('list');
const txt = doc.getText('body');

map.set('count', 1);
arr.push(['hello']);
txt.insert(0, 'こんにちは');

doc.on('update', (update, origin) => { /* 増分パッチ */ });
doc.transact(() => { /* まとめて 1 update に */ });

// 1) 明示的な遅延ロード (推奨)
await OmniP2P.loadAdapter('gundb');   // GunDB.js  リアルタイムグラフ同期
await OmniP2P.loadAdapter('matrix');  // Matrix.js Megolm E2EE 永続ルーム
await OmniP2P.loadAdapter('yjs');     // Yjs.js    本物の Y.Doc プロバイダ
await OmniP2P.loadAdapter('waku');    // Waku.js   並列匿名搬送 + Store 永続

// 2) 既にロード済み SDK と差し替える場合
OmniP2P.use(OmniP2P.adapters.Yjs);
OmniP2P.use(OmniP2P.adapters.Waku,   { pubsubTopic: '/omnip2p/1/msg/proto' });
OmniP2P.use(OmniP2P.adapters.Matrix, { homeserver: 'https://matrix.org' });