src/websocket_server.cpp

   1 /**
   2  * @file websocket_server.cpp
   3  *
   4  * @brief Settings daemon WebSocket server source.
   5  *
   6  * @author Ossama Othman @<ossama.othman@@intel.com@>
   7  *
   8  * @copyright @par
   9  * Copyright 2013 Intel Corporation All Rights Reserved.
  10  * @par
  11  * This library is free software; you can redistribute it and/or
  12  * modify it under the terms of the GNU Lesser General Public
  13  * License as published by the Free Software Foundation;
  14  * version 2.1 of the License.
  15  * @par
  16  * This library is distributed in the hope that it will be useful,
  17  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  18  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  19  * Lesser General Public License for more details.
  20  * @par
  21  * You should have received a copy of the GNU Lesser General Public
  22  * License along with this library; if not, write to the Free Software
  23  * Foundation, Inc., 51 Franklin Street, Fifth Floor,
  24  * Boston, MA  02110-1301  USA
  25  */
  26
  27 #include "websocket_server.hpp"
  28 #include "configurator.hpp"
  29 #include "../lib/config.hpp"
  30 #include "../lib/manager.hpp"
  31
  32 #include <stdexcept>
  33
  34
  35
  36 namespace
  37 {
  38   // --------------------------------------------------------------------
  39   // libwebsockets callbacks and related data.
  40   // --------------------------------------------------------------------
  41
  42   int
  43   callback_ivi_settings(libwebsocket_context * context,
  44                         libwebsocket * wsi,
  45                         enum libwebsocket_callback_reasons reason,
  46                         void * /* user */,
  47                         void * in,
  48                         size_t /* len */)
  49   {
  50     using namespace ivi::settings;
  51
  52     manager * const mgr = static_cast<manager *>(
  53         libwebsocket_context_user(context));
  54
  55     switch(reason) {
  56     case LWS_CALLBACK_ESTABLISHED:
  57       // Enable event dispatching to client.
  58       mgr->subscribe_client(wsi);
  59       break;
  60
  61     case LWS_CALLBACK_CLOSED:
  62       // Disable event dispatching to client.
  63       mgr->unsubscribe_client(wsi);
  64       break;
  65
  66     case LWS_CALLBACK_RECEIVE:
  67       // Request has come in from Settings app.  Pass it on to the
  68       // settings manager.
  69       mgr->dispatch(static_cast<char const *>(in), wsi);
  70       break;
  71
  72     default:
  73       break;
  74     }
  75
  76     return 0;
  77   }
  78
  79   struct ws_session_data_type
  80   {
  81   };
  82
  83   libwebsocket_protocols settings_protocols[] = {
  84     {
  85       "http-only",//"ivi-settings-protocol",
  86       callback_ivi_settings,
  87       sizeof(ws_session_data_type),
  88       0,
  89       nullptr,
  90       0
  91     },
  92     {
  93       nullptr,
  94       nullptr,
  95       0,
  96       0,
  97       nullptr,
  98       0
  99     }
 100   };
 101
 102 }
 103
 104 // ----------------------------------------------------------------------
 105
 106 ivi::settings::websocket_server::websocket_server(
 107   ivi::settings::configurator const & config,
 108   ivi::settings::manager & mgr)
 109   : context_(nullptr)
 110 {
 111   lws_context_creation_info info;
 112   info.port  = config.websocket_port();
 113   info.iface = "lo";  // Only allow communication over the loopback
 114                       // interface.
 115
 116   info.protocols  = settings_protocols;
 117   info.extensions = libwebsocket_get_internal_extensions();
 118
 119   info.ssl_cert_filepath        = config.ssl_cert_file();
 120   info.ssl_private_key_filepath = config.ssl_private_key_file();
 121   info.ssl_ca_filepath          = config.ssl_ca_file();
 122   info.ssl_cipher_list          = nullptr;
 123
 124   info.gid = -1;
 125   info.uid = -1;
 126
 127   info.options = 0;
 128
 129   info.user = &mgr;
 130
 131   info.ka_time     = 0;
 132   info.ka_probes   = 0;
 133   info.ka_interval = 0;
 134
 135   lws_set_log_level(LLL_INFO, lwsl_emit_syslog);
 136
 137   context_ = libwebsocket_create_context(&info);
 138   if (context_ == nullptr)
 139     throw std::runtime_error("Unable to initialize websocket.");
 140
 141   std::cout << "\n" PACKAGE_NAME " listening for requests on port "
 142             << info.port << ".\n";
 143 }
 144
 145 ivi::settings::websocket_server::~websocket_server()
 146 {
 147   libwebsocket_context_destroy(context_);
 148 }
 149
 150 void
 151 ivi::settings::websocket_server::run()
 152 {
 153   // Run the libwebsockets event loop with an infinite timeout.  The
 154   // negative timeout causes the underlying call poll() to block
 155   // indefinitely until an event occurs.
 156   constexpr int const timeout = -1;
 157
 158   while (libwebsocket_service(context_, timeout) == 0) {
 159   }
 160 }
 161
 162
 163 // Local Variables:
 164 // mode:c++
 165 // c-basic-offset:2
 166 // indent-tabs-mode: nil
 167 // End: