Creepso/webstreamr-github
1
0
Fork 0
Code Issues 27 Pull requests 7 Projects Releases 240 Packages Wiki Activity Actions

refactor: introduce createSources() analogue to createExtractors()

Browse source
This commit is contained in:
WebStreamr 2025-07-21 14:39:13 +00:00
parent 3d76b0a7b7
commit 453cc747a1
No known key found for this signature in database
4 changed files with 57 additions and 46 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

31
src/index.ts
View file

@ -5,7 +5,7 @@ import { v4 as uuidv4 } from 'uuid';
import winston from 'winston';
import { ConfigureController, ManifestController, StreamController } from './controller';
import { createExtractors, ExtractorRegistry } from './extractor';
import { CineHDPlus, Cuevana, Eurostreaming, Frembed, FrenchCloud, HomeCine, KinoGer, MegaKino, MeineCloud, MostraGuarda, Movix, PrimeWire, Soaper, Source, StreamKiste, VerHdLink, VidSrc, VixSrc } from './source';
import { createSources } from './source';
import { contextFromRequestAndResponse, envGet, envIsProd, Fetcher, StreamResolver } from './utils';
console.log = console.warn = console.error = console.info = console.debug = () => { /* disable in favor of logger */ };
@ -31,31 +31,8 @@ if (process.env['ALL_PROXY']) {
}
const fetcher = new Fetcher(logger);
const sources: Source[] = [
// multi
new VixSrc(fetcher),
// EN
new PrimeWire(fetcher),
new Soaper(fetcher),
new VidSrc(fetcher),
// ES / MX
new CineHDPlus(fetcher),
new Cuevana(fetcher),
new HomeCine(fetcher),
new VerHdLink(fetcher),
// DE
new KinoGer(fetcher),
new MegaKino(fetcher),
new MeineCloud(fetcher),
new StreamKiste(fetcher),
// FR
new Frembed(fetcher),
new FrenchCloud(fetcher),
new Movix(fetcher),
// IT
new Eurostreaming(fetcher),
new MostraGuarda(fetcher),
];
const sources = createSources(fetcher);
const extractors = createExtractors(fetcher);
const addon = express();
addon.set('trust proxy', true);
@ -76,7 +53,7 @@ addon.use((_req: Request, res: Response, next: NextFunction) => {
addon.use('/', (new ConfigureController(sources)).router);
addon.use('/', (new ManifestController(sources)).router);
const extractorRegistry = new ExtractorRegistry(logger, createExtractors(fetcher));
const extractorRegistry = new ExtractorRegistry(logger, extractors);
const streamResolver = new StreamResolver(logger, extractorRegistry);
addon.use('/', (new StreamController(logger, sources, streamResolver)).router);

63
src/source/index.ts
View file

@ -1,18 +1,47 @@
export * from './CineHDPlus';
export * from './Cuevana';
export * from './Eurostreaming';
export * from './Frembed';
export * from './FrenchCloud';
export * from './HomeCine';
export * from './KinoGer';
export * from './MegaKino';
export * from './MeineCloud';
export * from './MostraGuarda';
export * from './Movix';
export * from './PrimeWire';
export * from './Soaper';
export * from './StreamKiste';
export * from './VerHdLink';
export * from './VidSrc';
export * from './VixSrc';
import { Fetcher } from '../utils';
import { CineHDPlus } from './CineHDPlus';
import { Cuevana } from './Cuevana';
import { Eurostreaming } from './Eurostreaming';
import { Frembed } from './Frembed';
import { FrenchCloud } from './FrenchCloud';
import { HomeCine } from './HomeCine';
import { KinoGer } from './KinoGer';
import { MegaKino } from './MegaKino';
import { MeineCloud } from './MeineCloud';
import { MostraGuarda } from './MostraGuarda';
import { Movix } from './Movix';
import { PrimeWire } from './PrimeWire';
import { Soaper } from './Soaper';
import { StreamKiste } from './StreamKiste';
import { Source } from './types';
import { VerHdLink } from './VerHdLink';
import { VidSrc } from './VidSrc';
import { VixSrc } from './VixSrc';
export * from './types';
export const createSources = (fetcher: Fetcher): Source[] => [
// multi
new VixSrc(fetcher),
// EN
new PrimeWire(fetcher),
new Soaper(fetcher),
new VidSrc(fetcher),
// ES / MX
new CineHDPlus(fetcher),
new Cuevana(fetcher),
new HomeCine(fetcher),
new VerHdLink(fetcher),
// DE
new KinoGer(fetcher),
new MegaKino(fetcher),
new MeineCloud(fetcher),
new StreamKiste(fetcher),
// FR
new Frembed(fetcher),
new FrenchCloud(fetcher),
new Movix(fetcher),
// IT
new Eurostreaming(fetcher),
new MostraGuarda(fetcher),
];

4
src/utils/StreamResolver.test.ts
View file

@ -2,7 +2,9 @@ import { ContentType } from 'stremio-addon-sdk';
import winston from 'winston';
import { BlockedError, HttpError, NotFoundError, QueueIsFullError, TimeoutError, TooManyRequestsError, TooManyTimeoutsError } from '../error';
import { createExtractors, Extractor, ExtractorRegistry } from '../extractor';
import { MeineCloud, MostraGuarda, Source, SourceResult } from '../source';
import { Source, SourceResult } from '../source';
import { MeineCloud } from '../source/MeineCloud';
import { MostraGuarda } from '../source/MostraGuarda';
import { createTestContext } from '../test';
import { BlockedReason, CountryCode, Format, UrlResult } from '../types';
import { FetcherMock } from './FetcherMock';

5
src/utils/manifest.test.ts
View file

@ -1,4 +1,7 @@
import { MeineCloud, StreamKiste, VerHdLink, VixSrc } from '../source';
import { MeineCloud } from '../source/MeineCloud';
import { StreamKiste } from '../source/StreamKiste';
import { VerHdLink } from '../source/VerHdLink';
import { VixSrc } from '../source/VixSrc';
import { FetcherMock } from './FetcherMock';
import { buildManifest } from './manifest';