LiveKit Plugin (Node.js)

npm install @deepslate-labs/livekit

npm install @livekit/agents @livekit/rtc-node

import { fileURLToPath } from "node:url";
import { type JobContext, ServerOptions, cli, defineAgent, voice } from "@livekit/agents";
import { RealtimeModel, elevenLabsConfigFromEnv } from "@deepslate-labs/livekit";

export default defineAgent({
  entry: async (ctx: JobContext) => {
    await ctx.connect();

    const session = new voice.AgentSession({
      llm: new RealtimeModel({
        ttsConfig: elevenLabsConfigFromEnv(),
      }),
    });

    await session.start({
      agent: new voice.Agent({ instructions: "You are a helpful voice AI assistant." }),
      room: ctx.room,
    });

    session.generateReply({ instructions: "Greet the user and offer your assistance." });
  },
});

cli.runApp(new ServerOptions({ agent: fileURLToPath(import.meta.url) }));

import { llm, voice } from "@livekit/agents";
import { z } from "zod";

const lookupWeather = llm.tool({
  description: "Get the current weather for a given location.",
  parameters: z.object({
    location: z.string().describe("The city or location to look up weather for."),
  }),
  execute: async ({ location }) => `It's sunny and 22°C in ${location}.`,
});

const agent = new voice.Agent({
  instructions: "You are a helpful assistant.",
  tools: { lookupWeather },
});

import { RealtimeModel, elevenLabsConfigFromEnv } from "@deepslate-labs/livekit";

const model = new RealtimeModel({ ttsConfig: elevenLabsConfigFromEnv() });
const session = model.session();

import { voice } from "@livekit/agents";
import { RealtimeModel, DeepslateRealtimeSession, elevenLabsConfigFromEnv } from "@deepslate-labs/livekit";

class Assistant extends voice.Agent {
  constructor() {
    super({ instructions: "You are a helpful voice AI assistant." });
  }

  async onEnter(): Promise<void> {
    const session = this.getActivityOrThrow().realtimeLLMSession as DeepslateRealtimeSession;
    await session.speakDirect(
      "Please note that this call is handled by an AI and may be recorded.",
      /* includeInHistory */ true,
      /* uninterruptable */ true,
    );
  }
}

const session = new voice.AgentSession({
  llm: new RealtimeModel({ ttsConfig: elevenLabsConfigFromEnv() }),
});
await session.start({ agent: new Assistant(), room: ctx.room });

await session.speakDirect(
  "Welcome back! How can I help you today?",
  true,  // includeInHistory — record as an assistant turn (default: true)
  false, // uninterruptable — allow the user to barge in (default: false)
);

const summary = await session.queryConversation(
  "Summarize the conversation so far in one sentence.",
);
console.log(summary); // e.g., "The user asked about weather in Berlin."

// Listen for the export result
session.on("chat_history_exported", (messages) => {
  for (const msg of messages) {
    console.log(msg.role, msg.content);
  }
});

// Request the export
await session.exportChatHistory(
  false, // awaitPending — set true to wait for any in-flight operations first
  false, // excludeAudio — set true to omit audio blobs (transcripts only)
);

await session.updateInstructions(
  "You are now a concise assistant. Keep replies under two sentences.",
);