Add db.events() poc

Author: phillmac

orbitdbapi/__init__.py

@@ -0,0 +1,4 @@
+from .version import version, version_info
+from .client import OrbitDbAPI
+from .db import DB
+__version__ = version

orbitdbapi/__version__.py

@@ -15,6 +15,14 @@ def __init__ (self, **kwargs):
         self.__session = requests.Session()
         self.__session.mount(self.__base_url, HTTP20Adapter(timeout=self.__timeout))
 
+    @property
+    def session(self):
+        return self.__session
+
+    @property
+    def base_url(self):
+        return self.__base_url
+
     @property
     def use_db_cache(self):
         return self.__use_db_cache
@@ -27,9 +35,12 @@ def _do_request(self, *args, **kwargs):
             self.logger.exception('Exception during api call')
             raise
 
-    def _call(self, method, endpoint, body=None):
+    def _call_raw(self, method, endpoint, **kwargs):
         url = '/'.join([self.__base_url, endpoint])
-        res = self._do_request(method, url, json=body)
+        return self._do_request(method, url, **kwargs)
+
+    def _call(self, method, endpoint, body=None):
+        res = self._call_raw(method, endpoint, json=body)
         try:
             result = res.json()
         except:

orbitdbapi/client.py

@@ -1,6 +1,7 @@
 import json
 import logging
 from copy import deepcopy
+from sseclient import SSEClient
 from collections.abc import Hashable, Iterable
 from urllib.parse import quote as urlquote
 
@@ -172,6 +173,12 @@ def unload(self):
         endpoint = '/'.join(['db', self.__id_safe])
         return self.__client._call('delete', endpoint)
 
+    def events(self, eventname):
+        endpoint = '/'.join(['db', self.__id_safe,'events', eventname])
+        #return SSEClient('{}/{}'.format(self.__client.base_url, endpoint), session=self.__client.session)
+        req = self.__client._call_raw('get', endpoint, stream=True)
+        return SSEClient(req).events()
+
 class CapabilityError(Exception):
     pass
 

orbitdbapi/db.py

@@ -0,0 +1,2 @@
+version = '0.2.2-dev0'
+version_info = tuple([int(d) for d in version.split("-")[0].split(".")])

orbitdbapi/version.py

@@ -1,11 +1,13 @@
 #!/usr/bin/env python
 
-from orbitdbapi.__version__ import __version__
 from setuptools import setup, find_packages
 
+version = None
+exec(open('orbitdbapi/version.py').read())
+
 setup(
     name='orbitdbapi',
-    version=__version__,
+    version=version,
     description='A Python HTTP Orbitdb API Client',
     author='Phillip Mackintosh',
     url='https://github.com/phillmac/py-orbit-db-http-client',