@cariosan/client

import { Cariosan } from "@cariosan/client";
 
const client = new Cariosan({
  apiUrl: "https://chat.example.com",
  token: "<jwt issued by your backend>",
  reconnect: {
    enabled: true,
    initialDelayMs: 1000,
    maxDelayMs: 30000,
  },
});
 
await client.connect();

const channel = client.channel("order_123");

await channel.sendMessage({ text: "Halo!" });

const original = await channel.sendMessage({ text: "Is the order shipped?" });
await channel.sendMessage({ text: "Yes — on its way!", parentId: original.id });

await channel.sendMessage({ text: "ping @Andi", mentions: ["user_andi"] });

client.on("mention", ({ channel_id, message_id, by_user_id }) => { /* global badge */ });
channel.on("mention", ({ message_id, by_user_id }) => { /* per-channel badge */ });

channel.on("message", (msg) => {
  console.log(`${msg.user.name}: ${msg.content}`);
});

const page = await channel.getMessages({ limit: 50 });
// Load older:
const older = await channel.getMessages({ before: page.next_cursor ?? undefined });

const inChannel = await channel.searchMessages("brown fox", { limit: 20 });
const everywhere = await client.searchMessages("brown fox");
// Same page shape as getMessages; ranked by relevance then recency.

// Reactions (idempotent):
await channel.addReaction(messageId, "👍");
await channel.removeReaction(messageId, "👍");
 
// Edit / unsend — author-only:
const updated = await channel.editMessage(messageId, "fixed a typo");
await channel.deleteMessage(messageId); // soft-delete tombstone, content blanked
 
// React to other members' changes:
channel.on("reaction.add",    ({ message_id, user_id, emoji }) => {});
channel.on("reaction.remove", ({ message_id, user_id, emoji }) => {});
channel.on("message.updated", ({ id, content, edited_at }) => {});
channel.on("message.deleted", ({ id, deleted_at }) => {});

channel.startTyping();   // throttled to once per 2s; implicit stop after idle
channel.stopTyping();    // explicit stop
await channel.markRead(); // sets last_read_at on the server

await channel.getReceipts(); // seed cursors for accurate ticks on load
channel.on("receipt.update", () => {
  render(channel.receiptState(myMessage)); // "sent" | "delivered" | "read"
});

await client.registerDevice(fcmToken, "android"); // "ios" | "android" | "web"
await client.unregisterDevice(fcmToken);          // on logout

await client.blockUser("user_spammer");
const blocked = await client.listBlocked(); // [{ user_id, external_id, name }]
await client.unblockUser("user_spammer");

const { members } = await channel.getPresence();
// members: [{ user_id, external_id, name, role, status, last_seen_at }]
// role is "admin" | "member" for group channels.

const channel = client.channel("order_123");
 
await channel.updateChannel({ name: "Order #123 — VIP", avatarUrl: "https://cdn/g.png" });
await channel.addMembers(["user_support_2"]);
await channel.setMemberRole("user_support_2", "admin"); // or "member" to demote
await channel.removeMember("user_support_1");           // kick (admin)
await channel.removeMember(myExternalId);               // leave (any member)
 
channel.avatarUrl;   // group icon URL (undefined for direct)
channel.lastMessage; // { user_name, content, type, created_at } | undefined

const file: File = /* from <input type="file"> */;
const { publicUrl } = await channel.uploadAttachment(file);
await channel.sendMessage({ text: "", attachmentUrl: publicUrl });

client.on("connected", () => console.log("WS open"));
client.on("disconnected", ({ willReconnect }) => console.log("WS closed, retrying:", willReconnect));
client.on("error", (err) => {
  if (err.code === "UNAUTHORIZED") {
    // Token expired or was rejected. Fetch a new one from your
    // backend and reconnect.
  }
});

import { isAuthError } from "@cariosan/client";
 
try {
  await channel.sendMessage({ text: "hi" });
} catch (err) {
  if (isAuthError(err)) { /* refresh token */ }
  else { /* surface to UI */ }
}