class Terminalwire::Transport::WebSocket

def self.connect(url)
  uri = URI(url)
  endpoint = Async::HTTP::Endpoint.parse(uri)
  adapter = Async::WebSocket::Client.connect(endpoint)
  new(adapter)
end

def self.listen(url)
  # This would need to be implemented with a WebSocket server library
  raise NotImplementedError, "WebSocket server not implemented"
end

def close
  @websocket.close
end

def initialize(websocket)
  @websocket = websocket
end

def read
  @websocket.read&.buffer
end

def write(data)
  @websocket.write(data)
end