fix: packageAfter for transcode job

superstreamerapp · Oct 23, 2024 · 7e3c7a8 · 7e3c7a8
1 parent 686a64d
commit 7e3c7a8
Show file tree

Hide file tree

Showing 3 changed files with 10 additions and 2 deletions.
diff --git a/packages/app/index.html b/packages/app/index.html
@@ -1,5 +1,5 @@
 <!doctype html>
-<html lang="en">
+<html class="dark" lang="en">
   <head>
     <meta charset="UTF-8" />
     <meta name="viewport" content="width=device-width, initial-scale=1.0" />

diff --git a/packages/artisan/src/consumer/workers/transcode.ts b/packages/artisan/src/consumer/workers/transcode.ts
@@ -5,6 +5,7 @@ import { ffprobeQueue, ffmpegQueue } from "../../producer";
 import { uploadJson } from "../s3";
 import { assert } from "../../assert";
 import { getDefaultAudioBitrate, getDefaultVideoBitrate } from "../../defaults";
+import { addPackageJob } from "../../producer";
 import type { Input, PartialInput, Stream, PartialStream } from "../../types";
 import type { Job } from "bullmq";
 import type { FfprobeResult } from "./ffprobe";
@@ -62,6 +63,14 @@ export const transcodeCallback: WorkerCallback<
 
       case Step.Meta: {
         await handleStepMeta(job, token);
+
+        if (job.data.packageAfter) {
+          await addPackageJob({
+            assetId: job.data.assetId,
+            tag: job.data.tag,
+          });
+        }
+
         await job.updateData({
           ...job.data,
           step: Step.Finish,

diff --git a/packages/stitcher/src/vast.ts b/packages/stitcher/src/vast.ts
@@ -15,7 +15,6 @@ export type AdMedia = {
 
 export async function getAdMediasFromVast(adBreak: VmapAdBreak) {
   const adMedias = await getAdMedias(adBreak);
-
   const result: AdMedia[] = [];
 
   for (const adMedia of adMedias) {