Quick start

import {
  connect, disconnect, addSubscription,
  onConnecting, onConnected, onDisconnected, onError,
  onSubscribed, onPublication, helpers, utils,
} from "tauri-plugin-centrifugo-api";

const unlisten = [
  await onConnecting(({ payload }) => console.log("connecting", payload.code, payload.reason)),
  await onConnected(({ payload }) => console.log("connected, client", payload.client)),
  await onDisconnected(({ payload }) => console.log("disconnected", payload.code, payload.reason)),
  await onError(({ payload }) => console.error(payload.channel ?? "client", payload.error)),
  await onSubscribed(({ payload }) => console.log("subscribed to", payload.channel)),
  await onPublication(({ payload }) => {
    // `rawJson` is set when the data is valid JSON; `data` is always base64.
    console.log(payload.channel, payload.rawJson ?? utils.decode(payload.data));
  }),
];

await connect({
  url: "ws://localhost:8000/connection/websocket",
  token: "<connection JWT>", // omit for anonymous connections
  channels: ["news"],        // subscribed with default options
  useProtobuf: false,
});

// connect() returns at once; wait for the `connected` state before calling the server.
if (await helpers.waitForConnection(5000)) {
  await addSubscription("chat");
  await helpers.publishJson("news", { text: "hello" });
}

// Later:
await disconnect();
unlisten.forEach((fn) => fn());