test ws with react

lay/package.json

@@ -24,7 +24,10 @@
     "license": "MIT",
     "dependencies": {
         "react": "^15.5.4",
-        "react-dom": "^15.5.4"
+        "react-dom": "^15.5.4",
+        "react-redux": "^5.0.5",
+        "redux": "^3.6.0",
+        "redux-thunk": "^2.2.0"
     },
     "devDependencies": {
         "babel-core": "^6.24.1",
@@ -32,6 +35,7 @@
         "babel-preset-env": "^1.5.1",
         "babel-preset-es2015": "^6.24.1",
         "babel-preset-react": "^6.24.1",
+        "babel-preset-stage-0": "^6.24.1",
         "css-loader": "^0.28.2",
         "react-hot-loader": "^3.0.0-beta.7",
         "style-loader": "^0.18.1",
@@ -50,6 +54,7 @@
                     "modules": false
                 }
             ],
+            "stage-0",
             "react"
         ],
         "plugins": [

lay/webpack.config.js

@@ -2,11 +2,11 @@ const webpack = require('webpack');
 const path = require('path');
 
 module.exports = {
-    devtool: 'inline-source-map',
+    devtool: 'cheap-module-inline-source-map',
     entry: {
         'index': [
             'react-hot-loader/patch',
-            'webpack-dev-server/client?http://localhost:2000',
+            'webpack-dev-server/client?http://10.0.0.117:2000',
             'webpack/hot/only-dev-server',
             './src',
         ]

toREST/src/main.cxx

@@ -79,15 +79,19 @@ int main(int argc, char *argv[]) {
     } else {
       if (!message_service.joinable()) {
         message_service = std::thread([&]() {
-          auto connections = end_point.get_connections();
+          while (end_point.get_connections().begin() != end_point.get_connections().end()) {
-          while (connections.begin() != connections.end()) {
             std::vector<libtorrent::alert *> alerts;
             session.pop_alerts(&alerts);
             for (auto alert : alerts) {
-              alert->message();
+              std::cout << alert->message() << std::endl;
-              for (auto &c : connections) {
+              std::cout << alert->what() << std::endl;
+              for (auto &c : end_point.get_connections()) {
                 auto message_stream = std::make_shared<WsServer::SendStream>();
-                *message_stream << nlohmann::json({{"type",alert->message()}});
+                *message_stream << nlohmann::json({
+                  {"type",alert->type()},
+                  {"message",alert->message()},
+                  {"what",alert->what()}
+                  });
                 ws_server.send(c, message_stream);
               }
             }