openAgent

1export * as Pty from "./pty"
2 
3import { Schema } from "effect"
4import { optional } from "./schema"
5import { define, inventory } from "./event"
6import { ascending } from "./identifier"
7import { NonNegativeInt, PositiveInt, statics } from "./schema"
8 
9const IDSchema = Schema.String.check(Schema.isStartsWith("pty")).pipe(Schema.brand("PtyID"))
10 
11export const ID = IDSchema.pipe(
12  statics((schema: typeof IDSchema) => {
13    const create = () => schema.make("pty_" + 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 Info = Schema.Struct({
23  id: ID,
24  title: Schema.String,
25  command: Schema.String,
26  args: Schema.Array(Schema.String),
27  cwd: Schema.String,
28  status: Schema.Literals(["running", "exited"]),
29  pid: NonNegativeInt,
30  exitCode: optional(NonNegativeInt),
31}).annotate({ identifier: "Pty" })
32export interface Info extends Schema.Schema.Type<typeof Info> {}
33 
34const Created = define({ type: "pty.created", schema: { info: Info } })
35const Updated = define({ type: "pty.updated", schema: { info: Info } })
36const Exited = define({ type: "pty.exited", schema: { id: ID, exitCode: NonNegativeInt } })
37const Deleted = define({ type: "pty.deleted", schema: { id: ID } })
38export const Event = { Created, Updated, Exited, Deleted, Definitions: inventory(Created, Updated, Exited, Deleted) }
39 
40export const CreateInput = Schema.Struct({
41  command: optional(Schema.String),
42  args: optional(Schema.Array(Schema.String)),
43  cwd: optional(Schema.String),
44  title: optional(Schema.String),
45  env: optional(Schema.Record(Schema.String, Schema.String)),
46})
47export interface CreateInput extends Schema.Schema.Type<typeof CreateInput> {}
48 
49export const UpdateInput = Schema.Struct({
50  title: optional(Schema.String),
51  size: optional(
52    Schema.Struct({
53      rows: PositiveInt,
54      cols: PositiveInt,
55    }),
56  ),
57})
58export interface UpdateInput extends Schema.Schema.Type<typeof UpdateInput> {}
59