dersar00

dersar00

Hello, when I try to connect to my local websocket server I got error, but when I connect to wss://echo.websocket.org everything is good. If I try to connect to server through simply js client everything works nice too.

Websocket server:

require 'socket'
require 'digest/sha1'

server = TCPServer.new('localhost', 2345)

loop do

  socket = server.accept
  STDERR.puts "Incoming Request"

  http_request = ""
  while (line = socket.gets) && (line != "\r\n")
    http_request += line
  end

  if matches = http_request.match(/^Sec-WebSocket-Key: (\S+)/)
    websocket_key = matches[1]
    STDERR.puts "Websocket handshake detected with key: #{ websocket_key }"
  else
    STDERR.puts "Aborting non-websocket connection"
    socket.close
    next
  end


  response_key = Digest::SHA1.base64digest([websocket_key, "258EAFA5-E914-47DA-95CA-C5AB0DC85B11"].join)
  STDERR.puts "Responding to handshake with key: #{ response_key }"

  socket.write <<-eos
HTTP/1.1 101 Switching Protocols
Upgrade: websocket
Connection: Upgrade
Sec-WebSocket-Accept: #{ response_key }

  eos

  STDERR.puts "Handshake completed. Starting to parse the websocket frame."

  first_byte = socket.getbyte
  fin = first_byte & 0b10000000
  opcode = first_byte & 0b00001111

  raise "We don't support continuations" unless fin
  raise "We only support opcode 1" unless opcode == 1

  second_byte = socket.getbyte
  is_masked = second_byte & 0b10000000
  payload_size = second_byte & 0b01111111

  raise "All incoming frames should be masked according to the websocket spec" unless is_masked
  raise "We only support payloads < 126 bytes in length" unless payload_size < 126

  STDERR.puts "Payload size: #{ payload_size } bytes"

  mask = 4.times.map { socket.getbyte }
  STDERR.puts "Got mask: #{ mask.inspect }"

  data = payload_size.times.map { socket.getbyte }
  STDERR.puts "Got masked data: #{ data.inspect }"

  unmasked_data = data.each_with_index.map { |byte, i| byte ^ mask[i % 4] }
  STDERR.puts "Unmasked the data: #{ unmasked_data.inspect }"

  STDERR.puts "Converted to a string: #{ unmasked_data.pack('C*').force_encoding('utf-8').inspect }"

  socket.close
end

Websockex worker:

defmodule DispatcherService.Websockets do
  use WebSockex
  require Logger

  def start_link(state \\ []) do
    WebSockex.start_link("wss://echo.websocket.org", __MODULE__, state)
  end

  def handle_connect(_conn, state) do
     Logger.info("Binance Client Connected!")
     {:ok, state}
   end

  def handle_disconnect(%{reason: reason}, state) do
    Logger.warn "websocket closing: #{inspect reason}"
    {:ok, state}
  end

  def handle_frame({:binary, frame}, state) do
    IO.inspect "Received frame"
    {:ok, state}
  end
end

Btw, my js client:

<!doctype html>
<html lang="en">
<head>
  <title>Websocket Client</title>
</head>
<body>
  <script>
    var exampleSocket = new WebSocket("ws://localhost:2345");
    exampleSocket.onopen = function (event) {
      exampleSocket.send("Can you hear me?"); 
    };
    exampleSocket.onmessage = function (event) {
      console.log(event.data);
    }
  </script>
</body>
</html>

Showing Posts 1 to 5

dersar00

dersar00 OP

@Azolo, I think I need u’r help.

Ankhers

Ankhers

Can you show the error that you are getting?

dersar00

dersar00 OP

16:58:37.947 [error] Supervisor 'Elixir.DispatcherService.Supervisor' had child 'Elixir.DispatcherService.Websockets' started with 'Elixir.DispatcherService.Websockets':start_link(<<"ws://localhost:2345">>) at undefined exit with reason #{'__exception__' => true,'__struct__' => 'Elixir.WebSockex.ConnError',original => timeout} in context start_error
16:58:37.947 [error] CRASH REPORT Process <0.260.0> with 0 neighbours exited with reason: {{shutdown,{failed_to_start_child,'Elixir.DispatcherService.Websockets',#{'__exception__' => true,'__struct__' => 'Elixir.WebSockex.ConnError',original => timeout}}},{'Elixir.DispatcherService.Application',start,[normal,[]]}} in application_master:init/4 line 134

16:58:38.020 [info]  Application dispatcher_service exited: DispatcherService.Application.start(:normal, []) returned an error: shutdown: failed to start child: DispatcherService.Websockets
    ** (EXIT) %WebSockex.ConnError{original: :timeout}
16:58:38.020 [info] Application dispatcher_service exited with reason: {{shutdown,{failed_to_start_child,'Elixir.DispatcherService.Websockets',#{'__exception__' => true,'__struct__' => 'Elixir.WebSockex.ConnError',original => timeout}}},{'Elixir.DispatcherService.Application',start,[normal,[]]}}
** (Mix) Could not start application dispatcher_service: DispatcherService.Application.start(:normal, []) returned an error: shutdown: failed to start child: DispatcherService.Websockets
    ** (EXIT) %WebSockex.ConnError{original: :timeout}
Azolo

Azolo

Is that returning CRLFCRLF or just LFLF?

More than likely the browser conventions are more forgiving to the spec than WebSockex. But make sure those are returning carriage returns and line feeds.

Azolo

Azolo

@dersar00 Did that help you out or is there something else going on?

— All posts loaded —

Where Next? Top

Trending in Questions Top

stjefim
Hello! Suppose you are building workflow (order / task / payment) processing system with the following requirements: Each workflow con...
New
water
I’m aware of 2 such projects, are there others? git: GitHub - team-alembic/realworld: A fullstack Phoenix LiveView application with back...
New
katta
I having some trouble figuring out if I have set myself too strict of standards for my production server. Currently I can handle 75% of r...
New
peck
Hi everyone. My team and I have been working on a fairly modest app based around video streaming and chat, but we’ve landed a customer t...
New
bradley
I really like the adapter patterns that ecto, nebulex, waffle, etc. use and would love find something similar for a key management servic...
New
unaware8150
Hello folks! So at work, we are seeing some situations where we have to define some “fixed” strings that are used across the codebase in...
New
Alvinkariuki
How Can I Optimise Compile Time Dependencies I have been building an elixir application for about 2 years now. Many modules and files ha...
New

Other Trending Topics Top

mudasobwa
I fully migrated to my own harness from Anthropic/Gemini and I think it’s time to share it. Welcome DSH, the DeepSeek Harness, fully writ...
New
KristerV
Hey. Is there anyone here who creates agents in their apps? Not talking about using agents, but creating them. I’m finding it pretty diff...
New
jimsynz
Beam Bots (or just BB for short) is a framework for building fault-tolerant robotics applications in Elixir using familiar OTP patterns. ...
New
juhalehtonen
There has been a thread to discuss the Stack Overflow Developer Survey on this forum every year since 2018, so here’s yet another one for...
New
budgie
I love Elixir. It’s one of 2 programming languages I’ve ever fallen in love with. But I don’t use it anymore. Serverless was the promis...
New
ausimian
Emily is an Elixir library that runs Nx computations on Apple’s MLX. Install it as the default Nx backend and Nx, defn, Axon, Nx.Serving,...
New

We're in Beta

About us Mission Statement

Options

Thread Display Mode




Thread Preview

Skip Thread Previews