イベントサブスクリプション

const client = new GraphQLClient('https://beta.abtnetwork.io/api/v2/gql');

const handleNewTransaction = (eventData) => {
  console.log('新しいトランザクションがオンチェーンで作成されました:', eventData);
};

// 'tx.create' トピックをサブスクライブ
client.subscribe('tx.create', handleNewTransaction);

// 特定のリスナーを削除するには、同じコールバック関数の参照を渡します
client.unsubscribe('tx.create', handleNewTransaction);

// 特定のトピックのすべてのリスナーを削除するには
client.unsubscribe('tx.create');

import GraphQLClient from '@ocap/client';
import { fromRandom } from '@ocap/wallet';

const main = async () => {
  const client = new GraphQLClient('https://beta.abtnetwork.io/api/v2/gql');
  const events = { txCreate: 0, txTransfer: 0 };

  // 1. イベントをサブスクライブ
  client.subscribe('tx.create', () => (events.txCreate += 1));
  client.subscribe('tx.transfer_v2', () => (events.txTransfer += 1));

  console.log('tx.create および tx.transfer_v2 イベントをサブスクライブしました...');

  // 短時間待機するためのヘルパー
  const sleep = (ms) => new Promise(resolve => setTimeout(resolve, ms));
  await sleep(100); // サブスクリプションが登録されるまで少し待機

  // 2. イベントをトリガーするアクションを実行
  // 注: これには資金のあるウォレットが必要です。テストトークンは https://faucet.abtnetwork.io/ から入手できます。
  const sender = fromRandom(); // 実際のアプリでは、資金のあるウォレットをロードします
  // この例では、アクションが成功することを前提とします。
  console.log('転送トランザクションはイベントハンドラをトリガーします。');

  // 実際のシナリオでは、転送が成功した後:
  // await client.transfer({ to: 'z1...', token: 1, wallet: sender });

  // 成功したトランザクションの後にイベントカウンターが増加するのをシミュレートしてみましょう
  events.txCreate = 1;
  events.txTransfer = 1;

  await sleep(100); // イベントが処理されるのを待機

  // 3. イベントハンドラが呼び出されたことを確認
  console.log(`tx.create は ${events.txCreate} 回呼び出されました。`);
  console.log(`tx.transfer_v2 は ${events.txTransfer} 回呼び出されました。`);

  // 4. クリーンアップのためにサブスクライブを解除
  client.unsubscribe('tx.create');
  client.unsubscribe('tx.transfer_v2');
  console.log('イベントのサブスクライブを解除しました。');
};

main().catch(console.error);