puter/paseo
1
0
Fork 0
mirror of https://github.com/getpaseo/paseo.git synced 2026-11-01 22:23:07 +00:00
Code Issues Packages Projects Releases Wiki Activity

test(server): a setting a plugin changes on its own is forwarded as options_changed

Browse Source
This commit is contained in:
Mohamed Boudra
2026-11-01 15:20:05 +01:00
parent 62df2f3253
commit 8e28e3988b
1 changed files with 20 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
packages/server/src/server/agent/plugin-provider.test.ts
+20 -1
View File
@@ -1007,6 +1007,7 @@ describe("PluginAgentClientRegistry", () => {
// A plugin that keeps `voice` on "direct" whatever it is asked, and takes `loud` as given.
async function openStubbornVoiceSession(given: Record<string, boolean | string>) {
const state = { voice: "direct", loud: false };
let openedSessionId = "";
const settings = () => [
{
type: "select" as const,
@@ -1036,6 +1037,7 @@ describe("PluginAgentClientRegistry", () => {
const harness = createProviderHarness({
async handleInput(input, emit) {
if (input.type === "session.open") {
openedSessionId = input.sessionId;
emit({
type: "session.opened",
requestId: input.requestId,
@@ -1068,9 +1070,26 @@ describe("PluginAgentClientRegistry", () => {
});
const events: AgentStreamEvent[] = [];
session.subscribe((event) => events.push(event));
return { harness, session, events };
const changeOnItsOwn = (change: Partial<typeof state>) => {
Object.assign(state, change);
emitConfig(harness.emit, openedSessionId);
};
return { harness, session, events, changeOnItsOwn };
}
test("forwards a setting the plugin changes on its own", async () => {
const { session, events, changeOnItsOwn } = await openStubbornVoiceSession({});
changeOnItsOwn({ loud: true });
await vi.waitFor(() =>
expect(eventsOfType(events, "options_changed")).toEqual([
{ type: "options_changed", provider: "plugin-direct", patch: { loud: true } },
]),
);
await session.close();
});
test("a setting the plugin opened differently is the session's open patch, not an event", async () => {
const { session, events } = await openStubbornVoiceSession({ voice: "other", loud: false });