scottk/wlan-cloud-ucentralgw
1
0
Fork 0
mirror of https://github.com/Telecominfraproject/wlan-cloud-ucentralgw.git synced 2025-11-05 21:28:02 +00:00
Code Issues Packages Projects Releases 10 Wiki Activity

Adding PING command and execution time for RPC.

Browse Source
This commit is contained in:
stephb9959
2022-01-08 15:33:10 -08:00
parent 1d0a0a0bd0
commit 0bf0186e50
13 changed files with 167 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

52
src/RESTAPI/RESTAPI_device_commandHandler.cpp
View File

@@ -111,6 +111,8 @@ namespace OpenWifi {
return EventQueue();
} else if (Command_ == RESTAPI::Protocol::TELEMETRY) {
return Telemetry();
} else if (Command_ == RESTAPI::Protocol::PING) {
return Ping();
} else {
return BadRequest(RESTAPI::Errors::InvalidCommand);
}
@@ -190,6 +192,56 @@ void RESTAPI_device_commandHandler::DeleteStatistics() {
NotFound();
}
void RESTAPI_device_commandHandler::Ping() {
Logger_.information(Poco::format("DELETE-STATISTICS: user=%s serial=%s", UserInfo_.userinfo.email,SerialNumber_));
auto Obj = ParseStream();
if (Obj->has(RESTAPI::Protocol::SERIALNUMBER)) {
auto SNum = Obj->get(RESTAPI::Protocol::SERIALNUMBER).toString();
if (SerialNumber_ != SNum) {
return BadRequest(RESTAPI::Errors::SerialNumberMismatch);
}
GWObjects::CommandDetails Cmd;
Cmd.SerialNumber = SerialNumber_;
Cmd.UUID = MicroService::CreateUUID();
Cmd.SubmittedBy = UserInfo_.webtoken.username_;
Cmd.Command = uCentralProtocol::PING;
Cmd.RunAt = 0;
Poco::JSON::Object Params;
Params.set(uCentralProtocol::SERIAL, SerialNumber_);
std::stringstream ParamStream;
Params.stringify(ParamStream);
Cmd.Details = ParamStream.str();
RESTAPI_RPC::WaitForCommand(Cmd, Params, *Request, *Response, 60000ms, nullptr, this, Logger_);
GWObjects::CommandDetails Cmd2;
if(StorageService()->GetCommand(Cmd.UUID,Cmd2)) {
Poco::JSON::Object Answer;
Answer.set("latency", Cmd2.executionTime);
Answer.set("serialNumber", SerialNumber_);
Answer.set("currentUTCTime", std::chrono::duration_cast<std::chrono::milliseconds>(
std::chrono::system_clock::now().time_since_epoch()).count());
try {
Poco::JSON::Parser P;
auto ResponseObj = P.parse(Cmd2.Results).extract<Poco::JSON::Object::Ptr>();
if(ResponseObj->has("results")) {
auto Results = ResponseObj->get("results").extract<Poco::JSON::Object::Ptr>();
if(Results->has("deviceUTCTime"))
Answer.set("deviceUTCTime",Results->has("deviceUTCTime"));
}
} catch (...) {
}
return ReturnObject(Answer);
}
return BadRequest("Command could not be performed.");
}
return BadRequest(RESTAPI::Errors::MissingSerialNumber);
}
void RESTAPI_device_commandHandler::GetStatus() {
GWObjects::ConnectionState State;