- implementing recording (no monitoring at the moment)

  for mplayer and vlc
- zero size recordings will be deleted when player stops

Author: s-n-g

pyradio/player.py

@@ -620,6 +620,12 @@ def _is_in_playback_token(self, a_string):
                 return True
         return False
 
+    def _clear_empty_mkv(self):
+        if self.recording > 0 and self.recording_filename:
+            if os.path.exists(self.recording_filename):
+                if os.path.getsize(self.recording_filename) == 0:
+                    os.remove(self.recording_filename)
+
     def updateStatus(self, *args):
         stop = args[0]
         process = args[1]
@@ -649,7 +655,7 @@ def updateStatus(self, *args):
                     continue
                 subsystemOut = subsystemOut.strip()
                 subsystemOut = subsystemOut.replace('\r', '').replace('\n', '')
-                logger.error('DE subsystemOut = "{0}"'.format(subsystemOut))
+                # logger.error('DE subsystemOut = "{0}"'.format(subsystemOut))
 
                 if self.oldUserInput['Input'] != subsystemOut:
                     if (logger.isEnabledFor(logging.DEBUG)):
@@ -836,7 +842,10 @@ def updateStatus(self, *args):
                         if detect_if_player_exited():
                             if logger.isEnabledFor(logging.INFO):
                                 logger.info('----==== player disappeared! ====----')
-                            stop_player(from_update_thread=True)
+                            stop_player(
+                                from_update_thread=True,
+                                player_disappeared=True
+                            )
                         else:
                             if logger.isEnabledFor(logging.INFO):
                                 logger.info('Crash detection is off; waiting to timeout')
@@ -845,12 +854,16 @@ def updateStatus(self, *args):
                     if detect_if_player_exited():
                         if logger.isEnabledFor(logging.INFO):
                             logger.info('----==== player disappeared! ====----')
-                        stop_player(from_update_thread=True)
+                        stop_player(
+                            from_update_thread=True,
+                            player_disappeared = True
+                        )
                     else:
                         if logger.isEnabledFor(logging.INFO):
                             logger.info('Crash detection is off; waiting to timeout')
         if (logger.isEnabledFor(logging.INFO)):
             logger.info('updateStatus thread stopped.')
+        self._clear_empty_mkv()
 
     def updateMPVStatus(self, *args):
         stop = args[0]
@@ -953,6 +966,7 @@ def updateMPVStatus(self, *args):
                     logger.info('Crash detection is off; waiting to timeout')
         if (logger.isEnabledFor(logging.INFO)):
             logger.info('MPV updateStatus thread stopped.')
+        self._clear_empty_mkv()
 
     def _close_pipe(self, sock):
         if platform.startswith('win'):
@@ -1174,6 +1188,7 @@ def do_crash_detection(detect_if_player_exited, stop):
             fp.close()
         except:
             pass
+        self._clear_empty_mkv()
 
     def _request_mpv_info_data(self, sock):
         with self.status_update_lock:
@@ -2340,17 +2355,20 @@ def _buildStartOpts(self, streamUrl, playList=False):
         if self.USE_PROFILE == -1:
             self.USE_PROFILE = self._configHasProfile()
 
-        if self.USE_PROFILE == 1:
-            opts.append('-profile')
-            opts.append(self.profile_name)
-            if (logger.isEnabledFor(logging.INFO)):
-                logger.info('Using profile: "[{}]"'.format(self.profile_name))
+        if self._recording == self.RECORD_WITH_SILENCE:
+            opts.append('--profile=silent')
         else:
-            if (logger.isEnabledFor(logging.INFO)):
-                if self.USE_PROFILE == 0:
-                    logger.info('Profile "[{}]" not found in config file!!!'.format(self.profile_name))
-                else:
-                    logger.info('No usable profile found')
+            if self.USE_PROFILE == 1:
+                opts.append('-profile')
+                opts.append(self.profile_name)
+                if (logger.isEnabledFor(logging.INFO)):
+                    logger.info('Using profile: "[{}]"'.format(self.profile_name))
+            else:
+                if (logger.isEnabledFor(logging.INFO)):
+                    if self.USE_PROFILE == 0:
+                        logger.info('Profile "[{}]" not found in config file!!!'.format(self.profile_name))
+                    else:
+                        logger.info('No usable profile found')
 
         if playList:
             opts.append('-playlist')
