iptv-org-mirror/iptv
1
0
Fork 0
mirror of https://github.com/iptv-org/iptv.git synced 2025-05-14 11:00:03 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions

Update validate.ts

Browse source
This commit is contained in:
freearhey 2025-05-12 12:24:39 +03:00
parent f8a4eab5e3
commit 3c84179eb6
1 changed files with 4 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

8
scripts/commands/playlist/validate.ts
View file

@ -1,7 +1,7 @@
import { Logger, Storage, Collection, Dictionary } from '@freearhey/core' import { Logger, Storage, Collection, Dictionary } from '@freearhey/core'
import { DataLoader, DataProcessor, PlaylistParser } from '../../core' import { DataLoader, DataProcessor, PlaylistParser } from '../../core'
import { DataProcessorData } from '../../types/dataProcessor' import { DataProcessorData } from '../../types/dataProcessor'
import { DATA_DIR, STREAMS_DIR } from '../../constants' import { DATA_DIR, ROOT_DIR } from '../../constants'
import { DataLoaderData } from '../../types/dataLoader' import { DataLoaderData } from '../../types/dataLoader'
import { BlocklistRecord, Stream } from '../../models' import { BlocklistRecord, Stream } from '../../models'
import { program } from 'commander' import { program } from 'commander'
@ -30,13 +30,13 @@ async function main() {
}: DataProcessorData = processor.process(data) }: DataProcessorData = processor.process(data)
logger.info('loading streams...') logger.info('loading streams...')
const streamsStorage = new Storage(STREAMS_DIR) const rootStorage = new Storage(ROOT_DIR)
const parser = new PlaylistParser({ const parser = new PlaylistParser({
storage: streamsStorage, storage: rootStorage,
channelsKeyById, channelsKeyById,
feedsGroupedByChannelId feedsGroupedByChannelId
}) })
const files = program.args.length ? program.args : await streamsStorage.list('**/*.m3u') const files = program.args.length ? program.args : await rootStorage.list('streams/**/*.m3u')
const streams = await parser.parse(files) const streams = await parser.parse(files)
logger.info(`found ${streams.count()} streams`) logger.info(`found ${streams.count()} streams`)