ws.C

Go to the documentation of this file.

/// \file
/// \ingroup tutorial_http
///  This program demonstrate WebSocket usage with THttpServer
///  Custom ws.htm page is loaded and regularly sends messages to server
///
/// \macro_code
///
/// \author Sergey Linev
 
#include "THttpServer.h"
#include "THttpWSHandler.h"
#include "THttpCallArg.h"
#include "TString.h"
#include "TSystem.h"
#include "TDatime.h"
#include "TTimer.h"
 
#include <cstdio>
 
class TUserHandler : public THttpWSHandler {
   public:
      UInt_t fWSId{0};
      Int_t fServCnt{0};
 
      TUserHandler(const char *name = nullptr, const char *title = nullptr) : THttpWSHandler(name, title) {}
 
      // load custom HTML page when open correspondent address
      TString GetDefaultPageContent() override { return "file:ws.htm"; }
 
      Bool_t ProcessWS(THttpCallArg *arg) override
      {
         if (!arg || (arg->GetWSId() == 0)) return kTRUE;
 
         // printf("Method %s\n", arg->GetMethod());
 
         if (arg->IsMethod("WS_CONNECT")) {
            // accept only if connection not established
            return fWSId == 0;
        }
 
        if (arg->IsMethod("WS_READY")) {
            fWSId = arg->GetWSId();
            printf("Client connected %d\n", fWSId);
            return kTRUE;
        }
 
        if (arg->IsMethod("WS_CLOSE")) {
           fWSId = 0;
           printf("Client disconnected\n");
           return kTRUE;
        }
 
        if (arg->IsMethod("WS_DATA")) {
           TString str;
           str.Append((const char *)arg->GetPostData(), arg->GetPostDataLength());
           printf("Client msg: %s\n", str.Data());
           TDatime now;
           SendCharStarWS(arg->GetWSId(), TString::Format("Server replies:%s server counter:%d", now.AsString(), fServCnt++));
           return kTRUE;
        }
 
        return kFALSE;
      }
 
      /// per timeout sends data portion to the client
      Bool_t HandleTimer(TTimer *) override
      {
         TDatime now;
         if (fWSId) SendCharStarWS(fWSId, TString::Format("Server sends data:%s server counter:%d", now.AsString(), fServCnt++));
         return kTRUE;
      }
 
};
 
void ws()
{
   THttpServer *serv = new THttpServer("http:8090");
 
   TUserHandler *handler = new TUserHandler("name1", "title1");
 
   serv->Register("/folder1", handler);
 
   const char *addr = "http://localhost:8090/folder1/name1/";
 
   printf("Starting browser with URL address %s\n", addr);
   printf("In browser content of ws.htm file should be loaded\n");
   printf("Please be sure that ws.htm is provided in current directory\n");
 
   if (gSystem->InheritsFrom("TMacOSXSystem"))
      gSystem->Exec(TString::Format("open %s", addr));
   else if (gSystem->InheritsFrom("TWinNTSystem"))
      gSystem->Exec(TString::Format("start %s", addr));
   else
      gSystem->Exec(TString::Format("xdg-open %s &", addr));
 
   // when connection will be established, data will be send to the client
   TTimer *tm = new TTimer(handler, 3700);
   tm->Start();
}