@@ -2366,6 +2384,14 @@ def _buildStartOpts(self, streamUrl, playList=False):
         #opts.append('-dumpfile')
         #opts.append('/home/spiros/.config/pyradio/recordings/rec.mkv')
         ## opts.append(r'C:\Users\Spiros\AppData\Roaming\pyradio\recordings\rec.mkv')
+        logger.error('\n\nself._recording = {}'.format(self._recording))
+        if self._recording > 0:
+            self.recording_filename = self.getrecording_filename(self.name, '.mkv')
+            opts.append('-dumpstream')
+            opts.append('-dumpfile')
+            opts.append(self.recording_filename)
+            if logger.isEnabledFor(logging.DEBUG):
+                logger.debug('---=== Starting Recording: "{}" ===---',format(self.recording_filename))
         return opts
 
     def _mute(self):
@@ -2608,6 +2634,14 @@ def _buildStartOpts(self, streamUrl, playList=False):
         #opts.append('--sout')
         #opts.append('file/ts:/home/spiros/.config/pyradio/recordings/rec.mkv')
         ## opts.append(r'file/ts:C:\Users\Spiros\AppData\Roaming\pyradio\recordings\rec.mkv')
+        logger.error('\n\nself._recording = {}'.format(self._recording))
+        if self._recording > 0:
+            self.recording_filename = self.getrecording_filename(self.name, '.mkv')
+            opts.append('--sout')
+            opts.append(r'file/ts:' + self.recording_filename)
+            opts.append(self.recording_filename)
+            if logger.isEnabledFor(logging.DEBUG):
+                logger.debug('---=== Starting Recording: "{}" ===---',format(self.recording_filename))
         return opts
 
     def _mute(self):

pyradio/radio.py

@@ -3335,6 +3335,7 @@ def _show_extra_commands_help(self):
                      r      ||R|ename current playlist.
                      C      ||C|lear all registers.
                      u      |Show |U|nnamed Register.
+                     o      ||O|pen  config dir in file manager.
 
                     |Any other key exits current mode.
                   '''
@@ -3348,6 +3349,7 @@ def _show_extra_commands_help(self):
                          c      |Clear |c|urrent register.
                          C      ||C|lear all registers.
                          u      |Show |U|nnamed Register.
+                         o      ||O|pen  config dir in file manager.
 
                         |Any other key exits current mode.
                        '''
@@ -3356,6 +3358,7 @@ def _show_extra_commands_help(self):
                          p      ||P|aste to current playlist.
                          r      ||R|ename current playlist.
                          u      |Show |U|nnamed Register.
+                         o      ||O|pen  config dir in file manager.
 
                         |Any other key exits current mode.
                        '''
@@ -4470,6 +4473,7 @@ def _show_recording_status_in_header(
         from_header_update=False,
         player_disappeared=False
     ):
+        logger.error('\n\n')
         if self._limited_height_mode or \
                 self._limited_width_mode:
             return
@@ -4497,6 +4501,7 @@ def _show_recording_status_in_header(
             self.outerBodyWin.addstr(w_header, curses.color_pair(4))
             self.outerBodyWin.addstr(']', curses.color_pair(13))
             if player_disappeared:
+                logger.error('with refreshBody')
                 self.refreshBody()
 
     def _open_playlist(self, a_url=None):
@@ -8610,17 +8615,17 @@ def keypress(self, char):
             if self.ws.operation_mode == self.ws.NORMAL_MODE:
                 if char == ord('|'):
                     self._reset_status_bar_right()
-                    if self.player.PLAYER_NAME == 'mpv':
-                        self.player.recording = 1 if self.player.recording == 0 else 0
-                        if self.player.recording > 0:
-                            if self.player.isPlaying():
-                                self.player.already_playing = True
-                            else:
-                                self.player.already_playing = False
+                    # if self.player.PLAYER_NAME == 'mpv':
+                    self.player.recording = 1 if self.player.recording == 0 else 0
+                    if self.player.recording > 0:
+                        if self.player.isPlaying():
+                            self.player.already_playing = True
                         else:
                             self.player.already_playing = False
-                        self._show_recording_status_in_header()
-                        self._show_recording_toggle_window()
+                    else:
+                        self.player.already_playing = False
+                    self._show_recording_status_in_header()
+                    self._show_recording_toggle_window()
 
                 elif char == curses.ascii.BEL:
                     ''' ^G - show groups '''