Flutter×Agoraのビデオ通話機能に時間制限をつける(Agora Webhook)

_engine.registerEventHandler(RtcEngineEventHandler(
      onLeaveChannel: (RtcConnection connection, RtcStats stats) {
        // フロントでやる場合は本イベントで制限時間の更新処理を行う
        // 正常に退出できない場合、ここでは検知されないリスクがある
      },
 ));

// flutter app内でAgora Flutter SDKを初期化している場所
await rtcEngine.initialize(RtcEngineContext(
　appId: 'AGORAのプロジェクトAPPID',
　channelProfile: ChannelProfileType.channelProfileCommunication,
));

export enum EventType {
  EventUserLeft = 108, // 退出だけ使いたいので108のみ
}

export interface WebhookRequest {
  noticeId: string;
  productId: number;
  eventType: number;
  payload: Payload;
}

export interface Payload {
  // buildTokenWithUserAccountで生成した場合に文字列UserIdが使用可能
  // この場合フロント側はjoinChannelWithUserAccountを使用します
  account: string; 
  clientSeq: number;
  uid: number;
  channelName: string;
  ts: number;
  duration: number | null;
}

import crypto from 'crypto';
import { env } from './env';

export class SignatureVerifyService {

/**
 * calcSignatureV1
 * 与えられたペイロードとSecretを基にHMAC/SHA256署名を計算します。
 * @param secret - WebhookのSecret
 * @param payload - リクエストペイロード
 * @returns - 計算された署名
 */
  private calcSignatureV1(secret: string, payload: string): string {
    const hmac = crypto.createHmac('sha1', secret);
    hmac.update(payload, 'utf8');
    return hmac.digest('hex');
  }

/**
 * verify
 * リクエストボディのHMAC/SHA256署名が指定された署名と一致するかを検証します。
 * @param requestBody - リクエストのペイロード（ボディ）
 * @param signature - 検証対象の署名、リクエストヘッダーに存在
 * @returns - 検証結果 (true: 一致, false: 不一致)
 */
  verify(requestBody: string, signature: string): boolean {
    // agoraのWebHook secretは適宣格納する(envファイルや、環境変数)
    const calculatedSignature = this.calcSignatureV1(env.agora.webhook.secret, requestBody);
    return calculatedSignature === signature;
  }
}

export class EventHandler {
  
  private validEventCode(eventType: number): boolean {
    return eventType == EventType.EventUserLeft;
  }

  async handleEvent(webhookRequest: WebhookRequest) {
    const eventType = webhookRequest.eventType;

    try{
      
      if(!this.validEventCode(eventType)) {
        console.log('Invalid event code for this server. join and leave is only supported', eventType);
        return;
      }
      console.log('timestamp', webhookRequest.payload.ts);

      const dateFromTimeStamp = new Date(webhookRequest.payload.ts * 1000);
      const jstDateString = dateFromTimeStamp.toLocaleString("ja-JP", { timeZone: "Asia/Tokyo" });

 
      if(eventType == EventType.EventUserLeft) {
        console.log('EventCode', eventType);
        console.log('User Left at', jstDateString);
        console.log('connectionduration', webhookRequest.payload.duration, 's');

        console.log(webhookRequest)
      }
    } catch (error) {
      console.error('Error handling event:', error);
    }
  }
}

import express from 'express';
import http from 'http';
import cors from 'cors';
import { env } from './env';
import { WebhookRequest } from './event_handler';
import { SignatureVerifyService } from './signature_verify_service';
import { EventHandler } from './event_handler';

// 実際にCORSを設定する場合は、リクエストできるOriginの限定は必要です。
const app = express();
app.use(cors());
app.use(express.json());

const server = http.createServer(app);
const PORT = 3000; // Portも環境に応じて変更必要です。
app.get('/', (req, res) => {
  res.send('This agora webhook test api');
});

app.post('/webhook', async (req, res) => {
  const agoraSignature = req.header('Agora-Signature');

  const body = JSON.stringify(req.body);

  const signatureVerifyService = new SignatureVerifyService();
  if (!signatureVerifyService.verify(body, agoraSignature || '')) {
    console.log('Invalid signature');
    res.status(401).send('Invalid signature');
    return;
  }

  let webhookRequest: WebhookRequest;
  try {
      webhookRequest = req.body;
  } catch (error) {
      res.status(400).send('Invalid JSON');
      return;
  }
  
  // debug code
  console.log("Event code: %d Uid: %d Channel: %s ClientSeq: %d\n",
		webhookRequest.eventType, webhookRequest.payload.uid, webhookRequest.payload.channelName, webhookRequest.payload.clientSeq)

  const eventHandler = new EventHandler();
  await eventHandler.handleEvent(webhookRequest);

  res.status(200).send('Ok');
});

server.listen(PORT, () => {
  console.log(`Server is running on http://localhost:${PORT}`);
});

<プロジェクトのroot>% npm start

<プロジェクトのroot>% ngrok http 3000

Event code: 108 Uid: 1000000002 Channel: testVC001 ClientSeq: 1739786463280

timestamp 1739786466
EventCode 108
User Left at 2025/2/17 19:01:06
connection duration 3 s
{
  noticeId: '1413774833:662946:108',
  notifyMs: 1739786467677,
  eventType: 108,
  sid: '3DBA8534B30F417C8BCE203BD62C9F27',
  payload: {
    account: 'test_user_001',
    clientSeq: 1739786463280,
    uid: 1000000002,
    ts: 1739786466,
    platform: 1,
    reason: 1,
    duration: 3,
    channelName: 'testVC001'
  },
  productId: 1
}