mirror of
https://github.com/kennethnym/freya
synced 2026-07-05 07:21:15 +01:00
Compare commits
2 Commits
feat/core-
...
feat/agent
| Author | SHA1 | Date | |
|---|---|---|---|
|
2e3ec94f96
|
|||
|
350e1f5fcb
|
3
bun.lock
3
bun.lock
@@ -158,6 +158,9 @@
|
||||
"packages/freya-agent-protocol": {
|
||||
"name": "@freya/agent-protocol",
|
||||
"version": "0.0.0",
|
||||
"dependencies": {
|
||||
"@freya/core": "workspace:*",
|
||||
},
|
||||
},
|
||||
"packages/freya-components": {
|
||||
"name": "@freya/components",
|
||||
|
||||
@@ -6,5 +6,8 @@
|
||||
"types": "src/index.ts",
|
||||
"scripts": {
|
||||
"test": "bun test ./src"
|
||||
},
|
||||
"dependencies": {
|
||||
"@freya/core": "workspace:*"
|
||||
}
|
||||
}
|
||||
|
||||
@@ -1,20 +1,40 @@
|
||||
import { ConversationEntryKind, ConversationEntryVisibility } from "@freya/core"
|
||||
import { describe, expect, test } from "bun:test"
|
||||
|
||||
import type { AgentEvent, AgentServerApi } from "./index"
|
||||
import { AgentEventKind, type AgentEvent, type AgentServerApi } from "./index"
|
||||
|
||||
describe("agent protocol", () => {
|
||||
test("defines server methods and agent events", () => {
|
||||
const server: AgentServerApi = {
|
||||
async sendMessage(message) {
|
||||
return { message, conversationId: "conversation-1" }
|
||||
return {
|
||||
id: "entry-1",
|
||||
conversationId: "conversation-1",
|
||||
sequence: 1,
|
||||
kind: ConversationEntryKind.UserMessage,
|
||||
visibility: ConversationEntryVisibility.UserVisible,
|
||||
fileId: null,
|
||||
payload: {
|
||||
role: "user",
|
||||
parts: [{ type: "text", text: message }],
|
||||
},
|
||||
metadata: {},
|
||||
createdAt: "2026-07-03T00:00:00.000Z",
|
||||
}
|
||||
},
|
||||
notify() {
|
||||
// no-op for protocol shape test
|
||||
},
|
||||
ping() {
|
||||
return "pong"
|
||||
},
|
||||
}
|
||||
const event: AgentEvent = { type: "message_finished" }
|
||||
const event: AgentEvent = {
|
||||
kind: AgentEventKind.ResponseFinished,
|
||||
conversationId: "conversation-1",
|
||||
}
|
||||
|
||||
expect(server.ping()).toBe("pong")
|
||||
expect(event.type).toBe("message_finished")
|
||||
expect(event.kind).toBe(AgentEventKind.ResponseFinished)
|
||||
})
|
||||
})
|
||||
|
||||
@@ -1,18 +1,46 @@
|
||||
export interface SendMessageResult {
|
||||
message: string
|
||||
import type { ConversationEntry } from "@freya/core"
|
||||
|
||||
export const AgentEventKind = {
|
||||
ConversationStarted: "conversation_started",
|
||||
ConversationEntryCreated: "conversation_entry_created",
|
||||
ResponseFinished: "response_finished",
|
||||
ResponseFailed: "response_failed",
|
||||
} as const
|
||||
|
||||
export type AgentEventKind = (typeof AgentEventKind)[keyof typeof AgentEventKind]
|
||||
|
||||
export interface AgentConversationStartedEvent {
|
||||
kind: typeof AgentEventKind.ConversationStarted
|
||||
conversationId: string
|
||||
}
|
||||
|
||||
export interface AgentConversationEntryCreatedEvent {
|
||||
kind: typeof AgentEventKind.ConversationEntryCreated
|
||||
entry: ConversationEntry
|
||||
}
|
||||
|
||||
export interface AgentResponseFinishedEvent {
|
||||
kind: typeof AgentEventKind.ResponseFinished
|
||||
conversationId: string
|
||||
}
|
||||
|
||||
export interface AgentResponseFailedEvent {
|
||||
kind: typeof AgentEventKind.ResponseFailed
|
||||
conversationId: string
|
||||
error: string
|
||||
}
|
||||
|
||||
export type AgentEvent =
|
||||
| { type: "conversation_started"; conversationId: string }
|
||||
| { type: "message_created"; text: string }
|
||||
| { type: "tool_started"; toolName: string }
|
||||
| { type: "tool_finished"; toolName: string; ok: boolean }
|
||||
| { type: "message_finished" }
|
||||
| { type: "message_failed"; error: string }
|
||||
| AgentConversationStartedEvent
|
||||
| AgentConversationEntryCreatedEvent
|
||||
| AgentResponseFinishedEvent
|
||||
| AgentResponseFailedEvent
|
||||
|
||||
export type UserEvent = { type: "typing" }
|
||||
|
||||
export interface AgentServerApi {
|
||||
sendMessage(message: string): Promise<SendMessageResult>
|
||||
sendMessage(message: string): Promise<ConversationEntry>
|
||||
notify(event: UserEvent): void
|
||||
ping(): "pong"
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user