mirror of
https://github.com/Telecominfraproject/wlan-cloud-ucentralfms.git
synced 2025-11-03 12:18:00 +00:00
RESTAPI refactor
This commit is contained in:
@@ -10,100 +10,93 @@
|
||||
namespace OpenWifi {
|
||||
void
|
||||
RESTAPI_firmwaresHandler::DoGet() {
|
||||
try {
|
||||
std::string DeviceType = GetParameter(RESTAPI::Protocol::DEVICETYPE, "");
|
||||
bool IdOnly = GetBoolParameter(RESTAPI::Protocol::IDONLY, false);
|
||||
bool RevisionSet = GetBoolParameter(RESTAPI::Protocol::REVISIONSET, false);
|
||||
bool LatestOnly = GetBoolParameter(RESTAPI::Protocol::LATESTONLY, false);
|
||||
bool DeviceSet = GetBoolParameter(RESTAPI::Protocol::DEVICESET, false);
|
||||
|
||||
InitQueryBlock();
|
||||
std::string DeviceType = GetParameter(RESTAPI::Protocol::DEVICETYPE, "");
|
||||
bool IdOnly = GetBoolParameter(RESTAPI::Protocol::IDONLY, false);
|
||||
bool RevisionSet = GetBoolParameter(RESTAPI::Protocol::REVISIONSET, false);
|
||||
bool LatestOnly = GetBoolParameter(RESTAPI::Protocol::LATESTONLY, false);
|
||||
bool DeviceSet = GetBoolParameter(RESTAPI::Protocol::DEVICESET, false);
|
||||
|
||||
if(DeviceSet) {
|
||||
auto Revisions = LatestFirmwareCache()->GetDevices();
|
||||
Poco::JSON::Array ObjectArray;
|
||||
for (const auto &i:Revisions) {
|
||||
ObjectArray.add(i);
|
||||
}
|
||||
Poco::JSON::Object RetObj;
|
||||
RetObj.set(RESTAPI::Protocol::DEVICETYPES, ObjectArray);
|
||||
ReturnObject(RetObj);
|
||||
return;
|
||||
if(DeviceSet) {
|
||||
auto Revisions = LatestFirmwareCache()->GetDevices();
|
||||
Poco::JSON::Array ObjectArray;
|
||||
for (const auto &i:Revisions) {
|
||||
ObjectArray.add(i);
|
||||
}
|
||||
Poco::JSON::Object RetObj;
|
||||
RetObj.set(RESTAPI::Protocol::DEVICETYPES, ObjectArray);
|
||||
ReturnObject(RetObj);
|
||||
return;
|
||||
}
|
||||
|
||||
if(RevisionSet) {
|
||||
auto Revisions = LatestFirmwareCache()->GetRevisions();
|
||||
Poco::JSON::Array ObjectArray;
|
||||
for (const auto &i:Revisions) {
|
||||
ObjectArray.add(i);
|
||||
}
|
||||
Poco::JSON::Object RetObj;
|
||||
RetObj.set(RESTAPI::Protocol::REVISIONS, ObjectArray);
|
||||
ReturnObject(RetObj);
|
||||
return;
|
||||
if(RevisionSet) {
|
||||
auto Revisions = LatestFirmwareCache()->GetRevisions();
|
||||
Poco::JSON::Array ObjectArray;
|
||||
for (const auto &i:Revisions) {
|
||||
ObjectArray.add(i);
|
||||
}
|
||||
Poco::JSON::Object RetObj;
|
||||
RetObj.set(RESTAPI::Protocol::REVISIONS, ObjectArray);
|
||||
ReturnObject(RetObj);
|
||||
return;
|
||||
}
|
||||
|
||||
// special cases: if latestOnly and deviceType
|
||||
if(!DeviceType.empty()) {
|
||||
if(LatestOnly) {
|
||||
LatestFirmwareCacheEntry Entry;
|
||||
if(!LatestFirmwareCache()->FindLatestFirmware(DeviceType,Entry)) {
|
||||
NotFound();
|
||||
return;
|
||||
}
|
||||
|
||||
FMSObjects::Firmware F;
|
||||
if(Storage()->GetFirmware(Entry.Id,F)) {
|
||||
Poco::JSON::Object Answer;
|
||||
F.to_json(Answer);
|
||||
ReturnObject(Answer);
|
||||
return;
|
||||
}
|
||||
// special cases: if latestOnly and deviceType
|
||||
if(!DeviceType.empty()) {
|
||||
if(LatestOnly) {
|
||||
LatestFirmwareCacheEntry Entry;
|
||||
if(!LatestFirmwareCache()->FindLatestFirmware(DeviceType,Entry)) {
|
||||
NotFound();
|
||||
return;
|
||||
} else {
|
||||
std::vector<FMSObjects::Firmware> List;
|
||||
if (Storage()->GetFirmwares(QB_.Offset, QB_.Limit, DeviceType, List)) {
|
||||
Poco::JSON::Array ObjectArray;
|
||||
for (const auto &i:List) {
|
||||
if(IdOnly) {
|
||||
ObjectArray.add(i.id);
|
||||
} else {
|
||||
Poco::JSON::Object Obj;
|
||||
i.to_json(Obj);
|
||||
ObjectArray.add(Obj);
|
||||
}
|
||||
}
|
||||
Poco::JSON::Object RetObj;
|
||||
RetObj.set(RESTAPI::Protocol::FIRMWARES, ObjectArray);
|
||||
ReturnObject(RetObj);
|
||||
return;
|
||||
} else {
|
||||
NotFound();
|
||||
return;
|
||||
}
|
||||
}
|
||||
}
|
||||
std::vector<FMSObjects::Firmware> List;
|
||||
if (Storage()->GetFirmwares(QB_.Offset, QB_.Limit, DeviceType, List)) {
|
||||
Poco::JSON::Array ObjectArray;
|
||||
for (const auto &i:List) {
|
||||
if(IdOnly) {
|
||||
ObjectArray.add(i.id);
|
||||
} else {
|
||||
Poco::JSON::Object Obj;
|
||||
i.to_json(Obj);
|
||||
ObjectArray.add(Obj);
|
||||
}
|
||||
|
||||
FMSObjects::Firmware F;
|
||||
if(Storage()->GetFirmware(Entry.Id,F)) {
|
||||
Poco::JSON::Object Answer;
|
||||
F.to_json(Answer);
|
||||
ReturnObject(Answer);
|
||||
return;
|
||||
}
|
||||
Poco::JSON::Object RetObj;
|
||||
RetObj.set(RESTAPI::Protocol::FIRMWARES, ObjectArray);
|
||||
ReturnObject(RetObj);
|
||||
NotFound();
|
||||
return;
|
||||
} else {
|
||||
std::vector<FMSObjects::Firmware> List;
|
||||
if (Storage()->GetFirmwares(QB_.Offset, QB_.Limit, DeviceType, List)) {
|
||||
Poco::JSON::Array ObjectArray;
|
||||
for (const auto &i:List) {
|
||||
if(IdOnly) {
|
||||
ObjectArray.add(i.id);
|
||||
} else {
|
||||
Poco::JSON::Object Obj;
|
||||
i.to_json(Obj);
|
||||
ObjectArray.add(Obj);
|
||||
}
|
||||
}
|
||||
Poco::JSON::Object RetObj;
|
||||
RetObj.set(RESTAPI::Protocol::FIRMWARES, ObjectArray);
|
||||
ReturnObject(RetObj);
|
||||
return;
|
||||
} else {
|
||||
NotFound();
|
||||
return;
|
||||
}
|
||||
}
|
||||
} catch (const Poco::Exception &E) {
|
||||
Logger_.log(E);
|
||||
}
|
||||
BadRequest("Internal error.");
|
||||
|
||||
std::vector<FMSObjects::Firmware> List;
|
||||
Poco::JSON::Array ObjectArray;
|
||||
Poco::JSON::Object Answer;
|
||||
if (Storage()->GetFirmwares(QB_.Offset, QB_.Limit, DeviceType, List)) {
|
||||
for (const auto &i:List) {
|
||||
if(IdOnly) {
|
||||
ObjectArray.add(i.id);
|
||||
} else {
|
||||
Poco::JSON::Object Obj;
|
||||
i.to_json(Obj);
|
||||
ObjectArray.add(Obj);
|
||||
}
|
||||
}
|
||||
}
|
||||
Answer.set(RESTAPI::Protocol::FIRMWARES, ObjectArray);
|
||||
ReturnObject(Answer);
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user