실시간 (Realtime)

// Public Key 만으로 연결 (비로그인)
await cb.realtime.connect()

// 또는 앱 멤버 토큰으로 연결
const member = await cb.auth.signInMember({ login_id: 'myuser123', password: 'password123!' })
await cb.realtime.connect({ accessToken: member.access_token })

const chat = await cb.realtime.subscribe('chat-room-1')

console.log(chat.info.category, chat.info.persist)

const chat = await cb.realtime.subscribe('chat-room-1')

// 수신 핸들러 등록
const off = chat.onMessage<{ text: string }>((msg) => {
  console.log('새 메시지:', msg.data.text)
  console.log('보낸 멤버:', msg.fromMember) // 서버가 검증한 앱 멤버 ID (6.7.0+, 익명이 보낸 메시지면 undefined)
})

// 전송 (기본적으로 발신자에게도 echo 됨)
await chat.send({ text: '안녕!' })

// echo 없이 전송
await chat.send({ text: '...' }, { includeSelf: false })

// 핸들러 해제
off()

chat.onMessage((m) => {
  if (!m.fromMember) return              // 로그인 멤버의 메시지만 처리
  if (blocked.has(m.fromMember)) return  // 차단, 신고, 점수는 멤버 ID 로
  render(m.fromMember, m.data)
})

if (chat.info.persist) {
  const history = await chat.getHistory(50)
  history.messages.forEach((m) => {
    console.log(m.from, m.data, new Date(m.sentAt).toISOString())
  })
}

await chat.unsubscribe()
cb.realtime.disconnect()

const state = cb.realtime.getState()
// 'disconnected' | 'connecting' | 'connected' | 'reconnecting'

cb.realtime.connectionId  // 현재 연결 ID
cb.realtime.appId          // 연결된 앱 ID

import { RealtimeConnectionError } from 'connectbase-client'

try {
  await cb.realtime.connect()
} catch (e) {
  if (e instanceof RealtimeConnectionError) {
    // 'connection_limit_exceeded' | 'quota_exceeded' | 'server_at_capacity' | 'unauthorized' | ...
    if (e.code === 'connection_limit_exceeded') showFull(e.details?.limit)
    else if (e.retryable) setTimeout(() => cb.realtime.connect(), e.retryAfterMs ?? 5000)
  }
}

import { RealtimeRequestError } from 'connectbase-client'

const concert = await cb.realtime.subscribe('concert')
concert.info.isPublisher   // 이 연결이 방송인인지 (구독할 때 정해짐)

concert.onMessage((m) => {
  if (m.fromPublisher) renderStage(m.data) // 서버가 보증하는 방송인 메시지
  else addReaction(m.data)                  // upstream: 관객 반응은 방송인만 받는다
})

await concert.send({ cheer: 1 })                        // upstream 이면 방송인에게만
await concert.send({ cheer: 1 }, { to: 'publishers' })  // open 카테고리에서도 이 메시지만 방송인에게

try {
  await concert.send({ x: 1 })
} catch (e) {
  if (e instanceof RealtimeRequestError && e.code === 'SEND_NOT_ALLOWED') hideSendButton()
}

const stage = await cb.realtime.subscribe('concert', { room: 'show-1025' })
stage.channel           // 'concert:show-1025'
stage.room              // 'show-1025'
stage.info.isPublisher  // room 인가 함수가 이 멤버를 방송인으로 정했으면 true

await stage.send({ cheer: 1 })                        // send / getHistory / unsubscribe / onMessage 는 이 room 채널로 동작
await cb.realtime.markRead(stage.channel, ['msg-1'])  // 이름을 받는 메서드에는 channel 을 넘긴다

// 문자열로 써도 같다
await cb.realtime.subscribe('concert:show-1025')

{
  "event": "room_auth",
  "app_id": "앱 UUID",
  "category": "concert",
  "room": "show-1025",
  "client_id": "cb_k2x9a7",
  "user_id": "0b7c1f3e-5d2a-4c8e-9f10-2a3b4c5d6e7f",
  "member_id": "0b7c1f3e-5d2a-4c8e-9f10-2a3b4c5d6e7f",
  "action": "subscribe",
  "timestamp": 1761100000000
}

// 카테고리의 room_auth_function_id 로 연결한 함수
export default async function handler(payload, ctx) {
  const { room, member_id, action } = payload   // member_id: 서버가 검증한 멤버 ID (익명 연결이면 '')
  const show = await loadShow(ctx, room)   // 앱 데이터에서 공연 조회 (앱이 구현)
  if (!show || !member_id || !show.memberIds.includes(member_id)) return { authorized: false }
  if (action === 'subscribe') return { authorized: true, publisher: show.performerId === member_id }
  return { authorized: show.chatOpen === true }   // publish: 연결마다 room 마다 한 번만 불린다
}

{
  "room_rule": {
    "table_id": "공연 표 ID",
    "room_field": "room",
    "publisher_if": "data.owner_id == auth.member_id && data.status != 'ended'",
    "anonymous": "subscribe",
    "missing": "subscribe"
  }
}

await cb.realtime.connect()

const session = await cb.realtime.stream(
  [{ role: 'user', content: '안녕하세요' }],
  {
    onToken: (token) => process.stdout.write(token),
    onDone: (result) => console.log('\n완료:', result.fullText),
    onError: (e) => console.error('에러:', e)
  },
  { provider: 'gemini', model: 'gemini-2.0-flash', temperature: 0.7 }
)

// 필요 시 중지
await session.stop()

// 본인 온라인 상태 publish (다른 디바이스/사용자에게 알림)
await cb.realtime.setPresence('online', { device: 'web', metadata: { nickname: '홍길동' } })

// 클라이언트가 disconnect 되면 자동으로 적용될 status 미리 등록
await cb.realtime.setPresenceOnDisconnect('offline')

// 특정 사용자 현재 상태 조회 (단건)
const info = await cb.realtime.getPresence('user_123')

// 여러 사용자 한 번에 조회
const map = await cb.realtime.getPresenceMany(['user_123', 'user_456'])

// 특정 사용자 상태 구독
const unsub = await cb.realtime.subscribePresence('user_123', (event) => {
  console.log(event.userId, event.status, event.eventType)  // join | leave | update
})
unsub()  // 구독 해제

// Typing indicator — 룸 단위 (chat 카테고리 / 게임 룸 등 임의 키)
await cb.realtime.startTyping('chat-room-123')
await cb.realtime.stopTyping('chat-room-123')

// 다른 사용자 typing 변경 구독
const offTyping = cb.realtime.onTypingChange('chat-room-123', (event) => {
  console.log('현재 typing 중:', event.users)  // userId[]
})

// Read-receipt — 메시지 ID 단위 읽음 표시
await cb.realtime.markRead('chat-room-123', 'msg_xxx')