パフォーマンスガイド

繋ぎ屋を使った大規模テストの最適化方法です。

---

大量イベント処理のベストプラクティス

EventBuilder.bulk() を使って効率的にイベントを生成することを推奨します。また、timeline() で時系列データを効率的に生成することも重要です。さらに、limit を活用してフィルタリングを絞ることで、パフォーマンスを大幅に改善できます。

---

メモリ使用量の最適化

pool.reset() でメモリを解放する

テスト間で MockPool を再利用する場合、reset() でストアと受信ログをクリアします。

スナップショットのサイズに注意

スナップショットはストアと受信ログのディープコピーを作成します。大量データがある場合はメモリ消費が2倍になります。

不要なログを無効化

logging: true はすべてのメッセージをメモリに蓄積します。大量テストでは無効にします（デフォルト）。

---

ベンチマーク結果

tsunagiya v0.3.0 での参考値（環境依存）。

イベントストア登録

1,000 件  → < 5ms
10,000 件 → < 30ms
100,000 件 → < 300ms

フィルターマッチング（filterEvents）

10,000 件のストアから：

kinds のみ       → < 5ms
kinds + authors → < 8ms
タグフィルター     → < 15ms
limit: 10       → < 3ms（ソート後にスライス）

WebSocket メッセージの送受信

1 REQ → 100 EVENT + EOSE  → < 10ms (latency: 0)
1 REQ → 1000 EVENT + EOSE → < 50ms (latency: 0)

---

コード例

EventBuilder.bulk() での効率的な生成:

// ✅ 効率的：一括生成
const events = EventBuilder.bulk(1000, { kind: 1 });
for (const e of events) relay.store(e);

// ❌ 非効率：個別にビルダーを使う
for (let i = 0; i < 1000; i++) {
  relay.store(EventBuilder.kind1().content(`event ${i}`).build());
}

timeline() での時系列データ生成:

const events = EventBuilder.timeline(1000, {
  kind: 1,
  interval: 60,
  startTime: 1700000000,
});

limit を活用したフィルタリング:

// ✅ 必要な件数だけ取得
ws.send(JSON.stringify(["REQ", "s", { kinds: [1], limit: 50 }]));

pool.reset() でメモリを解放:

Deno.test("テストスイート", async (t) => {
  const pool = new MockPool();
  const relay = pool.relay("wss://relay.example.com");
  pool.install();

  try {
    await t.step("テスト1", () => {
      const events = EventBuilder.bulk(10000);
      for (const e of events) relay.store(e);
      // ...
      pool.reset(); // ← 10000件を解放
    });

    await t.step("テスト2", () => {
      // クリーンな状態
    });
  } finally {
    pool.uninstall();
  }
});

1000件を一括取得するパターン:

Deno.test("1000件のイベントを一括取得", async () => {
  const pool = new MockPool();
  const relay = pool.relay("wss://relay.example.com");

  const events = EventBuilder.bulk(1000, { kind: 1 });
  for (const e of events) relay.store(e);

  pool.install();
  try {
    const received: NostrEvent[] = [];
    const ws = new WebSocket("wss://relay.example.com");

    await new Promise<void>((resolve) => {
      ws.onopen = () => ws.send(JSON.stringify(["REQ", "s", { kinds: [1] }]));
      ws.onmessage = (e) => {
        const msg = JSON.parse(e.data);
        if (msg[0] === "EVENT") received.push(msg[2]);
        if (msg[0] === "EOSE") ws.close();
      };
      ws.onclose = () => resolve();
    });

    assertEquals(received.length, 1000);
  } finally {
    pool.uninstall();
  }
});

ストリーム配信パターン:

Deno.test("1000件をストリーム配信", async () => {
  const pool = new MockPool();
  const relay = pool.relay("wss://relay.example.com");

  pool.install();
  try {
    const received: NostrEvent[] = [];
    const ws = new WebSocket("wss://relay.example.com");

    await new Promise<void>((resolve) => {
      ws.onopen = () => {
        ws.send(JSON.stringify(["REQ", "live", { kinds: [1] }]));

        const stream = startStream(relay, {
          eventGenerator: () => EventBuilder.random({ kind: 1 }),
          interval: 1,
          count: 1000,
        });

        setTimeout(() => {
          stream.stop();
          ws.close();
        }, 2000);
      };

      ws.onmessage = (e) => {
        const msg = JSON.parse(e.data);
        if (msg[0] === "EVENT") received.push(msg[2]);
      };

      ws.onclose = () => resolve();
    });

    assertEquals(received.length, 1000);
  } finally {
    pool.uninstall();
  }
});

Deno.bench を使ったパフォーマンス測定:

Deno.bench("EventBuilder.bulk(1000)", () => {
  EventBuilder.bulk(1000, { kind: 1 });
});

Deno.bench("filterEvents 10000件から100件", () => {
  const events = EventBuilder.bulk(10000, { kind: 1 });
  filterEvents(events, { kinds: [1], limit: 100 });
});

Deno.bench("matchFilter", () => {
  const event = EventBuilder.kind1().build();
  matchFilter(event, { kinds: [1], authors: [event.pubkey] });
});

実行コマンド:

deno bench

手動計測:

const start = performance.now();

const events = EventBuilder.bulk(10000);
for (const e of events) relay.store(e);

const elapsed = performance.now() - start;
console.log(`${elapsed.toFixed(2)}ms`);

---

関連ドキュメント

• ベストプラクティス — テスト設計指針
• API リファレンス — API 詳細
• テストパターン — テストパターン