import {
  getLogger,
  SagaIterator,
  stripNamespacePrefix,
  VideoPlaybackEventNames,
  VideoPlaybackAction,
} from '@signalwire/core'
import { RoomSession } from '../RoomSession'
import { VideoCallWorkerParams } from './videoCallingWorker'
import { RoomSessionPlayback } from '../RoomSessionPlayback'

export const videoPlaybackWorker = function* (
  options: VideoCallWorkerParams<VideoPlaybackAction>
): SagaIterator {
  getLogger().trace('videoPlaybackWorker started')
  const {
    action: { type, payload },
    instanceMap: { get, set, remove },
  } = options

  const roomSessionInstance = get<RoomSession>(payload.room_session_id)
  if (!roomSessionInstance) {
    throw new Error('Missing room session instance for playback')
  }

  let playbackInstance = get<RoomSessionPlayback>(payload.playback.id)
  if (!playbackInstance) {
    playbackInstance = new RoomSessionPlayback({
      roomSession: roomSessionInstance,
      payload,
    })
  } else {
    playbackInstance.setPayload(payload)
  }
  set<RoomSessionPlayback>(payload.playback.id, playbackInstance)

  const event = stripNamespacePrefix(type) as VideoPlaybackEventNames

  switch (type) {
    case 'video.playback.started':
    case 'video.playback.updated':
      roomSessionInstance._emit(event, playbackInstance)
      playbackInstance._emit(event, playbackInstance)
      break
    case 'video.playback.ended':
      roomSessionInstance._emit(event, playbackInstance)
      playbackInstance._emit(event, playbackInstance)
      remove<RoomSessionPlayback>(payload.playback.id)
      break
    default:
      break
  }

  getLogger().trace('videoPlaybackWorker ended')
}