ffplayout/stores/playlist.ts

import dayjs from 'dayjs'
import utc from 'dayjs/plugin/utc.js'
import timezone from 'dayjs/plugin/timezone.js'

import { defineStore } from 'pinia'

dayjs.extend(utc)
dayjs.extend(timezone)

const { processPlaylist } = playlistOperations()

export const usePlaylist = defineStore('playlist', {
    state: () => ({
        playlist: [] as PlaylistItem[],
        isLoading: true,
        listDate: dayjs().format('YYYY-MM-DD'),
        progressValue: 0,
        currentClip: '',
        currentClipIndex: 0,
        currentClipTitle: null as null | string,
        currentClipStart: 0,
        currentClipDuration: 0,
        currentClipIn: 0,
        currentClipOut: 0,
        ingestRuns: false,
        elapsedSec: 0,
        shift: 0,
        playoutIsRunning: false,
        last_channel: 0,
        firstLoad: true,
    }),

    getters: {},
    actions: {
        async getPlaylist(date: string) {
            const { $_, $i18n } = useNuxtApp()
            const authStore = useAuth()
            const configStore = useConfig()
            const indexStore = useIndex()
            const channel = configStore.configChannel[configStore.configID].id

            await $fetch<Playlist>(`/api/playlist/${channel}?date=${date}`, {
                method: 'GET',
                headers: authStore.authHeader,
            })
                .then((data) => {
                    if (data.program) {
                        const programData = processPlaylist(date, data.program, false)

                        if (
                            channel === this.last_channel &&
                            this.playlist.length > 0 &&
                            programData.length > 0 &&
                            (this.playlist[0].date === date || configStore.playout.playlist.infinit) &&
                            $_.differenceWith(this.playlist, programData, (a, b) => {
                                return $_.isEqual($_.omit(a, ['uid']), $_.omit(b, ['uid']))
                            }).length > 0
                        ) {
                            indexStore.msgAlert('warning', $i18n.t('player.unsavedProgram'), 3)
                        } else {
                            this.playlist = programData ?? []
                        }
                    }
                })
                .catch((e) => {
                    if (e.status >= 400) {
                        indexStore.msgAlert('error', e.data, 5)
                    } else if (
                        channel === this.last_channel &&
                        this.playlist.length > 0 &&
                        this.playlist[0].date === date
                    ) {
                        indexStore.msgAlert('warning', $i18n.t('player.unsavedProgram'), 3)
                    } else {
                        this.playlist = []
                    }
                })

            this.last_channel = channel
        },

        setStatus(item: PlayoutStatus) {
            this.playoutIsRunning = true
            this.currentClip = item.media.source
            this.currentClipIn = item.media.in
            this.currentClipOut = item.media.out
            this.currentClipDuration = item.media.duration
            this.currentClipTitle = item.media.title ?? null
            this.currentClipIndex = item.index
            this.elapsedSec = item.elapsed
            this.ingestRuns = item.ingest
            this.shift = item.shift

            this.progressValue = (this.elapsedSec * 100) / this.currentClipOut
        },
    },
})