/usr/lib/python2.7/dist-packages/pyptlib/server.py is in python-pyptlib 0.0.6-2.
This file is owned by root:root, with mode 0o644.
The actual contents of the file can be viewed below.
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 | #!/usr/bin/python
# -*- coding: utf-8 -*-
"""
Public server-side pyptlib API.
"""
from pyptlib.core import TransportPlugin
from pyptlib.server_config import ServerConfig
class ServerTransportPlugin(TransportPlugin):
"""
Runtime process for a server TransportPlugin.
"""
configType = ServerConfig
methodName = 'SMETHOD'
def reportMethodSuccess(self, name, addrport, options):
"""
Write a message to stdout announcing that a server transport was
successfully launched.
:param str name: Name of transport.
:param tuple addrport: (addr,port) where this transport is listening for connections.
:param str options: String containting comma-separated
transport options in key=value form (as
they appear in the ARGS: SMETHOD option)
"""
extra = ""
if options:
extra = " ARGS:%s" % options
elif self.config.serverTransportOptions:
optlist = []
# self.config.serverTransportOptions looks like this:
# {'obfs3': {'k':'v'}, 'scramblesuit': {'k2' : 'v2', 'k' : 'v'} }
for transport_name, options_dict in self.config.serverTransportOptions.items():
if transport_name != name:
continue
for k, v in options_dict.items():
optlist.append("%s=%s" % (k,v))
extra = " ARGS:%s" % (",".join(optlist))
self.emit('SMETHOD %s %s:%s%s' % (name, addrport[0], addrport[1], extra))
def getBindAddresses(self):
"""
:returns: dict of names of the transports that this plugin can serve,
each mapped to the (ip,port) where the transport should bind.
:raises: :class:`ValueError` if called before :func:`init`.
"""
return dict((k, v)
for k, v in self.config.serverBindAddr.iteritems()
if k in self.getTransports())
def init(supported_transports):
"""DEPRECATED. Use ServerTransportPlugin().init() instead."""
server = ServerTransportPlugin()
server.init(supported_transports)
config = server.config
retval = {}
retval['state_loc'] = config.getStateLocation()
retval['orport'] = config.getORPort()
retval['ext_orport'] = config.getExtendedORPort()
retval['transports'] = server.getBindAddresses()
retval['auth_cookie_file'] = config.getAuthCookieFile()
return retval
def reportSuccess(name, addrport, options):
"""DEPRECATED. Use ClientTransportPlugin().reportMethodSuccess() instead."""
config = ServerTransportPlugin()
config.reportMethodSuccess(name, addrport, options)
def reportFailure(name, message):
"""DEPRECATED. Use ClientTransportPlugin().reportMethodError() instead."""
config = ServerTransportPlugin()
config.reportMethodError(name, message)
def reportEnd():
"""DEPRECATED. Use ClientTransportPlugin().reportMethodsEnd() instead."""
config = ServerTransportPlugin()
config.reportMethodsEnd()
|