Misultin haproxy websocket hixie76 bug

client-direct.js

var net = require('net');

console.log(" [.] Connecting to localhost:8000");
var conn = net.createConnection(8000, '127.0.0.1');

var data = [
    "GET /echo/1/1/websocket HTTP/1.1",
    "Upgrade: WebSocket",
    "Connection: Upgrade",
    "Host: localhost:8000",
    "Origin: http://localhost:8000",
    "Cookie: x=x",
    "Sec-WebSocket-Key1: 232J 4jm9 w6!4^ 9<05@ h# do",
    "Sec-WebSocket-Key2: ; 6KW91  %3 ` u7 59 -:c'58",
    "",
    "01234567"]


conn.on('connect', function() {
    conn.write(data.join('\r\n'));
    setTimeout(function(){conn.end()}, 200);
});

conn.on('data', function(d) {
    console.log(d.toString());
});

client-haproxy.js

var net = require('net');

console.log(" [.] Connecting to localhost:8000");
var conn = net.createConnection(8000, '127.0.0.1');

var data = [
    "GET /echo/1/1/websocket HTTP/1.1",
    "Upgrade: WebSocket",
    "Connection: Upgrade",
    "Host: localhost:8000",
    "Origin: http://localhost:8000",
    "Cookie: x=x",
    "Sec-WebSocket-Key1: 232J 4jm9 w6!4^ 9<05@ h# do",
    "Sec-WebSocket-Key2: ; 6KW91  %3 ` u7 59 -:c'58",
    "",
    ""]


conn.on('connect', function() {
    conn.write(data.join('\r\n'));
    setTimeout(function(){conn.end()}, 200);
});

conn.once('data', function(d) {
    conn.write('01234567');

    console.log(d.toString());
    conn.on('data', function(d) {
        console.log(d.toString());
    });

});

misultin_haproxy_bug.erl

#!/usr/bin/env escript
%%! -smp disable +A1 +K true -pz ./ebin -pa deps/misultin/ebin -input
-module(misultin_haproxy_bug).
-mode(compile).

-export([main/1]).

main(_) ->
    Port = 8000,

    io:format(" [*] Running at http://localhost:~p~n", [Port]),
    misultin:start_link(
      [{port, Port},
       {autoexit, false},
       {ws_autoexit, false},
       {loop,    fun (Req) -> handle_http(Req) end},
       {ws_loop, fun (Req) -> handle_ws(Req) end}]),
    receive
        _ -> ok
    end.


handle_http(Req) ->
    Req:respond(404,
                <<"404 - Nothing here\n">>).

handle_ws(Req) ->
    Req:send(<<"deadbabe">>),
    closed.