From 82c4257a97c7783906efdaf4bb856ac399a58627 Mon Sep 17 00:00:00 2001
From: Guillaume Pellerin <guillaume.pellerin@free.fr>
Date: Wed, 31 Jan 2024 18:17:59 +0100
Subject: [PATCH] use rb read / write, remove channel.sync (fix relay against
 libshout 2.4.6)

---
 deefuzzer/player.py   | 5 ++---
 deefuzzer/recorder.py | 2 +-
 deefuzzer/relay.py    | 2 +-
 deefuzzer/station.py  | 2 --
 4 files changed, 4 insertions(+), 7 deletions(-)

diff --git a/deefuzzer/player.py b/deefuzzer/player.py
index 7705e54..cff49d9 100644
--- a/deefuzzer/player.py
+++ b/deefuzzer/player.py
@@ -47,7 +47,6 @@ class Player:
         self.relay.set_url(self.url)
         self.relay.open()
         self.relay.start()
-        self.queue = self.relay.queue
 
     def stop_relay(self):
         self.relay.close()
@@ -86,11 +85,11 @@ class Player:
     def relay_read(self):
         """Read a distant media through its URL"""
         while True:
-            self.sub_chunk = self.queue.get(self.sub_buffer_size)
+            self.sub_chunk = self.relay.queue.get(self.sub_buffer_size)
             if not self.sub_chunk:
                 break
             yield self.sub_chunk
-            self.queue.task_done()
+            self.relay.queue.task_done()
         self.sub_chunk = 0
 
 
diff --git a/deefuzzer/recorder.py b/deefuzzer/recorder.py
index 187e06c..8e131b7 100644
--- a/deefuzzer/recorder.py
+++ b/deefuzzer/recorder.py
@@ -34,7 +34,7 @@ class Recorder:
 
     def open(self, filename):
         self.filename = filename
-        self.media = open(self.path + os.sep + self.filename, 'w')
+        self.media = open(self.path + os.sep + self.filename, 'wb')
 
     def write(self, chunk):
         try:
diff --git a/deefuzzer/relay.py b/deefuzzer/relay.py
index ab96384..afe6989 100644
--- a/deefuzzer/relay.py
+++ b/deefuzzer/relay.py
@@ -54,7 +54,7 @@ class Relay(Thread):
             if self.isopen:
                 self.chunk = self.stream.read(self.sub_buffer_size)
                 self.queue.put_nowait(self.chunk)
-#                print self.queue.qsize()
+                # print(self.queue.qsize())
             else:
                 if self.stream:
                     self.stream.close()
diff --git a/deefuzzer/station.py b/deefuzzer/station.py
index be9fea7..a42f4d5 100644
--- a/deefuzzer/station.py
+++ b/deefuzzer/station.py
@@ -982,7 +982,6 @@ class Station(Thread):
                         try:
                             # Send the chunk to the stream
                             self.channel.send(self.chunk)
-                            self.channel.sync()
                             self.is_alive = True
                         except:
                             self._err('could not send the buffer')
@@ -997,7 +996,6 @@ class Station(Thread):
                                 self.channel.set_metadata({'song': self.song, 'charset': 'utf8', })
                                 self._info('channel restarted')
                                 self.channel.send(self.chunk)
-                                self.channel.sync()
                                 self.is_alive = True
                             except:
                                 self._err('could not send data after restarting the channel')
-- 
2.47.3