add mechanism to end last track properly

feelfreelinux · Oct 7, 2023 · babe2e9 · babe2e9
1 parent 691041e
commit babe2e9
Show file tree

Hide file tree

Showing 4 changed files with 16 additions and 0 deletions.
diff --git a/cspot/include/SpircHandler.h b/cspot/include/SpircHandler.h
@@ -53,6 +53,7 @@ class SpircHandler {
   bool nextSong();
 
   void notifyAudioReachedPlayback();
+  void notifyAudioEnded();
   void updatePositionMs(uint32_t position);
   void setRemoteVolume(int volume);
   void loadTrackFromURI(const std::string& uri);

diff --git a/cspot/src/SpircHandler.cpp b/cspot/src/SpircHandler.cpp
@@ -77,6 +77,12 @@ void SpircHandler::subscribeToMercury() {
 
 void SpircHandler::loadTrackFromURI(const std::string& uri) {}
 
+void SpircHandler::notifyAudioEnded() {
+    playbackState->updatePositionMs(0);
+    notify();
+    trackPlayer->resetState(true);
+}
+
 void SpircHandler::notifyAudioReachedPlayback() {
   int offset = 0;
 

diff --git a/targets/cli/CliPlayer.cpp b/targets/cli/CliPlayer.cpp
@@ -66,8 +66,12 @@ CliPlayer::CliPlayer(std::unique_ptr<AudioSink> sink,
             break;
           case cspot::SpircHandler::EventType::PLAYBACK_START:
             this->isPaused = true;
+            this->playlistEnd = false;
             this->centralAudioBuffer->clearBuffer();
             break;
+          case cspot::SpircHandler::EventType::DEPLETED:
+            this->playlistEnd = true;
+            break;
           default:
             break;
         }
@@ -102,6 +106,10 @@ void CliPlayer::runTask() {
       }
 
       if (!chunk || chunk->pcmSize == 0) {
+        if (this->playlistEnd) {
+            this->handler->notifyAudioEnded();
+            this->playlistEnd = false;
+        }
         BELL_SLEEP_MS(10);
         continue;
       } else {

diff --git a/targets/cli/CliPlayer.h b/targets/cli/CliPlayer.h
@@ -37,6 +37,7 @@ class CliPlayer : public bell::Task {
   std::atomic<bool> isPaused = true;
   std::atomic<bool> isRunning = true;
   std::mutex runningMutex;
+  std::atomic<bool> playlistEnd = false;
 
   void runTask() override;
 };