async def add_chat_message(role: str, content: str):
        chat_ctx = agent.chat_ctx.copy()
        chat_ctx.add_message(
            role=role,
            content=content,
        )
        await agent.update_chat_ctx(chat_ctx)

    async def handle_clipboard_text(reader: TextStreamReader):
        try:
            clipboard_text = await reader.read_all()
            add_clipboard_text(ctx.room.name, clipboard_text) # db persistence
            await add_chat_message(
                role="system",
                content=f"The user provided a snippet from their clipboard:\n{clipboard_text}.",
            )
        except Exception as e:
            await add_chat_message(
                role="system",
                content=str(e)
            )
        finally:
            await session.generate_reply(
                instructions="Proceed with the workflow."
            )

    def text_stream_handler(reader: TextStreamReader, _: str):
        match reader.info.topic:
            case "clipboard":
                task = asyncio.create_task(handle_clipboard_text(reader))
                _active_tasks.add(task)
                task.add_done_callback(lambda t: _active_tasks.remove(t))
            case _:
                pass

    ctx.room.register_text_stream_handler(
        "clipboard",
        text_stream_handler,
    )