JavaScript SDK

npm install @zmesh/js

TypeScript

import { createClient } from "@zmesh/js";

const zmesh = createClient({
  url: "https://api.zmesh.in",
  apiKey: "your-project-api-key",
  projectId: "your-project-id",
});

const { user, access_token } = await zmesh.auth.signUp(
  "user@example.com",
  "securePassword123",
  "John Doe" // optional full name
);

const { user, access_token } = await zmesh.auth.signIn(
  "user@example.com",
  "securePassword123"
);

// Send OTP
await zmesh.auth.sendOtp({
  channel: "whatsapp", // or "sms"
  phone: "+919876543210",
});

// Verify OTP
const tokens = await zmesh.auth.verifyOtp({
  channel: "whatsapp",
  phone: "+919876543210",
  code: "123456",
});

// Redirect user to OAuth provider
window.location.href = zmesh.auth.getOAuthUrl("google");
// or
window.location.href = zmesh.auth.getOAuthUrl("github");

// Get current user
const user = await zmesh.auth.getUser();

// Refresh token
const newTokens = await zmesh.auth.refreshToken(refreshToken);

// Sign out
zmesh.auth.signOut();

const { data, total } = await zmesh.db
  .from("posts")
  .select("id, title, created_at")
  .eq("status", "published")
  .order("created_at", { ascending: false })
  .limit(10);

const { data: post } = await zmesh.db
  .from("posts")
  .insert({ title: "Hello World", content: "My first post" });

await zmesh.db
  .from("posts")
  .update({ title: "Updated Title" })
  .eq("id", "some-uuid");

await zmesh.db
  .from("posts")
  .delete()
  .eq("id", "some-uuid");

.eq("col", value)       // equals
.neq("col", value)      // not equals
.gt("col", value)       // greater than
.gte("col", value)      // greater than or equal
.lt("col", value)       // less than
.lte("col", value)      // less than or equal
.like("col", "%pattern%")
.ilike("col", "%pattern%")  // case-insensitive
.in("col", [1, 2, 3])       // in array

// Chaining
.order("col", { ascending: false })
.limit(25)
.offset(50)

const response = await zmesh.ai.chat({
  model: "gpt-4o",
  messages: [
    { role: "system", content: "You are a helpful assistant." },
    { role: "user", content: "What is zMesh?" },
  ],
  temperature: 0.7,
});

console.log(response.content);
console.log(response.usage); // { prompt_tokens, completion_tokens }

for await (const chunk of zmesh.ai.chatStream({
  model: "gpt-4o",
  messages: [{ role: "user", content: "Write a poem about code" }],
})) {
  if (chunk.type === "chunk") {
    process.stdout.write(chunk.content ?? "");
  }
}

// Upload a file
const result = await zmesh.storage.upload(file, "avatars/");
console.log(result.url);

// List files in a folder
const { files, folders } = await zmesh.storage.list("avatars/");

// Get public URL
const { url } = await zmesh.storage.getUrl("avatars/photo.jpg");

// Delete a file
await zmesh.storage.remove("avatars/photo.jpg");

const result = await zmesh.functions.invoke("send-welcome-email", {
  userId: "abc123",
  template: "onboarding",
});

console.log(result.data);   // function output
console.log(result.status); // "success" | "error" | "timeout"

// Connect to realtime
zmesh.realtime.connect();

// Listen for new rows in "messages" table
const unsubscribe = zmesh.realtime.onTable("messages", "INSERT", (msg) => {
  console.log("New message:", msg.data);
});

// Listen for all changes on "orders"
zmesh.realtime.onTable("orders", "*", (msg) => {
  console.log(msg.event, msg.data); // INSERT, UPDATE, or DELETE
});

// Stop listening
unsubscribe();

// Broadcast a message to a channel
zmesh.realtime.broadcast("chat-room", { text: "Hello!" });

// Listen for broadcasts
zmesh.realtime.onBroadcast("chat-room", (msg) => {
  console.log(msg.payload);
});

// Announce presence
zmesh.realtime.presence({ status: "online", user: "John" });

// Disconnect when done
zmesh.realtime.disconnect();

import { ZMeshError } from "@zmesh/js";

try {
  await zmesh.auth.signIn("bad@email.com", "wrong");
} catch (err) {
  if (err instanceof ZMeshError) {
    console.log(err.status); // 401
    console.log(err.body);   // { detail: "Invalid credentials" }
  }
}

import type {
  AuthTokens,
  AuthUser,
  ChatMessage,
  ChatResponse,
  StreamChunk,
  UploadResult,
  InvokeResult,
} from "@zmesh/js";