fixup! Add emulator support

Author: ckaraneen

pybpodapi/bpod/bpod_base.py

@@ -295,6 +295,7 @@ def run_state_machine(self, sma):
         # create a list of executed states
         state_change_indexes = []
 
+        pause_task = False
         # flags used to stop a trial (or all trials)
         interrupt_task = False
         kill_task = False
@@ -306,7 +307,7 @@ def run_state_machine(self, sma):
             if self.stdin is not None:
                 inline = self.stdin.readline()
                 if inline is not None:
-                    interrupt_task, kill_task = self.handle_inline(inline, sma)
+                    pause_task, interrupt_task, kill_task = self.handle_inline(inline, sma)
             #####################################################
 
             # read commands from a net socket ###################
@@ -315,8 +316,10 @@ def run_state_machine(self, sma):
 
                 if inline is not None:
                     inline = inline.decode().strip()
-                    interrupt_task, kill_task = self.handle_inline(inline, sma)
+                    pause_task, interrupt_task, kill_task = self.handle_inline(inline, sma)
             #####################################################
+            if pause_task:
+                continue
 
             opcode, data = None, None
             if self._emulator:
@@ -352,19 +355,31 @@ def run_state_machine(self, sma):
         return not interrupt_task
 
     def handle_inline(self, inline, sma):
+        pause_task = False
         interrupt_task = False
         kill_task = False
         if inline.startswith('pause-trial'):
-            self.pause()
+            if self._emulator is None:
+                self.pause()
+            else:
+                pause_task = True
         elif inline.startswith('resume-trial'):
-            self.resume()
+            if self._emulator is None:
+                self.resume()
+            else:
+                pause_task = False
         elif inline.startswith('stop-trial'):
-            self.stop_trial()
+            if self._emulator is None:
+                self.stop_trial()
+            else:
+                interrupt_task = True
         elif inline.startswith('close'):
-            self.stop_trial()
+            if self._emulator is None:
+                self.stop_trial()
             interrupt_task = True
         elif inline.startswith('kill'):
-            self.stop_trial()
+            if self._emulator is None:
+                self.stop_trial()
             interrupt_task = kill_task = True
         elif inline.startswith('SoftCode'):
             softcode = int(inline[-1]) - 1
@@ -395,7 +410,7 @@ def handle_inline(self, inline, sma):
                 final_msg.append(int(x))
             self.load_message(module_index, final_msg)
 
-        return interrupt_task, kill_task
+        return pause_task, interrupt_task, kill_task
 
     def load_serial_message(self, serial_channel, message_ID, serial_message):
         """