update

Author: sansyrox

starfyre/js/store.py

@@ -140,11 +140,23 @@ def get_signal(*args, **kwargs):
 import random
 
 # Assuming connection is already established
-connection = js.WebSocket("ws://localhost:8765")
+connection = js.WebSocket.new("ws://localhost:8080/web_socket")
+
+def on_message(event):
+    print("Message received:", event.data)
+    try:
+        data = json.loads(event.data)
+    except SyntaxError:
+        print("Invalid JSON")
+        return
+    # Process the data, update local state, notify observers, etc.
+
+connection.onmessage = on_message
 
 def server_state():
     id = random.randint(0, 100000)
 
+
     def use_server_signal(element=None):
         nonlocal id
         if element:
@@ -173,8 +185,3 @@ def get_server_signal():
     return [use_server_signal, set_server_signal, get_server_signal]
 
 # Handle incoming WebSocket messages
-def on_message(event):
-    data = json.loads(event.data)
-    # Process the data, update local state, notify observers, etc.
-
-connection.onmessage = on_message

test_application/pages/__init__.fyre

@@ -9,8 +9,11 @@ def mocked_request():
 # client functions can be async
 [use_parent_signal, set_parent_signal, get_parent_signal] = create_signal(1)
 
+[use_server_signal, set_server_signal, get_server_signal] = server_state()
+
 def handle_on_click(e):
    signal_value = get_parent_signal()
+   set_server_signal(1)
    set_parent_signal(signal_value+1)
 ---
 

test_application/server.py

@@ -0,0 +1,21 @@
+from robyn import Robyn, jsonify, WebSocket
+
+app = Robyn(__file__)
+websocket = WebSocket(app, "/web_socket")
+
+@websocket.on("message")
+def connect(ws, msg):
+    print(msg)
+    print(ws)
+    return message
+
+@websocket.on("close")
+def close():
+    return '{"message": "Goodbye"}'
+
+@websocket.on("connect")
+def message():
+    return '{"message": "Hello world, from ws"}'
+
+if __name__ == "__main__":
+    app.start()