Live updates

// For example, POST /api/chat-socket-session on your server
export async function openChatSession(appIds: string[]) {
  await checkBuilderAccess(appIds); // your own access check
  const response = await fetch("https://app.base44.com/api/v1/socket-sessions", {
    method: "POST",
    headers: {
      Authorization: `Bearer ${process.env.BASE44_WORKSPACE_API_KEY}`,
      "Content-Type": "application/json",
    },
    body: JSON.stringify({ app_ids: appIds }),
  });
  if (response.status !== 201) throw new Error(`Couldn't open a session: ${response.status}`);

  const { session_id, session_token, socket_url, socket_path } = await response.json();
  await saveSession(session_id); // stays on your server
  return { session_token, socket_url, socket_path };
}

import { createPlatformClient } from "@base44/platform";

const client = createPlatformClient();
const chat = client.chat.init({
  async getSession() {
    const response = await fetch("/api/chat-socket-session", { method: "POST" });
    if (!response.ok) throw new Error("Couldn't open a session");
    return response.json(); // { session_token, socket_url, socket_path }
  },
  onError: (error) => showConnectionError(error.code),
});

const subscription = chat.subscribe("6a2024af837c7a06c83021c1", {
  onSnapshot: (snapshot) => showApp(snapshot),
  onEvent: (event) => applyEvent(event),
  onError: (error) => showAppError(error.code),
});
await chat.connect();

// When the page closes
subscription.unsubscribe();
chat.close();