import { Country, Stream, Playlist } from '../models' import { Collection, Storage, File } from '@freearhey/core' import { PUBLIC_DIR, EOL } from '../constants' import { Generator } from './generator' type CountriesGeneratorProps = { streams: Collection countries: Collection logFile: File } export class CountriesGenerator implements Generator { streams: Collection countries: Collection storage: Storage logFile: File constructor({ streams, countries, logFile }: CountriesGeneratorProps) { this.streams = streams.clone() this.countries = countries this.storage = new Storage(PUBLIC_DIR) this.logFile = logFile } async generate(): Promise { const streams = this.streams .orderBy((stream: Stream) => stream.getTitle()) .filter((stream: Stream) => stream.isSFW()) this.countries.forEach(async (country: Country) => { const countryStreams = streams.filter((stream: Stream) => stream.isBroadcastInCountry(country) ) if (countryStreams.isEmpty()) return const playlist = new Playlist(countryStreams, { public: true }) const filepath = `countries/${country.code.toLowerCase()}.m3u` await this.storage.save(filepath, playlist.toString()) this.logFile.append( JSON.stringify({ type: 'country', filepath, count: playlist.streams.count() }) + EOL ) }) const undefinedStreams = streams.filter((stream: Stream) => !stream.hasBroadcastArea()) const undefinedPlaylist = new Playlist(undefinedStreams, { public: true }) const undefinedFilepath = 'countries/undefined.m3u' await this.storage.save(undefinedFilepath, undefinedPlaylist.toString()) this.logFile.append( JSON.stringify({ type: 'country', filepath: undefinedFilepath, count: undefinedPlaylist.streams.count() }) + EOL ) } }