use new policy engine for byEnvironmentId

Author: jsbroks

packages/api/src/router/deployment-version.ts

@@ -519,26 +519,52 @@ export const versionRouter = createTRPCRouter({
           }),
       })
       .query(({ input: { versionId, environmentId } }) =>
+        // db
+        //   .selectDistinctOn([SCHEMA.releaseJobTrigger.resourceId])
+        //   .from(SCHEMA.job)
+        //   .innerJoin(
+        //     SCHEMA.releaseJobTrigger,
+        //     eq(SCHEMA.job.id, SCHEMA.releaseJobTrigger.jobId),
+        //   )
+        //   .innerJoin(
+        //     SCHEMA.resource,
+        //     eq(SCHEMA.releaseJobTrigger.resourceId, SCHEMA.resource.id),
+        //   )
+        //   .orderBy(
+        //     SCHEMA.releaseJobTrigger.resourceId,
+        //     desc(SCHEMA.job.createdAt),
+        //   )
+        //   .where(
+        //     and(
+        //       eq(SCHEMA.releaseJobTrigger.versionId, versionId),
+        //       eq(SCHEMA.releaseJobTrigger.environmentId, environmentId),
+        //       isNull(SCHEMA.resource.deletedAt),
+        //     ),
+        //   ),
+
         db
-          .selectDistinctOn([SCHEMA.releaseJobTrigger.resourceId])
+          .selectDistinctOn([SCHEMA.releaseTarget.resourceId])
           .from(SCHEMA.job)
           .innerJoin(
-            SCHEMA.releaseJobTrigger,
-            eq(SCHEMA.job.id, SCHEMA.releaseJobTrigger.jobId),
+            SCHEMA.releaseJob,
+            eq(SCHEMA.job.id, SCHEMA.releaseJob.jobId),
           )
           .innerJoin(
-            SCHEMA.resource,
-            eq(SCHEMA.releaseJobTrigger.resourceId, SCHEMA.resource.id),
+            SCHEMA.release,
+            eq(SCHEMA.releaseJob.releaseId, SCHEMA.release.id),
           )
-          .orderBy(
-            SCHEMA.releaseJobTrigger.resourceId,
-            desc(SCHEMA.job.createdAt),
+          .innerJoin(
+            SCHEMA.versionRelease,
+            eq(SCHEMA.release.versionReleaseId, SCHEMA.versionRelease.id),
+          )
+          .innerJoin(
+            SCHEMA.releaseTarget,
+            eq(SCHEMA.versionRelease.releaseTargetId, SCHEMA.releaseTarget.id),
           )
           .where(
             and(
-              eq(SCHEMA.releaseJobTrigger.versionId, versionId),
-              eq(SCHEMA.releaseJobTrigger.environmentId, environmentId),
-              isNull(SCHEMA.resource.deletedAt),
+              eq(SCHEMA.releaseTarget.environmentId, environmentId),
+              eq(SCHEMA.versionRelease.versionId, versionId),
             ),
           ),
       ),