ステップ1: 手動で衝突チェック

まず、現在の衝突状況を確認します。

curl -H "Authorization: Bearer YOUR_TOKEN" \
  https://localhost:8443/api/checker/collisions

→ 重複している Source/Group/Port の組み合わせが JSON で返ってきます。

ステップ2: 自動実行を設定

10分ごとに自動実行するように設定します。

curl -X PUT https://localhost:8443/api/automation/jobs/collision-checker \
  -H "Authorization: Bearer YOUR_TOKEN" \
  -H "Content-Type: application/json" \
  -d '{
    "schedule_type": "interval",
    "interval_minutes": 10,
    "enabled": true
  }'

→ ジョブが有効化され、10分ごとに衝突チェックが実行されます。

ステップ3: REST で結果を取得し通知

直近の衝突結果を /api/checker/latest から取得し、Slack へ通知する例です。

import axios from "axios";

async function notifyCollision() {
  const resp = await fetch("https://localhost:8443/api/checker/latest?kind=collisions", {
    headers: { Authorization: `Bearer ${process.env.MMAM_TOKEN}` }
  });
  if (!resp.ok) throw new Error("API error");
  const data = await resp.json();
  if (data.status !== "success" || !data.result) return;

  const collisions = data.result.results.flatMap(group => group.entries);
  if (!collisions.length) return;

  await axios.post(process.env.SLACK_WEBHOOK_URL, {
    text: `⚠️ アドレス衝突を検出しました`,
    attachments: collisions.map(entry => ({
      color: "danger",
      fields: [{
        title: entry.value,
        value: `Flow IDs: ${entry.flows.map(f => f.flow_id).join(", ")}`,
        short: false
      }]
    }))
  });
}

notifyCollision().catch(console.error);