Örnek istemci

npm install pusher-js

import Pusher from 'pusher-js'

const API_ROOT = 'https://app.flextell.ai/api'
const AUTH_URL = `${API_ROOT}/broadcasting/auth`
const TENANT_ID = 123 // klinik kimliği

// Her yetkilendirmede güncel token'ı döndürün (süresi dolan token'ı yenileyin).
async function getAccessToken() {
  return '<access_token>'
}

const pusher = new Pusher('<PUSHER_KEY>', {
  cluster: 'eu',
  forceTLS: true,
  channelAuthorization: {
    endpoint: AUTH_URL,
    transport: 'ajax',
    customHandler: async ({ socketId, channelName }, callback) => {
      try {
        const res = await fetch(AUTH_URL, {
          method: 'POST',
          headers: {
            Authorization: `Bearer ${await getAccessToken()}`,
            Accept: 'application/json',
            'Content-Type': 'application/x-www-form-urlencoded',
          },
          body: new URLSearchParams({
            socket_id: socketId,
            channel_name: channelName,
          }),
        })
        if (!res.ok) return callback(new Error(`Yetkilendirme başarısız (${res.status})`), null)
        callback(null, await res.json()) // { "auth": "<anahtar>:<imza>" }
      } catch (err) {
        callback(err, null)
      }
    },
  },
})

const channel = pusher.subscribe(`private-chat-log-activity.${TENANT_ID}`)

channel.bind('pusher:subscription_succeeded', () => {
  // İlk abonelikte ve her yeniden bağlanmada çalışır.
  refreshConversations()
})

channel.bind('pusher:subscription_error', (err) => {
  // 401/403 durumunda buraya düşer.
  console.warn('Kanala abone olunamadı', err)
})

channel.bind('Modules\\Chat\\Events\\ChatLogChanged', ({ conversation_id, chat_log_id }) => {
  // chat_log_id null olabilir. Mesajı REST API'den okuyun.
  refreshMessages(conversation_id)
})

channel.bind('Modules\\Chat\\Events\\ConversationRead', ({ conversation_id }) => {
  markAsRead(conversation_id)
})

channel.bind('Modules\\Chat\\Events\\ConversationCreated', () => refreshConversations())
channel.bind('Modules\\Chat\\Events\\ConversationDeleted', () => refreshConversations())

async function api(path) {
  const res = await fetch(`${API_ROOT}/v1${path}`, {
    headers: {
      Authorization: `Bearer ${await getAccessToken()}`,
      'X-Tenant': String(TENANT_ID),
      Accept: 'application/json',
    },
  })
  if (!res.ok) throw new Error(`API hatası (${res.status})`)
  return res.json()
}

const refreshConversations = () => api('/conversations')
const refreshMessages = (id) => api(`/conversations/${id}/messages`)

const conversationId = 987
const ai = pusher.subscribe(`private-ai-suggestion.${conversationId}`)

const onSuggestion = (payload) => {
  if (payload.requires_hydration) {
    api(`/conversations/${conversationId}/ai-suggestion`)
  } else {
    // payload öneri alanlarını zaten içerir
  }
}

ai.bind('Modules\\Ai\\Events\\AiSuggestionCreated', onSuggestion)
ai.bind('Modules\\Ai\\Events\\AiSuggestionUpdated', onSuggestion)

pusher.connection.bind('state_change', ({ current }) => {
  if (current === 'unavailable' || current === 'failed') {
    showOfflineNotice()
  }
})