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,
    }),
  );