<reponame>sofa-framework/issofa
"""a readline console module (unix only). 

<EMAIL>

the module starts a subprocess for the readline console and
communicates through pipes (prompt/cmd).

the console is polled through a timer, which depends on PySide.
"""

from select import select
import os
import sys
import signal


if __name__ == '__main__':

    import readline

    # prompt input stream
    fd_in = int(sys.argv[1])    
    file_in = os.fdopen( fd_in )

    # cmd output stream
    fd_out = int(sys.argv[2])
    file_out = os.fdopen( fd_out, 'w' )

    # some helpers
    def send(data):
        file_out.write(data + '\n')
        file_out.flush()

    def recv():
        while True:
            res = file_in.readline().rstrip('\n')
            read, _, _ = select([ file_in ], [], [], 0)
            if not read: return res

            
    class History:
        """readline history safe open/close"""
        
        def __init__(self, filename):
            self.filename = os.path.expanduser( filename )

        def __enter__(self):
            try:
                readline.read_history_file(self.filename)
                # print 'loaded console history from', self.filename
            except IOError:
                pass
            return self

        def __exit__(self, type, value, traceback):
            readline.write_history_file( self.filename )

    def cleanup(*args):
        print('console cleanup')
        os.system('stty sane')


    for sig in [signal.SIGQUIT,
                signal.SIGTERM,
                signal.SIGILL,
                signal.SIGSEGV]:
            
        old = signal.getsignal(sig)

        def new(*args):
            cleanup()
            signal.signal(sig, old)
            os.kill(os.getpid(), sig)
            
        signal.signal(sig, new)
    
    
    # main loop
    try:
        with History( "~/.sofa-console" ):
            print 'console started'
            while True:
                send( raw_input( recv() ) )

    except KeyboardInterrupt:
        print 'console exited (SIGINT)'
    except EOFError:
        ppid = os.getppid()
        try:
            os.kill(os.getppid(), signal.SIGTERM)
            print 'console exited (EOF), terminating parent process'
        except OSError:
            pass

        
        
else:

    import subprocess
    import code
    import atexit


    _cleanup = None

    def _register( c ):
        global _cleanup
        if _cleanup: _cleanup()

        _cleanup = c


    class Console(code.InteractiveConsole):

        def __init__(self, locals = None, timeout = 100):
            """
            python interpreter taking input from console subprocess
            
            scope is provided through 'locals' (usually: locals() or globals())

            'timeout' (in milliseconds) sets how often is the console polled.
            """
            
            code.InteractiveConsole.__init__(self, locals)

            if timeout >= 0:
                def callback():
                    self.poll()

                from PySide import QtCore
                
                self.timer = QtCore.QTimer()
                self.timer.timeout.connect( callback )
                self.timer.start( timeout )

                _register( lambda: self.timer.stop() )

        # execute next command, blocks on console input
        def next(self):
            line = recv()
            data = '>>> '

            if self.push( line ):
                data = '... '

            send( data )

        # convenience
        def poll(self):
            if ready(): self.next()


    # send prompt to indicate we are ready
    def send(data):
        prompt_out.write(data + '\n')
        prompt_out.flush()
            
    # receive command line
    def recv():
        res = cmd_in.readline()
        if res: return res.rstrip('\n')
        return res

    # is there any available command ?
    def ready():
        read, _, _ = select([ cmd_in ], [], [], 0)
        return read


    # communication pipes
    prompt = os.pipe() 
    cmd = os.pipe()

    # subprocess with in/out fd, and forwarding stdin
    sub = subprocess.Popen(['python', __file__,
                            str(prompt[0]), str(cmd[1])],
                           stdin = sys.stdin)

    # open the tubes !
    prompt_out = os.fdopen(prompt[1], 'w')
    cmd_in = os.fdopen(cmd[0], 'r')

    # we're ready
    send('>>> ')
    
        
    # def cleanup(*args):
    #     print('console cleanup')
    #     os.system('stty sane')

    # def exit(*args):
    #     print 'exit'
    #     cleanup()

    # sys.exit(0) forces cleanup *from python* before the gui
    # closes. otherwise pyside causes segfault on python finalize.
    def handler(*args):
        sub.terminate()
        sub.wait()
        sys.exit(0)
        
    from PySide import QtCore
    app = QtCore.QCoreApplication.instance()
    app.aboutToQuit.connect( handler )

    # import atexit
    # atexit.register( handler )
    
    # import atexit
    # atexit.register(  exit )
    
    # for sig in [signal.SIGSEGV, signal.SIGILL]:
    #     old = signal.getsignal(sig)
        
    #     def h(*args):
    #         print args
    #         sub.terminate()
    #         signal.signal(sig, old)
    #         os.kill(os.getpid(), sig)
            
    #     signal.signal(sig, h)
 

"""a readline console module (unix only). 

<EMAIL>

the module starts a subprocess for the readline console and
communicates through pipes (prompt/cmd).

the console is polled through a timer, which depends on PySide.
"""

from select import select
import os
import sys
import signal


