fix: Init resource relationship routes

apps/webservice/src/app/api/v1/relationship/deployment-to-resource/route.ts

@@ -0,0 +1,73 @@
+import { z } from "zod";
+
+import { and, eq, takeFirstOrNull } from "@ctrlplane/db";
+import * as SCHEMA from "@ctrlplane/db/schema";
+
+import { authn } from "../../auth";
+import { parseBody } from "../../body-parser";
+import { request } from "../../middleware";
+
+const bodySchema = z.object({
+  workspaceId: z.string().uuid(),
+  deploymentId: z.string().uuid(),
+  resourceIdentifier: z.string(),
+});
+
+export const POST = request()
+  .use(authn)
+  .use(parseBody(bodySchema))
+  .handle<{ body: z.infer<typeof bodySchema> }>(async (ctx) => {
+    try {
+      const { body, db } = ctx;
+
+      const resource = await db
+        .select()
+        .from(SCHEMA.resource)
+        .where(
+          and(
+            eq(SCHEMA.resource.identifier, body.resourceIdentifier),
+            eq(SCHEMA.resource.workspaceId, body.workspaceId),
+          ),
+        )
+        .then(takeFirstOrNull);
+      if (!resource)
+        return Response.json({ error: "Resource not found" }, { status: 404 });
+
+      const deployment = await db
+        .select()
+        .from(SCHEMA.deployment)
+        .innerJoin(
+          SCHEMA.system,
+          eq(SCHEMA.deployment.systemId, SCHEMA.system.id),
+        )
+        .where(
+          and(
+            eq(SCHEMA.deployment.id, body.deploymentId),
+            eq(SCHEMA.system.workspaceId, body.workspaceId),
+          ),
+        )
+        .then(takeFirstOrNull);
+      if (!deployment)
+        return Response.json(
+          { error: "Deployment not found" },
+          { status: 404 },
+        );
+
+      await db
+        .insert(SCHEMA.deploymentResourceRelationship)
+        .values(body)
+        .returning();
+
+      return Response.json(body);
+    } catch (error) {
+      if (error instanceof Error && error.message.includes("duplicate key"))
+        return Response.json(
+          { error: "Resource already associated with a deployment" },
+          { status: 400 },
+        );
+      return Response.json(
+        { error: "Failed to create relationship" },
+        { status: 500 },
+      );
+    }
+  });

apps/webservice/src/app/api/v1/relationship/resource-to-resource/route.ts

@@ -0,0 +1,77 @@
+import { z } from "zod";
+
+import { and, eq, takeFirstOrNull } from "@ctrlplane/db";
+import * as SCHEMA from "@ctrlplane/db/schema";
+
+import { authn } from "../../auth";
+import { parseBody } from "../../body-parser";
+import { request } from "../../middleware";
+
+const bodySchema = z.object({
+  workspaceId: z.string().uuid(),
+  fromIdentifier: z.string(),
+  toIdentifier: z.string(),
+  type: z.enum(["associated_with", "depends_on"]),
+});
+
+export const POST = request()
+  .use(authn)
+  .use(parseBody(bodySchema))
+  .handle<{ body: z.infer<typeof bodySchema> }>(async (ctx) => {
+    try {
+      const { body, db } = ctx;
+
+      const fromResource = await db
+        .select()
+        .from(SCHEMA.resource)
+        .where(
+          and(
+            eq(SCHEMA.resource.identifier, body.fromIdentifier),
+            eq(SCHEMA.resource.workspaceId, body.workspaceId),
+          ),
+        )
+        .then(takeFirstOrNull);
+      if (!fromResource)
+        return Response.json(
+          { error: `${body.fromIdentifier} not found` },
+          { status: 404 },
+        );
+
+      const toResource = await db
+        .select()
+        .from(SCHEMA.resource)
+        .where(
+          and(
+            eq(SCHEMA.resource.identifier, body.toIdentifier),
+            eq(SCHEMA.resource.workspaceId, body.workspaceId),
+          ),
+        )
+        .then(takeFirstOrNull);
+      if (!toResource)
+        return Response.json(
+          { error: `${body.toIdentifier} not found` },
+          { status: 404 },
+        );
+
+      await db.insert(SCHEMA.resourceRelationship).values({
+        sourceId: fromResource.id,
+        targetId: toResource.id,
+        type: body.type,
+      });
+
+      return Response.json(
+        { message: "Relationship created" },
+        { status: 200 },
+      );
+    } catch (error) {
+      if (error instanceof Error && error.message.includes("duplicate key"))
+        return Response.json(
+          { error: "Relationship already exists" },
+          { status: 400 },
+        );
+      return Response.json(
+        { error: "Failed to create relationship" },
+        { status: 500 },
+      );
+    }
+  });

packages/db/drizzle/0039_hard_joystick.sql

@@ -0,0 +1,20 @@
+CREATE TABLE IF NOT EXISTS "deployment_resource_relationship" (
+	"id" uuid PRIMARY KEY DEFAULT gen_random_uuid() NOT NULL,
+	"workspace_id" uuid NOT NULL,
+	"deployment_id" uuid NOT NULL,
+	"resource_identifier" text NOT NULL
+);
+--> statement-breakpoint
+DO $$ BEGIN
+ ALTER TABLE "deployment_resource_relationship" ADD CONSTRAINT "deployment_resource_relationship_deployment_id_deployment_id_fk" FOREIGN KEY ("deployment_id") REFERENCES "public"."deployment"("id") ON DELETE cascade ON UPDATE no action;
+EXCEPTION
+ WHEN duplicate_object THEN null;
+END $$;
+--> statement-breakpoint
+DO $$ BEGIN
+ ALTER TABLE "deployment_resource_relationship" ADD CONSTRAINT "deployment_resource_relationship_resource_identifier_workspace_id_resource_identifier_workspace_id_fk" FOREIGN KEY ("resource_identifier","workspace_id") REFERENCES "public"."resource"("identifier","workspace_id") ON DELETE cascade ON UPDATE no action;
+EXCEPTION
+ WHEN duplicate_object THEN null;
+END $$;
+--> statement-breakpoint
+CREATE UNIQUE INDEX IF NOT EXISTS "deployment_resource_relationship_workspace_id_resource_identifier_index" ON "deployment_resource_relationship" USING btree ("workspace_id","resource_identifier");