iptvnator/libs/ui/epg/src/lib/epg-program.utils.ts

import { format } from 'date-fns';
import type { EpgProgram } from '@iptvnator/shared/interfaces';
import { EPG_DATE_KEY_FORMAT } from './epg-date';

export function getProgramTimeMs(
    isoValue: string,
    timestampValue?: number | null
): number {
    if (Number.isFinite(timestampValue) && Number(timestampValue) > 0) {
        return Number(timestampValue) * 1000;
    }

    return Date.parse(isoValue);
}

export function getProgramDateKey(
    isoValue: string,
    timestampValue?: number | null
): string {
    const programTimeMs = getProgramTimeMs(isoValue, timestampValue);

    if (!Number.isFinite(programTimeMs)) {
        return '';
    }

    return format(new Date(programTimeMs), EPG_DATE_KEY_FORMAT);
}

export function deduplicateProgramsByTimeSlot(
    programs: EpgProgram[]
): EpgProgram[] {
    const programsByTimeSlot = new Map<string, EpgProgram>();

    for (const program of programs) {
        const timeSlotKey = buildProgramTimeSlotKey(program);
        const existingProgram = programsByTimeSlot.get(timeSlotKey);

        programsByTimeSlot.set(
            timeSlotKey,
            existingProgram
                ? selectMoreInformativeProgram(existingProgram, program)
                : program
        );
    }

    return Array.from(programsByTimeSlot.values());
}

export function areProgramsSame(
    left: EpgProgram,
    right: EpgProgram
): boolean {
    return (
        (left.channel ?? '') === (right.channel ?? '') &&
        getProgramTimeMs(left.start, left.startTimestamp) ===
            getProgramTimeMs(right.start, right.startTimestamp) &&
        getProgramTimeMs(left.stop, left.stopTimestamp) ===
            getProgramTimeMs(right.stop, right.stopTimestamp)
    );
}

function buildProgramTimeSlotKey(program: EpgProgram): string {
    return [
        getProgramTimeMs(program.start, program.startTimestamp),
        getProgramTimeMs(program.stop, program.stopTimestamp),
    ].join('|');
}

function selectMoreInformativeProgram(
    existingProgram: EpgProgram,
    candidateProgram: EpgProgram
): EpgProgram {
    return getProgramMetadataScore(candidateProgram) >
        getProgramMetadataScore(existingProgram)
        ? candidateProgram
        : existingProgram;
}

function getProgramMetadataScore(program: EpgProgram): number {
    return (
        getTextScore(program.desc) * 8 +
        getTextScore(program.category) * 4 +
        getTextScore(program.iconUrl) * 2 +
        getTextScore(program.rating) * 2 +
        getTextScore(program.episodeNum) * 2 +
        getTextScore(program.title)
    );
}

function getTextScore(value: string | null | undefined): number {
    return value?.trim() ? 1 : 0;
}