if __name__ == '__main__':

    import readline

    # prompt input stream
    fd_in = int(sys.argv[1])    
    file_in = os.fdopen( fd_in )

    # cmd output stream
    fd_out = int(sys.argv[2])
    file_out = os.fdopen( fd_out, 'w' )

    # some helpers
    def send(data):
        file_out.write(data + '\n')
        file_out.flush()

    def recv():
        while True:
            res = file_in.readline().rstrip('\n')
            read, _, _ = select([ file_in ], [], [], 0)
            if not read: return res

            
    class History:
        """readline history safe open/close"""
        
        def __init__(self, filename):
            self.filename = os.path.expanduser( filename )

        def __enter__(self):
            try:
                readline.read_history_file(self.filename)
                # print 'loaded console history from', self.filename
            except IOError:
                pass
            return self

        def __exit__(self, type, value, traceback):
            readline.write_history_file( self.filename )

    def cleanup(*args):
        print('console cleanup')
        os.system('stty sane')


    for sig in [signal.SIGQUIT,
                signal.SIGTERM,
                signal.SIGILL,
                signal.SIGSEGV]:
            
        old = signal.getsignal(sig)

        def new(*args):
            cleanup()
            signal.signal(sig, old)
            os.kill(os.getpid(), sig)
            
        signal.signal(sig, new)
    
    
    # main loop
    try:
        with History( "~/.sofa-console" ):
            print 'console started'
            while True:
                send( raw_input( recv() ) )

    except KeyboardInterrupt:
        print 'console exited (SIGINT)'
    except EOFError:
        ppid = os.getppid()
        try:
            os.kill(os.getppid(), signal.SIGTERM)
            print 'console exited (EOF), terminating parent process'
        except OSError:
            pass

        
        
else:

    import subprocess
    import code
    import atexit


    _cleanup = None

    def _register( c ):
        global _cleanup
        if _cleanup: _cleanup()

        _cleanup = c


    class Console(code.InteractiveConsole):

        def __init__(self, locals = None, timeout = 100):
            """
            python interpreter taking input from console subprocess
            
            scope is provided through 'locals' (usually: locals() or globals())

            'timeout' (in milliseconds) sets how often is the console polled.
            """
            
            code.InteractiveConsole.__init__(self, locals)

            if timeout >= 0:
                def callback():
                    self.poll()

                from PySide import QtCore
                
                self.timer = QtCore.QTimer()
                self.timer.timeout.connect( callback )
                self.timer.start( timeout )

                _register( lambda: self.timer.stop() )

        # execute next command, blocks on console input
        def next(self):
            line = recv()
            data = '>>> '

            if self.push( line ):
                data = '... '

            send( data )

        # convenience
        def poll(self):
            if ready(): self.next()


    # send prompt to indicate we are ready
    def send(data):
        prompt_out.write(data + '\n')
        prompt_out.flush()
            
    # receive command line
    def recv():
        res = cmd_in.readline()
        if res: return res.rstrip('\n')
        return res

    # is there any available command ?
    def ready():
        read, _, _ = select([ cmd_in ], [], [], 0)
        return read


    # communication pipes
    prompt = os.pipe() 
    cmd = os.pipe()

    # subprocess with in/out fd, and forwarding stdin
    sub = subprocess.Popen(['python', __file__,
                            str(prompt[0]), str(cmd[1])],
                           stdin = sys.stdin)

    # open the tubes !
    prompt_out = os.fdopen(prompt[1], 'w')
    cmd_in = os.fdopen(cmd[0], 'r')

    # we're ready
    send('>>> ')
    
        
    # def cleanup(*args):
    #     print('console cleanup')
    #     os.system('stty sane')

    # def exit(*args):
    #     print 'exit'
    #     cleanup()

    # sys.exit(0) forces cleanup *from python* before the gui
    # closes. otherwise pyside causes segfault on python finalize.
    def handler(*args):
        sub.terminate()
        sub.wait()
        sys.exit(0)
        
    from PySide import QtCore
    app = QtCore.QCoreApplication.instance()
    app.aboutToQuit.connect( handler )

    # import atexit
    # atexit.register( handler )
    
    # import atexit
    # atexit.register(  exit )
    
    # for sig in [signal.SIGSEGV, signal.SIGILL]:
    #     old = signal.getsignal(sig)
        
    #     def h(*args):
    #         print args
    #         sub.terminate()
    #         signal.signal(sig, old)
    #         os.kill(os.getpid(), sig)
            
    #     signal.signal(sig, h)
a readline console module (unix only).   <EMAIL>  the module starts a subprocess for the readline console and communicates through pipes (prompt/cmd).  the console is polled through a timer, which depends on PySide. # prompt input stream # cmd output stream # some helpers readline history safe open/close # print 'loaded console history from', self.filename # main loop python interpreter taking input from console subprocess                          scope is provided through 'locals' (usually: locals() or globals())              'timeout' (in milliseconds) sets how often is the console polled. # execute next command, blocks on console input # convenience # send prompt to indicate we are ready # receive command line # is there any available command ? # communication pipes # subprocess with in/out fd, and forwarding stdin # open the tubes ! # we're ready # def cleanup(*args): #     print('console cleanup') #     os.system('stty sane') # def exit(*args): #     print 'exit' #     cleanup() # sys.exit(0) forces cleanup *from python* before the gui # closes. otherwise pyside causes segfault on python finalize. # import atexit # atexit.register( handler ) # import atexit # atexit.register(  exit ) # for sig in [signal.SIGSEGV, signal.SIGILL]: #     old = signal.getsignal(sig) #     def h(*args): #         print args #         sub.terminate() #         signal.signal(sig, old) #         os.kill(os.getpid(), sig) #     signal.signal(sig, h)