chore: Simplified test runner

packages/api/src/repositories/jobs.ts

@@ -1,17 +1,24 @@
 import {
   ffmpegQueue,
   ffprobeQueue,
-  flowProducer,
   outcomeQueue,
   packageQueue,
   pipelineQueue,
   transcodeQueue,
 } from "bolt";
-import { Job as RawJob } from "bullmq";
+import { FlowProducer, Job as RawJob } from "bullmq";
+import { env } from "../env";
 import { isRecordWithNumbers } from "../utils/type-guard";
 import type { Job } from "../types";
 import type { JobNode, JobState, Queue } from "bullmq";
 
+const flowProducer = new FlowProducer({
+  connection: {
+    host: env.REDIS_HOST,
+    port: env.REDIS_PORT,
+  },
+});
+
 const allQueus = [
   pipelineQueue,
   transcodeQueue,

packages/artisan/test/setup.ts

@@ -1,14 +1,9 @@
 import { mock } from "bun:test";
 
-// We're going to mock bolt entirely as we do not want job runners
-// to actually do work during tests.
-mock.module("bolt", () => ({
-  getChildren: () => [],
-  waitForChildren: () => Promise.resolve(),
-  outcomeQueue: undefined,
-  ffmpegQueue: undefined,
-  ffprobeQueue: undefined,
-  addToQueue: undefined,
+mock.module("bullmq", () => ({
+  Queue: class {},
+  Worker: class {},
+  WaitingChildrenError: class {},
 }));
 
 process.env = {

packages/bolt/src/add-to-queue.ts

@@ -1,12 +1,6 @@
 import { randomUUID } from "crypto";
-import { FlowProducer } from "bullmq";
-import { connection } from "./env";
 import type { Job, JobsOptions, Queue } from "bullmq";
 
-export const flowProducer = new FlowProducer({
-  connection,
-});
-
 export const DEFAULT_SEGMENT_SIZE = 2.24;
 
 export const DEFAULT_PACKAGE_NAME = "hls";

scripts/test.ts

@@ -1,6 +1,3 @@
 import { $ } from "bun";
-import { buildClientPackages } from "./devtools/client-packages";
-
-await buildClientPackages();
 
 await $`bun run --filter="*" test`;