import { Schema } from "effect";import { HttpApiEndpoint, HttpApiGroup } from "effect/unstable/httpapi";import { InternalError } from "@executor-js/sdk/shared"; const SourceSlugParams = {  slug: Schema.String,}; const CreateSourcePayload = Schema.Union([  Schema.Struct({    kind: Schema.Literal("git"),    slug: Schema.optional(Schema.String),    app: Schema.optional(Schema.String),    url: Schema.String,    ref: Schema.optional(Schema.String),    token: Schema.optional(Schema.String),  }),  Schema.Struct({    kind: Schema.Literal("local-directory"),    slug: Schema.optional(Schema.String),    app: Schema.optional(Schema.String),    path: Schema.String,  }),]); const SyncDiagnostic = Schema.Struct({  stage: Schema.Literals(["source", "discover", "bundle", "collect", "project"]),  message: Schema.String,  diagnostics: Schema.optional(    Schema.Array(Schema.Struct({ path: Schema.String, message: Schema.String })),  ),}); const SourceStatus = Schema.Union([  Schema.Struct({ type: Schema.Literal("pending") }),  Schema.Struct({    type: Schema.Literals(["published", "up-to-date"]),    at: Schema.Number,    tools: Schema.Array(Schema.String),  }),  Schema.Struct({    type: Schema.Literal("failed"),    at: Schema.Number,    errors: Schema.Array(SyncDiagnostic),  }),]); const SourceRecord = Schema.Struct({  slug: Schema.String,  app: Schema.String,  kind: Schema.Literals(["git", "local-directory"]),  config: CreateSourcePayload,  sourceRef: Schema.optional(Schema.String),  description: Schema.optional(Schema.String),  status: SourceStatus,  updatedAt: Schema.Number,}); const SourcesResponse = Schema.Struct({ sources: Schema.Array(SourceRecord) });const SourceResponse = Schema.Struct({ source: Schema.NullOr(SourceRecord) });const CreateSourceResponse = Schema.Struct({ source: SourceRecord });const DeleteSourceResponse = Schema.Struct({ removed: Schema.Boolean });const SyncSourceResponse = Schema.Struct({  status: Schema.Literals(["published", "up-to-date", "failed"]),  sourceRef: Schema.optional(Schema.String),  tools: Schema.Array(Schema.String),  errors: Schema.optional(Schema.Array(SyncDiagnostic)),}); const DomainErrors = [InternalError] as const; export const AppsGroup = HttpApiGroup.make("apps")  .add(    HttpApiEndpoint.get("listSources", "/apps/sources", {      success: SourcesResponse,      error: DomainErrors,    }),  )  .add(    HttpApiEndpoint.post("createSource", "/apps/sources", {      payload: CreateSourcePayload,      success: CreateSourceResponse,      error: DomainErrors,    }),  )  .add(    HttpApiEndpoint.get("getSource", "/apps/sources/:slug", {      params: SourceSlugParams,      success: SourceResponse,      error: DomainErrors,    }),  )  .add(    HttpApiEndpoint.delete("deleteSource", "/apps/sources/:slug", {      params: SourceSlugParams,      success: DeleteSourceResponse,      error: DomainErrors,    }),  )  .add(    HttpApiEndpoint.post("syncSource", "/apps/sources/:slug/sync", {      params: SourceSlugParams,      success: SyncSourceResponse,      error: DomainErrors,    }),  );