Sign in

@liveblocks/client

@liveblocks/client provides you with JavaScript bindings for our realtime collaboration APIs, built on top of WebSockets. Read our getting started guides to learn more.

createClient

Creates a client that allows you to connect to Liveblocks servers. You must define either authEndpoint or publicApiKey. Resolver functions should be placed inside here, and a number of other options are available.

import { createClient } from "@liveblocks/client";
const client = createClient({ authEndpoint: "/api/liveblocks-auth",
// Other options // ...});
Returns
  • clientClient

    Returns a Client, used for connecting to Liveblocks.

Options
  • authEndpoint

    The URL of your back end’s authentication endpoint as a string, or an async callback function that returns a Liveblocks token result. Either authEndpoint or publicApiKey are required. Learn more about using a URL string and using a callback.

  • publicApiKeystring

    The public API key taken from your project’s dashboard. Generally not recommended for production use. Either authEndpoint or publicApiKey are required. Learn more.

  • throttlenumberDefault is 100

    The throttle time between WebSocket messages in milliseconds, a number between 16 and 1000 is allowed. Using 16 means your app will update 60 times per second. Learn more.

  • preventUnsavedChangesbooleanDefault is false

    When set, navigating away from the current page is prevented while Liveblocks is still synchronizing local changes. Learn more.

  • lostConnectionTimeoutnumberDefault is 5000

    After a user disconnects, the time in milliseconds before a "lost-connection" event is fired. Learn more.

  • backgroundKeepAliveTimeoutnumber

    The time before an inactive WebSocket connection is disconnected. This is disabled by default, but setting a number will activate it. Learn more.

  • resolveUsers

    A function that resolves user information in Comments, Text Editor, and Notifications. Return an array of UserMeta["info"] objects in the same order they arrived. Learn more.

  • resolveRoomsInfo

    A function that resolves room information in Notifications. Return an array of RoomInfo objects in the same order they arrived. Learn more.

  • resolveGroupsInfo

    A function that resolves group information in Comments and Text Editor. Return an array of GroupInfo objects in the same order they arrived. Learn more.

  • resolveMentionSuggestions

    A function that resolves mention suggestions in Comments and Text Editor. Return an array of user IDs or mention objects. Learn more.

  • polyfills

    Place polyfills for atob, fetch, and WebSocket inside here. Useful when using a non-browser environment, such as Node.js or React Native.

  • badgeLocationDefault is "bottom-right"

    The location of the "Powered by Liveblocks" badge. Can be set to either "top-right", "bottom-right", "bottom-left", or "top-left". Learn more.

createClient with public key

When creating a client with a public key, you don’t need to set up an authorization endpoint. We only recommend using a public key when prototyping, or on public landing pages, as it makes it possible for end users to access any room’s data. You should instead use an auth endpoint.

import { createClient } from "@liveblocks/client";
const client = createClient({ publicApiKey: "",});

createClient with auth endpoint

If you are not using a public key, you need to set up your own authEndpoint. Please refer to our Authentication guide.

import { createClient } from "@liveblocks/client";
const client = createClient({ authEndpoint: "/api/liveblocks-auth" });

createClient with auth endpoint callback

If you need to add additional headers or use your own function to call your endpoint, authEndpoint can be provided as a custom callback. You should return the token created with Liveblocks.prepareSession or liveblocks.identifyUser, learn more in authentication guide.

import { createClient } from "@liveblocks/client";
const client = createClient({ authEndpoint: async (room) => { // Fetch your authentication endpoint and retrieve your access or ID token // ...
return { token: "..." }; },});

room is the room ID that the user is connecting to. When using Notifications, room can be undefined, as the client is requesting a token that grants access to multiple rooms, rather than a specific room.

Fetch your endpoint

Here’s an example of fetching your API endpoint at /api/liveblocks-auth within the callback.

import { createClient } from "@liveblocks/client";
const client = createClient({ authEndpoint: async (room) => { const response = await fetch("/api/liveblocks-auth", { method: "POST", headers: { Authentication: "<your own headers here>", "Content-Type": "application/json", }, // Don’t forget to pass `room` down. Note that it // can be undefined when using Notifications. body: JSON.stringify({ room }), }); return await response.json(); },});

Token details

You should return the token created with Liveblocks.prepareSession or liveblocks.identifyUser. These are the values the functions can return.

  1. A valid token, it returns a { "token": "..." } shaped response.
  2. A token that explicitly forbids access, it returns an { "error": "forbidden", "reason": "..." } shaped response. If this is returned, the client will disconnect and won’t keep trying to authorize.

Any other error will be treated as an unexpected error, after which the client will retry the request until it receives either 1. or 2.

WebSocket throttle

By default, the client throttles the WebSocket messages sent to one every 100 milliseconds, which translates to 10 updates per second. It’s possible to override that configuration with the throttle option with a value between 16 and 1000 milliseconds.

import { createClient } from "@liveblocks/client";
const client = createClient({ throttle: 16,
// Other options // ...});

This option is helpful for smoothing out realtime animations in your application, as you can effectively increase the framerate without using any interpolation. Here are some examples with their approximate frames per second (FPS) values.

throttle:  16, // 60 FPSthrottle:  32, // 30 FPSthrottle: 200, //  5 FPS

Prevent users losing unsaved changes

Liveblocks usually synchronizes milliseconds after a local change, but if a user immediately closes their tab, or if they have a slow connection, it may take longer for changes to synchronize. Enabling preventUnsavedChanges will stop tabs with unsaved changes closing, by opening a dialog that warns users. In usual circumstances, it will very rarely trigger.

import { createClient } from "@liveblocks/client";
const client = createClient({ preventUnsavedChanges: true,
// Other options // ...});

More specifically, this option triggers when:

  • There are unsaved changes after calling any hooks or methods, in all of our products.
  • There are unsaved changes in a Text Editor.
  • There’s an unsubmitted comment in the Composer.
  • The user has made changes and is currently offline.

Internally, this option uses the beforeunload event.

Lost connection timeout

If you’re connected to a room and briefly lose connection, Liveblocks will reconnect automatically and quickly. However, if reconnecting takes longer than usual, for example if your network is offline, then the room will emit an event informing you about this.

How quickly this event is triggered can be configured with the lostConnectionTimeout setting, and it takes a number in milliseconds. lostConnectionTimeout can be set between 1000 and 30000 milliseconds. The default is 5000, or 5 seconds.

import { createClient } from "@liveblocks/client";
const client = createClient({ lostConnectionTimeout: 5000,
// Other options // ...});

You can listen to the event with room.subscribe("lost-connection"). Note that this also affects when others are reset to an empty array after a disconnection. This helps prevent temporary flashes in your application as a user quickly disconnects and reconnects. For a demonstration of this behavior, see our connection status example.

Background keep-alive timeout

By default, Liveblocks applications will maintain an active WebSocket connection to the Liveblocks servers, even when running in a browser tab that’s in the background. However, if you’d prefer for background tabs to disconnect after a period of inactivity, then you can use backgroundKeepAliveTimeout.

When backgroundKeepAliveTimeout is specified, the client will automatically disconnect applications that have been in an unfocused background tab for at least the specified time. When the browser tab is refocused, the client will immediately reconnect to the room and synchronize the document.

import { createClient } from "@liveblocks/client";
const client = createClient({ // Disconnect users after 15 minutes of inactivity backgroundKeepAliveTimeout: 15 * 60 * 1000,
// Other options // ...});

backgroundKeepAliveTimeout accepts a number in milliseconds—we advise using a value of at least a few minutes, to avoid unnecessary disconnections.

resolveUsers

Comments and Text Editor store user IDs in their system, but no other user information. To display user information in Comments, Text Editor, and Notifications components, such as a user’s name or avatar, you need to resolve these IDs into user objects. This function receives a list of user IDs and you should return a list of user objects of the same size, in the same order.

User IDs are automatically resolved in batches with a maximum of 50 users per batch to optimize performance and prevent overwhelming your user resolution function.

import { createClient } from "@liveblocks/client";
const client = createClient({ resolveUsers: async ({ userIds }) => { const usersData = await (userIds);
return usersData.map((userData) => ({ name: userData.name, avatar: userData.avatar.src, })); },
// Other options // ...});

The name and avatar you return are rendered in Thread components.

User objects

The user objects returned by the resolver function take the shape of UserMeta["info"], which contains name and avatar by default. These two values are optional, though if you’re using the Comments default components, they are necessary. Here’s an example of userIds and the exact values returned.

resolveUsers: async ({ userIds }) => {  // ["marc@example.com", "nimesh@example.com"];  console.log(userIds);
return [ { name: "Marc", avatar: "https://example.com/marc.png" }, { name: "Nimesh", avatar: "https://example.com/nimesh.png" }, ];};

You can also return custom information, for example, a user’s color:

resolveUsers: async ({ userIds }) => {  // ["marc@example.com"];  console.log(userIds);
return [ { name: "Marc", avatar: "https://example.com/marc.png", color: "purple", }, ];};

Accessing user data in React

You can access any values set within resolveUsers with the useUser hook.

import { useUser } from "@liveblocks/react/suspense";
function Component() { const user = useUser("marc@example.com");
// { name: "Marc", avatar: "https://...", ... } console.log(user);}

resolveRoomsInfo

When using Notifications with Comments, room IDs will be used to contextualize notifications (e.g. “Chris mentioned you in room-id”) in the InboxNotification component. To replace room IDs with more fitting names (e.g. document names, “Chris mentioned you in Document A”), you can provide a resolver function to the resolveRoomsInfo option in createClient.

This resolver function will receive a list of room IDs and should return a list of room info objects of the same size and in the same order.

import { createClient } from "@liveblocks/client";
const client = createClient({ resolveRoomsInfo: async ({ roomIds }) => { const documentsData = await (roomIds);
return documentsData.map((documentData) => ({ name: documentData.name, // url: documentData.url, })); },
// Other options // ...});

In addition to the room’s name, you can also provide a room’s URL as the url property. If you do so, the InboxNotification component will automatically use it. It’s possible to use an inbox notification’s roomId property to construct a room’s URL directly in React and set it on InboxNotification via href, but the room ID might not be enough for you to construct the URL, you might need to call your backend for example. In that case, providing it via resolveRoomsInfo is the preferred way.

resolveGroupsInfo

When using group mentions with Comments and Text Editor, group IDs will be used instead of user IDs. Similarly to resolveUsers, you can provide a resolver function to the resolveGroupsInfo option in createClient to assign information like names and avatars to group IDs.

import { createClient } from "@liveblocks/client";
const client = createClient({ resolveGroupsInfo: async ({ groupIds }) => { const groupsData = await (groupIds);
return groupsData.map((groupData) => ({ name: groupData.name, avatar: groupData.avatar.src, })); },
// Other options // ...});

Accessing group info in React

You can access any values set within resolveGroupsInfo with the useGroupInfo hook.

import { useGroupInfo } from "@liveblocks/react/suspense";
function Component() { const group = useGroupInfo("group-engineering");
// { name: "Engineering", avatar: "https://...", ... } console.log(group);}

resolveMentionSuggestions

To enable creating mentions in Comments and Text Editor, you can provide a resolver function to the resolveMentionSuggestions option in createClient. These mentions will be displayed in the Composer component and in text editors.

This resolver function will receive the mention currently being typed (e.g. when writing “@jane”, text will be jane) and should return a list of user IDs matching that text. This function will be called every time the text changes but with some debouncing.

import { createClient } from "@liveblocks/client";
const client = createClient({ resolveMentionSuggestions: async ({ text, roomId }) => { const workspaceUsers = await (roomId);
if (!text) { // Show all workspace users by default return (workspaceUsers); } else { const matchingUsers = (workspaceUsers, text); return (matchingUsers); } },
// Other options // ...});

Group mentions

To support group mentions in Comments and Text Editor, you can return a list of mention objects instead of user IDs to suggest a mix of user and group mentions.

import { createClient } from "@liveblocks/client";
const client = createClient({ resolveMentionSuggestions: async ({ text, roomId }) => { const dbUsers = await (roomId); const dbGroups = await (roomId);
// Show groups and users matching the text being typed return [ ...dbGroups.map((group) => ({ kind: "group", id: group.id, })), ...dbUsers.map((user) => ({ kind: "user", id: user.id, })), ]; },
// Other options // ...});

The mention objects specify which kind of mention it is, the ID to mention (user ID or group ID), etc.

// A user mention suggestion{  kind: "user",  id: "user-1",}
// A group mention suggestion{ kind: "group", id: "group-1",}
// A group mention suggestion with fixed group members// When using fixed group members via `userIds`, they will take precedence// if the group ID exists on Liveblocks.{ kind: "group", id: "here", members: ["user-1", "user-2"],}

createClient for Node.js

To use @liveblocks/client in Node.js, you need to provide WebSocket and fetch polyfills. As polyfills, we recommend installing ws and node-fetch.

Terminal
npm install ws node-fetch

Then, pass them to the createClient polyfill option as below.

import { createClient } from "@liveblocks/client";import fetch from "node-fetch";import WebSocket from "ws";
const client = createClient({ polyfills: { fetch, WebSocket, },
// Other options // ...});

Note that node-fetch v3+ does not support CommonJS. If you are using CommonJS, downgrade node-fetch to v2.

createClient for React Native

To use @liveblocks/client with React Native, you need to add an atob polyfill. As a polyfill, we recommend installing base-64.

Terminal
npm install base-64

Then you can pass the decode function to our atob polyfill option when you create the client.

import { createClient } from "@liveblocks/client";import { decode } from "base-64";
const client = createClient({ polyfills: { atob: decode, },
// Other options // ...});

Powered by Liveblocks branding

By default, Liveblocks displays a "Powered by Liveblocks" badge in your application. You can adjust the position of the badge by setting the badgeLocation property on createClient.

Set badge location
import { createClient } from "@liveblocks/client";
// "top-right", "bottom-right", "bottom-left", "top-left"const client = createClient({ badgeLocation: "bottom-right",
// ...});

If you wish to remove the badge entirely, you can do so by following these steps:

  1. In the Liveblocks dashboard, navigate to your team's settings.
  2. Under General, toggle on the remove "Powered by Liveblocks" branding option.
Removing the "Powered by Liveblocks" badge

Removing the "Powered by Liveblocks" badge on your projects requires a paid plan. See the pricing page for more information.

Client

Client returned by createClient which allows you to connect to Liveblocks servers in your application, and enter rooms.

Client.enterRoom

Enters a room and returns both the local Room instance, and a leave unsubscribe function. The authentication endpoint is called as soon as you call this function. Used for setting initial Presence and initial Storage values.

const { room, leave } = client.enterRoom("my-room-id", {  // Options  // ...});

Note that it’s possible to add types to your room.

Returns
  • roomRoom<Presence, Storage, UserMeta, RoomEvent>

    A Room, used for building your Liveblocks application. Learn more about typing your room.

  • leave() => void

    A function that’s used to leave the room and disconnect.

Arguments
  • roomIdstringRequired

    The ID of the room you’re connecting to.

  • options.initialPresenceJsonObject

    The initial Presence of the user entering the room. Each user has their own presence, and this is readable for all other connected users. A user’s Presence resets every time they disconnect. This object must be JSON-serializable. Learn more.

  • options.initialStorageLsonObject

    The initial Storage structure for the room when it’s joined for the first time. This is only set a single time, when the room has not yet been populated. This object must contain conflict-free live structures. Learn more.

  • options.autoConnectbooleanDefault is true

    Whether the room immediately connects to Liveblocks servers.

  • options.engine1 | 2

    Preferred storage engine version to use when creating the room. Only takes effect if the room doesn’t exist yet. The v2 Storage engine supports larger documents, is more performant, has native streaming support, and will become the default in the future. Learn more.

Setting initial Presence

Presence is used for storing temporary user-based values, such as a user’s cursor coordinates, or their current selection. Each user has their own presence, and this is readable for all other connected users. Set your initial Presence value by using initialPresence.

const { room, leave } = client.enterRoom("my-room-id", {  initialPresence: {    cursor: null,    colors: ["red", "purple"],    selection: {      id: 72426,    },  },
// Other options // ...});

Each user’s Presence resets every time they disconnect, as this is only meant for temporary data. Any JSON-serializable object is allowed (the JsonObject type).

Setting initial Storage

Storage is used to store permanent data that’s used in your application, such as shapes on a whiteboard, nodes on a flowchart, or text in a form. The first time a room is entered, you can set an initial value by using initialStorage. initialStorage is only read and set a single time, unless a new top-level property is added.

import { LiveList, LiveObject } from "@liveblocks/client";
const { room, leave } = client.enterRoom("my-room-id", { initialStorage: { title: "Untitled", shapes: new LiveList([ new LiveObject({ type: "rectangle", color: "yellow" }), ]), },
// Other options // ...});

If a new top-level property is added to initialStorage, the next time a user connects, the new property will be created. Other properties will be unaffected. Any conflict-free live structures and JSON-serializable objects are allowed (the LsonObject type).

Speed up connecting to a room

To speed up connecting to a room, you can call Liveblocks.prewarmRoom on the server, which will warm up a room for the next 10 seconds. Triggering this directly before a user navigates to a room is an easy to way use this API.

Client.getRoom

Gets a room by its ID. Returns null if client.enterRoom has not been called previously.

const room = client.getRoom("my-room");

It’s unlikely you’ll need this API if you’re using the newer client.enterRoom API. Note that it’s possible to add types to your room.

Returns
  • roomRoom<Presence, Storage, UserMeta, RoomEvent> | null

    A Room, used for building your Liveblocks application. Returns null if the room has not yet been joined by the current client. Learn more about typing your room.

Arguments
  • roomIdstringRequired

    The ID of the room you’re connecting to.

Client.getSyncStatus

Gets the current Liveblocks synchronization status.

const syncStatus = client.getSyncStatus();// "synchronizing" | "synchronized"
Returns
  • returns"synchronizing" | "synchronized"

    Will be "synchronizing" if there are any local changes to any part of Liveblocks that still need to be acknowledged by the server. Will be "synchronized" when all local changes have been persisted.

Client.logout

Purges any auth tokens from the client’s memory. If there are any rooms that are still connected, they will be forced to reauthorize.

client.logout();
Returns
Nothing
Arguments
None

When to logout

Use this function if you have a single page application (SPA) and you wish to log your user out, and reauthenticate them. This is a way to update your user’s info after a connection has begun.

AI Copilots

defineAiTool

Create a custom tool for your AI copilot to use. Defining tools allow the AI copilot to look up information on-demand, render your own components based on the tool’s arguments, or perform actions in your application on behalf of the current user, such as creating content, updating the application state, or interacting with external services.

import { defineAiTool } from "@liveblocks/client";
const myTool = defineAiTool()({ description: "Fetch user information by ID", parameters: { type: "object", properties: { userId: { type: "string", description: "The user’s unique identifier" }, }, required: ["userId"], additionalProperties: false, }, execute: async ({ userId }) => { const user = await getUserById(userId); return { data: { user } }; }, render: ({ result }) => ( <AiTool title="User Lookup" icon="👤"> {!result.data ? ( <div>Looking up user...</div> ) : ( <div>Found user: {result.data.user.name}</div> )} </AiTool> ),});

Note that the function should be called like this defineAiTool()({ ... }) (double-parens). This allows TypeScript’s inference to work correctly. For the best type inference experience, TypeScript 5.3 or higher is recommended. While Liveblocks supports TypeScript 5.0+, full type inference for defineAiTool() requires TypeScript 5.3+.

Returns
  • toolAiOpaqueToolDefinition

    An AI tool.

Arguments
  • descriptionstringRequired

    A clear description of what the tool does. Used by AI to understand when to call this tool.

  • parametersJSONSchema7Required

    JSON Schema defining the tool’s input parameters. The AI will validate arguments against this schema.

  • enabledboolean

    Whether this tool should be enabled. When set to false, the tool will not be made available to the AI copilot for any new/future chat messages, but will still allow existing tool invocations to be rendered that are part of the historic chat record. Defaults to true.

  • executefunction

    Async function that performs the tool’s action. Receives validated arguments and execution context, returns structured data. See implementing the tool call via execute.

  • renderfunction

    React component function that renders the tool’s UI during different execution stages. See tool call rendering stages.

Tools can be registered globally with RegisterAiTool or passed directly to AiChat.

Tool call rendering stages

Rendering a tool call can be done before the tool call is executed, which allows you to display a UI during its entire lifecycle. The tool call stages are:

  • receiving (since 3.4) The tool call is being received and its args are being streamed in. During this stage, you can access partialArgs to display a UI while the tool call arguments are still being constructed, but before the tool call is executed.
  • executing The tool call is currently executing, or is ready to be. In this stage, the args are fully known, but the result of the tool call is not known yet.
  • executed The tool call has been executed, and the result is known. This happens after your execute function was run, or after you called respond() inside render. In this stage, the result object will be available.

The render component will automatically re-render when its stage changes.

Implementing tool calls

When you implement a tool call, use one of these combinations:

  1. Implement execute and render
  2. Implement only execute, but no render
  3. Implement only render, but make sure to eventually call respond()

Implementing your tool call via execute

If you implement the execute function, this function will automatically be invoked when the tool call gets made. The return value of this function will be the result that will be passed back to the AI copilot.

  • { data: any, description?: string } The data to return in case of success. data must be a legal JSON value. Providing a description is optional. If you provide a description, it will be passed to the AI copilot to help it understand the returned data or to provide follow-up instructions for how to respond to this tool result.
  • { error: string } The error message in case the tool call failed to execute.
  • { cancel: true | string } If the tool call should be cancelled. You can optionally provide a cancel reason as an instruction to the AI copilot.

The returned value can be observed in the render method, through the result param:

defineAiTool()({  /* ... */
execute: async () => { await sleep(1000); return { data: { user: { name: "Alice" } } }; },
render: ({ result }) => { if (result.data) { return <div>Found user: {result.data.user.name}</div>; }
// Tool hasn’t executed yet return <Spinner />; },});

If you do not implement render alongside execute, the tool call will still be executed, but no UI will be displayed. The result will still be passed back to the AI copilot.

Implementing your tool call via render

Sometimes you may not want to immediately execute the tool call. This is most common to build a Human-in-the-Loop (HITL) style UI where you want the user to confirm or correct the tool call’s behavior. In these scenarios, you do not want to implement execute. Instead, you could display any UI, as long as you eventually call the respond function that is provided to render’s props.

defineAiTool()({  /* ... */  /* NOTE: No execute method used here! */
render: ({ respond }) => { return ( <div> <button onClick={() => { respond({ data: { user: { name: "Alice" } } }); }} > Confirm </button> <button onClick={() => { respond({ cancel: true }); }} > Cancel </button> </div> ); },});

In this example, until the Confirm button is clicked, the AI chat will remain in “executing” stage, awaiting the result of this tool call.

This example is for illustrative purposes only. In practice, using our AiTool.Confirmation tool is preferred for building confirm/cancel flows.

Like with the execute function, the respond function should be called with a value of this shape:

  • { data: any, description?: string } The data to return in case of success. data must be a legal JSON value. Providing a description is optional. If you provide a description, it will be passed to the AI copilot to help it understand the returned data or to provide follow-up instructions for how to respond to this tool result.
  • { error: string } The error message in case the tool call failed to execute.
  • { cancel: true | string } If the tool call should be cancelled. You can optionally provide a cancel reason as an instruction to the AI copilot.

Handling different tool call stages

You can handle all three stages of a tool call in your render function to provide a smooth user experience during tool call streaming and execution:

const bookFlightTool = defineAiTool()({  description: "Book a flight for a user",  parameters: {    type: "object",    properties: {      origin: { type: "string", description: "Departure city" },      destination: { type: "string", description: "Arrival city" },      departureDate: {        type: "string",        description: "Departure date (YYYY-MM-DD)",      },      passengers: {        type: "array",        items: {          type: "object",          properties: {            name: { type: "string" },            age: { type: "number" },          },          required: ["name", "age"],          additionalProperties: false,        },        description: "List of passengers",      },    },    required: ["origin", "destination", "departureDate", "passengers"],    additionalProperties: false,  },  execute: async ({ origin, destination, departureDate, passengers }) => {    const booking = await bookFlight({      origin,      destination,      departureDate,      passengers,    });    return { data: { bookingId: booking.id } };  },  render: ({ stage, partialArgs, args, result }) => {    return (      <AiTool title="Flight Booking" icon="✈️">        {stage === "receiving" && (          <div>            <h4>Preparing flight booking...</h4>            {partialArgs.origin && <p>From: {partialArgs.origin}</p>}            {partialArgs.destination && <p>To: {partialArgs.destination}</p>}            {partialArgs.departureDate && (              <p>Date: {partialArgs.departureDate}</p>            )}            {partialArgs.passengers && (              <div>                <p>Passengers ({partialArgs.passengers.length}):</p>                <ul>                  {partialArgs.passengers.map((passenger, index) => (                    <li key={index}>                      {passenger?.name || "Loading..."}                      {passenger?.age && ` (${passenger.age})`}                    </li>                  ))}                </ul>              </div>            )}          </div>        )}        {stage === "executing" && (          <div>            <h4>Booking flight...</h4>            <p>              {args.origin}{args.destination} on {args.departureDate}            </p>            <p>{args.passengers.length} passenger(s)</p>          </div>        )}        {stage === "executed" && result.data && (          <div>            <h4>Flight booked successfully!</h4>            <p>Booking ID: {result.data.bookingId}</p>          </div>        )}      </AiTool>    );  },});

In this example, the tool arguments stream in progressively during the receiving stage, causing multiple re-renders as each field appears:

  • 1st render: { stage: "receiving", partialArgs: {} }
  • 2nd render: { stage: "receiving", partialArgs: { origin: "New York" } }
  • 3rd render: { stage: "receiving", partialArgs: { origin: "New York", destination: "London" } }
  • 4th render: { stage: "receiving", partialArgs: { origin: "New York", destination: "London", departureDate: "2024-12-15" } }
  • 5th render: { stage: "receiving", partialArgs: { ..., passengers: [] } }
  • 6th render: { stage: "receiving", partialArgs: { ..., passengers: [{ name: "John" }] } }
  • 7th render: { stage: "receiving", partialArgs: { ..., passengers: [{ name: "John", age: 3 }] } }
  • 8th render: { stage: "receiving", partialArgs: { ..., passengers: [{ name: "John", age: 30 }] } }
  • Final render: { stage: "executing", args: { /* complete object */ } }

This demonstrates how each field and nested property appears incrementally, providing real-time feedback to users as the AI constructs the tool call arguments.

Arguments are streamed in forward-only order. Once a field begins appearing, all previous fields are complete and won’t be modified. You’ll never see { origin: "New York", destination: "London" } followed by { origin: "San Francisco", destination: "London" }, but you might see { origin: "New" } then { origin: "New York" } then { origin: "New York", destination: "London" }.

Room

Room returned by client.enterRoom (or client.getRoom).

Room.getPresence

Return the current user’s Presence. Presence is used to store custom properties on each user that exist until the user disconnects. An example use would be storing a user’s cursor coordinates.

const presence = room.getPresence();
// { cursor: { x: 363, y: 723 } }console.log(presence);

Presence is set with updatePresence and can be typed when you enter a room. The example above is using the following type:

liveblocks.config.ts
declare global {  interface Liveblocks {    Presence: {      cursor: { x: number; y: number };    };  }}
Returns
  • presenceTPresence

    An object holding the Presence value for the currently connected user. Presence is set with updatePresence. Will always be JSON-serializable. TPresence is the Presence type you set yourself, learn more.

Arguments
None

Room.updatePresence

Updates the current user’s Presence. Only pass the properties you wish to update—any changes will be merged into the current presence. The entire presence object will not be replaced.

room.updatePresence({ typing: true });room.updatePresence({ status: "Online" });
// { typing: true, status: "Online" }const presence = room.getPresence();
Returns
Nothing
Arguments
  • updateTPresenceRequired

    The updated Presence properties for the current user inside an object. The user’s entire Presence object will not be replaced, instead these properties will be merged with the existing Presence. This object must be JSON-serializable.

  • options.addToHistorybooleanDefault is false

    Adds Presence values to the history stack, meaning using undo and redo functions will change them. Learn more.

Add Presence to history

By default, Presence values are not added to history. However, using the addToHistory option will add items to the undo/redo stack.

room.updatePresence({ color: "blue" }, { addToHistory: true });room.updatePresence({ color: "red" }, { addToHistory: true });room.history.undo();
// { color: "blue" }const presence = room.getPresence();

See room.history for more information.

Room.getOthers

Returns an array of currently connected users in the room. Returns a User object for each user. Note that you can also subscribe to others using Room.subscribe("others").

const others = room.getOthers();
for (const other of others) { const { connectionId, id, info, presence, canWrite, canComment } = other; // Do things}
Returns
  • othersUser<Presence, UserMeta>[]

    An array holding each connected user’s User object. User contains the current user’s Presence value, along with other information. Presence is set with updatePresence. Returns an empty array when no other users are currently connected. Will always be JSON-serializable.

Arguments
None

Room.broadcastEvent

Broadcast an event to other users in the Room. Events broadcast to the room can be listened to with Room.subscribe("event"). Takes a custom event payload as first argument. Should be serializable to JSON.

room.broadcastEvent({ type: "REACTION", emoji: "🔥" });
Returns
Nothing
Arguments
  • eventTRoomEventRequired

    The event to broadcast to every other user in the room. Must be JSON-serializable. TRoomEvent is the RoomEvent type you set yourself, learn more.

  • options.shouldQueueEventIfNotReadybooleanDefault is false

    Queue the event if the connection is currently closed, or has not been opened yet. We’re not sure if we want to support this option in the future so it might be deprecated to be replaced by something else. Learn more.

Receiving an event

To receive an event, use Room.subscribe("event"). The user property received on the other end is the sender’s User instance.

// User 1room.broadcastEvent({ type: "REACTION", emoji: "🔥" });
// User 2const unsubscribe = room.subscribe("event", ({ event, user, connectionId }) => { // ^^^^ User 1 if (event.type === "REACTION") { // Do something }});

We recommend using a property such as type, so that it’s easy to distinguish between different events on the receiving end.

Typing multiple events

When defining your types, you can pass a RoomEvent type in your config file to receive type hints in your app. To define multiple different custom events, use a union.

declare global {  interface Liveblocks {    RoomEvent:      | { type: "REACTION"; emoji: string }      | { type: "ACTION"; action: string };  }}
room.subscribe("event", ({ event, user, connectionId }) => {  if (event.type === "REACTION") {    // Do something  }  if (event.type === "ACTION") {    // Do something else  }});

Broadcasting an event when disconnected

By default, broadcasting an event is a “fire and forget” action. If the sending client is not currently connected to a room, the event is simply discarded. When passing the shouldQueueEventIfNotReady option, the client will queue up the event, and only send it once the connection to the room is (re)established.

We’re not sure if we want to support shouldQueueEventIfNotReady in the future, so it may be deprecated and replaced with something else.

room.broadcastEvent(  { type: "REACTION", emoji: "🔥" },  {    shouldQueueEventIfNotReady: true,  });

Room.getSelf

Gets the current User. Returns null if the client is not yet connected to the room.

const { connectionId, presence, id, info, canWrite, canComment } =  room.getSelf();
Returns
  • userUser<Presence, UserMeta> | null

    Returns the current User. Returns null if the client is not yet connected to the room.

Arguments
None

Here’s an example of a full return value, assuming Presence and UserMeta have been set.

const user = room.getSelf();
// {// connectionId: 52,// presence: {// cursor: { x: 263, y: 786 },// },// id: "mislav.abha@example.com",// info: {// avatar: "/mislav.png",// },// canWrite: true,// canComment: true,// }console.log(user);

Room.getStatus

Gets the current WebSocket connection status of the room. The possible value are: initial, connecting, connected, reconnecting, or disconnected.

const status = room.getStatus();
// "connected"console.log(status);
Returns
  • status"initial" | "connecting" | "connected" | "reconnecting" | "disconnected"

    Returns the room’s current connection status. It can return one of five values:

    • "initial" The room has not attempted to connect yet.
    • "connecting" The room is currently authenticating or connecting.
    • "connected" The room is connected.
    • "reconnecting" The room has disconnected, and is trying to connect again.
    • "disconnected" The room is disconnected, and is no longer attempting to connect.
Arguments
None

Room.getStorageStatus

Get the Storage status. Use this to tell whether Storage has been synchronized with the Liveblocks servers.

const status = room.getStorageStatus();
// "synchronizing"console.log(status);
Returns
  • status"not-loaded" | "loading" | "synchronizing" | "synchronized"

    The current room’s Storage status. status can be one of four types.

    • "not-loaded" Storage has not been loaded yet as room.getStorage has not been called.
    • "loading" Storage is currently loading for the first time.
    • "synchronizing" Local Storage changes are currently being synchronized.
    • "synchronized" Local Storage changes have been synchronized.
Arguments
None

Room.subscribe(storageItem)

Subscribe to updates on a particular storage item, and takes a callback function that’s called when the storage item is updated. The Storage root is a LiveObject, which means you can subscribe to this, as well as other live structures. Returns an unsubscribe function.

const { root } = await room.getStorage();
const unsubscribe = room.subscribe(root, (updatedRoot) => { // Do something});
Returns
  • unsubscribe() => void

    Unsubscribe function. Call it to cancel the subscription.

Arguments
  • storageItemL extends (LiveObject | LiveMap | LiveList)Required

    The LiveObject, LiveMap, or LiveList which is being subscribed to. Each time the structure is updated, the callback is called.

  • callback(node: L) => voidRequired

    Function that’s called when storageItem updates. Returns the updated storage structure.

  • options.isDeepboolean

    Subscribe to both storageItem and its children. The callback function will be passed a list of updates instead of just the new Storage item. Learn more.

Typing Storage

To type the Storage values you receive, make sure to set your Storage type.

liveblocks.config.ts
import { LiveList } from "@liveblocks/client";
declare global { interface Liveblocks { Storage: { animals: LiveList<{ name: string }>; }; }}

The type received in the callback will match the type passed. Learn more under typing your room.

const { root } = await room.getStorage();const animals = root.get("animals");
const unsubscribe = room.subscribe(animals, (updatedAnimals) => { // LiveList<[{ name: "Fido" }, { name: "Felix" }]> console.log(updatedAnimals);});

Subscribe to any live structure

You can subscribe to any live structure, be it the Storage root, a child, or a structure even more deeply nested.

liveblocks.config.ts
import { LiveMap, LiveObject } from "@liveblocks/client";
type Person = LiveObject<{ name: string; age: number }>;
declare global { interface Liveblocks { Storage: { people: LiveMap<string, Person>; }; }}
const { root } = await room.getStorage();const people = root.get("people");const steven = people.get("steven");
const unsubscribeRoot = room.subscribe(root, (updatedRoot) => { // ...});
const unsubscribePeople = room.subscribe(people, (updatedPeople) => { // ...});
const unsubscribeSteven = room.subscribe(steven, (updatedSteven) => { // ...});

Listening for nested changes

It’s also possible to subscribe to a Storage item and all of its children by passing an optional isDeep option in the third argument. In this case, the callback will be passed a list of updates instead of just the new Storage item. Each such update is a { type, node, updates, source } object.

const { root } = await room.getStorage();
const unsubscribe = room.subscribe( root, (storageUpdates) => { for (const update of storageUpdates) { const { type, // "LiveObject", "LiveList", "LiveMap", or "LiveText" node, updates, source, // Where the change came from, see below } = update; switch (type) { case "LiveObject": { // updates["property"]?.type; is "update" or "delete" // update.node is the LiveObject that has been updated/deleted break; } case "LiveMap": { // updates["key"]?.type; is "update" or "delete" // update.node is the LiveMap that has been updated/deleted break; } case "LiveList": { // updates[0]?.type; is "delete", "insert", "move", or "set" // update.node is the LiveList that has been updated, deleted, or modified break; } case "LiveText": { // updates[0]?.type; is "insert", "delete", or "format" // update.node is the LiveText that has been updated break; } } } }, { isDeep: true });

Checking where a change came from

Every update carries a source field, telling you where the change came from. Use it to tell changes made by this client apart from changes made by others, for example when syncing Storage into an editor that already applied the local change itself.

const unsubscribe = room.subscribe(  root,  (storageUpdates) => {    for (const update of storageUpdates) {      const { source } = update;      if (source.origin === "remote") {        // Changed by another client, and received over the network      } else if (source.via === "edit") {        // Changed by this client, as a regular edit      } else {        // Changed by this client, replayed from history ("undo" or "redo")      }    }  },  { isDeep: true });
Properties
  • source.origin"local" | "remote"

    "local" if the change was made by this client, "remote" if it was made by another client and reached this client over the network.

  • source.via"edit" | "undo" | "redo"

    Only present when origin is "local". How the change was made: a regular edit, or a replay from the undo/redo history.

When a single notification merges local and remote changes to the same node, the merged update is reported as { origin: "remote" }.

Using async functions

You use an async function inside the subscription callback, though bear in mind that the callback itself is synchronous, and there’s no guarantee the async function will complete before the callback is run again.

const { root } = await room.getStorage();
const unsubscribe = room.subscribe(root, (updatedRoot) => { async function doThing() { await fetch(/* ... */); }
doThing();});

If the order of updates is important in your application, and it’s important to ensure that your async function doesn’t start before the previous one finishes, you can use a package such as async-mutex to help you with this. Using runExclusive will effectively form a queue for all upcoming updates, guaranteeing serial execution.

import { Mutex } from "async-mutex";
const { root } = await room.getStorage();const myMutex = new Mutex();
const unsubscribeUpdates = room.subscribe(root, (root) => { void myMutex.runExclusive(async () => { await fetch(/* ... */); });});

Note that this may cause a performance penalty in your application, as certain updates will be ignored.

Room.subscribe("event")

Subscribe to events broadcast by Room.broadcastEvent. Takes a callback that’s run when another user calls Room.broadcastEvent. Provides the event along with the user and their connectionId of the user that sent the message. Returns an unsubscribe function.

// User 1room.broadcastEvent({ type: "REACTION", emoji: "🔥" });
// User 2const unsubscribe = room.subscribe("event", ({ event, user, connectionId }) => { // ^^^^ Will be User 1 if (event.type === "REACTION") { // Do something }});
Returns
  • unsubscribe() => void

    Unsubscribe function. Call it to cancel the subscription.

Arguments
  • eventType"event"Required

    Listen to events.

  • callbackRequired

    Function that’s called when another user sends an event. Receives the event, the user that sent the event, and their connectionId. If this event was sent via liveblocks.broadcastEvent or the Broadcast event API, user will be null and connectionId will be -1. Learn more

Typing events

When defining your types, you can pass a RoomEvent type to your config file to receive type hints in your app. To define multiple different custom events, use a union.

declare global {  interface Liveblocks {    RoomEvent:      | { type: "REACTION"; emoji: string }      | { type: "ACTION"; action: string };  }}
room.subscribe("event", ({ event, user, connectionId }) => {  if (event.type === "REACTION") {    // Do something  }  if (event.type === "ACTION") {    // Do something else  }});

Receiving events from the server

Events can be received from the server with either liveblocks.broadcastEvent or the Broadcast Event API. In events sent from the server, user will be null, and connectionId will be -1.

import { Liveblocks } from "@liveblocks/node";
const liveblocks = new Liveblocks({ secret: "",});
export async function POST() { await liveblocks.broadcastEvent({ type: "REACTION", emoji: "🔥" });}
const unsubscribe = room.subscribe("event", ({ event, user, connectionId }) => {  // `null`, `-1`  console.log(user, connectionId);});

Room.subscribe("my-presence")

Subscribe to the current user’s Presence. Takes a callback that is called every time the current user presence is updated with Room.updatePresence. Returns an unsubscribe function.

const unsubscribe = room.subscribe("my-presence", (presence) => {  // Do something});
Returns
  • unsubscribe() => void

    Unsubscribe function. Call it to cancel the subscription.

Arguments
  • eventType"my-presence"Required

    Listen to the current user’s presence.

  • callback(presence: TPresence) => voidRequired

    Function that’s called when the current user’s Presence has updated, for example with Room.updatePresence. Receives the updates Presence value.

Typing Presence

To type the Presence values you receive, make sure to set your Presence type.

liveblocks.config.ts
declare global {  interface Liveblocks {    Presence: {      status: string;      cursor: { x: number; y: number };    };  }}

The type received in the callback will match the type passed. Learn more under typing your data.

const unsubscribe = room.subscribe("my-presence", (presence) => {  // { status: "typing", cursor: { x: 45, y: 67 }  console.log(presence);});

Room.subscribe("others")

Subscribe to every other users’ updates. Takes a callback that’s called when a user’s Presence updates, or when they enter or leave the room. Returns an unsubscribe function.

const unsubscribe = room.subscribe("others", (others, event) => {  // Do something});
Returns
  • unsubscribe() => void

    Unsubscribe function. Call it to cancel the subscription.

Arguments
  • eventType"others"Required

    Listen to others.

  • callback(others: User<Presence, UserMeta>[], event: OthersEvent) => voidRequired

    Function that’s called when another user’s Presence has updated, for example with Room.updatePresence, or an others event has occurred. Receives an array of User values for each currently connected user. Also received an object with information about the event that has triggered the update, learn more.

Typing Presence

To type the Presence values you receive, make sure to set your Presence type.

liveblocks.config.ts
declare global {  interface Liveblocks {    Presence: {      status: string;      cursor: { x: number; y: number };    };  }}

The type received in the callback will match the type passed. Learn more under typing your data.

const unsubscribe = room.subscribe("others", (others, event) => {  // { status: "typing", cursor: { x: 45, y: 67 }  console.log(others[0].presence);});

Listening for others events

The event parameter returns information on why the callback has just run, for example if their Presence has updated, if they’ve just left or entered the room, or if the current user has disconnected.

const unsubscribe = room.subscribe("others", (others, event) => {  if (event.type === "leave") {    // A user has left the room    // event.user;  }
if (event.type === "enter") { // A user has entered the room // event.user; }
if (event.type === "update") { // A user has updated // event.user; // event.updates; }
if (event.type === "reset") { // A disconnection has occurred and others has reset }});

Live cursors

Here’s a basic example showing you how to render live cursors. Room.updatePresence is being used to update each user’s cursor position.

liveblocks.config.ts
declare global {  interface Liveblocks {    Presence: {      cursor: { x: number; y: number };    };  }}
const { room, leave } = client.enterRoom("my-room-id");
// Call this to update the current user’s Presencefunction updateCursorPosition({ x, y }) { room.updatePresence({ cursor: { x, y } });}
const others = room.getOthers();
// Run __renderCursor__ when any other connected user updates their presenceconst unsubscribe = room.subscribe("others", (others, event) => { for (const { id, presence } of others) { const { x, y } = presence.cursor; (id, { x, y }); }}
// Handle events and rendering// ...

Check our examples page for live demos.

Room.subscribe("status")

Subscribe to WebSocket connection status updates. Takes a callback that is called whenever the connection status changes. Possible value are: initial, connecting, connected, reconnecting, or disconnected. Returns an unsubscribe function.

const unsubscribe = room.subscribe("status", (status) => {  // "connected"  console.log(status);});
Returns
  • unsubscribe() => void

    Unsubscribe function. Call it to cancel the subscription.

Arguments
  • eventType"status"Required

    Listen to status updates.

  • callbackRequired

    Function that’s called when the room’s connection status has changed. It can return one of five values:

    • "initial" The room has not attempted to connect yet.
    • "connecting" The room is currently authenticating or connecting.
    • "connected" The room is connected.
    • "reconnecting" The room has disconnected, and is trying to connect again.
    • "disconnected" The room is disconnected, and is no longer attempting to connect.

When to use status

Status is a low-level API that exposes the WebSocket’s connectivity status. You can use this, for example, to update a connection status indicator in your UI. It would be normal for a client to briefly lose the connection and restore it with quick connectedreconnectingconnected status jumps.

let indicator = "⚪";
const unsubscribe = room.subscribe("status", (status) => { switch (status) { case "connecting": indicator = "🟡"; break; case "connected": indicator = "🟢"; break; // ... }});

If you’d like to let users know that there may be connectivity issues, don’t use this API, but instead refer to Room.subscribe("lost-connection") which was specially built for this purpose.

Do not use this API to detect when Storage or Presence are initialized or loaded. "Connected" does not guarantee that Storage or Presence are ready. To detect when Storage is loaded, rely on awaiting the Room.getStorage promise or using the Room.subscribe("storage-status") event.

Room.subscribe("lost-connection")

A special-purpose event that will fire when a previously connected Liveblocks client has lost connection, for example due to a network outage, and was unable to recover quickly. This event is designed to help improve UX for your users, and will not trigger on short interruptions, those that are less than 5 seconds by default. The event only triggers if a previously connected client disconnects.

const unsubscribe = room.subscribe("lost-connection", (event) => {  // "lost"  console.log(event);});
Returns
  • unsubscribe() => void

    Unsubscribe function. Call it to cancel the subscription.

Arguments
  • eventType"lost-connection"Required

    Listen to lost connection events.

  • callbackRequired

    Function that’s called when a room’s lost connection event has been triggered. It can return one of three values:

    • "lost" A connection has been lost for longer than lostConnectionTimeout.
    • "restored" The connection has been restored again.
    • "failed" The room has been unable to reconnect again, and is no longer trying. This may happen if a user’s network has recovered, but the room’s authentication values no longer allow them to enter.

When to use lost connection events

Lost connections events allows you to build high-quality UIs by warning your users that the application is still trying to re-establish the connection, for example through a toast notification. You may want to take extra care in the mean time to ensure their changes won’t go unsaved, or to help them understand why they’re not seeing updates made by others yet.

When this happens, this callback is called with the event lost. Then, once the connection restores, the callback will be called with the value restored. If the connection could definitively not be restored, it will be called with failed (uncommon).

import { toast } from "my-preferred-toast-library";
const unsubscribe = room.subscribe("lost-connection", (event) => { switch (event) { case "lost": toast.warn("Still trying to reconnect..."); break;
case "restored": toast.success("Successfully reconnected again!"); break;
case "failed": toast.error("Could not restore the connection"); break; }});

Setting lost connection timeout

The lostConnectionTimeout configuration option will determine how quickly the event triggers after a connection loss occurs. By default, it’s set to 5000ms, which is 5 seconds.

import { createClient } from "@liveblocks/client";
const client = createClient({ // Throw lost-connection event after 5 seconds offline lostConnectionTimeout: 5000,
// ...});

Room.subscribe("error")

Subscribe to unrecoverable room connection errors. This event will be emitted immediately before the client disconnects and won’t try reconnecting again. Returns an unsubscribe function. If you’d like to retry connecting, call room.reconnect.

const unsubscribe = room.subscribe("error", (error) => {  switch (error.context.code) {    case -1:      // Authentication error      break;
case 4001: // Could not connect because you don’t have access to this room break;
case 4005: // Could not connect because room was full break;
case 4006: // The room ID has changed, get the new room ID (use this for redirecting) const newRoomId = error.message; break;
default: // Unexpected error break; }});
Returns
  • unsubscribe() => void

    Unsubscribe function. Call it to cancel the subscription.

Arguments
  • eventType"error"Required

    Listen to error events.

  • callbackRequired

    Function that’s called when an unrecoverable error event has been triggered. error.code can return one of these values:

    • -1 Authentication error.
    • 4001 Could not connect because you don’t have access to this room.
    • 4005 Could not connect because room was full.
    • 4006 The room ID has changed.

When to use error events

You can use this event to trigger a “Not allowed” screen/dialog. It can also be helpful for implementing a redirect to another page.

const unsubscribe = room.subscribe("error", (error) => {  // Could not connect because you don’t have access to this room  if (error.context.code === 4001)    return ();  }});

When a room ID has changed

When a room ID has been changed with liveblocks.updateRoomId or the Update Room ID API, error.message will contain the new room ID.

const unsubscribe = room.subscribe("error", (error) => {  // The room ID has changed, get the new room ID  if (error.context.code === 4006)    const newRoomId = error.message;    return (`/app/${newRoomId}`)  }});

Room.subscribe("history")

Subscribe to the current user’s history changes. Returns an unsubscribe function.

const unsubscribe = room.subscribe("history", ({ canUndo, canRedo }) => {  // Do something});
Returns
  • unsubscribe() => void

    Unsubscribe function. Call it to cancel the subscription.

Arguments
  • eventType"history"Required

    Listen to history events.

  • callbackRequired

    Function that’s called when the current user’s history changes. Returns booleans that describe whether the user can use undo or redo.

Room.subscribe("storage-status")

Subscribe to Storage status changes. Use this to tell whether Storage has been synchronized with the Liveblocks servers. Returns an unsubscribe function.

const unsubscribe = room.subscribe("storage-status", (status) => {  switch (status) {    case "not-loaded":      // Storage has not been loaded yet      break;    case "loading":      // Storage is currently loading      break;    case "synchronizing":      // Local Storage changes are being synchronized      break;    case "synchronized":      // Local Storage changes have been synchronized      break;  }});
Returns
  • unsubscribe() => void

    Unsubscribe function. Call it to cancel the subscription.

Arguments
  • eventType"storage-status"Required

    Listen to Storage status events.

  • callbackRequired

    Function that’s called when the current user’s Storage updated status have changed. status can be one of four types.

    • "not-loaded - Storage has not been loaded yet as [getStorage][] has not been called.
    • "loading" - Storage is currently loading for the first time.
    • "synchronizing" - Local Storage changes are currently being synchronized.
    • "synchronized" - Local Storage changes have been synchronized

Room.batch

Batches Storage and Presence modifications made during the given function. Each modification is grouped together, which means that other clients receive the changes as a single message after the batch function has run. When undoing or redoing these changes, the entire batch will be undone/redone together instead of atomically.

const { root } = await room.getStorage();
room.batch(() => { root.set("x", 0); room.updatePresence({ cursor: { x: 100, y: 100 } });});
Returns
  • returnT

    Returns the return value from the callback.

Arguments
  • callback() => TRequired

    A callback containing every Storage and Presence notification that will be part of the batch. Cannot be an async function.

When to batch updates

For the most part, you don’t need to batch updates. For example, given a whiteboard application, it’s perfectly fine to update a note’s position on the board multiple times per second, in separate updates. However, should you implement a “Delete all” button, that may delete 50 notes at once, this is where you should use a batch.

const { root } = await room.getStorage();const notes = root.get("notes");
// ✅ Batch simultaneous changes togetherroom.batch(() => { for (const noteId of notes.keys()) { notes.delete(noteId); }});

This batch places each LiveMap.delete call into a single WebSocket update, instead of sending multiple updates. This will be much quicker.

Batching groups history changes

Batching changes will also group changes into a single history state.

const { root } = await room.getStorage();const pet = root.set("pet", new LiveObject({ name: "Fido", age: 5 }));
// ✅ Batch groups changes into oneroom.batch(() => { pet.set("name", "Felix"); pet.set("age", 10);});
// { name: "Felix", age: 10 }pet.toJSON();
room.history.undo();
// { name: "Fido", age: 5 }pet.toJSON();

Doesn’t work with async functions

Note that room.batch cannot take an async function.

// ❌ Won’t workroom.batch(async () => {  // ...});
// ✅ Will workroom.batch(() => { // ...});

Room.history

Room’s history contains functions that let you undo and redo operations made to Storage and Presence on the current client. Each user has a separate history stored in memory, and history is reset when the page is reloaded.

const { undo, redo, pause, resume /*, ... */ } = room.history;
History in Yjs

Note that to undo or redo in Yjs, you must use a separate history manager, Y.UndoManager.

Add Presence to history

By default, history is only enabled for Storage. However, you can use the addToHistory option to additionally add Presence state to history.

room.updatePresence({ color: "blue" }, { addToHistory: true });

Room.history.undo

Reverts the last operation. It does not impact operations made by other clients, and will only undo changes made by the current client.

const person = new LiveObject();person.set("name", "Pierre");person.set("name", "Jonathan");
room.history.undo();
// "Pierre"root.get("name");
Returns
Nothing
Arguments
None

Room.history.redo

Restores the last undone operation. It does not impact operations made by other clients, and will only restore changes made by the current client.

const person = new LiveObject();person.set("name", "Pierre");person.set("name", "Jonathan");
room.history.undo();room.history.redo();
// "Jonathan"root.get("name");
Returns
Nothing
Arguments
None

Room.history.canUndo

Returns true or false, depending on whether there are any operations to undo. Helpful for disabling undo buttons.

const person = new LiveObject();person.set("name", "Pierre");
// trueroom.history.canUndo();
room.history.undo();
// falseroom.history.canUndo();
Returns
  • canUndoboolean

    Whether there is an undo operation in the current history stack.

Arguments
None

Room.history.canRedo

Returns true or false, depending on whether there are any operations to redo. Helpful for disabling redo buttons.

const person = new LiveObject();person.set("name", "Pierre");
// falseroom.history.canRedo();
room.history.undo();
// trueroom.history.canRedo();
Returns
  • canRedoboolean

    Whether there is a redo operation in the current history stack.

Arguments
None

Room.history.clear

Clears the undo and redo stacks for the current client. Explicitly clearing history resets the ability to undo beyond the current document state. Other clients’ histories are unaffected.

const person = new LiveObject();person.set("name", "Pierre");
// trueroom.history.canUndo();
room.history.clear();
// falseroom.history.canUndo();
Returns
Nothing
Arguments
None

Room.history.pause

All future modifications made on the Room will be merged together to create a single history item until resume is called.

const info = new LiveObject({ time: "one" });
room.history.pause();info.set("time", "two");info.set("time", "three");room.history.resume();
room.history.undo();
// "one"room.get("time");
Returns
Nothing
Arguments
None

Room.history.resume

Resumes history after a pause. Modifications made on the Room are not merged into a single history item any more.

const info = new LiveObject({ time: "one" });
room.history.pause();info.set("time", "two");info.set("time", "three");room.history.resume();
room.history.undo();
// "one"room.get("time");
Returns
Nothing
Arguments
None

Room.history.disable

Executes a callback with history tracking temporarily disabled. Any storage mutations made inside the callback will be applied normally but will not appear on the undo/redo stacks. This is useful for background writes that should not be undoable, such as writing back results from agent updates or reconciling state from an external source.

If the callback throws, the undo/redo stacks are left unchanged (as if the callback never ran).

room.history.disable(() => {  root.set("generatedText", result);});

Batching

When combining with room.batch, always place the batch inside the disable call. If batch wraps disable, the batched mutations will still end up on the undo stack.

// ✅ Disabling undo must happen around a batchroom.history.disable(() => {  room.batch(() => {    root.set("x", 1);    root.set("y", 2);  });});
// ❌ Batch wraps disable, mutations will still end up in the undo stackroom.batch(() => { room.history.disable(() => { root.set("x", 1); root.set("y", 2); });});

Async

The history API is synchronous. For long-running async tasks, call history.disable at each synchronous step rather than wrapping the entire async function:

async function generateSummary() {  room.history.disable(() => root.set("status", "generating"));  const summary = await fetchSummaryFromAgent();  room.history.disable(() => {    room.batch(() => {      root.set("summary", summary);      root.set("status", "done");    });  });}
Returns
  • returnT

    The return value of the callback.

Arguments
  • fn() => TRequired

    The callback to execute while history is disabled.

Room.connect

Connect the local room instance to the Liveblocks server. Does nothing if the room is already connecting, reconnecting or connected. We don’t recommend using this API directly.

room.connect();
Returns
Nothing
Arguments
None

Room.reconnect

Reconnect the local room instance to the Liveblocks server, using a new WebSocket connection.

room.reconnect();
Returns
Nothing
Arguments
None

Room.disconnect

Disconnect the local room instance from the Liveblocks server. The room instance will remain functional (for example, it will still allow local presence or storage mutations), but since it’s no longer connected, changes will not be persisted or synchronized until the room instance is reconnected again. We don’t recommend using this API directly.

room.disconnect();
Returns
Nothing
Arguments
None

Comments

Room.getThreads

Returns threads, and their associated inbox notifications and subscriptions, that are in the current room. It also returns the request date that can be used for subsequent polling. It’s possible to filter for a thread’s resolved status and using custom metadata.

const { threads, inboxNotifications, requestedAt } = await room.getThreads();
// [{ id: "th_s436g8...", type: "thread" }, ...]console.log(threads);
// [{ id: "in_fwh3d4...", kind: "thread", }, ...]console.log(inboxNotifications);
Returns
  • threadsThreadData[]

    Threads within the current room.

  • inboxNotificationsInboxNotificationData[]

    Inbox notifications associated with the threads.

  • subscriptionsSubscriptionData[]

    Subscriptions associated with the threads.

  • requestedAtDate

    The request date to use for subsequent polling.

Options
  • resolvedboolean

    Only return resolved or unresolved threads. Learn more.

  • visibility"public" | "private"

    Only return public or private threads. Permissions are taken into account so users without access to private threads won’t receive them. Learn more.

  • subscribedboolean

    Only return subscribed or unsubscribed threads. Learn more.

  • metadataPartial<ThreadMetadata>

    Only return threads containing the custom metadata. Metadata is set yourself when creating a thread, for example { priority: "HIGH" }. Learn more.

Filtering resolved status

You can filter threads by those that are resolved, or unresolved, by passing a boolean to query.resolved.

// Filtering for threads that are unresolvedconst threads = await room.getThreads({  query: {    resolved: false,  },});

Filtering visibility

You can filter threads based on visibility by passing "public" or "private" to query.visibility.

Permissions are taken into account, for example querying private threads returns no threads if the current user does not have access to private threads.

// Filtering for private threadsconst threads = await room.getThreads({  query: {    visibility: "private",  },});

Filtering subscribed status

You can filter threads by those that the user is subscribed to, or not, by passing a boolean to query.subscribed.

// Filtering for threads that the user is subscribed toconst threads = await room.getThreads({  query: {    subscribed: true,  },});

Filtering metadata

You can define custom metadata when creating a thread, and the query.metadata option allows you to return only threads that match.

// Creating a thread with `priority` metadataawait room.createThread({  body: {    // ...  },  metadata: { priority: "HIGH" },});
// Filtering for threads with the same metadataconst threads = await room.getThreads({ query: { metadata: { priority: "HIGH" }, },});

You can also filter for metadata that begins with a specific string.

// Creating a thread with `{ assigned: "sales:stacy" } metadataawait room.createThread({  body: {    // ...  },  metadata: { assigned: "sales:stacy" },});
// Filtering for threads with `assigned` metadata that starts with `sales:`const threads = await room.getThreads({ query: { metadata: { assigned: { startsWith: "sales:", }, }, },});

You can also filter for metadata using numeric operators.

// Creating a thread with `{ posX: 87, level: 5 } metadataawait room.createThread({  body: {    // ...  },  metadata: { posX: 87, level: 5 },});
// Filtering for threads with `posX` greater than 50 and lower than 100, and level greater than or equal to 5const threads = await room.getThreads({ query: { metadata: { posX: { gt: 50, lt: 100, }, level: { gte: 5, }, }, },});

Room.getThreadsSince

Returns threads, and their associated inbox notifications and subscriptions, that have been updated or deleted since the requested date. Helpful when used in combination with Room.getThreads to initially fetch all threads, then receive updates later.

const initial = await room.getThreads();
const { threads, inboxNotifications, subscriptions, requestedAt } = await room.getThreadsSince({ since: initial.requestedAt });
// { updated: [{ id: "th_s4368s...", type: "thread" }, ...], deleted: [...] }console.log(threads);
// { updated: [{ id: "in_ds83hs...", kind: "thread", }, ...], deleted: [...] }console.log(inboxNotifications);
// { updated: [{ subjectId: "th_s4368s...", kind: "thread", }, ...], deleted: [...] }console.log(subscriptions);
Returns
  • threads

    Threads that have been updated or deleted since the requested date.

  • inboxNotifications

    Inbox notifications that have been updated or deleted since the requested date.

  • subscriptions

    Subscriptions that have been updated or deleted since the requested date.

  • requestedAtDate

    The request date to use for subsequent polling.

Options
  • sinceDateRequired

    Only return threads that have been updated or deleted after this date.

Room.getThread

Returns a thread and its associated inbox notification and subscription, from its ID, if it exists.

const { thread, inboxNotification, subscription } =  await room.getThread("th_xxx");

The thread ID can be retrieved from existing threads.

const newThread = await room.createThread(/* ... */);
const { thread, inboxNotification } = await room.getThread(newThread.id);
Returns
  • threadThreadData | undefined

    The requested thread, or undefined if it doesn’t exist.

  • inboxNotificationInboxNotificationThreadData | undefined

    The inbox notification associated with the thread, or undefined if it doesn’t exist.

  • subscriptionSubscriptionData | undefined

    The subscription associated with the thread, or undefined if it doesn’t exist.

Arguments
  • valuestringRequired

    The ID of the thread you want to retrieve.

Room.createThread

Creates a thread, and its initial comment, in the current room. A comment’s body is an array of paragraphs, each containing child nodes, learn more under creating thread content.

const thread = await room.createThread({  body: {    version: 1,    content: [{ type: "paragraph", children: [{ text: "Hello" }] }],  },});
Returns
  • valueThreadData

    The thread that has been created.

Options
  • bodyCommentBodyRequired

    The content of the comment, see creating thread content.

  • attachmentIdsstring[]

    The IDs of the comment’s attachments.

  • commentMetadataCommentMetadata

    Custom metadata to be attached to the initial comment, see defining comment metadata.

  • metadataThreadMetadata

    Custom metadata to be attached to the thread, see defining thread metadata.

  • visibility"public" | "private"Default is "public"

    Whether to create a public or private thread. Permissions are taken into account so a user without write access to private threads can’t create a private thread.

Creating thread content

A comment’s body is an array of paragraphs, each containing child nodes. Here’s an example of how to construct the following simple comment body, which can be passed to room.createThread.

Hello world

Second paragraph!

import { CommentBody } from "@liveblocks/client";
const body: CommentBody = { version: 1, content: [ { type: "paragraph", children: [{ text: "Hello " }, { text: "world", bold: true }], }, { type: "paragraph", children: [{ text: "Second", italic: true }, { text: " paragraph!" }], }, ],};
const thread = await room.createThread({ body });

It’s also possible to create links and mentions.

@Jody Hekla the Liveblocks website is cool!

const body: CommentBody = {  version: 1,  content: [    {      type: "paragraph",      children: [        { type: "mention", id: "jody.hekla" },        { text: " the " },        { text: "Liveblocks", type: "link", url: "https://liveblocks.io" },        { text: " website is cool!" },      ],    },  ],};

Defining thread metadata

Custom metadata can be attached to each thread. string, number, and boolean properties are allowed.

const metadata: Liveblocks["ThreadMetadata"] = {  color: "blue",  page: 3,  pinned: true,};
const thread = await room.createThread({ body, metadata });

Creating private threads

Threads are public by default. To create a private thread, pass visibility: "private".

const thread = await room.createThread({  body,  visibility: "private",});

Permissions are taken into account when threads are created and retrieved. A user without write access to private threads can’t create a private thread, and users without read access to private threads won’t receive private threads from room.getThreads or room.getThread.

Private threads are only available on Team and Enterprise plans.

Room.deleteThread

Deletes a thread by its ID.

await room.deleteThread("th_xxx");
Returns
Nothing
Arguments
  • threadIdstringRequired

    The ID of the thread to delete.

Room.editThreadMetadata

Edits a thread’s custom metadata. Metadata can be a string, number, or boolean. To delete an existing metadata property, set its value to null.

await room.editThreadMetadata({  threadId: "th_xxx",  metadata: {    color: "blue",    page: 3,    pinned: true,  },});
Returns
  • metadataThreadMetadata

    The thread metadata.

Options
  • threadIdstringRequired

    The ID of the thread.

  • metadataPatchable<ThreadMetadata>Required

    An object containing the metadata properties to update. Metadata can be a string, number, or boolean. To delete an existing metadata property, set its value to null.

Room.markThreadAsResolved

Marks a thread as resolved.

await room.markThreadAsResolved("th_xxx");
Returns
Nothing
Arguments
  • threadIdstringRequired

    The ID of the thread to resolve.

Room.markThreadAsUnresolved

Marks a thread as unresolved.

await room.markThreadAsUnresolved("th_xxx");
Returns
Nothing
Arguments
  • threadIdstringRequired

    The ID of the thread to resolve.

Room.subscribeToThread

Subscribes the user to a thread, meaning they will receive inbox notifications when new comments are posted.

await room.subscribeToThread("th_xxx");
Returns
  • valueSubscriptionData

    The thread’s subscription.

Arguments
  • threadIdstringRequired

    The ID of the thread to subscribe to.

Replacing room-level subscriptions

Subscribing will replace any existing subscription for the current thread set at room-level. This value can also be overridden by a room-level call that is run afterwards.

// 1. Disables notifications for all threadsawait room.updateSubscriptionSettings({  threads: "none",});
// 2. Enables notifications just for this thread, "th_d75sF3..."await room.subscribeToThread("th_d75sF3...");
// 3. Disables notifications for all threads, including "th_d75sF3..."await room.updateSubscriptionSettings({ threads: "none",});

Room.unsubscribeFromThread

Unsubscribes the user from a thread, meaning they will no longer receive inbox notifications when new comments are posted.

await room.unsubscribeFromThread("th_xxx");
Returns
Nothing
Arguments
  • threadIdstringRequired

    The ID of the thread to unsubscribe from.

Replacing room-level unsubscriptions

Unsubscribing will replace any existing unsubscription for the current thread set at room-level. This value can also be overridden by a room-level call that is run afterwards.

// 1. Enable notifications for all threadsawait room.updateSubscriptionSettings({  threads: "all",});
// 2. Disables notifications just for this thread, "th_d75sF3..."await room.unsubscribeFromThread("th_d75sF3...");
// 3. Enables notifications for all threads, including "th_d75sF3..."await room.updateSubscriptionSettings({ threads: "all",});

Room.createComment

Creates a comment in a given thread.

const comment = await room.createComment({  threadId: "th_xxx",  body: {    version: 1,    content: [{ type: "paragraph", children: [{ text: "Hello" }] }],  },});
Returns
  • valueCommentData

    The comment that has been created.

Options
  • threadIdstringRequired

    The ID of the thread that the comment will be added to.

  • bodyCommentBodyRequired

    The content of the comment, see creating comment content.

  • attachmentIdsstring[]

    The IDs of the comment’s attachments.

  • metadataCommentMetadata

    Custom metadata to be attached to the comment, see defining comment metadata.

Creating comment content

A comment’s body is an array of paragraphs, each containing child nodes. Here’s an example of how to construct the following simple comment body, which can be passed to room.createComment.

Hello world

Second paragraph!

import { CommentBody } from "@liveblocks/client";
const thread = await room.createThread(/* ... */);
const body: CommentBody = { version: 1, content: [ { type: "paragraph", children: [{ text: "Hello " }, { text: "world", bold: true }], }, { type: "paragraph", children: [{ text: "Second", italic: true }, { text: " paragraph!" }], }, ],};
const comment = await room.createComment({ threadId: thread.id, body });

It’s also possible to create links and mentions.

@Jody Hekla the Liveblocks website is cool!

const body: CommentBody = {  version: 1,  content: [    {      type: "paragraph",      children: [        { type: "mention", id: "jody.hekla" },        { text: " the " },        { text: "Liveblocks", type: "link", url: "https://liveblocks.io" },        { text: " website is cool!" },      ],    },  ],};