i want to save the chats of livekit rooms in db wh...
# ask-aib
busy-breakfast-32623
08/14/2025, 10:22 AMi want to save the chats of livekit rooms in db what are the possible ways of doing this
t
tall-airline-16756
08/14/2025, 10:22 AMThanks for reaching out, Aman. I'm an AI assistant and I'm here to help. Give me a moment while I research this topic.
tall-airline-16756
08/14/2025, 10:23 AMLiveKit doesn’t come with built-in chat persistence, but no worries—you can set up chat history storage yourself using a database. Here are a couple of common ways to do it:
• Using Key-Value Storage: You might try a key-value store like Vercel KV to save and pull up chat history. For example, you can save messages with a unique key and link them to users or rooms using pipelines.
• Using a SQL Database: Another option is creating a database table to hold chat messages, including details like room ID, participant ID, message content, and timestamp. Then you can use SQL queries to add and fetch messages whenever you need.
When you’re ready for production, it’s a good idea to use scalable databases like PostgreSQL or MySQL. Also, think about adding features like user authentication, rate limiting, and regular cleanup to keep everything running smoothly and your storage in check.
b
busy-breakfast-32623
08/14/2025, 10:25 AMhow to implement it . i have a db but hoe to implement the chat i want to save the chats based on the room_name , it will always be unique.
t
tall-airline-16756
08/14/2025, 10:26 AMHey there! If you want to save your LiveKit chats in a database using unique room names, here’s a friendly step-by-step guide to help you out:
1. Database Schema: Start by creating tables to keep track of rooms, participants, and messages. Here’s a simple example:
Copy code
CREATE TABLE rooms (
id SERIAL PRIMARY KEY,
room_name VARCHAR(255) UNIQUE NOT NULL,
created_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP
);
CREATE TABLE messages (
id SERIAL PRIMARY KEY,
room_id INT REFERENCES rooms(id),
participant_id VARCHAR(255),
message TEXT NOT NULL,
sent_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP
);roomsmessages Copy code
def save_message(room_name, participant_id, message):
room_id = get_room_id(room_name) # Grab the room ID from your database
conn.execute(
"INSERT INTO messages (room_id, participant_id, message, sent_at) VALUES (?, ?, ?, ?)",
(room_id, participant_id, message, datetime.now())
)b
busy-breakfast-32623
08/15/2025, 3:52 PMokey where to call the save message from ..
import asyncio
import logging
from dotenv import load_dotenv
import json
import os
from time import perf_counter
from typing import Annotated
from livekit import rtc, api
from livekit.agents import (
AutoSubscribe,
JobContext,
JobProcess,
WorkerOptions,
cli,
llm,
)
from livekit.agents.pipeline import VoicePipelineAgent
from livekit.plugins import deepgram, openai, silero
# load environment variables, this is optional, only used for local development
load_dotenv(dotenv_path=".env.local")
logger = logging.getLogger("outbound-caller")
logger.setLevel(logging.INFO)
outbound_trunk_id = os.getenv("SIP_OUTBOUND_TRUNK_ID")
_default_instructions = (
"You are a scheduling assistant for a game development studio. Your interface with user will be voice."
"You will be on a call with a customer who has an upcoming appointment. Your goal is to confirm the appointment details."
"As a customer service representative, you will be polite and professional at all times. Allow user to end the conversation."
)
async def entrypoint(ctx: JobContext):
global _default_instructions, outbound_trunk_id
logger.info(f"connecting to room {ctx.room.name}")
await ctx.connect(auto_subscribe=AutoSubscribe.AUDIO_ONLY)
user_identity = "phone_user"
# the phone number to dial is provided in the job metadata
phone_number = ctx.job.metadata
logger.info(f"dialing {phone_number} to room {ctx.room.name}")
# look up the user's phone number and appointment details
instructions = (
_default_instructions
+ "The customer's name is Kyle. His appointment is next Tuesday at 3pm."
)
#
create_sip_participantsip_call_toagent_namet
tall-airline-16756
08/15/2025, 3:53 PMHey there! To save chat messages in your LiveKit setup, you can simply call the save message function whenever a new message pops up—whether it’s sent or received. Here’s a friendly little guide on how to weave it into your code:
1. Spot the Event: Keep an eye out for the right event or callback in your LiveKit SDK that tells you when a message is sent or received. For instance, you can listen for chat-related events right in your app’s logic.
2. Call That Save Function: Once you catch the event, just call your save message function with the details it needs, like the room name, participant ID, and the message itself. Something like this:
Copy code
async def on_message_received(room_name, participant_id, message):
save_message(room_name, participant_id, message) Copy code
turn_ctx.add_message(
role="assistant",
content=message
)
await self.update_chat_ctx(turn_ctx)