feat: add data-pathways delete and health check commands

deno.json

@@ -2,7 +2,7 @@
   "$schema": "https://deno.land/x/deno/cli/schemas/config-file.v1.json",
   "name": "@flowcore/sdk",
   "description": "Flowcore SDK",
-  "version": "1.70.0",
+  "version": "1.71.0",
   "license": "MIT",
   "exports": "./src/mod.ts",
   "publish": {

src/commands/data-pathways/health.check.ts

@@ -0,0 +1,26 @@
+import { Command } from "../../common/command.ts"
+import { type DataPathwayHealth, DataPathwayHealthSchema } from "../../contracts/data-pathways.ts"
+import { parseResponseHelper } from "../../utils/parse-response-helper.ts"
+
+export type DataPathwayHealthCheckInput = Record<string, never>
+
+export class DataPathwayHealthCheckCommand extends Command<DataPathwayHealthCheckInput, DataPathwayHealth> {
+  protected override retryOnFailure: boolean = false
+  protected override allowedModes: ("apiKey" | "bearer")[] = ["bearer"]
+
+  protected override getMethod(): string {
+    return "GET"
+  }
+
+  protected override getBaseUrl(): string {
+    return "https://data-pathways.api.flowcore.io"
+  }
+
+  protected override getPath(): string {
+    return "/api/v1/health"
+  }
+
+  protected override parseResponse(rawResponse: unknown): DataPathwayHealth {
+    return parseResponseHelper(DataPathwayHealthSchema, rawResponse)
+  }
+}

src/commands/data-pathways/index.ts

@@ -3,6 +3,7 @@ export * from "./pathway.create.ts"
 export * from "./pathway.fetch.ts"
 export * from "./pathway.list.ts"
 export * from "./pathway.disable.ts"
+export * from "./pathway.delete.ts"
 
 // Slots
 export * from "./slot.register.ts"
@@ -40,3 +41,6 @@ export * from "./quota.list.ts"
 // Pump State
 export * from "./pump-state.fetch.ts"
 export * from "./pump-state.save.ts"
+
+// Health
+export * from "./health.check.ts"

src/commands/data-pathways/pathway.delete.ts

@@ -0,0 +1,43 @@
+import { Command } from "../../common/command.ts"
+import { type DataPathwayMutationResponse, DataPathwayMutationResponseSchema } from "../../contracts/data-pathways.ts"
+import type { ClientError } from "../../exceptions/client-error.ts"
+import { NotFoundException } from "../../exceptions/not-found.ts"
+import { parseResponseHelper } from "../../utils/parse-response-helper.ts"
+
+export interface DataPathwayDeleteInput {
+  id: string
+  reason?: string
+}
+
+export class DataPathwayDeleteCommand extends Command<DataPathwayDeleteInput, DataPathwayMutationResponse> {
+  protected override retryOnFailure: boolean = false
+  protected override allowedModes: ("apiKey" | "bearer")[] = ["bearer"]
+
+  protected override getMethod(): string {
+    return "DELETE"
+  }
+
+  protected override getBaseUrl(): string {
+    return "https://data-pathways.api.flowcore.io"
+  }
+
+  protected override getPath(): string {
+    return `/api/v1/pathways/${this.input.id}`
+  }
+
+  protected override getBody(): Record<string, unknown> {
+    const { id: _id, ...payload } = this.input
+    return payload
+  }
+
+  protected override parseResponse(rawResponse: unknown): DataPathwayMutationResponse {
+    return parseResponseHelper(DataPathwayMutationResponseSchema, rawResponse)
+  }
+
+  protected override handleClientError(error: ClientError): void {
+    if (error.status === 404) {
+      throw new NotFoundException("DataPathway", { id: this.input.id })
+    }
+    throw error
+  }
+}

src/contracts/data-pathways.ts

@@ -455,3 +455,16 @@ export const DataPathwayPumpStateSaveResponseSchema: TObject<{
   status: Type.String(),
 })
 export type DataPathwayPumpStateSaveResponse = Static<typeof DataPathwayPumpStateSaveResponseSchema>
+
+// ── Health ──
+
+export const DataPathwayHealthSchema: TObject<{
+  status: TUnion<[TLiteral<"healthy">, TLiteral<"unhealthy">]>
+  checks: TObject<{ db: TUnion<[TLiteral<"ok">, TLiteral<"error">]> }>
+  uptime: TNumber
+}> = Type.Object({
+  status: Type.Union([Type.Literal("healthy"), Type.Literal("unhealthy")]),
+  checks: Type.Object({ db: Type.Union([Type.Literal("ok"), Type.Literal("error")]) }),
+  uptime: Type.Number(),
+})
+export type DataPathwayHealth = Static<typeof DataPathwayHealthSchema>