forked from jellyfin/jellyfin-chromecast
-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Create new class for handling message commands
- Loading branch information
1 parent
48b3be3
commit 4372e2b
Showing
2 changed files
with
186 additions
and
62 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,173 @@ | ||
| import { | ||
| translateItems, | ||
| shuffle, | ||
| instantMix, | ||
| isPlaying, | ||
| playNextItem, | ||
| playPreviousItem, | ||
| setAudioStreamIndex, | ||
| setSubtitleStreamIndex, | ||
| seek, | ||
| stop | ||
| } from "./maincontroller"; | ||
|
|
||
| import { getReportingParams } from "../helpers"; | ||
|
|
||
| import { factory as jellyfinActions } from "./jellyfinactions"; | ||
|
|
||
| export class commandHandler { | ||
| constructor(castContext, playerManager) { | ||
| this.castContext = castContext; | ||
| this.playerManager = playerManager; | ||
|
|
||
| this.supportedCommands = { | ||
| PlayNext: this.playNextHandler, | ||
| PlayLast: this.playLastHandler, | ||
| Shuffle: this.shuffleHandler, | ||
| InstantMix: this.instantMixHandler, | ||
| DisplayContent: this.displayContentHandler, | ||
| NextTrack: this.nextTrackHandler, | ||
| PreviousTrack: this.previousTrackHandler, | ||
| SetAudioStreamIndex: this.setAudioStreamIndexHandler, | ||
| SetSubtitleStreamIndex: this.setSubtitleStreamIndexHandler, | ||
| VolumeUp: this.VolumeUpHandler, | ||
| VolumeDown: this.VolumeDownHandler, | ||
| ToggleMute: this.ToggleMuteHandler, | ||
| Identify: this.IdentifyHandler, | ||
| SetVolume: this.SetVolumeHandler, | ||
| Seek: this.SeekHandler, | ||
| Mute: this.MuteHandler, | ||
| Unmute: this.MuteHandler, | ||
| Stop: this.StopHandler, | ||
| PlayPause: this.PlayPauseHandler, | ||
| Pause: this.PauseHandler, | ||
| SetRepeatMode: this.SetRepeatModeHandler, | ||
| Unpause: this.UnpauseHandler | ||
| }; | ||
| } | ||
|
|
||
| playNextHandler(data) { | ||
| translateItems(data, data.options, data.options.items, data.command); | ||
| } | ||
|
|
||
| playLastHandler(data) { | ||
| translateItems(data, data.options, data.options.items, data.command); | ||
| } | ||
|
|
||
| shuffleHandler(data) { | ||
| shuffle(data, data.options, data.options.items[0]); | ||
| } | ||
|
|
||
| instantMixHandler(data) { | ||
| instantMix(data, data.options, data.options.items[0]); | ||
| } | ||
|
|
||
| displayContentHandler(data) { | ||
| if (!isPlaying()) { | ||
| jellyfinActions.displayItem($scope, data.serverAddress, data.accessToken, data.userId, data.options.ItemId); | ||
| } | ||
| } | ||
|
|
||
| nextTrackHandler() { | ||
| if (window.playlist && window.currentPlaylistIndex < window.playlist.length - 1) { | ||
| playNextItem({}, true); | ||
| } | ||
| } | ||
|
|
||
| previousTrackHandler() { | ||
| if (window.playlist && window.currentPlaylistIndex > 0) { | ||
| playPreviousItem({}); | ||
| } | ||
| } | ||
|
|
||
| setAudioStreamIndexHandler(data) { | ||
| setAudioStreamIndex($scope, data.options.index); | ||
| } | ||
|
|
||
| setSubtitleStreamIndexHandler(data) { | ||
| setSubtitleStreamIndex($scope, data.options.index, data.serverAddress); | ||
| } | ||
|
|
||
| // VolumeUp, VolumeDown and ToggleMute commands seem to be handled on the sender in the current implementation. | ||
| // From what I can tell there's no convenient way for the receiver to get its own volume. | ||
| // We should probably remove these commands in the future. | ||
| VolumeUpHandler() { | ||
| console.log("VolumeUp handler not implemented"); | ||
| } | ||
|
|
||
| VolumeDownHandler() { | ||
| console.log("VolumeDown handler not implemented"); | ||
| } | ||
|
|
||
| ToggleMuteHandler() { | ||
| console.log("ToggleMute handler not implemented"); | ||
| } | ||
|
|
||
| SetVolumeHandler(data) { | ||
| // Scale 0-100 | ||
| this.castContext.setSystemVolumeLevel(data.options.volume / 100); | ||
| } | ||
|
|
||
| IdentifyHandler(data) { | ||
| if (!isPlaying()) { | ||
| jellyfinActions.displayUserInfo($scope, data.serverAddress, data.accessToken, data.userId); | ||
| } else { | ||
| // When a client connects send back the initial device state (volume etc) via a playbackstop message | ||
| jellyfinActions.reportPlaybackProgress($scope, getReportingParams($scope), true, "playbackstop"); | ||
| } | ||
| } | ||
|
|
||
| SeekHandler(data) { | ||
| seek(data.options.position * 10000000); | ||
| } | ||
|
|
||
| MuteHandler() { | ||
| this.castContext.setSystemVolumeMuted(true); | ||
| } | ||
|
|
||
| UnmuteHandler() { | ||
| this.castContext.setSystemVolumeMuted(false); | ||
| } | ||
|
|
||
| StopHandler() { | ||
| stop(); | ||
| } | ||
|
|
||
| PlayPauseHandler() { | ||
| if (this.playerManager.getPlayerState() === cast.framework.messages.PlayerState.PAUSED) { | ||
| this.playerManager.play(); | ||
| } else { | ||
| this.playerManager.pause(); | ||
| } | ||
| } | ||
|
|
||
| PauseHandler() { | ||
| this.playerManager.pause(); | ||
| } | ||
|
|
||
| SetRepeatModeHandler(data) { | ||
| window.repeatMode = data.options.RepeatMode; | ||
| window.reportEventType = 'repeatmodechange'; | ||
| } | ||
|
|
||
| UnpauseHandler() { | ||
| this.playerManager.play(); | ||
| } | ||
|
|
||
| // We should avoid using a defaulthandler that has a purpose other than informing the dev/user | ||
| // Currently all unhandled commands will be treated as play commands. | ||
| defaultHandler(data) { | ||
| translateItems(data, data.options, data.options.items, 'play'); | ||
| } | ||
|
|
||
| processMessage(data, command) { | ||
| const commandHandler = this.supportedCommands[command]; | ||
| if (typeof commandHandler === "function") { | ||
| console.debug(`Command "${command}" received. Calling identified handler.`); | ||
| (commandHandler.bind(this))(data); | ||
| } else { | ||
| console.debug(`Command "${command}" received. Calling default handler.`); | ||
| this.defaultHandler(data); | ||
| } | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters