Something went wrong. Try again.
opencode v2 mirror
Something went wrong. Try again.
1.6 kB · 39 lines
TypeScript
12345678910111213141516171819202122232425262728293031323334353637383940// Generated by @opencode/httpapi-codegen. Do not edit.import { Effect, Schema, Stream } from "effect"import { Sse } from "effect/unstable/encoding"import { HttpClientError } from "effect/unstable/http"import { HttpApiClient, HttpApiEndpoint, HttpApiGroup, HttpApiSchema } from "effect/unstable/httpapi"import { ClientError } from "./client-error.js"
const EndpointSubscribeSuccessData = Schema.Struct({ type: Schema.String })
const EndpointSubscribeSuccessError = Schema.Never
export const GroupEvent = HttpApiGroup.make("event", { topLevel: false }).add( HttpApiEndpoint.make("GET")("subscribe", "/event", { success: HttpApiSchema.StreamSse({ data: EndpointSubscribeSuccessData, error: EndpointSubscribeSuccessError, contentType: "text/event-stream", }).pipe(HttpApiSchema.status(202)), }),)
type RawGroup = HttpApiClient.Client.Group<typeof GroupEvent, never, never>
const EndpointSubscribeDeclaredError = Schema.Union([EndpointSubscribeSuccessError])const mapEndpointSubscribeError = (error: unknown) => HttpClientError.isHttpClientError(error) || Schema.isSchemaError(error) || Sse.Retry.is(error) ? new ClientError({ cause: error }) : Schema.is(EndpointSubscribeDeclaredError)(error) ? error : new ClientError({ cause: error })const EndpointSubscribe = (raw: RawGroup) => () => Stream.unwrap( raw["subscribe"]({}).pipe( Effect.mapError(mapEndpointSubscribeError), Effect.map((stream) => stream.pipe(Stream.mapError(mapEndpointSubscribeError))), ), )
export const adaptGroupEvent = (raw: RawGroup) => ({ subscribe: EndpointSubscribe(raw) })