웹훅 이벤트

import "github.com/playcamp/playcamp-go-sdk/webhookutil"

func handleWebhook(w http.ResponseWriter, r *http.Request) {
    body, _ := io.ReadAll(r.Body)

    result := webhookutil.Verify(webhookutil.VerifyOptions{
        Payload:   body,
        Signature: r.Header.Get("X-Webhook-Signature"),
        Secret:    os.Getenv("WEBHOOK_SECRET"),
        Tolerance: 300, // 최대 허용 시간 초 (기본값: 300)
    })

    if !result.Valid {
        http.Error(w, result.Error, http.StatusUnauthorized)
        return
    }

    for _, event := range result.Payload.Events {
        switch event.Event {
        case playcamp.WebhookEventCouponRedeemed:
            fmt.Println("쿠폰 사용")
        case playcamp.WebhookEventPaymentCreated:
            fmt.Println("결제 등록")
        case playcamp.WebhookEventPaymentBulkCreated:
            fmt.Println("벌크 결제")
        case playcamp.WebhookEventSponsorCreated:
            fmt.Println("부스트 등록")
        case playcamp.WebhookEventSponsorEnded:
            fmt.Println("부스트 해제")
        }
    }

    w.WriteHeader(http.StatusOK)
    json.NewEncoder(w).Encode(map[string]bool{"received": true})
}

import crypto from 'crypto';

function verifyWebhookSignature(
  payload: string,      // raw request body
  signature: string,    // X-Webhook-Signature 헤더 값
  secret: string        // 웹훅 시크릿
): boolean {
  const expected = crypto
    .createHmac('sha256', secret)
    .update(payload)
    .digest('hex');

  return crypto.timingSafeEqual(
    Buffer.from(signature),
    Buffer.from(expected)
  );
}

import crypto from 'crypto';

app.post('/webhooks/playcamp', express.raw({ type: 'application/json' }), (req, res) => {
  const signature = req.headers['x-webhook-signature'] as string;
  const isBatch = req.headers['x-webhook-batch'] === 'true';
  const webhookSecret = process.env.WEBHOOK_SECRET;

  const payload = Buffer.isBuffer(req.body)
    ? req.body.toString()
    : req.body;

  // 1. 서명 검증
  if (webhookSecret && signature) {
    const expected = crypto
      .createHmac('sha256', webhookSecret)
      .update(payload)
      .digest('hex');

    if (!crypto.timingSafeEqual(Buffer.from(signature), Buffer.from(expected))) {
      return res.status(401).json({ error: 'Invalid signature' });
    }
  }

  // 2. JSON 파싱
  const data = JSON.parse(payload);

  // 3. 이벤트 처리
  const events = isBatch || data.events ? data.events : [data];

  for (const event of events) {
    switch (event.event) {
      case 'coupon.redeemed':
        console.log('쿠폰 사용:', event.data);
        break;
      case 'payment.created':
        console.log('결제 등록:', event.data);
        break;
    }
  }

  res.json({ received: true });
});

// 웹훅 등록
const webhook = await server.webhooks.create({
  eventType: 'coupon.redeemed',
  url: 'https://your-server.com/webhooks/playcamp',
});

// 웹훅 목록
const webhooks = await server.webhooks.listWebhooks();

// 웹훅 수정
await server.webhooks.update(webhook.id, {
  url: 'https://your-server.com/webhooks/v2',
});

// 웹훅 삭제
await server.webhooks.remove(webhook.id);

// 웹훅 전송 로그
const logs = await server.webhooks.getLogs(webhook.id);

// 테스트 이벤트 전송
await server.webhooks.test(webhook.id);

// 웹훅 등록
webhook, err := server.Webhooks.Create(ctx, playcamp.CreateWebhookParams{
    EventType: playcamp.WebhookEventCouponRedeemed,
    URL:       "https://your-server.com/webhooks/playcamp",
})

// 웹훅 목록
webhooks, err := server.Webhooks.List(ctx)

// 웹훅 수정
updated, err := server.Webhooks.Update(ctx, webhook.ID, playcamp.UpdateWebhookParams{
    URL: playcamp.String("https://your-server.com/webhooks/v2"),
})

// 웹훅 삭제
err := server.Webhooks.Delete(ctx, webhook.ID)

// 웹훅 전송 로그
logs, err := server.Webhooks.GetLogs(ctx, webhook.ID)

// 테스트 이벤트 전송
result, err := server.Webhooks.Test(ctx, webhook.ID)