통화 요약을 슬랙으로 보내기: CALL_COMPLETED 웹훅 활용

export SLACK_WEBHOOK_URL="https://hooks.slack.com/services/T000/B000/XXXX"

curl -s -X POST "$SLACK_WEBHOOK_URL" \
  -H "Content-Type: application/json" \
  -d '{"text":"KAT Cloud 통화 알림 연동 테스트"}'

// slack-format.js
const TAG_LABEL = { AI: 'AI 응대', DIRECT: '직원 응대', AI_TO_DIRECT: 'AI→직원 연결', UNKNOWN: '확인 불가' };
const STATUS_LABEL = { ANSWERED: '응답', MISSED: '부재중', REJECTED: '거절', UNKNOWN: '확인 불가' };

function formatDuration(sec = 0) {
  const s = Math.max(0, Math.round(sec));
  const m = Math.floor(s / 60);
  return m > 0 ? `${m}분 ${s % 60}초` : `${s}초`;
}

function maskPhone(num = '') {
  const d = String(num).replace(/\D/g, '');
  if (d.length < 8) return d || '번호 없음';
  return `${d.slice(0, 3)}-****-${d.slice(-4)}`; // 01012345678 → 010-****-5678
}

function toKst(iso) {
  if (!iso) return '-';
  return new Intl.DateTimeFormat('ko-KR', {
    timeZone: 'Asia/Seoul', month: 'numeric', day: 'numeric',
    hour: '2-digit', minute: '2-digit', hourCycle: 'h23',
  }).format(new Date(iso));
}

// 슬랙 mrkdwn에서 특수하게 쓰이는 문자 세 개를 이스케이프
const escape = (t = '') => t.replace(/&/g, '&amp;').replace(/</g, '&lt;').replace(/>/g, '&gt;');

function buildSlackMessage(d) {
  const tag = TAG_LABEL[d.tag] || '확인 불가';
  const status = STATUS_LABEL[d.status] || '확인 불가';
  const direction = d.isInbound ? '수신' : '발신';
  const who = d.isInbound ? '발신자' : '수신자';
  const number = d.isInbound ? d.fromNumber : d.toNumber;
  const summary = escape(d.summary || '요약 없음').slice(0, 2900); // section 텍스트 한도 3,000자
  const title = `${direction} 통화 · ${tag} · ${status}`;

  return {
    text: `${title} - ${summary.slice(0, 80)}`,
    blocks: [
      { type: 'header', text: { type: 'plain_text', text: title } },
      {
        type: 'section',
        fields: [
          { type: 'mrkdwn', text: `*${who}*\n${maskPhone(number)}` },
          { type: 'mrkdwn', text: `*통화 시간*\n${formatDuration(d.duration)}` },
          { type: 'mrkdwn', text: `*응대 태그*\n${tag}` },
          { type: 'mrkdwn', text: `*시작 시각*\n${toKst(d.startedAt)}` },
        ],
      },
      { type: 'section', text: { type: 'mrkdwn', text: `*요약*\n${summary}` } },
      { type: 'context', elements: [{ type: 'mrkdwn', text: `callHistoryId: ${d.callHistoryId}` }] },
    ],
  };
}

module.exports = { buildSlackMessage };

// server.js — Node.js 18+, Express 4
const express = require('express');
const { buildSlackMessage } = require('./slack-format');

const SLACK_DEFAULT = process.env.SLACK_WEBHOOK_URL;
const SLACK_MISSED = process.env.SLACK_MISSED_WEBHOOK_URL || SLACK_DEFAULT;
const posted = new Set(); // 보낸 callHistoryId (운영에서는 Redis·DB)

async function postToSlack(url, message) {
  for (let attempt = 1; attempt <= 3; attempt++) {
    const res = await fetch(url, {
      method: 'POST',
      headers: { 'Content-Type': 'application/json' },
      body: JSON.stringify(message),
    });
    if (res.ok) return;
    if (res.status === 429 || res.status >= 500) {
      const waitSec = Number(res.headers.get('retry-after')) || attempt * 2;
      await new Promise((r) => setTimeout(r, waitSec * 1000));
      continue;
    }
    throw new Error(`Slack ${res.status} ${await res.text()}`);
  }
  throw new Error('Slack 전송 재시도 초과');
}

const app = express();
app.use(express.json({ limit: '2mb' })); // STT 배열이 길 수 있다

app.post('/webhook/call-completed', (req, res) => {
  res.sendStatus(200); // KAT Cloud 웹훅 타임아웃은 10초

  const { eventType, data } = req.body || {};
  if (eventType !== 'CALL_COMPLETED' || !data?.callHistoryId) return;
  if (posted.has(data.callHistoryId)) return;
  posted.add(data.callHistoryId);

  const url = data.status === 'MISSED' ? SLACK_MISSED : SLACK_DEFAULT;
  postToSlack(url, buildSlackMessage(data)).catch((err) => {
    posted.delete(data.callHistoryId); // 다음 재전송 때 다시 시도할 수 있게
    console.error('[slack]', data.callHistoryId, err);
  });
});

app.listen(process.env.PORT || 3000);

export KAT_API_KEY="콘솔에서 발급받은 키"
BASE="https://studio-gateway.zerocall.kr"

curl -s -X POST "$BASE/webhook" \
  -H "x-api-key: $KAT_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{"eventType":"CALL_COMPLETED","url":"https://hooks.example.com/webhook/call-completed"}'

# 응답의 id로 테스트 페이로드 전송 → success, statusCode, responseTime, error 확인
curl -s -X POST "$BASE/webhook/1/test" -H "x-api-key: $KAT_API_KEY"

curl -s -X POST http://localhost:3000/webhook/call-completed \
  -H "Content-Type: application/json" \
  -d '{"eventType":"CALL_COMPLETED","timestamp":"2026-03-12T02:45:30.000Z","data":{"callHistoryId":"8f3f8fd9-7ab8-4a26-b523-4f8eb7d38b85","groupId":1,"channelId":100,"fromNumber":"01012345678","toNumber":"07012345678","isInbound":true,"status":"ANSWERED","tag":"AI_TO_DIRECT","duration":96,"summary":"예약 변경 요청을 접수하고 변경 가능한 시간대를 안내함","sttAI":[],"sttDirect":[],"startedAt":"2026-03-12T02:40:00.000Z","completedAt":"2026-03-12T02:41:36.000Z"}}'