Module gonioanalysis.tkgui.run_measurement

class MeasurementWindow:
    '''
    Sets the manalyser to do the movement measurements and
    opens a window showing the progress.

    Because this sets stdout to a StringIO temporalily, it's best
    to run this in a subprocess.
    '''

    def __init__(self, tk_root, thread_targets, title='', callback_on_exit=None):
        '''
        tk_root         Tkinter root object, needed for scheduling events with after-method
        thread_targets  Callables
        '''
        self.root = tk_root
        self.title = title
        self.callback_on_exit = callback_on_exit

        self.i_target = -1
        self.thread_targets = thread_targets
        self.processes = []

        self.all_run = False
        self.exit = False
        self.run()


    def run(self):
        self.top = tk.Toplevel()
        self.top.title(self.title)

        self.oldout = sys.stdout
        sys.stdout = io.StringIO()

        BufferShower(self.top, sys.stdout).grid()
        self.cancel_button = tk.Button(self.top, text='Cancel', command=self.on_cancel)
        self.cancel_button.grid()
        
        self.check_finished()


    def _run_next_target(self):
        '''
        Set next manalyser to work or return False if none left.
        '''
        self.i_target += 1
        
        if self.i_target == len(self.thread_targets):
            return False

        self.stop_event = threading.Event()
        
        p = threading.Thread(target=self.thread_targets[self.i_target],
                args=[self.stop_event,])

        p.start()
        self.processes.append(p)
    
        return True
    

    def alives(self):
        return [process.is_alive() for process in self.processes]


    def check_finished(self):
        '''
        Check if all the threads are finished and if there are more targets to run.
        Reschedule every 1000 ms.
        '''
        if not self.exit:
            if not any(self.alives()):
                targets_left = self._run_next_target()
            else:
                targets_left = True

            if targets_left:
                self.root.after(1000, self.check_finished)
            else:
                self.cancel_button.config(text='Ok')
                self.all_run = True


    def on_cancel(self):
        self.exit = True
        
        # Calcelled, only send thread signal to stop
        self.stop_event.set()
        
        if self.all_run:
            self.callback_on_exit()

        if not all(self.alives()):
            self.top.destroy()
            sys.stdout = self.oldout
        else:
            self.root.after(1000, self.on_cancel)