start channels (django) support

CHANGELOG.rst

@@ -1,6 +1,10 @@
 Changelog
 ---------
 
+v0.4.16
+=======
+- Channels (django) (https://github.com/django/channels) server support
+
 v0.4.15
 =======
 - Websockets server support (https://github.com/python-websockets/websockets)

README.md

@@ -17,6 +17,7 @@ You may also install using some **extras**:
 | rx              | ReactiveX ([v3](https://pypi.org/project/Rx/)) integration                                 | [Tutorial](https://rsocket.io/guides/rsocket-py/tutorial/reactivex) |
 | reactivex       | [ReactiveX](https://reactivex.io/) ([v4](https://pypi.org/project/reactivex/)) integration | [Tutorial](https://rsocket.io/guides/rsocket-py/tutorial/reactivex) |
 | aiohttp         | [aiohttp](https://docs.aiohttp.org/en/stable/) Websocket transport (server/client)         | [Tutorial](https://rsocket.io/guides/rsocket-py/tutorial/websocket) |
+| channels        | Websocket transport (server only) using channels (django)                                  |                                                                     |
 | quart           | [Quart](https://pgjones.gitlab.io/quart/) Websocket transport (server only)                |                                                                     |
 | quic            | [QUIC](https://github.com/aiortc/aioquic) transport                                        |                                                                     |
 | websockets      | [Websockets](https://github.com/python-websockets/websockets) transport (server only)      |                                                                     |

requirements.txt

@@ -23,5 +23,6 @@ pydantic==1.10.13
 Werkzeug==3.0.1
 graphql-core==3.2.3
 gql==3.4.1
+channels==4.0.0
 websockets==12.0
-asyncwebsockets==0.9.4
+asyncwebsockets==0.9.4

rsocket/transports/channels_transport.py

@@ -0,0 +1,29 @@
+import json
+
+from channels.generic.websocket import WebsocketConsumer
+
+from rsocket.frame import Frame
+from rsocket.transports.abstract_messaging import AbstractMessagingTransport
+
+
+class RSocketConsumer(WebsocketConsumer):
+    def connect(self):
+        self.accept()
+
+    def disconnect(self, close_code):
+        pass
+
+    def receive(self, text_data=None, bytes_data=None):
+        text_data_json = json.loads(text_data)
+        message = text_data_json["message"]
+
+        self.send(text_data=json.dumps({"message": message}))
+
+
+class ChannelsTransport(AbstractMessagingTransport):
+
+    async def send_frame(self, frame: Frame):
+        pass
+
+    async def close(self):
+        pass

setup.cfg

@@ -62,6 +62,7 @@ graphql =
     graphql-core>=3.2.0
     gql>=3.4.0
 websockets = websockets>=11.0.0
+channels = channels>=4.0.0
 asyncwebsockets = asyncwebsockets>=0.9.4
 
 [options.entry_points]