backend: update JsonParam sends Ok to websocket on setting value successful, uWebsocketserver outputs error on create socket fail

Author: JeyRunner

catflow/cpp/include/server/ApiuWebsocketsServer.h

@@ -88,6 +88,9 @@ class ApiuWebsocketsServer: public ApiServer
  }
  });
 
+ hub.onError([this](int type){
+ err("err on port " + to_string(type));
+ });
  }
 
  void start() override
@@ -96,7 +99,7 @@ class ApiuWebsocketsServer: public ApiServer
  serverThread = new thread([this](){
  if (hub.listen(Catflow::port)) {
  // run is blocking
- ok("listen for webSocket connection on port " + to_string(Catflow::port));
+ ok("listen for webSocket/http connection on port " + to_string(Catflow::port));
 
  // cache web files
  if (Catflow::httpServerPath.size() > 0) {
@@ -127,6 +130,7 @@ class ApiuWebsocketsServer: public ApiServer
 
  hub.run();
  } else {
+ fatal("listen for webSocket/http connection on port " + to_string(Catflow::port));
  }
  });
  ok("created serverWebsocket thread");

catflow/cpp/source/ApiJsonObject.cpp

@@ -118,6 +118,7 @@ ApiRespond *ApiJsonObject::processApi(ApiRequest request)
  try {
  // update own params by json, fromJson() will send update to subscribers but will skip sender
  this->fromJson(request.data, *request.client);
+ return new ApiRespondOk(request);
  } catch (JsonObjectException &e) {
  return new ApiRespondError(e.what(), request, routeString);
  }

trainServer/source/source/NeuralNetwork.cpp

@@ -171,20 +171,6 @@ NeuralNetwork::NeuralNetwork(DataStructure *structure)
  graphBindIo();
 }
 
-struct OpOrSymbol {
- Symbol symbol;
- Operator op;
- bool isSymbol = false;
-
- OpOrSymbol(Symbol sym): op(""){
- isSymbol = true;
- symbol = sym;
- }
-
- OpOrSymbol(Operator o): op(o){
- isSymbol = false;
- }
-};
 
 void NeuralNetwork::setModelDefinition(vector<OperationNode> model)
 {

trainServer/source/source/main.cpp

@@ -49,7 +49,7 @@ int main(int argc, char *argv[])
  return 0;
  }
 
- string hmtlFilesPath = cliArgs["html-files-path"].as<string>();
+ string htmlFilesPath = cliArgs["html-files-path"].as<string>();
  string configStorePath = cliArgs["store-path"].as<string>();
  int port = cliArgs["port"].as<int>();
 
@@ -76,7 +76,7 @@ int main(int argc, char *argv[])
  Catflow::setApiRootRoute(apiRoot);
  Catflow::start<ApiuWebsocketsServer>(
  port,
- hmtlFilesPath // webserver root
+ htmlFilesPath // webserver root
  );
 
  // start blocking taskManager