Merge a90f452f0d into 10081a2276

2025-12-17 09:17:16 +01:00 · 2025-12-17 09:17:16 +01:00 · 214f47797c
commit 214f47797c
parent 10081a2276 a90f452f0d
1 changed files with 122 additions and 0 deletions
--- a/src/extractor/StreamWish.ts
+++ b/src/extractor/StreamWish.ts
@ -0,0 +1,122 @@
+import { Context, Format, Meta, UrlResult } from '../types';
+import { buildMediaFlowProxyExtractorStreamUrl } from '../utils';
+import { Extractor } from './Extractor';
+
+/** @see https://github.com/Gujal00/ResolveURL/blob/master/script.module.resolveurl/lib/resolveurl/plugins/streamwish.py */
+export class StreamWish extends Extractor {
+  public readonly id = 'StreamWish';
+  public readonly label = 'StreamWish(MFP)';
+
+  public override viaMediaFlowProxy = true;
+
+  private readonly domains = [
+    'streamwish.com', 'streamwish.to', 'ajmidyad.sbs', 'khadhnayad.sbs', 'yadmalik.sbs',
+    'hayaatieadhab.sbs', 'kharabnahs.sbs', 'atabkhha.sbs', 'atabknha.sbs', 'atabknhk.sbs',
+    'atabknhs.sbs', 'abkrzkr.sbs', 'abkrzkz.sbs', 'wishembed.pro', 'mwish.pro', 'strmwis.xyz',
+    'awish.pro', 'dwish.pro', 'vidmoviesb.xyz', 'embedwish.com', 'cilootv.store', 'uqloads.xyz',
+    'tuktukcinema.store', 'doodporn.xyz', 'ankrzkz.sbs', 'volvovideo.top', 'streamwish.site',
+    'wishfast.top', 'ankrznm.sbs', 'sfastwish.com', 'eghjrutf.sbs', 'eghzrutw.sbs', 'guxhag.com',
+    'playembed.online', 'egsyxurh.sbs', 'egtpgrvh.sbs', 'flaswish.com', 'obeywish.com',
+    'cdnwish.com', 'javsw.me', 'cinemathek.online', 'trgsfjll.sbs', 'fsdcmo.sbs', 'hailindihg.com',
+    'anime4low.sbs', 'mohahhda.site', 'ma2d.store', 'dancima.shop', 'swhoi.com', 'aiavh.com',
+    'gsfqzmqu.sbs', 'jodwish.com', 'swdyu.com', 'strwish.com', 'asnwish.com', 'kravaxxa.com',
+    'wishonly.site', 'playerwish.com', 'katomen.store', 'hlswish.com', 'streamwish.fun',
+    'swishsrv.com', 'iplayerhls.com', 'hlsflast.com', '4yftwvrdz7.sbs', 'ghbrisk.com',
+    'hgbazooka.com', 'eb8gfmjn71.sbs', 'cybervynx.com', 'edbrdl7pab.sbs', 'stbhg.click',
+    'dhcplay.com', 'strwish.xyz', 'gradehgplus.com', 'tryzendm.com', 'hglink.to', 'dumbalag.com',
+    'haxloppd.com', 'davioad.com', 'uasopt.com',
+  ];
+
+  private readonly dmcaHosts = [
+    'hgplaycdn.com', 'habetar.com', 'yuguaab.com',
+    'guxhag.com', 'auvexiug.com', 'xenolyzb.com',
+  ];
+
+  private readonly ruleHosts = [
+    'dhcplay.com', 'hglink.to', 'test.hglink.to',
+    'wish-redirect.aiavh.com',
+  ];
+
+  private readonly mainHosts = [
+    'kravaxxa.com', 'davioad.com', 'haxloppd.com',
+    'tryzendm.com', 'dumbalag.com',
+  ];
+
+  public supports(_ctx: Context, url: URL): boolean {
+    return this.domains.some(d => url.host.includes(d));
+  }
+
+  public override normalize(url: URL): URL {
+    return new URL(url.href.replace('/f/', '/e/').replace('/d/', '/e/'));
+  }
+
+  private rand<T>(arr: T[]): T {
+    if (arr.length === 0) {
+      throw new Error('rand(): empty array');
+    }
+
+    const index = Math.floor(Math.random() * arr.length);
+    const value = arr[index];
+
+    if (value === undefined) {
+      throw new Error('rand(): unexpected undefined');
+    }
+
+    return value;
+  }
+
+  private getMediaId(path: string): string {
+    const m = path.match(/\/(?:e|f|d)\/([^/?#]+)/);
+    const id = m?.[1];
+
+    if (!id) {
+      throw new Error('StreamWish: Invalid media ID');
+    }
+
+    return id;
+  }
+
+  private rewrite(url: URL): URL {
+    const mediaId = this.getMediaId(url.pathname);
+
+    const finalHost = this.ruleHosts.includes(url.host)
+      ? this.rand(this.mainHosts)
+      : this.rand(this.dmcaHosts);
+
+    return new URL(`https://${finalHost}/e/${mediaId}`);
+  }
+
+  protected async extractInternal(
+    ctx: Context,
+    url: URL,
+    meta: Meta,
+    originalUrl?: URL,
+  ): Promise<UrlResult[]> {
+    const normalized = this.normalize(url);
+    const rewritten = this.rewrite(normalized);
+
+    const headers = {
+      Referer: meta.referer ?? originalUrl?.href ?? rewritten.href,
+    };
+
+    const proxyUrl = await buildMediaFlowProxyExtractorStreamUrl(
+      ctx,
+      this.fetcher,
+      this.id,
+      rewritten,
+      headers,
+    );
+
+    return [
+      {
+        url: proxyUrl,
+        format: Format.hls,
+        label: this.label,
+        sourceId: this.id,
+        ttl: this.ttl,
+        requestHeaders: headers,
+        meta,
+      },
+    ];
+  }
+}