fix: Create jobs for latest valid releases on env create (#197)

apps/webservice/src/app/api/v1/environments/route.ts

@@ -1,11 +1,13 @@
 import type { PermissionChecker } from "@ctrlplane/auth/utils";
+import type { Tx } from "@ctrlplane/db";
 import type { User } from "@ctrlplane/db/schema";
 import { NextResponse } from "next/server";
 import { isPresent } from "ts-is-present";
 import { z } from "zod";
 
 import { takeFirst } from "@ctrlplane/db";
 import * as schema from "@ctrlplane/db/schema";
+import { createJobsForNewEnvironment } from "@ctrlplane/job-dispatch";
 import { Permission } from "@ctrlplane/validators/auth";
 
 import { authn, authz } from "../auth";
@@ -19,6 +21,19 @@ const body = schema.createEnvironment.extend({
     .optional(),
 });
 
+const createReleaseChannels = (
+  db: Tx,
+  environmentId: string,
+  releaseChannels: { channelId: string; deploymentId: string }[],
+) =>
+  db.insert(schema.environmentReleaseChannel).values(
+    releaseChannels.map(({ channelId, deploymentId }) => ({
+      environmentId,
+      channelId,
+      deploymentId,
+    })),
+  );
+
 export const POST = request()
   .use(authn)
   .use(parseBody(body))
@@ -41,7 +56,19 @@ export const POST = request()
         })
         .returning()
         .then(takeFirst)
-        .then((environment) => NextResponse.json({ environment }))
+        .then(async (environment) => {
+          if (
+            isPresent(ctx.body.releaseChannels) &&
+            ctx.body.releaseChannels.length > 0
+          )
+            await createReleaseChannels(
+              ctx.db,
+              environment.id,
+              ctx.body.releaseChannels,
+            );
+          await createJobsForNewEnvironment(ctx.db, environment);
+          return NextResponse.json({ environment });
+        })
         .catch(() =>
           NextResponse.json(
             { error: "Failed to create environment" },

packages/db/drizzle/0030_easy_alex_wilder.sql

@@ -0,0 +1 @@
+ALTER TYPE "release_job_trigger_type" ADD VALUE 'new_environment';