diff --git a/common/cpp/src/system_io/system_io.cpp b/common/cpp/src/system_io/system_io.cpp
index 7dd9819da5710221a8ce433cecb0eea6d8675e2c..77a7bf0b718359b1f05d50b2e923ef7a04ee3e3c 100644
--- a/common/cpp/src/system_io/system_io.cpp
+++ b/common/cpp/src/system_io/system_io.cpp
@@ -152,6 +152,7 @@ Error SystemIO::WriteDataToFile(const std::string& root_folder, const std::strin
full_name = fname;
}
Error err;
+ //todo:: add IO_OPEN_MODE_SET_LENGTH_0 + tests
auto fd = Open(full_name, IO_OPEN_MODE_CREATE | IO_OPEN_MODE_RW, &err);
if (err == IOErrorTemplates::kFileNotFound && create_directories) {
size_t pos = fname.rfind(kPathSeparator);
diff --git a/receiver/src/request_handler_authorize.cpp b/receiver/src/request_handler_authorize.cpp
index 8cc5a5e50da7dc54ee6e211a827fccbbb3a8268b..576f1bd8eedf27e5b02ca1ad1619f83c0f9e4e9d 100644
--- a/receiver/src/request_handler_authorize.cpp
+++ b/receiver/src/request_handler_authorize.cpp
@@ -11,7 +11,7 @@ namespace asapo {
std::string RequestHandlerAuthorize::GetRequestString(const Request* request, const char* source_credentials) const {
std::string request_string = std::string("{\"SourceCredentials\":\"") +
- source_credentials + "\",\"OriginHost\":\"" + request->GetOriginUri() + "\"}";
+ source_credentials + "\",\"OriginHost\":\"" + request->GetOriginUri() + "\"}";
return request_string;
}
@@ -49,7 +49,7 @@ Error RequestHandlerAuthorize::Authorize(Request* request, const char* source_cr
return ErrorFromServerResponse(err, code);
} else {
log__->Debug(std::string("authorized connection from ") + request->GetOriginUri() + " beamline: " +
- beamline_ + ", beamtime id: " + beamtime_id_+", stream: "+stream_);
+ beamline_ + ", beamtime id: " + beamtime_id_ + ", stream: " + stream_);
}
last_updated_ = system_clock::now();
diff --git a/receiver/src/request_handler_db.cpp b/receiver/src/request_handler_db.cpp
index 874c5846e260d9e16cbcdd0359998ade9db12b76..9b0efb526884148de4080f44a93411fb7df63871 100644
--- a/receiver/src/request_handler_db.cpp
+++ b/receiver/src/request_handler_db.cpp
@@ -10,7 +10,7 @@ Error RequestHandlerDb::ProcessRequest(Request* request) const {
db_name_ = request->GetBeamtimeId();
auto stream = request->GetStream();
if (stream != "detector") {
- db_name_+="_"+stream;
+ db_name_ += "_" + stream;
}
}
diff --git a/receiver/unittests/test_request_handler_authorizer.cpp b/receiver/unittests/test_request_handler_authorizer.cpp
index cd3f455036e74c83e806009bdeaab99e25eb2a47..1c7565ae904f5650c920f5dbb0cc405bc779440c 100644
--- a/receiver/unittests/test_request_handler_authorizer.cpp
+++ b/receiver/unittests/test_request_handler_authorizer.cpp
@@ -69,7 +69,8 @@ class AuthorizerHandlerTests : public Test {
std::string expected_beamline = "beamline";
std::string expected_producer_uri = "producer_uri";
std::string expected_authorization_server = "authorizer_host";
- std::string expect_request_string = std::string("{\"SourceCredentials\":\"") + expected_source_credentials + "\",\"OriginHost\":\"" +
+ std::string expect_request_string = std::string("{\"SourceCredentials\":\"") + expected_source_credentials +
+ "\",\"OriginHost\":\"" +
expected_producer_uri + "\"}";
void MockRequestData();
@@ -104,8 +105,8 @@ class AuthorizerHandlerTests : public Test {
DoAll(SetArgPointee<3>(nullptr),
SetArgPointee<2>(code),
Return("{\"BeamtimeId\":\"" + expected_beamtime_id +
- "\",\"Stream\":" + "\"" + expected_stream +
- "\",\"Beamline\":" + "\"" + expected_beamline + "\"}")
+ "\",\"Stream\":" + "\"" + expected_stream +
+ "\",\"Beamline\":" + "\"" + expected_beamline + "\"}")
));
if (code != HttpCode::OK) {
EXPECT_CALL(mock_logger, Error(AllOf(HasSubstr("failure authorizing"),
diff --git a/receiver/unittests/test_request_handler_db.cpp b/receiver/unittests/test_request_handler_db.cpp
index b058c57dd73bf38ae708d00f484f80fb5d398ea5..4aa86641f075299024ba70bed7b6c7eecf04d994 100644
--- a/receiver/unittests/test_request_handler_db.cpp
+++ b/receiver/unittests/test_request_handler_db.cpp
@@ -105,12 +105,13 @@ TEST_F(DbHandlerTests, ProcessRequestCallsConnectDbWhenNotConnected) {
;
EXPECT_CALL(*mock_request, GetStream())
- .WillOnce(ReturnRef(expected_stream))
- ;
+ .WillOnce(ReturnRef(expected_stream))
+ ;
- EXPECT_CALL(mock_db, Connect_t("127.0.0.1:27017", expected_beamtime_id+"_"+expected_stream, expected_collection_name)).
+ EXPECT_CALL(mock_db, Connect_t("127.0.0.1:27017", expected_beamtime_id + "_" + expected_stream,
+ expected_collection_name)).
WillOnce(testing::Return(nullptr));
auto err = handler.ProcessRequest(mock_request.get());
@@ -123,16 +124,16 @@ TEST_F(DbHandlerTests, ProcessRequestUsesCorrectDbNameForDetector) {
EXPECT_CALL(*mock_request, GetBeamtimeId())
- .WillOnce(ReturnRef(expected_beamtime_id))
- ;
+ .WillOnce(ReturnRef(expected_beamtime_id))
+ ;
EXPECT_CALL(*mock_request, GetStream())
- .WillOnce(ReturnRef(expected_default_stream))
- ;
+ .WillOnce(ReturnRef(expected_default_stream))
+ ;
EXPECT_CALL(mock_db, Connect_t("127.0.0.1:27017", expected_beamtime_id, expected_collection_name)).
- WillOnce(testing::Return(nullptr));
+ WillOnce(testing::Return(nullptr));
auto err = handler.ProcessRequest(mock_request.get());
ASSERT_THAT(err, Eq(nullptr));
diff --git a/receiver/unittests/test_request_handler_db_meta_writer.cpp b/receiver/unittests/test_request_handler_db_meta_writer.cpp
index 8e851db8c8b9ce4a8f1db4f947fa4e6eadd4aa82..00aaee3cec84fa5604e891b963c63fc19a58d7d1 100644
--- a/receiver/unittests/test_request_handler_db_meta_writer.cpp
+++ b/receiver/unittests/test_request_handler_db_meta_writer.cpp
@@ -92,11 +92,12 @@ TEST_F(DbMetaWriterHandlerTests, CallsUpdate) {
;
EXPECT_CALL(*mock_request, GetStream())
- .WillOnce(ReturnRef(expected_stream))
- ;
+ .WillOnce(ReturnRef(expected_stream))
+ ;
- EXPECT_CALL(mock_db, Connect_t(config.broker_db_uri, expected_beamtime_id+"_"+expected_stream, expected_collection_name)).
+ EXPECT_CALL(mock_db, Connect_t(config.broker_db_uri, expected_beamtime_id + "_" + expected_stream,
+ expected_collection_name)).
WillOnce(testing::Return(nullptr));
diff --git a/receiver/unittests/test_request_handler_db_writer.cpp b/receiver/unittests/test_request_handler_db_writer.cpp
index 2ba6e289f2b28886bc7bb3b49ff2bb4f642eefa7..1f93f42e5df214352be47fbcd0715528e812c71e 100644
--- a/receiver/unittests/test_request_handler_db_writer.cpp
+++ b/receiver/unittests/test_request_handler_db_writer.cpp
@@ -88,9 +88,9 @@ class DbWriterHandlerTests : public Test {
ON_CALL(*mock_request, GetBeamtimeId()).WillByDefault(ReturnRef(expected_beamtime_id));
}
- void ExpectRequestParams(asapo::Opcode op_code,const std::string& stream);
+ void ExpectRequestParams(asapo::Opcode op_code, const std::string& stream);
- FileInfo PrepareFileInfo();
+ FileInfo PrepareFileInfo();
void TearDown() override {
handler.db_client__.release();
}
@@ -110,14 +110,14 @@ MATCHER_P(CompareFileInfo, file, "") {
}
-void DbWriterHandlerTests::ExpectRequestParams(asapo::Opcode op_code,const std::string& stream) {
+void DbWriterHandlerTests::ExpectRequestParams(asapo::Opcode op_code, const std::string& stream) {
EXPECT_CALL(*mock_request, GetBeamtimeId())
.WillOnce(ReturnRef(expected_beamtime_id))
;
EXPECT_CALL(*mock_request, GetStream())
- .WillOnce(ReturnRef(stream))
- ;
+ .WillOnce(ReturnRef(stream))
+ ;
EXPECT_CALL(*mock_request, GetSlotId())
@@ -126,7 +126,7 @@ void DbWriterHandlerTests::ExpectRequestParams(asapo::Opcode op_code,const std::
std::string db_name = expected_beamtime_id;
if (stream != "detector") {
- db_name +="_"+stream;
+ db_name += "_" + stream;
}
EXPECT_CALL(mock_db, Connect_t(config.broker_db_uri, db_name, expected_collection_name)).
WillOnce(testing::Return(nullptr));
@@ -174,7 +174,7 @@ FileInfo DbWriterHandlerTests::PrepareFileInfo() {
TEST_F(DbWriterHandlerTests, CallsInsert) {
- ExpectRequestParams(asapo::Opcode::kOpcodeTransferData,expected_stream);
+ ExpectRequestParams(asapo::Opcode::kOpcodeTransferData, expected_stream);
auto file_info = PrepareFileInfo();
EXPECT_CALL(mock_db, Insert_t(CompareFileInfo(file_info), _)).
@@ -194,7 +194,7 @@ TEST_F(DbWriterHandlerTests, CallsInsert) {
TEST_F(DbWriterHandlerTests, CallsInsertSubset) {
- ExpectRequestParams(asapo::Opcode::kOpcodeTransferSubsetData,expected_default_stream);
+ ExpectRequestParams(asapo::Opcode::kOpcodeTransferSubsetData, expected_default_stream);
auto file_info = PrepareFileInfo();
diff --git a/worker/api/cpp/src/server_data_broker.cpp b/worker/api/cpp/src/server_data_broker.cpp
index 09daf5952789776ee9377b19f084a23ea75a6b09..6f00f55290af55dad743db0cd0c6c8816600f47a 100644
--- a/worker/api/cpp/src/server_data_broker.cpp
+++ b/worker/api/cpp/src/server_data_broker.cpp
@@ -38,7 +38,7 @@ ServerDataBroker::ServerDataBroker(std::string server_uri,
SourceCredentials source) :
io__{GenerateDefaultIO()}, httpclient__{DefaultHttpClient()},
net_client__{new TcpClient()},
-server_uri_{std::move(server_uri)}, source_path_{std::move(source_path)}, source_credentials_{std::move(source)} {
+server_uri_{std::move(server_uri)}, source_path_{std::move(source_path)}, source_credentials_(std::move(source)) {
if (source_credentials_.stream.empty()) {
source_credentials_.stream = SourceCredentials::kDefaultStream;