API Reference

// thingschat-client.js

const EventSource = globalThis.EventSource ?? require('eventsource')

const BASE_URL = process.env.BASE_URL || 'https://api.thingschat.online'
const TOKEN    = process.env.TOKEN
const THING    = process.env.THING || 'my-device'

if (!TOKEN) {
  console.error('Missing TOKEN env var')
  process.exit(1)
}

const url = `${BASE_URL}/${TOKEN}/chat/${THING}/listen`
console.log(`Connecting to ${url}`)

const es = new EventSource(url)

// --- Connection lifecycle ---
es.addEventListener('status', (e) => {
  const data = JSON.parse(e.data)
  console.log('[connected]', data)

  if (data.retry) {
    console.log(`  Free plan — idle connections close after 3 min`)
    console.log(`  Auto-reconnect delay: ${data.retry / 1000}s`)
  }
})

// --- Incoming messages ---
es.addEventListener('message', (e) => {
  const msg = JSON.parse(e.data)
  console.log(`[message] id=${msg.id} thing=${msg.thing}`)
  console.log('  payload:', msg.chat)
  console.log('  at:', msg.createdAt)
})

// --- Session management (free plan only) ---
es.addEventListener('session', (e) => {
  const data = JSON.parse(e.data)
  console.log('[session]', data)
  if (data.type === 'expired' && data.reason === 'idle') {
    console.log('  Expired due to inactivity — will reconnect automatically')
  }
})

// --- Error handling ---
es.onerror = () => {
  if (es.readyState === EventSource.CONNECTING) {
    console.log('[reconnecting...]')
  } else if (es.readyState === EventSource.CLOSED) {
    console.log('[closed] connection was terminated')
  }
}

// --- Graceful shutdown ---
process.on('SIGINT', () => {
  console.log('\nClosing connection...')
  es.close()
  process.exit(0)
})