repod/src/store/player.js

import axios from '@nextcloud/axios'
import { format } from 'date-fns'
import { generateUrl } from '@nextcloud/router'
import router from '../router.js'
import store from './main.js'

const audio = new Audio()
audio.ondurationchange = () => store.commit('player/duration', audio.duration)
audio.onended = () => store.dispatch('player/stop')
audio.onloadeddata = () => store.commit('player/loaded', true)
audio.onplay = () => store.commit('player/paused', false)
audio.onpause = () => store.commit('player/paused', true)
audio.onseeked = () => store.commit('player/currentTime', audio.currentTime)
audio.ontimeupdate = () => store.commit('player/currentTime', audio.currentTime)
audio.onvolumechange = () => store.commit('player/volume', audio.volume)

export const player = {
	namespaced: true,
	state: {
		currentTime: null,
		duration: null,
		episode: null,
		loaded: false,
		paused: null,
		podcastUrl: null,
		volume: 1,
	},
	mutations: {
		action: (state, action) => {
			state.episode.action = action

			if (action && action.position && action.position < action.total) {
				audio.currentTime = action.position
			}
		},
		currentTime: (state, currentTime) => {
			state.currentTime = currentTime
		},
		duration: (state, duration) => {
			state.duration = duration
		},
		episode: (state, episode) => {
			state.episode = episode

			if (episode) {
				state.podcastUrl = atob(router.currentRoute.params.url)
				audio.src = episode.episodeUrl
				audio.load()
				audio.play()

				if (episode.action && episode.action.position && episode.action.position < episode.action.total) {
					audio.currentTime = episode.action.position
				}
			} else {
				state.loaded = false
				state.podcastUrl = null
				audio.src = ''
			}
		},
		loaded: (state, loaded) => {
			state.loaded = loaded
		},
		paused: (state, paused) => {
			state.paused = paused
		},
		volume: (state, volume) => {
			state.volume = volume
		},
	},
	actions: {
		load: async (context, episode) => {
			context.commit('episode', episode)
			try {
				const action = await axios.get(generateUrl('/apps/repod/episodes/action?url={url}', { url: episode.episodeUrl }))
				context.commit('action', action.data)
			} catch {}
		},
		pause: (context) => {
			audio.pause()
			context.dispatch('time')
		},
		play: () => audio.play(),
		seek: (context, currentTime) => {
			audio.currentTime = currentTime
			context.dispatch('time')
		},
		stop: (context) => {
			context.dispatch('pause')
			context.commit('episode', null)
			context.commit('action', null)
		},
		time: async (context) => axios.post(generateUrl('/apps/gpoddersync/episode_action/create'), [{
			podcast: context.state.podcastUrl,
			episode: context.state.episode.episodeUrl,
			guid: context.state.episode.episodeGuid,
			action: 'play',
			timestamp: format(new Date(), 'yyyy-MM-dd\'T\'HH:mm:ss'),
			started: Math.round(context.state.action ? context.state.action.started : 0),
			position: Math.round(audio.currentTime),
			total: Math.round(audio.duration),
		}]),
		volume: (context, volume) => {
			audio.volume = volume
		},
	},
}