Changes from @arconamagi

switchio/apps/dtmf.py

@@ -38,7 +38,7 @@ def on_park(self, sess):
                 "Transmitting DTMF seq '{}' for session  '{}'"
                 .format(self.sequence, sess.uuid)
             )
-            sess.broadcast('playback::silence_stream://0')
+            sess.broadcast('playback::silence_stream://-1')
             sess.send_dtmf(''.join(map(str, self.sequence)), self.duration)
 
     @event_callback('DTMF')

switchio/apps/players.py

@@ -70,7 +70,7 @@ def prepost(
         self.rec_period = rec_period
         self.stereo = rec_stereo
         self.log = utils.get_logger(self.__class__.__name__)
-        self.silence = 'silence_stream://0'  # infinite silence stream
+        self.silence = 'silence_stream://-1'  # infinite silence stream
         self.iterations = iterations
         self.tail = 1.0
 

switchio/connection.py

@@ -299,6 +299,8 @@ def _handle_socket_data(event):
         body = event.get('Body') if event else None
         if not body:
             return False, None
+        else:
+            body = body.strip()
         if '-ERR' in body.splitlines()[-1]:
             raise utils.APIError(body)
         return True, body

switchio/handlers.py

@@ -170,8 +170,10 @@ def _handle_bj(self, e):
             resp = body.strip(ok + '\n')
 
         job = self.bg_jobs.get(job_uuid, None)
+        job_just_created = False
         if not job:
             job = Job(event=e)
+            job_just_created = True
         else:
             job.events.update(e)
 
@@ -187,8 +189,9 @@ def _handle_bj(self, e):
                     job.sess_uuid, str(body))
                 )
             job.fail(resp)  # fail the job
-            # always pop failed jobs
-            self.bg_jobs.pop(job_uuid)
+            if not job_just_created:
+                # always pop failed jobs
+                self.bg_jobs.pop(job_uuid)
             # append the id for later lookup and discard?
             self.failed_jobs[resp] += 1
             consumed = True