@absolutejs/voice

bun add @absolutejs/voice @absolutejs/voice-deepgram @absolutejs/voice-elevenlabs elysia

import { Elysia } from "elysia";
import { createVoiceMemoryStore, voice } from "@absolutejs/voice";
import { deepgram } from "@absolutejs/voice-deepgram";
import { elevenlabs } from "@absolutejs/voice-elevenlabs";

const sessions = createVoiceMemoryStore();
const stt = deepgram({ apiKey: process.env.DEEPGRAM_API_KEY! });
const tts = elevenlabs({
	apiKey: process.env.ELEVENLABS_API_KEY!,
	voiceId: process.env.ELEVENLABS_VOICE_ID!
});

new Elysia()
	.use(voice({
		path: "/voice/realtime",
		session: sessions,
		stt,
		tts,
		greeting: "Hi, how can I help?",
		context: async ({ session }) => ({ sessionId: session.id }),
		onTurn: async (_session, turn, api) => {
			await api.say(`You said: ${turn.text}`);
		}
	}))
	.listen(3000);

console.log("voice websocket: ws://localhost:3000/voice/realtime");

import { createVoiceConfiguration, voice } from "@absolutejs/voice";

const channelDefaults = (channelPath: string) => ({
	correctTurn,
	handoff: handoffAdapters.length > 0 ? { adapters: handoffAdapters, deliveryQueue } : undefined,
	liveOps: liveOpsRuntime,
	onTurn: contractAwareOnTurn,
	ops: assistant.ops,
	preset: "reliability" as const,
	profileSwitchGuard: createProfileSwitchGuard(channelPath),
	session: sessionStore,
	onComplete: async ({ session }) => persistIntake(buildSavedIntake(session)),
	phraseHints: async ({ context, sessionId }) => {
		await rememberSessionRoutingMode({ context, sessionId });
		return VOICE_DEMO_PHRASE_HINTS;
	}
});

export const voiceConfig = createVoiceConfiguration({
	...channelDefaults("/voice/intake"),
	path: "/voice/intake",
	stt,
	tts,
	htmx: renderSavedIntakeHtmx
});

app.use(voice(voiceConfig));