handy_test/htest/source/app.d

import std.stdio;
import std.conv;


import slf4d;
import handy_httpd;
import handy_httpd.components.websocket;
import handy_httpd.handlers.path_handler;
import handy_httpd.handlers.file_resolving_handler;



class MyWebSocketHandler : WebSocketMessageHandler{
  override void onConnectionEstablished(WebSocketConnection conn, in HttpRequest request){
    infoF!"Connection established with id %s"(conn.id); // id 8a4429e7-19b8-4dc4-bca6-14f64a471392
    conn.sendTextMessage("Hey yourself!");
  }
  
  override void onTextMessage(WebSocketTextMessage msg){
    infoF!"Got TEXT: %s"(msg.payload);
    //msg.conn.sendTextMessage("Hey yourself!");
    msg.conn.sendTextMessage(msg.payload ~ " :)");
  }
  
  override void onCloseMessage(WebSocketCloseMessage msg){
    infoF!"Closed: %d, %s"(msg.statusCode, msg.message);
  }
}


void main(string[] args){
  ServerConfig cfg;
  if(args.length > 1){
    cfg.port = args[1].to!ushort;
  }
  
  cfg.workerPoolSize = 3;
  cfg.enableWebSockets = true; // Important! Websockets won't work unless `enableWebSockets` is set to true!
  WebSocketHandler handler = new WebSocketHandler(new MyWebSocketHandler());
  
  //new HttpServer(new FileResolvingHandler("public"), cfg).start();
  PathHandler pathHandler = new PathHandler()
    .addMapping(Method.GET, "/ws", handler)
    .addMapping("/**", new FileResolvingHandler("public"));
  
  new HttpServer(pathHandler, cfg).start();
}