fix(presets/mediafusion): override cache key via wrapper APi

Author: Viren070

packages/core/src/main/wrapper.ts

@@ -185,6 +185,7 @@ export class Wrapper {
         resource: 'manifest',
         type: 'manifest',
         id: 'manifest',
+        headers: this.addon.headers,
         options: this.addon.preset.options,
       }) || this.manifestUrl;
 
@@ -262,6 +263,7 @@ export class Wrapper {
         type,
         id,
         options: this.addon.preset.options,
+        headers: this.addon.headers,
       }) || this.buildResourceUrl('stream', type, id);
     const streamTtl = resolveTtl(
       appConfig.resources.cache.stream.ttl,
@@ -279,6 +281,7 @@ export class Wrapper {
         resource: 'stream',
         type,
         id,
+        headers: this.addon.headers,
         options: this.addon.preset.options,
       })
     );
@@ -348,6 +351,7 @@ export class Wrapper {
         type,
         id,
         options: this.addon.preset.options,
+        headers: this.addon.headers,
         extras,
       })
     );
@@ -386,6 +390,7 @@ export class Wrapper {
         resource: 'meta',
         type,
         id,
+        headers: this.addon.headers,
         options: this.addon.preset.options,
       })
     );
@@ -430,6 +435,7 @@ export class Wrapper {
         resource: 'subtitles',
         type,
         id,
+        headers: this.addon.headers,
         options: this.addon.preset.options,
       })
     );
@@ -461,6 +467,7 @@ export class Wrapper {
         type,
         id,
         options: this.addon.preset.options,
+        headers: this.addon.headers,
       })
     );
   }

packages/core/src/presets/mediafusion.ts

@@ -6,7 +6,7 @@ import {
   Stream,
   ParsedStream,
 } from '../db/index.js';
-import { baseOptions, Preset } from './preset.js';
+import { baseOptions, CacheKeyRequestOptions, Preset } from './preset.js';
 import { createLogger, getSimpleTextHash } from '../utils/index.js';
 import { constants, ServiceId } from '../utils/index.js';
 import { config as appConfig } from '../config/index.js';
@@ -407,6 +407,16 @@ export class MediaFusionPreset extends Preset {
     };
   }
 
+  public static getCacheKey(
+    options: CacheKeyRequestOptions
+  ): string | undefined {
+    const { headers } = options;
+    if (headers?.encoded_user_data) {
+      return getSimpleTextHash(headers.encoded_user_data);
+    }
+    return undefined;
+  }
+
   private static generateManifestUrl(
     options: Record<string, any>,
     encodedUserData: string
@@ -415,7 +425,7 @@ export class MediaFusionPreset extends Preset {
     if (url.endsWith('/manifest.json')) {
       return url;
     }
-    return `${url}/${getSimpleTextHash(encodedUserData)}/manifest.json`;
+    return `${url}/manifest.json`;
   }
 
   private static generateEncodedUserData(

packages/core/src/presets/preset.ts

@@ -105,6 +105,7 @@ export interface CacheKeyRequestOptions {
   type: string;
   id: string;
   options: Record<string, any>;
+  headers: Record<string, string> | undefined;
   extras?: string;
 }