GNOME.org
 

[Vala] I cannot get a simple websocket server working

I followed all the scarce resources I could find, but I am stuck, I have
this so far, but in Firefox, the client stays in
101 Switching Protocols
 state, when I try to send message, the connection is "WebSocket is already
in CLOSING or CLOSED state.". What can I do ?

using GLib;
using Soup;

public class ControllerServer : Soup.Server {

  public ControllerServer () {
    Object (port: 8088);
assert (this != null);
this.add_handler (null, default_handler);
this.add_handler ("/index.html", index_handler);
this.add_handler ("/favicon.ico", favicon_handler);
this.add_websocket_handler ("/ws", null, null, websocket_handler);
}

  private static void index_handler (Soup.Server server, Soup.Message msg,
string path, GLib.HashTable? query, Soup.ClientContext client) {
string current_dir = Environment.get_current_dir();
uint8[] contents;
FileUtils.get_data ("%s/index.html".printf(current_dir), out contents);
msg.set_status (200);
msg.set_response ("text/html", Soup.MemoryUse.COPY, contents);
}

  private static void favicon_handler (Soup.Server server, Soup.Message msg,
string path, GLib.HashTable? query, Soup.ClientContext client) {
string current_dir = Environment.get_current_dir();
try {
uint8[] contents;
FileUtils.get_data ("%s/favicon.ico".printf(current_dir), out contents);
msg.set_response ("image/x-icon", Soup.MemoryUse.COPY, contents);
msg.set_status (200);
} catch (Error e) {
stderr.printf ("Error: %s\n", e.message);
}
}

  private static void default_handler (Soup.Server server, Soup.Message msg,
string path, GLib.HashTable? query, Soup.ClientContext client) {
if (path == "/") {
index_handler(server, msg, path, query, client);
return;
}
stderr.printf ("404 - request %s\n", path);
msg.set_response ("text/html", Soup.MemoryUse.COPY, "<html><body>Page not
found</body></html>".data);
msg.set_status (404);
}

  private static void websocket_handler(Soup.Server server, Soup.
WebsocketConnection conn, string path, Soup.ClientContext client) {
stdout.printf ("Websocket handler goes here");
conn.message.connect ((type, message) => {
// receive messages en responds ...
stdout.printf ("Websocket message");
});
  }
}

class Main.Application : GLib.Object {
public static int main(string[] args) {
stdout.printf ("Main application running\n");
MainLoop loop = new MainLoop();
const uint16 port = 8888;
InetAddress address = new InetAddress.loopback (SocketFamily.IPV4);
InetSocketAddress inetaddress = new InetSocketAddress (address, port);
GLib.Socket socket = new GLib.Socket (SocketFamily.IPV4, SocketType.STREAM,
SocketProtocol.TCP);
socket.bind (inetaddress, true);
socket.listen ();
ControllerServer server = new ControllerServer();
server.listen_socket (socket, 0);
loop.run();
new MainLoop ().run ();
return 0;
}
}


The client code is:

<!doctype html>
<html class="no-js" lang="">
<head>
<meta charset="utf-8">
<meta http-equiv="x-ua-compatible" content="ie=edge">
<title>Server</title>
<meta name="description" content="">
<meta name="viewport" content="width=device-width, initial-scale=1,
shrink-to-fit=no">
</head>
<body>
Server waiting for connections
<script type="text/javascript">
var ws = new WebSocket('ws://localhost:8888/ws');
ws.onclose = () => {
console.log('websocket closed');
};
ws.onopen = () => {
console.log('websocket open');
ws.send('message');
}
ws.onerror = (err) => console.error(err);
ws.onmessage = (msg) => console.debug(msg);
</script>
</body>
</html>


-- 
*Ionut Stoica <http://www.zend.com/en/yellow-pages/ZEND016175>*
Zend Certified Engineer <http://www.zend.com/en/yellow-pages/ZEND016175>
[Date Prev][Date Next]   [Thread Prev][Thread Next]   [Thread Index] [Date Index] [Author Index]