-
-
Save dankrause/9607475 to your computer and use it in GitHub Desktop.
| # Copyright 2017 Dan Krause | |
| # | |
| # Licensed under the Apache License, Version 2.0 (the "License"); | |
| # you may not use this file except in compliance with the License. | |
| # You may obtain a copy of the License at | |
| # | |
| # http://www.apache.org/licenses/LICENSE-2.0 | |
| # | |
| # Unless required by applicable law or agreed to in writing, software | |
| # distributed under the License is distributed on an "AS IS" BASIS, | |
| # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. | |
| # See the License for the specific language governing permissions and | |
| # limitations under the License. | |
| import SocketServer | |
| import socket | |
| import struct | |
| import json | |
| class IPCError(Exception): | |
| pass | |
| class UnknownMessageClass(IPCError): | |
| pass | |
| class InvalidSerialization(IPCError): | |
| pass | |
| class ConnectionClosed(IPCError): | |
| pass | |
| def _read_objects(sock): | |
| header = sock.recv(4) | |
| if len(header) == 0: | |
| raise ConnectionClosed() | |
| size = struct.unpack('!i', header)[0] | |
| data = sock.recv(size - 4) | |
| if len(data) == 0: | |
| raise ConnectionClosed() | |
| return Message.deserialize(json.loads(data)) | |
| def _write_objects(sock, objects): | |
| data = json.dumps([o.serialize() for o in objects]) | |
| sock.sendall(struct.pack('!i', len(data) + 4)) | |
| sock.sendall(data) | |
| def _recursive_subclasses(cls): | |
| classmap = {} | |
| for subcls in cls.__subclasses__(): | |
| classmap[subcls.__name__] = subcls | |
| classmap.update(_recursive_subclasses(subcls)) | |
| return classmap | |
| class Message(object): | |
| @classmethod | |
| def deserialize(cls, objects): | |
| classmap = _recursive_subclasses(cls) | |
| serialized = [] | |
| for obj in objects: | |
| if isinstance(obj, Message): | |
| serialized.append(obj) | |
| else: | |
| try: | |
| serialized.append(classmap[obj['class']](*obj['args'], **obj['kwargs'])) | |
| except KeyError as e: | |
| raise UnknownMessageClass(e) | |
| except TypeError as e: | |
| raise InvalidSerialization(e) | |
| return serialized | |
| def serialize(self): | |
| args, kwargs = self._get_args() | |
| return {'class': type(self).__name__, 'args': args, 'kwargs': kwargs} | |
| def _get_args(self): | |
| return [], {} | |
| def __repr__(self): | |
| r = self.serialize() | |
| args = ', '.join([repr(arg) for arg in r['args']]) | |
| kwargs = ''.join([', {}={}'.format(k, repr(v)) for k, v in r['kwargs'].items()]) | |
| name = r['class'] | |
| return '{}({}{})'.format(name, args, kwargs) | |
| class Client(object): | |
| def __init__(self, server_address): | |
| self.addr = server_address | |
| if isinstance(self.addr, basestring): | |
| address_family = socket.AF_UNIX | |
| else: | |
| address_family = socket.AF_INET | |
| self.sock = socket.socket(address_family, socket.SOCK_STREAM) | |
| def connect(self): | |
| self.sock.connect(self.addr) | |
| def close(self): | |
| self.sock.close() | |
| def __enter__(self): | |
| self.connect() | |
| return self | |
| def __exit__(self, exc_type, exc_value, traceback): | |
| self.close() | |
| def send(self, objects): | |
| _write_objects(self.sock, objects) | |
| return _read_objects(self.sock) | |
| class Server(SocketServer.ThreadingUnixStreamServer): | |
| def __init__(self, server_address, callback, bind_and_activate=True): | |
| if not callable(callback): | |
| callback = lambda x: [] | |
| class IPCHandler(SocketServer.BaseRequestHandler): | |
| def handle(self): | |
| while True: | |
| try: | |
| results = _read_objects(self.request) | |
| except ConnectionClosed as e: | |
| return | |
| _write_objects(self.request, callback(results)) | |
| if isinstance(server_address, basestring): | |
| self.address_family = socket.AF_UNIX | |
| else: | |
| self.address_family = socket.AF_INET | |
| SocketServer.TCPServer.__init__(self, server_address, IPCHandler, bind_and_activate) |
| #!/usr/bin/env python | |
| # Copyright 2017 Dan Krause | |
| # | |
| # Licensed under the Apache License, Version 2.0 (the "License"); | |
| # you may not use this file except in compliance with the License. | |
| # You may obtain a copy of the License at | |
| # | |
| # http://www.apache.org/licenses/LICENSE-2.0 | |
| # | |
| # Unless required by applicable law or agreed to in writing, software | |
| # distributed under the License is distributed on an "AS IS" BASIS, | |
| # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. | |
| # See the License for the specific language governing permissions and | |
| # limitations under the License. | |
| """ ipc_example.py | |
| Usage: | |
| ipc_example.py server [options] | |
| ipc_example.py client [options] <class> [--arg=<arg>...] [--kwarg=<kwarg>...] | |
| Options: | |
| -p --port=<port> The port number to communicate over [default: 5795] | |
| -h --host=<host> The host name to communicate over [default: localhost] | |
| -s --socket=<socket> A socket file to use, instead of a host:port | |
| -a --arg=<arg> A positional arg to supply the class constructor | |
| -k --kwarg=<kwarg> A keyword arg to supply the class constructor | |
| """ | |
| import docopt | |
| import ipc | |
| class Event(ipc.Message): | |
| def __init__(self, event_type, **properties): | |
| self.type = event_type | |
| self.properties = properties | |
| def _get_args(self): | |
| return [self.type], self.properties | |
| class Response(ipc.Message): | |
| def __init__(self, text): | |
| self.text = text | |
| def _get_args(self): | |
| return [self.text], {} | |
| def server_process_request(objects): | |
| response = [Response('Received {} objects'.format(len(objects)))] | |
| print 'Received objects: {}'.format(objects) | |
| print 'Sent objects: {}'.format(response) | |
| return response | |
| if __name__ == '__main__': | |
| args = docopt.docopt(__doc__) | |
| server_address = args['--socket'] or (args['--host'], int(args['--port'])) | |
| if args['server']: | |
| ipc.Server(server_address, server_process_request).serve_forever() | |
| if args['client']: | |
| kwargs = {k: v for k, v in [i.split('=', 1) for i in args['--kwarg']]} | |
| user_input = [{'class': args['<class>'], 'args': args['--arg'], 'kwargs': kwargs}] | |
| objects = ipc.Message.deserialize(user_input) | |
| print 'Sending objects: {}'.format(objects) | |
| with ipc.Client(server_address) as client: | |
| response = client.send(objects) | |
| print 'Received objects: {}'.format(response) | |
| # Example usage: | |
| # $ ./ipc_example.py server | |
| # then in another terminal: | |
| # $ ./ipc_example.py client Event --arg=testevent --kwarg=exampleproperty=examplevalue |
Apache2 license added.
Minor point (That is all I am smart enough to render at this point) "Recieved" is properly spelled "Received". Used in the example program.
fixed
I am a beginner Python programmer and much of the code above is hard for me to understand so be forewarned about the accuracy of this comment
I made the following changes which seemed to be necessary to make the code compatible with Python 3.7
ipc.py
import SocketServer -> import socketserver
sock.sendall(data) -> sock.sendall(data.encode())
if isinstance(self.addr, basestring): -> if isinstance(self.addr, str):
class Server(SocketServer.ThreadingUnixStreamServer): -> class Server(socketserver.ThreadingUnixStreamServer):
class IPCHandler(SocketServer.BaseRequestHandler): -> class IPCHandler(socketserver.BaseRequestHandler):
if isinstance(server_address, basestring): -> if isinstance(server_address, str):
SocketServer.TCPServer.init(self, server_address, IPCHandler, bind_and_activate) -> socketserver.TCPServer.init(self, server_address, IPCHandler, bind_and_activate)
ipc_example.py
print 'Received objects: {}'.format(objects) -> print ('Received objects: {}'.format(objects))
print 'Sent objects: {}'.format(response) -> print ('Sent objects: {}'.format(response))
print 'Sending objects: {}'.format(objects) -> print('Sending objects: {}'.format(objects))
print 'Received objects: {}'.format(response) -> print('Received objects: {}'.format(response))
Hi Dan,
can you explicitly provide an open source license for this neat little gist?
Thank you so much.
Regards
Tobias