From 01c6fc40b35c1b99a0dd7b6469cd30b8451b83ea Mon Sep 17 00:00:00 2001
From: 2bc4 <119853089+2bc4@users.noreply.github.com>
Date: Sun, 11 Feb 2024 19:31:10 +0000
Subject: [PATCH] worker: fix playlist unchanged on startup

---
 src/hls/segment.rs | 7 +++++--
 src/worker.rs      | 2 +-
 2 files changed, 6 insertions(+), 3 deletions(-)

diff --git a/src/hls/segment.rs b/src/hls/segment.rs
index e401785..863caad 100644
--- a/src/hls/segment.rs
+++ b/src/hls/segment.rs
@@ -110,7 +110,7 @@ impl Handler {
         match self.playlist.segments() {
             SegmentRange::Partial(segments) => {
                 for segment in segments {
-                    debug!("Sending segment to worker:\n{:?}", segment);
+                    debug!("Sending segment to worker:\n{segment:?}");
                     match segment {
                         Segment::Normal(_, url)
                         | Segment::NextPrefetch(url)
@@ -128,7 +128,10 @@ impl Handler {
                 }
                 self.init = false;
 
-                match newest.context("Failed to find newest segment")? {
+                let newest = newest.context("Failed to find newest segment")?;
+                debug!("Sending newest segment to worker:\n{newest:?}");
+
+                match newest {
                     Segment::Normal(duration, url) => {
                         self.worker.url(url.clone())?;
                         duration.sleep(time.elapsed());
diff --git a/src/worker.rs b/src/worker.rs
index 6014bb7..90a938b 100644
--- a/src/worker.rs
+++ b/src/worker.rs
@@ -80,7 +80,7 @@ impl Worker {
     }
 
     pub fn sync_url(&mut self, url: Arc<Url>) -> Result<()> {
-        self.send(url, false)
+        self.send(url, true)
     }
 
     pub fn url(&mut self, url: Arc<Url>) -> Result<()> {