scottk/wlan-cloud-owprov
1
0
Fork 0
mirror of https://github.com/Telecominfraproject/wlan-cloud-owprov.git synced 2025-10-30 18:18:03 +00:00
Code Issues Packages Projects Releases 10 Wiki Activity

Initial

Browse Source
This commit is contained in:
stephb9959
2021-08-18 16:46:13 -07:00
parent b26cbae7cf
commit 0c7fcd5fdc
1 changed files with 190 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

194
src/RESTAPI_inventory_handler.cpp
View File

@@ -3,6 +3,11 @@
// //
#include "RESTAPI_inventory_handler.h" #include "RESTAPI_inventory_handler.h"
#include "RESTAPI_protocol.h"
#include "StorageService.h"
#include "Poco/JSON/Parser.h"
#include "Daemon.h"
#include "RESTAPI_utils.h"
namespace OpenWifi{ namespace OpenWifi{
void RESTAPI_inventory_handler::handleRequest(Poco::Net::HTTPServerRequest &Request, void RESTAPI_inventory_handler::handleRequest(Poco::Net::HTTPServerRequest &Request,
@@ -27,14 +32,195 @@ namespace OpenWifi{
} }
void RESTAPI_inventory_handler::DoGet(Poco::Net::HTTPServerRequest &Request, void RESTAPI_inventory_handler::DoGet(Poco::Net::HTTPServerRequest &Request,
Poco::Net::HTTPServerResponse &Response) {} Poco::Net::HTTPServerResponse &Response) {
try {
std::string SerialNumber = GetBinding(uCentral::RESTAPI::Protocol::SERIALNUMBER,"");
if(SerialNumber.empty()) {
BadRequest(Request, Response, "Missing SerialNumber.");
return;
}
ProvObjects::InventoryTag IT;
if(Storage()->InventoryDB().GetRecord(uCentral::RESTAPI::Protocol::SERIALNUMBER,SerialNumber,IT)) {
Poco::JSON::Object Answer;
IT.to_json(Answer);
ReturnObject(Request, Answer, Response);
return;
} else {
NotFound(Request,Response);
return;
}
} catch(const Poco::Exception &E) {
Logger_.log(E);
}
BadRequest(Request, Response);
}
void RESTAPI_inventory_handler::DoDelete(Poco::Net::HTTPServerRequest &Request, void RESTAPI_inventory_handler::DoDelete(Poco::Net::HTTPServerRequest &Request,
Poco::Net::HTTPServerResponse &Response) {} Poco::Net::HTTPServerResponse &Response) {
try {
std::string SerialNumber = GetBinding(uCentral::RESTAPI::Protocol::SERIALNUMBER,"");
if(SerialNumber.empty()) {
BadRequest(Request, Response, "Missing SerialNumber.");
return;
}
ProvObjects::InventoryTag IT;
if(!Storage()->InventoryDB().GetRecord(uCentral::RESTAPI::Protocol::SERIALNUMBER,SerialNumber,IT)) {
NotFound(Request,Response);
return;
}
if(!IT.entity.empty())
Storage()->EntityDB().DeleteChild(uCentral::RESTAPI::Protocol::ID,IT.entity,IT.info.id);
if(!IT.subEntity.empty())
Storage()->EntityDB().DeleteChild(uCentral::RESTAPI::Protocol::ID,IT.subEntity,IT.info.id);
if(!IT.venue.empty())
Storage()->EntityDB().DeleteChild(uCentral::RESTAPI::Protocol::ID,IT.venue,IT.info.id);
if(!IT.subVenue.empty())
Storage()->EntityDB().DeleteChild(uCentral::RESTAPI::Protocol::ID,IT.subVenue,IT.info.id);
Storage()->InventoryDB().DeleteRecord(uCentral::RESTAPI::Protocol::ID, IT.info.id);
OK(Request, Response);
return;
} catch(const Poco::Exception &E) {
Logger_.log(E);
}
BadRequest(Request, Response);
}
void RESTAPI_inventory_handler::DoPost(Poco::Net::HTTPServerRequest &Request, void RESTAPI_inventory_handler::DoPost(Poco::Net::HTTPServerRequest &Request,
Poco::Net::HTTPServerResponse &Response) {} Poco::Net::HTTPServerResponse &Response) {
try {
std::string SerialNumber = GetBinding(uCentral::RESTAPI::Protocol::SERIALNUMBER,"");
if(SerialNumber.empty()) {
BadRequest(Request, Response, "Missing SerialNumber.");
return;
}
std::string f{uCentral::RESTAPI::Protocol::SERIALNUMBER};
if(Storage()->InventoryDB().Exists(f,SerialNumber)) {
BadRequest(Request,Response, "SerialNumber: " + SerialNumber + " already exists.");
return;
}
Poco::JSON::Parser IncomingParser;
Poco::JSON::Object::Ptr Obj = IncomingParser.parse(Request.stream()).extract<Poco::JSON::Object::Ptr>();
ProvObjects::InventoryTag IT;
if (!IT.from_json(Obj)) {
BadRequest(Request, Response, "Cannot parse incoming POST.");
return;
}
if(IT.entity.empty()) {
BadRequest(Request, Response, "Device must be associated with a top entity.");
return;
}
IT.info.modified = IT.info.created = std::time(nullptr);
f = "id";
if(!IT.entity.empty() && !Storage()->InventoryDB().Exists(f,IT.entity)) {
BadRequest(Request, Response, "Entity: " + IT.entity + " does not exist.");
return;
}
if(!IT.venue.empty() && !Storage()->VenueDB().Exists(f,IT.venue)) {
BadRequest(Request, Response, "Venue: " + IT.venue + " does not exist.");
return;
}
IT.subEntity = IT.subVenue = "";
IT.info.id = uCentral::Daemon()->CreateUUID();
if(Storage()->InventoryDB().CreateRecord(IT)) {
Storage()->EntityDB().AddChild(f,IT.entity,IT.info.id);
if(!IT.venue.empty())
Storage()->VenueDB().AddChild(f,IT.venue,IT.info.id);
Poco::JSON::Object Answer;
IT.to_json(Answer);
ReturnObject(Request, Answer, Response);
return;
}
BadRequest(Request, Response, "Record could not be added.");
return;
} catch(const Poco::Exception &E) {
Logger_.log(E);
}
BadRequest(Request, Response);
}
void RESTAPI_inventory_handler::DoPut(Poco::Net::HTTPServerRequest &Request, void RESTAPI_inventory_handler::DoPut(Poco::Net::HTTPServerRequest &Request,
Poco::Net::HTTPServerResponse &Response) {} Poco::Net::HTTPServerResponse &Response) {
try {
std::string SerialNumber = GetBinding(uCentral::RESTAPI::Protocol::SERIALNUMBER,"");
if(SerialNumber.empty()) {
BadRequest(Request, Response, "Missing SerialNumber.");
return;
}
ProvObjects::InventoryTag ExistingObject;
std::string SN{uCentral::RESTAPI::Protocol::SERIALNUMBER};
if(!Storage()->InventoryDB().GetRecord(SN,SerialNumber,ExistingObject)) {
NotFound(Request, Response);
return;
}
Poco::JSON::Parser IncomingParser;
Poco::JSON::Object::Ptr RawObject = IncomingParser.parse(Request.stream()).extract<Poco::JSON::Object::Ptr>();
if(RawObject->has("notes")) {
uCentral::SecurityObjects::NoteInfoVec NIV;
NIV = uCentral::RESTAPI_utils::to_object_array<uCentral::SecurityObjects::NoteInfo>(RawObject->get("notes").toString());
for(auto const &i:NIV) {
uCentral::SecurityObjects::NoteInfo ii{.created=(uint64_t)std::time(nullptr), .createdBy=UserInfo_.userinfo.email, .note=i.note};
ExistingObject.info.notes.push_back(ii);
}
}
if(RawObject->has("name"))
ExistingObject.info.name = RawObject->get("name").toString();
if(RawObject->has("description"))
ExistingObject.info.description = RawObject->get("description").toString();
ExistingObject.info.modified = std::time(nullptr);
// if we are changing venues...
std::string ID{"id"};
if(RawObject->has("entity")) {
std::string Entity{RawObject->get("entity").toString()};
if(!Storage()->EntityDB().Exists(ID,Entity)) {
BadRequest(Request, Response, "Entity association does not exist.");
return;
}
if(Entity!=ExistingObject.entity) {
Storage()->EntityDB().DeleteChild(ID, ExistingObject.entity, ExistingObject.info.id);
Storage()->EntityDB().AddChild(ID,Entity,ExistingObject.info.id);
}
}
if(RawObject->has("venue")) {
std::string Venue{RawObject->get("venue").toString()};
if(!Storage()->VenueDB().Exists(ID,Venue)) {
BadRequest(Request, Response, "Venue association does not exist.");
return;
}
if(Venue!=ExistingObject.venue) {
if(!ExistingObject.venue.empty())
Storage()->VenueDB().DeleteChild(ID, ExistingObject.venue, ExistingObject.info.id);
Storage()->VenueDB().AddChild(ID,Venue,ExistingObject.info.id);
}
}
if(RawObject->has("deviceType")) {
std::string DeviceType{RawObject->get("deviceType").toString()};
ExistingObject.deviceType = DeviceType;
}
if(Storage()->InventoryDB().UpdateRecord(ID, ExistingObject.info.id, ExistingObject)) {
Poco::JSON::Object Answer;
ExistingObject.to_json(Answer);
ReturnObject(Request, Answer, Response);
return;
}
} catch(const Poco::Exception &E) {
Logger_.log(E);
}
BadRequest(Request, Response);
}
} }