Push API

Authorization: Bearer opseer_sk_a1b2c3d4e5f6...

curl -X POST https://api.opseer.com/v1/push/send \
  -H "Authorization: Bearer opseer_sk_xxxxxxxxxxxxxxxxxxxx" \
  -H "Content-Type: application/json" \
  -d '{
    "target": { "type": "token", "tokens": ["cVGT3wxTT1..."] },
    "title": "새 댓글",
    "body": "지나님이 댓글을 남겼어요",
    "data": { "post_id": "12345" }
  }'

{
  "ok": true,
  "message_id": "projects/my-app/messages/0:1618...",
  "sent_count": 1,
  "failure_count": 0,
  "usage": {
    "today": 42,
    "limit": 100,
    "remaining": 58,
    "resets_at": "2026-04-22T00:00:00Z"
  }
}

{
  "ok": true,
  "sent_count": 12,
  "failure_count": 1,
  "failures": [
    {
      "token": "cVGT3wxTT1-...",
      "error_code": "registration-token-not-registered",
      "message": "Requested entity was not found."
    }
  ],
  "usage": { "today": 54, "limit": 100, "remaining": 46, "resets_at": "2026-04-22T00:00:00Z" }
}

{
  "ok": false,
  "error": "INVALID_TOKEN",
  "message": "The FCM token is not registered for your Firebase project.",
  "details": { /* 에러별 추가 컨텍스트가 있을 때 포함 */ }
}

{
  "ok": false,
  "error": "RATE_LIMITED",
  "message": "Daily quota exceeded. Upgrade your plan or wait until reset.",
  "details": {
    "today": 101,
    "limit": 100,
    "resets_at": "2026-04-22T00:00:00Z",
    "retry_after_seconds": 43200
  }
}

// app/api/notify/route.ts
// .env.local 에 OPSEER_API_KEY 설정

export async function POST(req: Request) {
  const { authorFcmToken, commenterName, postId } = await req.json()

  const res = await fetch('https://api.opseer.com/v1/push/send', {
    method: 'POST',
    headers: {
      'Authorization': `Bearer ${process.env.OPSEER_API_KEY}`,
      'Content-Type': 'application/json',
    },
    body: JSON.stringify({
      target: { type: 'token', tokens: [authorFcmToken] },
      title: '새 댓글',
      body: `${commenterName}님이 댓글을 남겼어요`,
      data: { type: 'comment', post_id: postId },
    }),
  })

  const result = await res.json()
  if (!result.ok) {
    return Response.json({ ok: false, error: result.error }, { status: res.status })
  }
  return Response.json({ ok: true, message_id: result.message_id })
}

const OPSEER_CLIENT_KEY = 'opseer_ck_xxxxxxxxxxxxxxxxxxxx' // 앱 번들에 내장

export async function sendPushToUser(
  fcmToken: string,
  title: string,
  body: string,
  data?: Record<string, string>,
) {
  const res = await fetch('https://api.opseer.com/v1/push/send', {
    method: 'POST',
    headers: {
      'Authorization': `Bearer ${OPSEER_CLIENT_KEY}`,
      'Content-Type': 'application/json',
    },
    body: JSON.stringify({
      target: { type: 'token', tokens: [fcmToken] },
      title, body,
      ...(data && { data }),
    }),
  })

  const result = await res.json()
  if (!result.ok) throw new Error(result.error)
  return result
}

struct OpseerPush {
  static let apiKey = "opseer_ck_xxxxxxxxxxxxxxxxxxxx"
  static let baseURL = URL(string: "https://api.opseer.com/v1")!

  static func send(fcmToken: String, title: String, body: String) async throws {
    let url = baseURL.appendingPathComponent("push/send")
    var request = URLRequest(url: url)
    request.httpMethod = "POST"
    request.addValue("Bearer \(apiKey)", forHTTPHeaderField: "Authorization")
    request.addValue("application/json", forHTTPHeaderField: "Content-Type")

    let payload: [String: Any] = [
      "target": ["type": "token", "tokens": [fcmToken]],
      "title": title,
      "body": body,
    ]
    request.httpBody = try JSONSerialization.data(withJSONObject: payload)

    let (_, response) = try await URLSession.shared.data(for: request)
    guard let http = response as? HTTPURLResponse, (200...299).contains(http.statusCode) else {
      throw URLError(.badServerResponse)
    }
  }
}

object OpseerPush {
  private const val API_KEY = "opseer_ck_xxxxxxxxxxxxxxxxxxxx"
  private const val BASE_URL = "https://api.opseer.com/v1"
  private val client = OkHttpClient()

  suspend fun send(fcmToken: String, title: String, body: String) = withContext(Dispatchers.IO) {
    val payload = JSONObject().apply {
      put("target", JSONObject().apply {
        put("type", "token")
        put("tokens", listOf(fcmToken))
      })
      put("title", title)
      put("body", body)
    }
    val request = Request.Builder()
      .url("$BASE_URL/push/send")
      .addHeader("Authorization", "Bearer $API_KEY")
      .post(payload.toString().toRequestBody("application/json".toMediaType()))
      .build()
    client.newCall(request).execute().use { response ->
      if (!response.isSuccessful) throw RuntimeException("Push failed: ${response.code}")
    }
  }
}

curl -X POST https://api.opseer.com/v1/push/send \
  -H "Authorization: Bearer opseer_sk_xxxxxxxxxxxxxxxxxxxx" \
  -H "Content-Type: application/json" \
  -d '{
    "target": {"type":"topic","topic":"all_users"},
    "title": "새 게시글이 올라왔어요",
    "body": "최신 업데이트를 확인해보세요",
    "data": {"type": "announcement"}
  }'

import admin from 'firebase-admin'

admin.initializeApp({
  credential: admin.credential.cert(require('./service-account.json')),
})

await admin.messaging().send({
  token: authorFcmToken,
  notification: { title: '새 댓글', body: commenterMessage },
  data: { post_id: '12345' },
})

await fetch('https://api.opseer.com/v1/push/send', {
  method: 'POST',
  headers: {
    'Authorization': `Bearer ${process.env.OPSEER_API_KEY}`,
    'Content-Type': 'application/json',
  },
  body: JSON.stringify({
    target: { type: 'token', tokens: [authorFcmToken] },
    title: '새 댓글',
    body: commenterMessage,
    data: { post_id: '12345' },
  }),
})
// SDK 초기화·서비스 계정 파일 로딩 불필요