Merge remote-tracking branch 'orig/master'

Author: nkitsaini

README.md

@@ -6,7 +6,7 @@ Python Client Library to interface with the Phoenix Realtime Server
 
 ## Installation
 ```bash
-pip3 install realtime_py==0.1.1a0
+pip3 install realtime==0.1.1a0
 ```
 
 ## Installation from source 
@@ -18,7 +18,7 @@ python3 usage.py
 
 ## Quick Start 
 ```python
-from realtime_py.connection import Socket
+from realtime.connection import Socket
 
 def callback1(payload):
     print("Callback 1: ", payload)
@@ -47,7 +47,7 @@ if __name__ == "__main__":
 Here's how you could connect to your realtime endpoint using Supabase endpoint. Correct as of 5th June 2021. Please replace `SUPABASE_ID` and `API_KEY` with your own `SUPABASE_ID` and `API_KEY`. The variables shown below are fake and they will not work if you try to run the snippet.
 
 ```python
-from realtime_py.connection import Socket
+from realtime.connection import Socket
 
 SUPABASE_ID = "dlzlllxhaakqdmaapvji"
 API_KEY = "eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJyb2xlIjoiYW5vbiIsImlhdCI6MT"

pyproject.toml

@@ -1,6 +1,6 @@
 [tool.poetry]
-name = "realtime-py"
-version = "0.1.3"
+name = "realtime"
+version = "0.0.3"
 description = ""
 authors = ["None"]
 

realtime/__init__.py

@@ -0,0 +1,7 @@
+__version__ = "0.0.3"
+
+from realtime.channel import CallbackListener, Channel
+from realtime.connection import Socket
+from realtime.exceptions import NotConnectedError
+from realtime.message import *
+from realtime.transformers import *

realtime_py/channel.py renamed to realtime/channel.py

@@ -6,7 +6,7 @@
 from typing import List, TYPE_CHECKING
 
 if TYPE_CHECKING:
-    from realtime_py.connection import Socket
+    from realtime.connection import Socket
 
 """
 Callback Listener is a tuple with `event` and `callback` 
@@ -49,7 +49,8 @@ async def _join(self) -> None:
         Coroutine that attempts to join Phoenix Realtime server via a certain topic
         :return: None
         """
-        join_req = dict(topic=self.topic, event="phx_join", payload={}, ref=None)
+        join_req = dict(topic=self.topic, event="phx_join",
+                        payload={}, ref=None)
 
         try:
             await self.socket.ws_connection.send(json.dumps(join_req))
@@ -74,4 +75,5 @@ def off(self, event: str) -> None:
         :param event: Stop responding to a certain event
         :return: None
         """
-        self.listeners = [callback for callback in self.listeners if callback.event != event]
+        self.listeners = [
+            callback for callback in self.listeners if callback.event != event]

realtime_py/connection.py renamed to realtime/connection.py

@@ -7,11 +7,12 @@
 
 import websockets
 
-from realtime_py.channel import Channel
-from realtime_py.exceptions import NotConnectedError
-from realtime_py.message import HEARTBEAT_PAYLOAD, PHOENIX_CHANNEL, ChannelEvents, Message
+from realtime.channel import Channel
+from realtime.exceptions import NotConnectedError
+from realtime.message import HEARTBEAT_PAYLOAD, PHOENIX_CHANNEL, ChannelEvents, Message
 
-logging.basicConfig(format="%(asctime)s:%(levelname)s - %(message)s", level=logging.INFO)
+logging.basicConfig(
+    format="%(asctime)s:%(levelname)s - %(message)s", level=logging.INFO)
 
 
 def ensure_connection(func: Callable):
@@ -24,6 +25,7 @@ def wrapper(*args: Any, **kwargs: Any):
 
     return wrapper
 
+
 class Socket:
     def __init__(self, url: str, params: dict = {}, hb_interval: int = 5) -> None:
         """
@@ -50,7 +52,8 @@ def listen(self) -> None:
         :return: None
         """
         loop = asyncio.get_event_loop()  # TODO: replace with get_running_loop
-        loop.run_until_complete(asyncio.gather(self._listen(), self._keep_alive()))
+        loop.run_until_complete(asyncio.gather(
+            self._listen(), self._keep_alive()))
 
     async def _listen(self) -> None:
         """
@@ -129,4 +132,5 @@ def summary(self) -> None:
         """
         for topic, chans in self.channels.items():
             for chan in chans:
-                print(f"Topic: {topic} | Events: {[e for e, _ in chan.callbacks]}]")
+                print(
+                    f"Topic: {topic} | Events: {[e for e, _ in chan.callbacks]}]")