openAgent

1export * as Question from "./question"
2 
3import { Schema } from "effect"
4import { optional } from "./schema"
5import { define, inventory } from "./event"
6import { ascending } from "./identifier"
7import { SessionID } from "./session-id"
8import { statics } from "./schema"
9 
10export const ID = Schema.String.check(Schema.isStartsWith("que")).pipe(
11  Schema.brand("QuestionV2.ID"),
12  statics((schema) => {
13    const create = () => schema.make("que_" + ascending())
14    return {
15      create,
16      ascending: (id?: string) => (id === undefined ? create() : schema.make(id)),
17    }
18  }),
19)
20export type ID = typeof ID.Type
21 
22export const Option = Schema.Struct({
23  label: Schema.String.annotate({ description: "Display text (1-5 words, concise)" }),
24  description: Schema.String.annotate({ description: "Explanation of choice" }),
25}).annotate({ identifier: "QuestionV2.Option" })
26export interface Option extends Schema.Schema.Type<typeof Option> {}
27 
28const base = {
29  question: Schema.String.annotate({ description: "Complete question" }),
30  header: Schema.String.annotate({ description: "Very short label (max 30 chars)" }),
31  options: Schema.Array(Option).annotate({ description: "Available choices" }),
32  multiple: Schema.Boolean.pipe(optional).annotate({ description: "Allow selecting multiple choices" }),
33}
34 
35export const Info = Schema.Struct({
36  ...base,
37  custom: Schema.Boolean.pipe(optional).annotate({
38    description: "Allow typing a custom answer (default: true)",
39  }),
40}).annotate({ identifier: "QuestionV2.Info" })
41export interface Info extends Schema.Schema.Type<typeof Info> {}
42 
43export const Prompt = Schema.Struct(base).annotate({ identifier: "QuestionV2.Prompt" })
44export interface Prompt extends Schema.Schema.Type<typeof Prompt> {}
45 
46export const Tool = Schema.Struct({
47  messageID: Schema.String,
48  callID: Schema.String,
49}).annotate({ identifier: "QuestionV2.Tool" })
50export interface Tool extends Schema.Schema.Type<typeof Tool> {}
51 
52export const Request = Schema.Struct({
53  id: ID,
54  sessionID: SessionID,
55  questions: Schema.Array(Info).annotate({ description: "Questions to ask" }),
56  tool: Tool.pipe(optional),
57}).annotate({ identifier: "QuestionV2.Request" })
58export interface Request extends Schema.Schema.Type<typeof Request> {}
59 
60export const Answer = Schema.Array(Schema.String).annotate({ identifier: "QuestionV2.Answer" })
61export type Answer = typeof Answer.Type
62 
63export const Reply = Schema.Struct({
64  answers: Schema.Array(Answer).annotate({
65    description: "User answers in order of questions (each answer is an array of selected labels)",
66  }),
67}).annotate({ identifier: "QuestionV2.Reply" })
68export interface Reply extends Schema.Schema.Type<typeof Reply> {}
69 
70const Asked = define({ type: "question.v2.asked", schema: Request.fields })
71const Replied = define({
72  type: "question.v2.replied",
73  schema: {
74    sessionID: SessionID,
75    requestID: ID,
76    answers: Schema.Array(Answer),
77  },
78})
79const Rejected = define({
80  type: "question.v2.rejected",
81  schema: {
82    sessionID: SessionID,
83    requestID: ID,
84  },
85})
86export const Event = { Asked, Replied, Rejected, Definitions: inventory(Asked, Replied, Rejected) }
87