|
|
@@ -1,5 +1,7 @@
|
|
|
(ns tubo.player.events
|
|
|
(:require
|
|
|
+ [tubo.components.player :as player :refer [get-player-sources]]
|
|
|
+ [tubo.stream.views :as stream]
|
|
|
[tubo.utils :as utils]
|
|
|
[goog.object :as gobj]
|
|
|
[re-frame.core :as rf]
|
|
|
@@ -8,21 +10,24 @@
|
|
|
(rf/reg-fx
|
|
|
:volume
|
|
|
(fn [{:keys [player volume]}]
|
|
|
- (when (and @player (> (.-readyState @player) 0))
|
|
|
+ (when @player
|
|
|
(set! (.-volume @player) (/ volume 100)))))
|
|
|
|
|
|
(rf/reg-fx
|
|
|
:mute
|
|
|
(fn [{:keys [player muted?]}]
|
|
|
- (when (and @player (> (.-readyState @player) 0))
|
|
|
+ (when @player
|
|
|
(set! (.-muted @player) muted?))))
|
|
|
|
|
|
(rf/reg-fx
|
|
|
:src
|
|
|
(fn [{:keys [player src current-pos]}]
|
|
|
- (set! (.-src @player) src)
|
|
|
- (set! (.-onended @player)
|
|
|
- #(rf/dispatch [:queue/change-pos (inc current-pos)]))))
|
|
|
+ (set! (.-source @player) (clj->js src))))
|
|
|
+
|
|
|
+(rf/reg-fx
|
|
|
+ :loop
|
|
|
+ (fn [{:keys [player loop]}]
|
|
|
+ (set! (.-loop @player) loop)))
|
|
|
|
|
|
(rf/reg-fx
|
|
|
:current-time
|
|
|
@@ -30,73 +35,83 @@
|
|
|
(set! (.-currentTime @player) time)))
|
|
|
|
|
|
(rf/reg-event-fx
|
|
|
- :player/seek
|
|
|
+ :background-player/seek
|
|
|
[(rf/inject-cofx ::inject/sub [:player])]
|
|
|
(fn [{:keys [db player]} [_ time]]
|
|
|
- {:current-time {:time time :player player}}))
|
|
|
+ (when (:background-player/ready db)
|
|
|
+ {:current-time {:time time :player player}})))
|
|
|
+
|
|
|
+(rf/reg-event-fx
|
|
|
+ :main-player/seek
|
|
|
+ [(rf/inject-cofx ::inject/sub [:main-player])]
|
|
|
+ (fn [{:keys [db main-player]} [_ time]]
|
|
|
+ {:current-time {:time time :player main-player}}))
|
|
|
|
|
|
(rf/reg-fx
|
|
|
- :pause
|
|
|
+ :pause!
|
|
|
(fn [{:keys [paused? player]}]
|
|
|
- (when (and @player (> (.-readyState @player) 0))
|
|
|
- (if paused?
|
|
|
- (.play @player)
|
|
|
- (.pause @player)))))
|
|
|
+ (when @player
|
|
|
+ (set! (.-paused @player) paused?))))
|
|
|
|
|
|
(rf/reg-event-db
|
|
|
- :player/set-paused
|
|
|
+ :background-player/set-paused
|
|
|
(fn [db [_ val]]
|
|
|
(assoc db :paused val)))
|
|
|
|
|
|
(rf/reg-event-fx
|
|
|
- :player/pause
|
|
|
+ :background-player/pause
|
|
|
[(rf/inject-cofx ::inject/sub [:player])]
|
|
|
(fn [{:keys [db player]} [_ paused?]]
|
|
|
- {:pause {:paused? (not paused?)
|
|
|
- :player player}}))
|
|
|
+ {:pause! {:paused? paused?
|
|
|
+ :player player}
|
|
|
+ :db (assoc db :paused paused?)}))
|
|
|
|
|
|
(rf/reg-event-fx
|
|
|
- :player/stop
|
|
|
- (fn [{:keys [db]}]
|
|
|
- {:fx [[:dispatch [:player/pause true]]
|
|
|
- [:dispatch [:player/seek 0]]]}))
|
|
|
+ :main-player/pause
|
|
|
+ [(rf/inject-cofx ::inject/sub [:main-player])]
|
|
|
+ (fn [{:keys [db main-player]} [_ paused?]]
|
|
|
+ (when (:main-player/ready db)
|
|
|
+ {:pause! {:paused? paused?
|
|
|
+ :player main-player}})))
|
|
|
|
|
|
(rf/reg-event-fx
|
|
|
- :player/start-in-background
|
|
|
- [(rf/inject-cofx ::inject/sub [:player])
|
|
|
- (rf/inject-cofx ::inject/sub [:elapsed-time])]
|
|
|
- (fn [{:keys [db player]} _]
|
|
|
- {:fx [[:dispatch [:player/set-paused true]]
|
|
|
- [:dispatch [:player/pause false]]
|
|
|
- [:dispatch [:player/change-volume (:volume-level db) player]]]
|
|
|
- :db (assoc db :player-ready (and @player (> (.-readyState @player) 0)))}))
|
|
|
+ :background-player/play
|
|
|
+ [(rf/inject-cofx ::inject/sub [:elapsed-time])
|
|
|
+ (rf/inject-cofx ::inject/sub [:main-player])]
|
|
|
+ (fn [{:keys [db elapsed-time main-player]}]
|
|
|
+ {:fx [[:dispatch [:background-player/seek @elapsed-time]]
|
|
|
+ (when (and (:main-player/ready db) @main-player)
|
|
|
+ [:dispatch [:main-player/pause true]])]}))
|
|
|
|
|
|
-(rf/reg-fx
|
|
|
- :audio-poster-mode
|
|
|
- (fn [{:keys [player options]}]
|
|
|
- (.audioPosterMode
|
|
|
- @player
|
|
|
- (-> (filter #(= (:src %) (.src @player)) (:sources options))
|
|
|
- first
|
|
|
- :label
|
|
|
- (clojure.string/includes? "audio-only")))))
|
|
|
+(rf/reg-event-fx
|
|
|
+ :main-player/play
|
|
|
+ [(rf/inject-cofx ::inject/sub [:elapsed-time])
|
|
|
+ (rf/inject-cofx ::inject/sub [:player])]
|
|
|
+ (fn [{:keys [db elapsed-time player]}]
|
|
|
+ {:fx [(when (and (:background-player/ready db) @player)
|
|
|
+ [:dispatch [:background-player/pause true]])]}))
|
|
|
|
|
|
-(rf/reg-fx
|
|
|
- :slider-color
|
|
|
- (fn [{:keys [player color]}]
|
|
|
- (doseq [class [".vjs-play-progress" ".vjs-volume-level" ".vjs-slider-bar"]]
|
|
|
- (set! (.. (.$ (.getChild ^videojs/VideoJsPlayer @player "ControlBar") class) -style -background) color))))
|
|
|
+(rf/reg-event-fx
|
|
|
+ :background-player/stop
|
|
|
+ (fn [{:keys [db]}]
|
|
|
+ {:fx [[:dispatch [:background-player/pause true]]
|
|
|
+ [:dispatch [:background-player/seek 0]]]}))
|
|
|
|
|
|
(rf/reg-event-fx
|
|
|
- :player/set-slider-color
|
|
|
- (fn [_ [_ !player service-id]]
|
|
|
- {:slider-color {:player !player :color (utils/get-service-color service-id)}}))
|
|
|
+ :background-player/start
|
|
|
+ [(rf/inject-cofx ::inject/sub [:player])
|
|
|
+ (rf/inject-cofx ::inject/sub [:elapsed-time])]
|
|
|
+ (fn [{:keys [db player elapsed-time]} _]
|
|
|
+ {:fx [[:dispatch [:background-player/pause false]]
|
|
|
+ [:dispatch [:player/change-volume (:volume-level db) player]]]}))
|
|
|
|
|
|
(rf/reg-event-fx
|
|
|
- :player/start-in-main
|
|
|
+ :main-player/start
|
|
|
[(rf/inject-cofx ::inject/sub [:elapsed-time])]
|
|
|
- (fn [{:keys [db]} [_ !player options service-id]]
|
|
|
- {:fx [[:audio-poster-mode {:player !player :options options}]]}))
|
|
|
+ (fn [{:keys [db elapsed-time]} _]
|
|
|
+ {:fx [[:dispatch [:main-player/pause false]]
|
|
|
+ (when (and (:main-player/show db) (not (:background-player/ready db)))
|
|
|
+ [:dispatch [:main-player/seek @elapsed-time]])]}))
|
|
|
|
|
|
(rf/reg-fx
|
|
|
:media-session-metadata
|
|
|
@@ -114,13 +129,13 @@
|
|
|
#(.setPositionState js/navigator.mediaSession
|
|
|
{:duration (.-duration @player)
|
|
|
:playbackRate (.-playbackRate @player)
|
|
|
- :position (.-currentTime @player)})
|
|
|
+ :position current-time})
|
|
|
seek #(do (rf/dispatch [:seek %]) (update-position))
|
|
|
events
|
|
|
{"play" #(.play @player)
|
|
|
"pause" #(.pause @player)
|
|
|
- "previoustrack" #(rf/dispatch [:change-queue-pos (dec current-pos)])
|
|
|
- "nexttrack" #(rf/dispatch [:change-queue-pos (inc current-pos)])
|
|
|
+ "previoustrack" #(rf/dispatch [:queue/change-pos (dec current-pos)])
|
|
|
+ "nexttrack" #(rf/dispatch [:queue/change-pos (inc current-pos)])
|
|
|
"seekbackward" (fn [^js/navigator.MediaSessionActionDetails details]
|
|
|
(seek (- current-time (or (.-seekOffset details) 10))))
|
|
|
"seekforward" (fn [^js/navigator.MediaSessionActionDetails details]
|
|
|
@@ -140,7 +155,7 @@
|
|
|
:volume {:player player :volume value}}))
|
|
|
|
|
|
(rf/reg-event-fx
|
|
|
- :player/mute
|
|
|
+ :background-player/mute
|
|
|
[(rf/inject-cofx :store)]
|
|
|
(fn [{:keys [db store]} [_ value player]]
|
|
|
{:db (assoc db :muted value)
|
|
|
@@ -159,38 +174,71 @@
|
|
|
:store (assoc store :loop-playback loop-state)})))
|
|
|
|
|
|
(rf/reg-event-fx
|
|
|
- :player/dispose
|
|
|
+ :background-player/dispose
|
|
|
[(rf/inject-cofx :store)]
|
|
|
(fn [{:keys [db store]} _]
|
|
|
(let [remove-entries
|
|
|
(fn [elem]
|
|
|
(-> elem
|
|
|
- (update :show-background-player #(not %))
|
|
|
- (assoc :player-ready false)
|
|
|
+ (assoc :background-player/show false)
|
|
|
(assoc :queue [])
|
|
|
(assoc :queue-pos 0)))]
|
|
|
{:db (remove-entries db)
|
|
|
:store (remove-entries store)
|
|
|
- :fx [[:dispatch [:player/pause true]]
|
|
|
- [:dispatch [:player/seek 0]]]})))
|
|
|
+ :fx [[:dispatch [:background-player/pause true]]
|
|
|
+ [:dispatch [:background-player/seek 0]]]})))
|
|
|
+
|
|
|
+(rf/reg-event-db
|
|
|
+ :background-player/ready
|
|
|
+ (fn [db [_ ready]]
|
|
|
+ (assoc db :background-player/ready ready)))
|
|
|
+
|
|
|
+(rf/reg-event-db
|
|
|
+ :main-player/ready
|
|
|
+ (fn [db [_ ready]]
|
|
|
+ (assoc db :main-player/ready ready)))
|
|
|
|
|
|
(rf/reg-event-fx
|
|
|
:player/switch-to-background
|
|
|
[(rf/inject-cofx :store)]
|
|
|
- (fn [{:keys [db store]} [_ stream]]
|
|
|
+ (fn [{:keys [db store]} [_ stream notify?]]
|
|
|
(let [updated-db (update db :queue conj stream)
|
|
|
idx (.indexOf (:queue updated-db) stream)]
|
|
|
- {:db (-> updated-db
|
|
|
- (assoc :show-background-player true))
|
|
|
+ {:db (assoc updated-db :background-player/show (not (:main-player/show db)))
|
|
|
:store (-> store
|
|
|
- (assoc :show-background-player true)
|
|
|
+ (assoc :background-player/show (not (:main-player/show db)))
|
|
|
(assoc :queue (:queue updated-db)))
|
|
|
:fx [[:dispatch [:player/fetch-stream
|
|
|
(:url stream) idx (= (count (:queue db)) 0)]]
|
|
|
- (when-not (= (count (:queue db)) 0)
|
|
|
+ (when (and notify? (not (= (count (:queue db)) 0)))
|
|
|
[:dispatch [:notifications/add
|
|
|
- {:status-text (str "Added stream to queue")
|
|
|
- :failure :success}]])]})))
|
|
|
+ {:status-text "Added stream to queue"
|
|
|
+ :failure :info}]])]})))
|
|
|
+
|
|
|
+(rf/reg-event-fx
|
|
|
+ :player/show-main-player
|
|
|
+ (fn [{:keys [db]} [_ val]]
|
|
|
+ {:db (assoc db :main-player/show val)
|
|
|
+ :body-overflow val}))
|
|
|
+
|
|
|
+(rf/reg-event-fx
|
|
|
+ :player/switch-from-main
|
|
|
+ [(rf/inject-cofx :store)
|
|
|
+ (rf/inject-cofx ::inject/sub [:elapsed-time])]
|
|
|
+ (fn [{:keys [db store elapsed-time]} [_ stream]]
|
|
|
+ {:db (assoc db :background-player/show true)
|
|
|
+ :store (assoc store :background-player/show true)
|
|
|
+ :fx [[:dispatch [:player/show-main-player false]]
|
|
|
+ [:dispatch [:main-player/pause true]]]}))
|
|
|
+
|
|
|
+(rf/reg-event-fx
|
|
|
+ :player/switch-to-main
|
|
|
+ [(rf/inject-cofx :store)]
|
|
|
+ (fn [{:keys [db store]} [_ stream]]
|
|
|
+ {:fx [[:dispatch [:player/show-main-player true]]]
|
|
|
+ :db (assoc db :background-player/show false)
|
|
|
+ :store (assoc store :background-player/show false)
|
|
|
+ :scroll-to-top nil}))
|
|
|
|
|
|
(rf/reg-event-fx
|
|
|
:player/load-related-streams
|
|
|
@@ -203,49 +251,42 @@
|
|
|
[(rf/inject-cofx ::inject/sub [:player])]
|
|
|
(fn [{:keys [db player]} [_ idx play? res]]
|
|
|
(let [stream-res (js->clj res :keywordize-keys true)]
|
|
|
- {:db (assoc db :show-background-player-loading false)
|
|
|
- :fx (apply conj [[:dispatch [:queue/change-stream-source
|
|
|
- (-> stream-res :audio-streams first :content)
|
|
|
- idx]]]
|
|
|
- (when play?
|
|
|
- [[:src
|
|
|
- {:player player
|
|
|
- :src (-> stream-res :audio-streams first :content)
|
|
|
- :current-pos (:queue-pos db)}]
|
|
|
- [:media-session-metadata
|
|
|
+ {:db (assoc db :background-player/loading false)
|
|
|
+ :fx (apply conj [(when play? [:dispatch [:queue/change-stream stream-res idx]])]
|
|
|
+ (when (and (:background-player/ready db) play?)
|
|
|
+ [[:media-session-metadata
|
|
|
{:title (:name stream-res)
|
|
|
:artist (:uploader-name stream-res)
|
|
|
:artwork [{:src (:thumbnail-url stream-res)}]}]
|
|
|
[:media-session-handlers
|
|
|
{:current-pos (:queue-pos db)
|
|
|
- :player player}]]))})))
|
|
|
+ :player player}]]))})))
|
|
|
|
|
|
(rf/reg-event-fx
|
|
|
:player/bad-response
|
|
|
- (fn [{:keys [db]} [_ play? res]]
|
|
|
+ (fn [{:keys [db]} [_ idx play? res]]
|
|
|
{:db (assoc db
|
|
|
- :show-background-player-loading false
|
|
|
- :player-ready true)
|
|
|
+ :background-player/loading false)
|
|
|
:fx [[:dispatch [:bad-response res]]
|
|
|
(when play?
|
|
|
(if (> (-> db :queue count) 1)
|
|
|
- [:dispatch [:queue/change-pos (-> db :queue-pos inc)]]
|
|
|
- [:dispatch [:player/dispose]]))]}))
|
|
|
+ [:dispatch [:queue/change-pos (inc idx)]]
|
|
|
+ [:dispatch [:background-player/dispose]]))]}))
|
|
|
|
|
|
(rf/reg-event-fx
|
|
|
:player/fetch-related-streams
|
|
|
(fn [{:keys [db]} [_ url]]
|
|
|
{:fx [[:dispatch [:stream/fetch url
|
|
|
[:player/load-related-streams]] [:bad-response]]]
|
|
|
- :db (assoc db :show-background-player-loading true)}))
|
|
|
+ :db (assoc db :background-player/loading true)}))
|
|
|
|
|
|
(rf/reg-event-fx
|
|
|
:player/fetch-stream
|
|
|
(fn [{:keys [db]} [_ url idx play?]]
|
|
|
{:fx [[:dispatch [:stream/fetch url
|
|
|
[:player/load-stream idx play?]
|
|
|
- [:player/bad-response play?]]]]
|
|
|
- :db (assoc db :show-background-player-loading true)}))
|
|
|
+ [:player/bad-response idx play?]]]]
|
|
|
+ :db (assoc db :background-player/loading play?)}))
|
|
|
|
|
|
(rf/reg-event-fx
|
|
|
:player/start-radio
|
|
|
@@ -253,4 +294,13 @@
|
|
|
{:fx [[:dispatch [:player/switch-to-background stream]]
|
|
|
(when (not= (count (:queue db)) 0)
|
|
|
[:dispatch [:queue/change-pos (count (:queue db))]])
|
|
|
- [:dispatch [:player/fetch-related-streams (:url stream)]]]}))
|
|
|
+ [:dispatch [:player/fetch-related-streams (:url stream)]]
|
|
|
+ [:dispatch [:notifications/add
|
|
|
+ {:status-text "Started stream radio"
|
|
|
+ :failure :info}]]]}))
|
|
|
+
|
|
|
+(rf/reg-event-db
|
|
|
+ :main-player/toggle-layout
|
|
|
+ (fn [db [_ layout]]
|
|
|
+ (assoc-in db [:queue (:queue-pos db) layout]
|
|
|
+ (not (get-in db [:queue (:queue-pos db) layout])))))
|
Miguel Ángel Moreno