Remove unneeded create project job

Author: FyreByrd

src/lib/server/bullmq/BullMQ.ts

@@ -6,7 +6,6 @@ export const allWorkers = building
   : [
       new Workers.Builds(),
       new Workers.S3(),
-      new Workers.Projects(),
       new Workers.Releases(),
       new Workers.Polling(),
       new Workers.SystemStartup()

src/lib/server/bullmq/BullWorker.ts

@@ -136,18 +136,6 @@ export class S3<J extends BullMQ.S3Job> extends BullWorker<J> {
   }
 }
 
-export class Projects<J extends BullMQ.ProjectJob> extends BullWorker<J> {
-  constructor() {
-    super(BullMQ.QueueName.Projects);
-  }
-  async run(job: Job<J>) {
-    switch (job.data.type) {
-      case BullMQ.JobType.Project_Create:
-        return Executor.Project.create(job as Job<BullMQ.Project.Create>);
-    }
-  }
-}
-
 export class Releases<J extends BullMQ.PublishJob> extends BullWorker<J> {
   constructor() {
     super(BullMQ.QueueName.Releases);

src/lib/server/bullmq/queues.ts

@@ -1,15 +1,7 @@
 import { Queue } from 'bullmq';
 import { BullMQOtel } from 'bullmq-otel';
 import { Redis } from 'ioredis';
-import type {
-  BuildJob,
-  PollJob,
-  ProjectJob,
-  PublishJob,
-  RecurringJob,
-  S3Job,
-  StartupJob
-} from './types';
+import type { BuildJob, PollJob, PublishJob, RecurringJob, S3Job, StartupJob } from './types';
 import { QueueName } from './types';
 import { env } from '$env/dynamic/private';
 import OTEL from '$lib/otel';
@@ -129,8 +121,6 @@ function createQueues() {
   const Builds = new Queue<BuildJob>(QueueName.Builds, getQueueConfig());
   /** Queue for S3 jobs */
   const S3 = new Queue<S3Job>(QueueName.S3, getQueueConfig());
-  /** Queue for miscellaneous jobs in BuildEngine such as Product and Project Creation */
-  const Projects = new Queue<ProjectJob>(QueueName.Projects, getQueueConfig());
   /** Queue for Product Publishing  */
   const Releases = new Queue<PublishJob>(QueueName.Releases, getQueueConfig());
   /** Queue for jobs that poll BuildEngine, such as checking the status of a build */
@@ -142,7 +132,6 @@ function createQueues() {
   return {
     Builds,
     S3,
-    Projects,
     Releases,
     Polling,
     SystemStartup,

src/lib/server/bullmq/types.ts

@@ -19,7 +19,6 @@ export const RepeatEveryMinute: RepeatOptions = {
 export enum QueueName {
   Builds = 'Builds',
   S3 = 'S3',
-  Projects = 'Projects',
   Releases = 'Releases',
   Polling = 'Polling',
   System_Startup = 'System (Startup)',
@@ -33,8 +32,6 @@ export enum JobType {
   // Polling Jobs
   Poll_Build = 'Check Product Build',
   Poll_Release = 'Check Product Release',
-  // Project Jobs
-  Project_Create = 'Create Project',
   // Publishing Jobs
   Release_Product = 'Release Product',
   Release_Cancel = 'Cancel Release',
@@ -75,13 +72,6 @@ export namespace Polling {
   }
 }
 
-export namespace Project {
-  export interface Create {
-    type: JobType.Project_Create;
-    projectId: number;
-  }
-}
-
 export namespace Release {
   export interface Product {
     type: JobType.Release_Product;
@@ -123,7 +113,6 @@ export type BuildJob = JobTypeMap[JobType.Build_Product | JobType.Build_Cancel];
 export type S3Job = JobTypeMap[JobType.S3_CopyArtifacts | JobType.S3_CopyError];
 export type PublishJob = JobTypeMap[JobType.Release_Product | JobType.Release_Cancel];
 export type PollJob = JobTypeMap[JobType.Poll_Build | JobType.Poll_Release];
-export type ProjectJob = JobTypeMap[JobType.Project_Create];
 export type StartupJob = JobTypeMap[
   | JobType.System_CreateCodeBuildProject
   | JobType.System_RefreshAppVersions];
@@ -134,7 +123,6 @@ export type JobTypeMap = {
   [JobType.Build_Cancel]: Build.Cancel;
   [JobType.Poll_Build]: Polling.Build;
   [JobType.Poll_Release]: Polling.Release;
-  [JobType.Project_Create]: Project.Create;
   [JobType.Release_Product]: Release.Product;
   [JobType.Release_Cancel]: Release.Cancel;
   [JobType.S3_CopyArtifacts]: S3.CopyArtifacts;

src/lib/server/job-executors/index.ts

@@ -1,6 +1,5 @@
 export * as Build from './build';
 export * as Polling from './polling';
-export * as Project from './project';
 export * as Release from './release';
 export * as S3 from './s3';
 export * as System from './system';

src/lib/server/job-executors/project.ts

@@ -25,7 +25,7 @@ const projectSchema = v.strictObject({
 export const POST: RequestHandler = async ({ request, locals }) => {
   const parsed = v.safeParse(projectSchema, await request.json());
   if (!parsed.success) return ErrorResponse(400, JSON.stringify(v.flatten(parsed.issues)));
-  // TODO enqueue project creation job
+
   const withoutStorage = { ...parsed.output, storage_type: undefined };
   const project = await prisma.project.create({
     data: {
@@ -54,7 +54,7 @@ export const POST: RequestHandler = async ({ request, locals }) => {
     })
   );
 };
-// TODO create bucket???
+
 function getS3Folder(
   project: Prisma.projectGetPayload<{
     select: {