@delphi-ai/multi-tenant-chat

Multi-tenant runtime manager for the Vercel Chat SDK. Manages per-connection Chat instances with lazy creation, LRU eviction, and AsyncLocalStorage-based connection context.

Install

pnpm add @delphi-ai/multi-tenant-chat

# Peer dependency
pnpm add chat

Usage

import { MultiTenantChat, type ChatConnection } from "@delphi-ai/multi-tenant-chat";

interface MyConnection extends ChatConnection {
  ownerId: string;
}

const manager = new MultiTenantChat<MyConnection>({
  async resolveConnection({ platform, connectionKey, request }) {
    // Look up connection from your database
    return { id: connectionKey, platform, ownerId: "user-123" };
  },

  async resolveCredentials(connection) {
    // Return platform-specific credentials
    return { botToken: "xoxb-..." };
  },

  state: yourStateAdapter,

  platforms: {
    slack: (credentials) => createSlackAdapter(credentials),
    telegram: (credentials) => createTelegramAdapter(credentials),
  },

  async onDirectMessage(ctx, thread, message) {
    await thread.post("Hello from multi-tenant chat!");
  },
});

// In your webhook handler:
export async function POST(request: Request) {
  return manager.handleWebhook(request, {
    platform: "telegram",
    connectionKey: "connection-id",
  });
}

API

MultiTenantChat<T extends ChatConnection>

Main class that manages per-connection Chat instances.

Config:

• resolveConnection — resolve a connection from platform + key + request
• resolveCredentials — return credentials for a connection
• state — a StateAdapter (shared across all connections, keys are auto-prefixed)
• platforms — map of platform name to adapter factory
• onDirectMessage / onMention / onSubscribedMessage — message handlers
• onError — global error handler
• runtimeCacheMax — max cached Chat instances (default 1000)

Methods:

• handleWebhook(request, { platform, connectionKey }) — route a webhook to the correct Chat instance
• destroyRuntime(connectionId) — tear down a cached runtime

getConnection<T>()

Retrieve the current connection from AsyncLocalStorage context (inside a handler).

createPrefixedState(base, prefix)

Wrap any StateAdapter with per-connection key namespacing.

RuntimeCache

LRU cache of live Chat instances with lazy creation and eviction.

License

MIT