문자 발송 결과 확인: SEND_RESULT 웹훅과 성공 코드

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":"SEND_RESULT","url":"https://hooks.example.com/webhook/send-result"}'

{
  "eventType": "SEND_RESULT",
  "timestamp": "2024-03-05T10:30:05.000Z",
  "data": {
    "chatId": "xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx",
    "chatRoomId": "yyyyyyyyyyyyyyyyyyyyyyyyyyyyyy",
    "groupId": 1,
    "channelId": 100,
    "sendPhoneNumber": "07012345678",
    "recvPhoneNumber": "01098765432",
    "content": "예약이 확정되었습니다.",
    "chatType": "SMS",
    "sendStatus": "SUCCESS",
    "resultStatus": "4100",
    "resultMessage": "전달",
    "sentAt": "2024-03-05T10:30:05.000Z"
  }
}

// send-result-webhook.js — Node.js 18+, Express 4
const express = require('express');

const SUCCESS_CODES = new Set(['4100', '6600', '7000']); // SMS, LMS·MMS, 카카오

function classify({ sendStatus, resultStatus }) {
  if (sendStatus === 'FAILED') return 'REQUEST_FAILED'; // 사업자 요청 단계에서 실패
  if (resultStatus == null || resultStatus === '') return 'PENDING';
  return SUCCESS_CODES.has(String(resultStatus)) ? 'DELIVERED' : 'UNDELIVERED';
}

// 내 DB에 맞게 구현하는 부분
const messages = {
  async updateByChatId(chatId, patch) {
    // UPDATE messages SET outcome = ?, result_status = ?, ... WHERE chat_id = ?
  },
};

const app = express();
app.use(express.json());

app.post('/webhook/send-result', (req, res) => {
  res.sendStatus(200); // 먼저 응답 (타임아웃 10초)

  const { eventType, data } = req.body || {};
  if (eventType !== 'SEND_RESULT' || !data?.chatId) return;

  setImmediate(async () => {
    try {
      await messages.updateByChatId(data.chatId, {
        outcome: classify(data),
        chatType: data.chatType,
        sendStatus: data.sendStatus,
        resultStatus: data.resultStatus,
        resultMessage: data.resultMessage,
        sentAt: data.sentAt,
      });
    } catch (err) {
      console.error('[send-result] 저장 실패', data.chatId, err);
    }
  });
});

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

curl -s "$BASE/message/send-result/xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx" \
  -H "x-api-key: $KAT_API_KEY"

{
  "code": "0",
  "message": "Success",
  "result": {
    "id": "xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx",
    "content": "안녕하세요. 예약이 확정되었습니다.",
    "subject": "예약 확정 안내",
    "imageList": [],
    "externalMessageId": "biz_1234567890",
    "fromPhoneNumber": "07012345678",
    "toPhoneNumber": "01098765432",
    "sendStatus": "SUCCESS",
    "chatType": "SMS",
    "resultStatus": "4100",
    "resultMessage": "전달",
    "createdAt": "2024-03-05T10:30:05.000Z"
  }
}

import os
import time

import requests

BASE_URL = "https://studio-gateway.zerocall.kr"
HEADERS = {"x-api-key": os.environ["KAT_API_KEY"]}
SUCCESS_CODES = {"4100", "6600", "7000"}


def get_send_result(chat_id: str) -> dict:
    r = requests.get(f"{BASE_URL}/message/send-result/{chat_id}", headers=HEADERS, timeout=10)
    r.raise_for_status()
    return r.json()["result"]


def wait_for_result(chat_id: str, attempts: int = 6, first_delay: float = 5.0) -> dict:
    delay = first_delay
    for _ in range(attempts):
        result = get_send_result(chat_id)
        if result.get("sendStatus") == "FAILED":
            return {"outcome": "REQUEST_FAILED", **result}
        code = result.get("resultStatus")
        if code:
            outcome = "DELIVERED" if str(code) in SUCCESS_CODES else "UNDELIVERED"
            return {"outcome": outcome, **result}
        time.sleep(delay)
        delay = min(delay * 2, 60)  # 5초, 10초, 20초 ... 최대 60초
    return {"outcome": "PENDING", "id": chat_id}