REDROOM

Navigation

Breadcrumbs

Create

Edit File Size: 2.71 KB

//lib/python3/dist-packages/twisted/conch/stdio.py

Text Base64

# -*- test-case-name: twisted.conch.test.test_manhole -*-
# Copyright (c) Twisted Matrix Laboratories.
# See LICENSE for details.

"""
Asynchronous local terminal input handling

@author: Jp Calderone
"""

import os
import sys
import termios
import tty

from twisted.conch.insults.insults import ServerProtocol
from twisted.conch.manhole import ColoredManhole
from twisted.internet import defer, protocol, reactor, stdio
from twisted.python import failure, log, reflect

class UnexpectedOutputError(Exception):
    pass

class TerminalProcessProtocol(protocol.ProcessProtocol):
    def __init__(self, proto):
        self.proto = proto
        self.onConnection = defer.Deferred()

def connectionMade(self):
        self.proto.makeConnection(self)
        self.onConnection.callback(None)
        self.onConnection = None

def write(self, data):
        """
        Write to the terminal.

@param data: Data to write.
        @type data: L{bytes}
        """
        self.transport.write(data)

def outReceived(self, data):
        """
        Receive data from the terminal.

@param data: Data received.
        @type data: L{bytes}
        """
        self.proto.dataReceived(data)

def errReceived(self, data):
        """
        Report an error.

@param data: Data to include in L{Failure}.
        @type data: L{bytes}
        """
        self.transport.loseConnection()
        if self.proto is not None:
            self.proto.connectionLost(failure.Failure(UnexpectedOutputError(data)))
            self.proto = None

def childConnectionLost(self, childFD):
        if self.proto is not None:
            self.proto.childConnectionLost(childFD)

def processEnded(self, reason):
        if self.proto is not None:
            self.proto.connectionLost(reason)
            self.proto = None

class ConsoleManhole(ColoredManhole):
    """
    A manhole protocol specifically for use with L{stdio.StandardIO}.
    """

def connectionLost(self, reason):
        """
        When the connection is lost, there is nothing more to do.  Stop the
        reactor so that the process can exit.
        """
        reactor.stop()

def runWithProtocol(klass):
    fd = sys.__stdin__.fileno()
    oldSettings = termios.tcgetattr(fd)
    tty.setraw(fd)
    try:
        stdio.StandardIO(ServerProtocol(klass))
        reactor.run()
    finally:
        termios.tcsetattr(fd, termios.TCSANOW, oldSettings)
        os.write(fd, b"\r\x1bc\r")

def main(argv=None):
    log.startLogging(open("child.log", "w"))

if argv is None:
        argv = sys.argv[1:]
    if argv:
        klass = reflect.namedClass(argv[0])
    else:
        klass = ConsoleManhole
    runWithProtocol(klass)

if __name__ == "__main__":
    main()

Exit & Reset Text mode: syntax highlighting auto-detects file type.

Name	Size	Perms	Modified	Actions
client DIR	-	drwxr-xr-x	2026-01-08 12:56:22	Edit Download recursive recursive
insults DIR	-	drwxr-xr-x	2026-01-08 12:56:22	Edit Download recursive recursive
newsfragments DIR	-	drwxr-xr-x	2026-01-08 12:55:41	Edit Download recursive recursive
openssh_compat DIR	-	drwxr-xr-x	2026-01-08 12:56:22	Edit Download recursive recursive
scripts DIR	-	drwxr-xr-x	2026-01-08 12:56:22	Edit Download recursive recursive
ssh DIR	-	drwxr-xr-x	2026-01-08 12:56:22	Edit Download recursive recursive
test DIR	-	drwxr-xr-x	2026-01-08 12:56:22	Edit Download recursive recursive
ui DIR	-	drwxr-xr-x	2026-01-08 12:56:22	Edit Download recursive recursive
__pycache__ DIR	-	drwxr-xr-x	2026-01-08 12:56:23	Edit Download recursive recursive
avatar.py	1.60 KB	lrw-r--r--	2024-08-27 10:30:39	Edit Download recursive recursive
checkers.py	21.41 KB	lrw-r--r--	2024-08-27 10:30:39	Edit Download recursive recursive
endpoints.py	29.26 KB	lrw-r--r--	2024-08-27 10:30:39	Edit Download recursive recursive
error.py	2.60 KB	lrw-r--r--	2024-08-27 10:30:39	Edit Download recursive recursive
interfaces.py	14.57 KB	lrw-r--r--	2024-08-27 10:30:39	Edit Download recursive recursive
ls.py	2.63 KB	lrw-r--r--	2024-08-27 10:30:39	Edit Download recursive recursive
manhole.py	12.08 KB	lrw-r--r--	2024-08-27 10:30:39	Edit Download recursive recursive
manhole_ssh.py	4.32 KB	lrw-r--r--	2024-08-27 10:30:39	Edit Download recursive recursive
manhole_tap.py	5.36 KB	lrw-r--r--	2024-08-27 10:30:39	Edit Download recursive recursive
mixin.py	1.34 KB	lrw-r--r--	2024-08-27 10:30:39	Edit Download recursive recursive
recvline.py	18.71 KB	lrw-r--r--	2024-08-27 10:30:39	Edit Download recursive recursive
stdio.py	2.71 KB	lrw-r--r--	2024-08-27 10:30:39	Edit Download recursive recursive
tap.py	3.12 KB	lrw-r--r--	2024-08-27 10:30:39	Edit Download recursive recursive
telnet.py	37.16 KB	lrw-r--r--	2024-08-27 10:30:39	Edit Download recursive recursive
ttymodes.py	2.14 KB	lrw-r--r--	2024-08-27 10:30:39	Edit Download recursive recursive
unix.py	16.67 KB	lrw-r--r--	2024-08-27 10:30:39	Edit Download recursive recursive
__init__.py	198 B	lrw-r--r--	2024-08-27 10:30:39	Edit Download recursive recursive

Directory Contents