-
-
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