Real-Time for Every Device

import mqtt from 'mqtt'
import AsyncStorage from '@react-native-async-storage/async-storage'

// Connect with offline-aware configuration
const client = mqtt.connect('wss://mqtt.cloudsignal.app', {
  username: await AsyncStorage.getItem('deviceId'),
  password: await AsyncStorage.getItem('token'),
  clean: false,  // Enable session persistence
  clientId: `mobile-${deviceId}`,
  reconnectPeriod: 1000,
})

// Subscribe with QoS 1 for guaranteed delivery
client.subscribe('user/notifications', { qos: 1 })
client.subscribe('chat/room-123', { qos: 1 })

// Messages received even after reconnecting
client.on('message', (topic, message) => {
  const data = JSON.parse(message.toString())
  
  if (topic.includes('notifications')) {
    showLocalNotification(data)
  } else if (topic.includes('chat')) {
    addMessageToUI(data)
  }
})

// Publish with offline queuing
function sendMessage(roomId, text) {
  client.publish(`chat/${roomId}`, JSON.stringify({
    text,
    sender: userId,
    timestamp: Date.now()
  }), { qos: 1 })  // Will queue if offline
}