break it up into packages

Author: Tony Crisci

MANIFEST.in

@@ -0,0 +1,2 @@
+include README.rst LICENSE CHANGELOG.md pytest.ini requirements.txt .flake8 .style.yapf
+recursive-include test *.py

i3ipc/__init__.py

@@ -1,4 +1,5 @@
-from .i3ipc import (BarConfigReply, BarconfigUpdateEvent, BindingEvent, BindingInfo, CommandReply,
-                    Con, ConfigReply, Connection, Event, Gaps, GenericEvent, MessageType,
-                    OutputReply, Rect, TickEvent, TickReply, VersionReply, WindowEvent,
-                    WorkspaceEvent, WorkspaceReply)
+from .model import (BarConfigReply, BarconfigUpdateEvent, BindingEvent, BindingInfo, CommandReply,
+                    ConfigReply, Event, Gaps, GenericEvent, MessageType, OutputReply, Rect,
+                    TickEvent, TickReply, VersionReply, WindowEvent, WorkspaceEvent, WorkspaceReply)
+from .con import Con
+from .connection import Connection

i3ipc/_private/__init__.py

@@ -0,0 +1,2 @@
+from .pubsub import PubSub
+from .props_object import PropsObject

i3ipc/_private/props_object.py

@@ -0,0 +1,15 @@
+# this is for compatability with i3ipc-glib
+
+
+class PropsObject(object):
+    def __init__(self, obj):
+        object.__setattr__(self, "_obj", obj)
+
+    def __getattribute__(self, name):
+        return getattr(object.__getattribute__(self, "_obj"), name)
+
+    def __delattr__(self, name):
+        delattr(object.__getattribute__(self, "_obj"), name)
+
+    def __setattr__(self, name, value):
+        setattr(object.__getattribute__(self, "_obj"), name, value)

i3ipc/_private/pubsub.py

@@ -0,0 +1,30 @@
+class PubSub(object):
+    def __init__(self, conn):
+        self.conn = conn
+        self._subscriptions = []
+
+    def subscribe(self, detailed_event, handler):
+        event = detailed_event.replace('-', '_')
+        detail = ''
+
+        if detailed_event.count('::') > 0:
+            [event, detail] = detailed_event.split('::')
+
+        self._subscriptions.append({'event': event, 'detail': detail, 'handler': handler})
+
+    def unsubscribe(self, handler):
+        self._subscriptions = list(filter(lambda s: s['handler'] != handler, self._subscriptions))
+
+    def emit(self, event, data):
+        detail = ''
+
+        if data and hasattr(data, 'change'):
+            detail = data.change
+
+        for s in self._subscriptions:
+            if s['event'] == event:
+                if not s['detail'] or s['detail'] == detail:
+                    if data:
+                        s['handler'](self.conn, data)
+                    else:
+                        s['handler'](self.conn)