scottk/wlan-cloud-ucentralsec
1
0
Fork 0
mirror of https://github.com/Telecominfraproject/wlan-cloud-ucentralsec.git synced 2025-10-31 02:37:56 +00:00
Code Issues Packages Projects Releases 10 Wiki Activity

Debugging subscriber service.

Browse Source
This commit is contained in:
stephb9959
2022-05-11 21:59:40 -07:00
parent 40fe54d18a
commit 1ba4bda798
4 changed files with 563 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

51
src/framework/MicroService.h
View File

@@ -83,7 +83,7 @@ using namespace std::chrono_literals;
#include "Poco/Environment.h"
#include "Poco/NObserver.h"
#include "Poco/Net/SocketNotification.h"
#include "Poco/Base64Decoder.h"
#include "cppkafka/cppkafka.h"
#include "framework/OpenWifiTypes.h"
@@ -1121,6 +1121,39 @@ namespace OpenWifi::Utils {
return stream.str();
}
inline bool ExtractBase64CompressedData(const std::string &CompressedData,
std::string &UnCompressedData, uint64_t compress_sz ) {
std::istringstream ifs(CompressedData);
Poco::Base64Decoder b64in(ifs);
std::ostringstream ofs;
Poco::StreamCopier::copyStream(b64in, ofs);
int factor = 20;
unsigned long MaxSize = compress_sz ? (unsigned long) (compress_sz + 5000) : (unsigned long) (ofs.str().size() * factor);
while(true) {
std::vector<uint8_t> UncompressedBuffer(MaxSize);
unsigned long FinalSize = MaxSize;
auto status = uncompress((uint8_t *)&UncompressedBuffer[0], &FinalSize,
(uint8_t *)ofs.str().c_str(), ofs.str().size());
if(status==Z_OK) {
UncompressedBuffer[FinalSize] = 0;
UnCompressedData = (char *)&UncompressedBuffer[0];
return true;
}
if(status==Z_BUF_ERROR) {
if(factor<300) {
factor+=10;
MaxSize = ofs.str().size() * factor;
continue;
} else {
return false;
}
}
return false;
}
return false;
}
}
namespace OpenWifi {
@@ -4356,7 +4389,7 @@ namespace OpenWifi {
Path,
Poco::Net::HTTPMessage::HTTP_1_1);
Poco::Logger::get("REST-CALLER").information(fmt::format("GET: {}", URI.toString()));
Poco::Logger::get("REST-CALLER-GET").information(fmt::format(" {}", URI.toString()));
if(BearerToken.empty()) {
Request.add("X-API-KEY", Svc.AccessKey);
@@ -4397,7 +4430,7 @@ namespace OpenWifi {
}
catch (const Poco::Exception &E)
{
std::cerr << E.displayText() << std::endl;
Poco::Logger::get("REST-CALLER-GET").log(E);
}
return Poco::Net::HTTPServerResponse::HTTP_GATEWAY_TIMEOUT;
}
@@ -4415,7 +4448,7 @@ namespace OpenWifi {
for (const auto &qp : QueryData_)
URI.addQueryParameter(qp.first, qp.second);
Poco::Logger::get("REST-CALLER").information(fmt::format("PUT: {}", URI.toString()));
Poco::Logger::get("REST-CALLER-PUT").information(fmt::format("{}", URI.toString()));
std::string Path(URI.getPathAndQuery());
@@ -4475,7 +4508,7 @@ namespace OpenWifi {
}
catch (const Poco::Exception &E)
{
std::cerr << E.displayText() << std::endl;
Poco::Logger::get("REST-CALLER-PUT").log(E);
}
return Poco::Net::HTTPServerResponse::HTTP_GATEWAY_TIMEOUT;
}
@@ -4494,7 +4527,7 @@ namespace OpenWifi {
for (const auto &qp : QueryData_)
URI.addQueryParameter(qp.first, qp.second);
Poco::Logger::get("REST-CALLER").information(fmt::format("POST: {}", URI.toString()));
Poco::Logger::get("REST-CALLER-POST").information(fmt::format(" {}", URI.toString()));
std::string Path(URI.getPathAndQuery());
@@ -4552,7 +4585,7 @@ namespace OpenWifi {
}
catch (const Poco::Exception &E)
{
std::cerr << E.displayText() << std::endl;
Poco::Logger::get("REST-CALLER-POST").log(E);
}
return Poco::Net::HTTPServerResponse::HTTP_GATEWAY_TIMEOUT;
}
@@ -4570,7 +4603,7 @@ namespace OpenWifi {
for (const auto &qp : QueryData_)
URI.addQueryParameter(qp.first, qp.second);
Poco::Logger::get("REST-CALLER").information(fmt::format("DELETE: {}", URI.toString()));
Poco::Logger::get("REST-CALLER-DELETE").information(fmt::format(" {}", URI.toString()));
std::string Path(URI.getPathAndQuery());
@@ -4604,7 +4637,7 @@ namespace OpenWifi {
}
catch (const Poco::Exception &E)
{
std::cerr << E.displayText() << std::endl;
Poco::Logger::get("REST-CALLER-DELETE").log(E);
}
return Poco::Net::HTTPServerResponse::HTTP_GATEWAY_TIMEOUT;
}