phxsocket 0.0.1

Websocket client for Phoenix Elixir

phxsocket

Synchronous phoenix websocket client using callbacks

Phoenix channels

Requirements

websocket_client

Usage

Import the package

import phxsocket

Create socket client

socket = phxsocket.Client("wss://target.url/websocket", {"options": "something"})

Connect and join a channel

def on_open(socket):
  channel = socket.channel("room:roomname", {"more options": "something else"})

  join_success, resp = self.channel.join()

def reconnect():
  socket.connect()

socket.on_open = on_open
socket.on_error = lambda socket, message: (print(message), reconnect())
socket.connect()

Subscribe to events

def do_something(payload):
  thing = payload["thing"]

channel.on("eventname", do_something)

Push data to a channel

channel.push("eventname", {"some": "data"})

Push data and wait for a response

message = channel.push("eventname", {"some": "data"}, reply=True)
response = message.wait_for_response() # blocking

Push data and react to the response with a callback

def respond(payload):
  print(payload)

channel.push("eventname", {"some": "data"}, respond)

Leave a channel

channel.leave()

Disconnect

socket.close()