openAgent

1export * as AccountV2 from "./account"
2 
3import { Schema } from "effect"
4import type * as HttpClientError from "effect/unstable/http/HttpClientError"
5 
6export const ID = Schema.String.pipe(Schema.brand("AccountID"))
7export type ID = Schema.Schema.Type<typeof ID>
8 
9export const OrgID = Schema.String.pipe(Schema.brand("OrgID"))
10export type OrgID = Schema.Schema.Type<typeof OrgID>
11 
12export const AccessToken = Schema.String.pipe(Schema.brand("AccessToken"))
13export type AccessToken = Schema.Schema.Type<typeof AccessToken>
14 
15export const RefreshToken = Schema.String.pipe(Schema.brand("RefreshToken"))
16export type RefreshToken = Schema.Schema.Type<typeof RefreshToken>
17 
18export const DeviceCode = Schema.String.pipe(Schema.brand("DeviceCode"))
19export type DeviceCode = Schema.Schema.Type<typeof DeviceCode>
20 
21export const UserCode = Schema.String.pipe(Schema.brand("UserCode"))
22export type UserCode = Schema.Schema.Type<typeof UserCode>
23 
24export class Info extends Schema.Class<Info>("Account")({
25  id: ID,
26  email: Schema.String,
27  url: Schema.String,
28  active_org_id: Schema.NullOr(OrgID),
29}) {}
30 
31export class Org extends Schema.Class<Org>("Org")({
32  id: OrgID,
33  name: Schema.String,
34}) {}
35 
36export class AccountRepoError extends Schema.TaggedErrorClass<AccountRepoError>()("AccountRepoError", {
37  message: Schema.String,
38  cause: Schema.optional(Schema.Defect()),
39}) {}
40 
41export class AccountServiceError extends Schema.TaggedErrorClass<AccountServiceError>()("AccountServiceError", {
42  message: Schema.String,
43  cause: Schema.optional(Schema.Defect()),
44}) {}
45 
46export class AccountTransportError extends Schema.TaggedErrorClass<AccountTransportError>()("AccountTransportError", {
47  method: Schema.String,
48  url: Schema.String,
49  description: Schema.optional(Schema.String),
50  cause: Schema.optional(Schema.Defect()),
51}) {
52  static fromHttpClientError(error: HttpClientError.TransportError): AccountTransportError {
53    return new AccountTransportError({
54      method: error.request.method,
55      url: error.request.url,
56      description: error.description,
57      cause: error.cause,
58    })
59  }
60 
61  override get message(): string {
62    return [
63      `Could not reach ${this.method} ${this.url}.`,
64      `This failed before the server returned an HTTP response.`,
65      this.description,
66      `Check your network, proxy, or VPN configuration and try again.`,
67    ]
68      .filter(Boolean)
69      .join("\n")
70  }
71}
72 
73export type AccountError = AccountRepoError | AccountServiceError | AccountTransportError
74 
75export class Login extends Schema.Class<Login>("Login")({
76  code: DeviceCode,
77  user: UserCode,
78  url: Schema.String,
79  server: Schema.String,
80  expiry: Schema.Duration,
81  interval: Schema.Duration,
82}) {}
83 
84export class PollSuccess extends Schema.TaggedClass<PollSuccess>()("PollSuccess", {
85  email: Schema.String,
86}) {}
87 
88export class PollPending extends Schema.TaggedClass<PollPending>()("PollPending", {}) {}
89 
90export class PollSlow extends Schema.TaggedClass<PollSlow>()("PollSlow", {}) {}
91 
92export class PollExpired extends Schema.TaggedClass<PollExpired>()("PollExpired", {}) {}
93 
94export class PollDenied extends Schema.TaggedClass<PollDenied>()("PollDenied", {}) {}
95 
96export class PollError extends Schema.TaggedClass<PollError>()("PollError", {
97  cause: Schema.Defect(),
98}) {}
99 
100export const PollResult = Schema.Union([PollSuccess, PollPending, PollSlow, PollExpired, PollDenied, PollError])
101export type PollResult = Schema.Schema.Type<typeof PollResult>
102