generic-library/poco
1
0
Fork 0
mirror of https://github.com/pocoproject/poco.git synced 2024-12-17 03:55:59 +01:00
Code Issues Projects Releases Wiki Activity

fix compatibility with DocumentDB

Browse Source
This commit is contained in:
Guenter Obiltschnig 2017-02-13 20:45:53 +01:00
parent 5c0db0bb89
commit 83bc36c923
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
MongoDB/src/Database.cpp
View File

@ -156,7 +156,7 @@ bool Database::authCR(Connection& connection, const std::string& username, const
if (response.documents().size() > 0) if (response.documents().size() > 0)
{ {
Document::Ptr pDoc = response.documents()[0]; Document::Ptr pDoc = response.documents()[0];
if (pDoc->get<double>("ok") != 1) return false; if (pDoc->getInteger("ok") != 1) return false;
nonce = pDoc->get<std::string>("nonce", ""); nonce = pDoc->get<std::string>("nonce", "");
if (nonce.empty()) throw Poco::ProtocolException("no nonce received"); if (nonce.empty()) throw Poco::ProtocolException("no nonce received");
} }
@ -181,7 +181,7 @@ bool Database::authCR(Connection& connection, const std::string& username, const
if (response.documents().size() > 0) if (response.documents().size() > 0)
{ {
Document::Ptr pDoc = response.documents()[0]; Document::Ptr pDoc = response.documents()[0];
return pDoc->get<double>("ok") == 1; return pDoc->getInteger("ok") == 1;
} }
else throw Poco::ProtocolException("empty response for authenticate"); else throw Poco::ProtocolException("empty response for authenticate");
} }
@ -208,7 +208,7 @@ bool Database::authSCRAM(Connection& connection, const std::string& username, co
if (response.documents().size() > 0) if (response.documents().size() > 0)
{ {
Document::Ptr pDoc = response.documents()[0]; Document::Ptr pDoc = response.documents()[0];
if (pDoc->get<double>("ok") == 1) if (pDoc->getInteger("ok") == 1)
{ {
Binary::Ptr pPayload = pDoc->get<Binary::Ptr>("payload"); Binary::Ptr pPayload = pDoc->get<Binary::Ptr>("payload");
serverFirstMsg = pPayload->toRawString(); serverFirstMsg = pPayload->toRawString();
@ -264,7 +264,7 @@ bool Database::authSCRAM(Connection& connection, const std::string& username, co
if (response.documents().size() > 0) if (response.documents().size() > 0)
{ {
Document::Ptr pDoc = response.documents()[0]; Document::Ptr pDoc = response.documents()[0];
if (pDoc->get<double>("ok") == 1) if (pDoc->getInteger("ok") == 1)
{ {
Binary::Ptr pPayload = pDoc->get<Binary::Ptr>("payload"); Binary::Ptr pPayload = pDoc->get<Binary::Ptr>("payload");
serverSecondMsg.assign(reinterpret_cast<const char*>(pPayload->buffer().begin()), pPayload->buffer().size()); serverSecondMsg.assign(reinterpret_cast<const char*>(pPayload->buffer().begin()), pPayload->buffer().size());
@ -297,7 +297,7 @@ bool Database::authSCRAM(Connection& connection, const std::string& username, co
if (response.documents().size() > 0) if (response.documents().size() > 0)
{ {
Document::Ptr pDoc = response.documents()[0]; Document::Ptr pDoc = response.documents()[0];
return pDoc->get<double>("ok") == 1; return pDoc->getInteger("ok") == 1;
} }
else throw Poco::ProtocolException("empty response for saslContinue"); else throw Poco::ProtocolException("empty response for saslContinue");
} }