diff --git a/.docker/Dockerfile b/.docker/Dockerfile
index efd33f3b30beaa153b749ac6cfb669f494cff66e..255c3b703e12f063223522803a8ecc1aa7dac66e 100644
--- a/.docker/Dockerfile
+++ b/.docker/Dockerfile
@@ -13,6 +13,7 @@ WORKDIR /caosdb-cppinttest
RUN rm -rf .git
COPY .docker/caosdb-client.json /caosdb-client.json
+COPY .docker/linkahead-client.json /linkahead-client.json
# Build and run tests.
# If no other command is given to the Docker image
diff --git a/.docker/cert.sh b/.docker/cert.sh
index efc660ba784924cca0b21515d3c846348b1fa628..af412ff6f2e2fb29820c3cde8971d8a19826602c 100755
--- a/.docker/cert.sh
+++ b/.docker/cert.sh
@@ -1,7 +1,7 @@
#!/bin/bash
# ** header v3.0
-# This file is a part of the CaosDB Project.
+# This file is a part of the LinkAhead Project.
#
# Copyright (C) 2019 Daniel Hornung, Göttingen
#
diff --git a/.docker/linkahead-client.json b/.docker/linkahead-client.json
new file mode 100644
index 0000000000000000000000000000000000000000..5da162e2561da384892fc62e02f2fdaddad2e6aa
--- /dev/null
+++ b/.docker/linkahead-client.json
@@ -0,0 +1,14 @@
+{
+ "connections": {
+ "default": {
+ "host": "caosdb-server",
+ "port": 8443,
+ "server_certificate_path": "/cert/caosdb.cert.pem",
+ "authentication": {
+ "type": "plain",
+ "username": "admin",
+ "password": "caosdb"
+ }
+ }
+ }
+}
diff --git a/.docker/tester.yml b/.docker/tester.yml
index 764fcd63475a8baa1b2e8aed533336f1326c161f..f9010d5b3acd1f059e1f119986d4218514fb7a4e 100644
--- a/.docker/tester.yml
+++ b/.docker/tester.yml
@@ -5,7 +5,7 @@ services:
environment:
CAOSDB_SERVER_HOST: caosdb-server
CAOSDB_SERVER_CERT: /cert/caosdb.cert.pem
- CAOSDB_CLIENT_CONFIGURATION: /caosdb-client.json
+ LINKAHEAD_CLIENT_CONFIGURATION: /linkahead-client.json
networks:
- docker_caosnet
volumes:
diff --git a/.gitignore b/.gitignore
index 425118edef63bd4aaf7962d39f6db9db776187a3..0acf6ce66251eecdeb4883105a64b5030ee03a3c 100644
--- a/.gitignore
+++ b/.gitignore
@@ -1,6 +1,6 @@
# General
build/
-include/libcaosdbConfig.h
+include/liblinkaheadConfig.h
cert/
# CMake
diff --git a/.gitlab-ci.yml b/.gitlab-ci.yml
index 7db556ade9e65934034e1a02d376f34e663274da..d731c9f8493e2c43fccc93ac931512beda2d5ed9 100644
--- a/.gitlab-ci.yml
+++ b/.gitlab-ci.yml
@@ -1,5 +1,5 @@
#
-# This file is a part of the CaosDB Project.
+# This file is a part of the LinkAhead Project.
#
# Copyright (C) 2018 Research Group Biomedical Physics,
# Max-Planck-Institute for Dynamics and Self-Organization Göttingen
diff --git a/CMakeLists.txt b/CMakeLists.txt
index 7f9f58f309e395676313e9e2b683895e4e87f920..2e970c9544fcdf995648b40b010005a814311f8f 100644
--- a/CMakeLists.txt
+++ b/CMakeLists.txt
@@ -1,5 +1,5 @@
#
-# This file is a part of the CaosDB Project.
+# This file is a part of the LinkAhead Project.
#
# Copyright (C) 2021 Timm Fitschen <t.fitschen@indiscale.com>
# Copyright (C) 2021 IndiScale GmbH <info@indiscale.com>
@@ -20,8 +20,8 @@
cmake_minimum_required(VERSION 3.13)
-project(libcaosdb_inttests
- DESCRIPTION "Integration tests for the C++ client libraries of the CaosDB project which run against the CaosDB server."
+project(liblinkahead_inttests
+ DESCRIPTION "Integration tests for the C++ client libraries of the LinkAhead project which run against the LinkAhead server."
LANGUAGES CXX)
set(CMAKE_CXX_STANDARD 17)
diff --git a/CMakeUserPresets.json b/CMakeUserPresets.json
new file mode 100644
index 0000000000000000000000000000000000000000..71aeacec3faad5d62b85b6b6d0bb128875892286
--- /dev/null
+++ b/CMakeUserPresets.json
@@ -0,0 +1,9 @@
+{
+ "version": 4,
+ "vendor": {
+ "conan": {}
+ },
+ "include": [
+ "build/Release/generators/CMakePresets.json"
+ ]
+}
\ No newline at end of file
diff --git a/README.md b/README.md
index 62f212d73fe34679b36c26c2a6e5f0404113e223..e1680f34fb9064245ffe386a692a14a6d54a7f8f 100644
--- a/README.md
+++ b/README.md
@@ -1,6 +1,6 @@
-# caosdb-cppinttest
+# linkahead-cppinttest
-Integration tests for caosdb-cpplib and the caosdb-server
+Integration tests for linkahead-cpplib and the linkahead-server
# Dependencies
@@ -14,7 +14,7 @@ Integration tests for caosdb-cpplib and the caosdb-server
## Prerequisites
-Create a local conan package from the caosdb-cpplib repository
+Create a local conan package from the linkahead-cpplib repository
## Build & Execution
@@ -28,7 +28,7 @@ or manually via
2. `cmake --preset conan-<debug/release>`
3. `cd build <Debug/Release>`
4. `cmake --build .`
-5. Provide client configuration at `~/.caosdb-client.json` or via any other method described in the docs.
+5. Provide client configuration at `~/.linkahead-client.json` or via any other method described in the docs.
6. There are tests which need access to the server's certificate file. Define
path to the pem file in the `CAOSDB_SERVER_CERT` environment variable.
7. Run with `ctest` in the build directory.
diff --git a/conanfile.txt b/conanfile.txt
index 05e1980285d6357168d97392f1d828bcc2074fe5..0066b0b6fbd30284cb147e3fa810873d71b3403f 100644
--- a/conanfile.txt
+++ b/conanfile.txt
@@ -1,5 +1,5 @@
[requires]
-caosdb/[>=0.3.0-dev, include_prerelease=True]
+linkahead/[>=0.3.0-dev, include_prerelease=True]
protobuf/3.21.12
grpc/1.48.4
@@ -11,7 +11,7 @@ CMakeDeps
CMakeToolchain
[options]
-caosdb*:build_acm=True
+linkahead*:build_acm=True
[layout]
cmake_layout
\ No newline at end of file
diff --git a/test/CMakeLists.txt b/test/CMakeLists.txt
index 1b89cfdb7a130d6741a51f152f056400bd2c0b60..4c10d0de2c46c7738048404f04242eefa118afd7 100644
--- a/test/CMakeLists.txt
+++ b/test/CMakeLists.txt
@@ -1,5 +1,5 @@
#
-# This file is a part of the CaosDB Project.
+# This file is a part of the LinkAhead Project.
#
# Copyright (C) 2021 Timm Fitschen <t.fitschen@indiscale.com>
# Copyright (C) 2021 IndiScale GmbH <info@indiscale.com>
@@ -27,7 +27,7 @@ set(test_cases
test_list_properties
test_properties
test_transaction
- test_ccaosdb
+ test_clinkahead
test_issues
test_user
test_select
@@ -102,7 +102,7 @@ endif()
# add special cmake functions for gtest
include(GoogleTest REQUIRED)
-find_package(caosdb)
+find_package(linkahead)
find_package(GTest)
find_package(gRPC)
find_package(protobuf)
@@ -114,11 +114,8 @@ foreach (i RANGE "${len_test_cases}")
list(GET test_cases ${i} test_case_name)
add_executable(${test_case_name} ${test_case_name}.cpp)
target_link_libraries(${test_case_name} PRIVATE
- caosdb::caosdb gtest::gtest grpc::grpc protobuf::protobuf
+ linkahead::linkahead gtest::gtest grpc::grpc protobuf::protobuf
)
- if("${CMAKE_BUILD_TYPE}" MATCHES "Debug")
- target_link_libraries(${test_case_name} PRIVATE caosdb_grpc)
- endif()
target_include_directories(${test_case_name}
PUBLIC ${CMAKE_CURRENT_SOURCE_DIR})
if(LINTING)
@@ -129,5 +126,5 @@ foreach (i RANGE "${len_test_cases}")
endif()
gtest_discover_tests(${test_case_name}
PROPERTIES
- LABELS "caosdb-cpplib-int-tests")
+ LABELS "linkahead-cpplib-int-tests")
endforeach ()
diff --git a/test/caosdb_test_utility.h b/test/linkahead_test_utility.h
similarity index 97%
rename from test/caosdb_test_utility.h
rename to test/linkahead_test_utility.h
index 7c29f902d8bd0fa3308ff174ad8609820d67fa1f..25aa78c5475cbf91d54bcfe8e8da73ad01d80714 100644
--- a/test/caosdb_test_utility.h
+++ b/test/linkahead_test_utility.h
@@ -1,6 +1,6 @@
/*
*
- * This file is a part of the CaosDB Project.
+ * This file is a part of the LinkAhead Project.
*
* Copyright (C) 2021 Timm Fitschen <t.fitschen@indiscale.com>
* Copyright (C) 2021 IndiScale GmbH <info@indiscale.com>
@@ -26,7 +26,7 @@
* WARNING: THIS FILE IS MAINTAINED AS PART OF THE caosdb-cpplib. Please commit
* changes there and keep these files in sync!
*
- * @file caosdb_test_utility.h
+ * @file linkahead_test_utility.h
* @brief Utility for the unit tests
* @author Timm Fitschen
* @date 2021-07-07
diff --git a/test/test_async.cpp b/test/test_async.cpp
index bf437f6065f386ccfd49b01c56bc6b6d31848af0..2b5d3587d7eb404f7ccb40035bb5e34d80f17477 100644
--- a/test/test_async.cpp
+++ b/test/test_async.cpp
@@ -1,5 +1,5 @@
/*
- * This file is a part of the CaosDB Project.
+ * This file is a part of the LinkAhead Project.
*
* Copyright (C) 2022 IndiScale GmbH <info@indiscale.com>
* Copyright (C) 2022 Timm Fitschen <t.fitschen@indiscale.com>
@@ -18,12 +18,12 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*
*/
-#include "caosdb/entity.h" // for Entity, Property
-#include "caosdb/connection.h" // for Connection, Connec...
-#include "caosdb/message_code.h" // for ENTITY_DOES_NOT_EXIST, Messag...
-#include "caosdb/status_code.h" // for StatusCode, SUCCESS
-#include "caosdb/transaction.h" // for Entity, Transaction
-#include "caosdb/transaction_status.h" // for TransactionStatus
+#include "linkahead/entity.h" // for Entity, Property
+#include "linkahead/connection.h" // for Connection, Connec...
+#include "linkahead/message_code.h" // for ENTITY_DOES_NOT_EXIST, Messag...
+#include "linkahead/status_code.h" // for StatusCode, SUCCESS
+#include "linkahead/transaction.h" // for Entity, Transaction
+#include "linkahead/transaction_status.h" // for TransactionStatus
#include <chrono> // for operator""ms, chrono_literals
#include <gtest/gtest-message.h> // for Message
#include <gtest/gtest-test-part.h> // for TestPartResult
@@ -31,8 +31,8 @@
#include <memory> // for allocator, unique_ptr, __shar...
#include <thread>
-namespace caosdb::transaction {
-using caosdb::entity::MessageCode;
+namespace linkahead::transaction {
+using linkahead::entity::MessageCode;
/*
* Test the retrieval of a non-existing entity
@@ -42,7 +42,7 @@ using caosdb::entity::MessageCode;
*/
TEST(test_async, retrieve_non_existing) {
using namespace std::chrono_literals;
- const auto &connection = caosdb::connection::ConnectionManager::GetDefaultConnection();
+ const auto &connection = linkahead::connection::ConnectionManager::GetDefaultConnection();
auto transaction(connection->CreateTransaction());
@@ -76,4 +76,4 @@ TEST(test_async, retrieve_non_existing) {
EXPECT_EQ(entity.GetErrors().at(0).GetCode(), MessageCode::ENTITY_DOES_NOT_EXIST);
}
-} // namespace caosdb::transaction
+} // namespace linkahead::transaction
diff --git a/test/test_ccaosdb.cpp b/test/test_ccaosdb.cpp
deleted file mode 100644
index 347b8696e015cdf865fe94623599f4cf8cb07143..0000000000000000000000000000000000000000
--- a/test/test_ccaosdb.cpp
+++ /dev/null
@@ -1,630 +0,0 @@
-/*
- * This file is a part of the CaosDB Project.
- *
- * Copyright (C) 2021 Timm Fitschen <t.fitschen@indiscale.com>
- * Copyright (C) 2021 Florian Spreckelsen <f.spreckelsen@indiscale.com>
- * Copyright (C) 2021 IndiScale GmbH <info@indiscale.com>
- *
- * This program is free software: you can redistribute it and/or modify
- * it under the terms of the GNU Affero General Public License as
- * published by the Free Software Foundation, either version 3 of the
- * License, or (at your option) any later version.
- *
- * This program is distributed in the hope that it will be useful,
- * but WITHOUT ANY WARRANTY; without even the implied warranty of
- * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
- * GNU Affero General Public License for more details.
- *
- * You should have received a copy of the GNU Affero General Public License
- * along with this program. If not, see <https://www.gnu.org/licenses/>.
- */
-#include "caosdb/file_transmission/file_writer.h" // for FileWriter
-#include "caosdb/message_code.h" // for ENTITY_DOES_NOT_EXIST
-#include "caosdb/status_code.h" // for GO_ON, StatusCode
-#include "ccaosdb.h" // for caosdb_connection_...
-#include <chrono> // for filesystem
-#include <cstring> // for strcmp
-#include <filesystem> // for remove
-#include <gtest/gtest-message.h> // for Message
-#include <gtest/gtest-test-part.h> // for TestPartResult
-#include <gtest/gtest_pred_impl.h> // for EXPECT_EQ, TestInfo
-#include <iostream> // for operator<<, endl
-#include <string> // for allocator, string
-
-namespace fs = std::filesystem;
-class test_ccaosdb : public ::testing::Test {
-protected:
- fs::path test_upload_file_1;
- fs::path test_download_file_1;
-
- void SetUp() override {
- DeleteEntities();
- test_upload_file_1 = fs::path("test_upload_file_1_delete_me.dat");
- test_download_file_1 = fs::path("test_download_file_1_delete_me.dat");
-
- // fill the file that shall be uploaded
- caosdb::transaction::FileWriter writer(test_upload_file_1);
- std::string buffer(1024, 'c');
- for (int i = 0; i < 20; i++) {
- writer.write(buffer);
- }
- }
-
- void TearDown() override {
- // delete files
- fs::remove(test_upload_file_1);
- fs::remove(test_download_file_1);
-
- DeleteEntities();
- }
-
- /**
- * Delete everything with id>99, C style
- */
- static void DeleteEntities() {
- caosdb_connection_connection connection;
- caosdb_connection_connection_manager_get_default_connection(&connection);
-
- caosdb_transaction_transaction query_transaction;
- caosdb_connection_connection_create_transaction(&connection, &query_transaction);
- caosdb_transaction_transaction_query(&query_transaction, "FIND ENTITY WITH id > 99");
- caosdb_transaction_transaction_execute(&query_transaction);
-
- caosdb_transaction_result_set result_set;
- caosdb_transaction_transaction_get_result_set(&query_transaction, &result_set);
- int count[] = {-1}; // NOLINT
- caosdb_transaction_result_set_size(&result_set, count);
- if (*count > 0) {
- caosdb_transaction_transaction delete_transaction;
- caosdb_connection_connection_create_transaction(&connection, &delete_transaction);
- caosdb_entity_entity entity;
- char *id = nullptr; // NOLINT
- for (int i = 0; i < *count; i++) {
- caosdb_transaction_result_set_at(&result_set, &entity, i);
- caosdb_entity_entity_get_id(&entity, &id);
- caosdb_transaction_transaction_delete_by_id(&delete_transaction, id);
- }
-
- caosdb_transaction_transaction_execute(&delete_transaction);
- caosdb_transaction_delete_transaction(&delete_transaction);
- }
-
- caosdb_transaction_delete_transaction(&query_transaction);
- }
-};
-
-TEST_F(test_ccaosdb, connection_ssl_authentication_success) {
-
- caosdb_connection_connection connection;
- caosdb_connection_connection_manager_get_default_connection(&connection);
-
- caosdb_info_version_info version_info;
- caosdb_connection_get_version_info(&version_info, &connection);
-
- auto major = caosdb_constants_COMPATIBLE_SERVER_VERSION_MAJOR();
- auto minor = caosdb_constants_COMPATIBLE_SERVER_VERSION_MINOR();
- auto patch = caosdb_constants_COMPATIBLE_SERVER_VERSION_PATCH();
- const auto *const pre_release = caosdb_constants_COMPATIBLE_SERVER_VERSION_PRE_RELEASE();
-
- EXPECT_EQ(major, version_info.major);
- EXPECT_LE(minor, version_info.minor);
- if (minor == version_info.minor) {
- EXPECT_LE(patch, version_info.patch);
- }
- if (strcmp(pre_release, "") != 0) {
- EXPECT_STREQ(pre_release, version_info.pre_release);
- }
-}
-
-TEST_F(test_ccaosdb, test_count_query) {
-
- caosdb_connection_connection connection;
- int return_code(caosdb_connection_connection_manager_get_default_connection(&connection));
- EXPECT_EQ(return_code, 0);
-
- caosdb_transaction_transaction transaction;
- return_code = caosdb_connection_connection_create_transaction(&connection, &transaction);
- EXPECT_EQ(return_code, 0);
-
- // COUNT query with an empty result
- return_code = caosdb_transaction_transaction_query(&transaction, "COUNT ENTITY WITH id=-1");
- EXPECT_EQ(return_code, caosdb::StatusCode::GO_ON);
-
- return_code = caosdb_transaction_transaction_execute(&transaction);
- EXPECT_EQ(return_code, 0);
-
- long dummy(-1); // NOLINT
- long *count = &dummy; // NOLINT
- return_code = caosdb_transaction_transaction_get_count_result(&transaction, count);
- EXPECT_EQ(return_code, 0);
- EXPECT_EQ(*count, 0);
-
- return_code = caosdb_transaction_delete_transaction(&transaction);
- EXPECT_EQ(return_code, 0);
-}
-
-TEST_F(test_ccaosdb, test_query) {
- caosdb_connection_connection connection;
- int return_code(caosdb_connection_connection_manager_get_default_connection(&connection));
- EXPECT_EQ(return_code, 0);
-
- caosdb_transaction_transaction transaction;
- return_code = caosdb_connection_connection_create_transaction(&connection, &transaction);
- EXPECT_EQ(return_code, 0);
-
- return_code = caosdb_transaction_transaction_query(&transaction, "FIND ENTITY WITH id=-1");
- EXPECT_EQ(return_code, caosdb::StatusCode::GO_ON);
-
- return_code = caosdb_transaction_transaction_execute(&transaction);
- EXPECT_EQ(return_code, 0);
-
- caosdb_transaction_result_set result_set;
- return_code = caosdb_transaction_transaction_get_result_set(&transaction, &result_set);
- EXPECT_EQ(return_code, 0);
-
- int dummy(-1);
- int *count = &dummy; // NOLINT
- return_code = caosdb_transaction_result_set_size(&result_set, count);
- EXPECT_EQ(return_code, 0);
- EXPECT_EQ(*count, 0);
-
- return_code = caosdb_transaction_delete_transaction(&transaction);
- EXPECT_EQ(return_code, 0);
-}
-
-TEST_F(test_ccaosdb, test_single_id_retrieve) {
- caosdb_connection_connection connection;
- int return_code(caosdb_connection_connection_manager_get_default_connection(&connection));
- EXPECT_EQ(return_code, 0);
-
- caosdb_transaction_transaction transaction;
- return_code = caosdb_connection_connection_create_transaction(&connection, &transaction);
- EXPECT_EQ(return_code, 0);
-
- return_code = caosdb_transaction_transaction_retrieve_by_id(&transaction, "21");
- EXPECT_EQ(return_code, caosdb::StatusCode::GO_ON);
-
- return_code = caosdb_transaction_transaction_execute(&transaction);
- EXPECT_EQ(return_code, 0);
-
- caosdb_transaction_result_set result_set;
- return_code = caosdb_transaction_transaction_get_result_set(&transaction, &result_set);
- EXPECT_EQ(return_code, 0);
-
- int dummy(-1);
- int *count = &dummy; // NOLINT
- return_code = caosdb_transaction_result_set_size(&result_set, count);
- EXPECT_EQ(return_code, 0);
- EXPECT_EQ(*count, 1);
-
- caosdb_entity_entity entity;
- return_code = caosdb_transaction_result_set_at(&result_set, &entity, 0);
- EXPECT_EQ(return_code, 0);
-
- return_code = caosdb_entity_entity_get_errors_size(&entity, count);
- EXPECT_EQ(return_code, 0);
- EXPECT_EQ(*count, 0);
-
- char *out = nullptr; // NOLINT
- return_code = caosdb_entity_entity_get_name(&entity, &out);
- EXPECT_EQ(return_code, 0);
- EXPECT_STREQ(out, "unit");
-
- return_code = caosdb_transaction_delete_transaction(&transaction);
- EXPECT_EQ(return_code, 0);
-}
-
-TEST_F(test_ccaosdb, test_multi_id_retrieve) {
- caosdb_connection_connection connection;
- int return_code(caosdb_connection_connection_manager_get_default_connection(&connection));
- EXPECT_EQ(return_code, 0);
-
- caosdb_transaction_transaction transaction;
- return_code = caosdb_connection_connection_create_transaction(&connection, &transaction);
- EXPECT_EQ(return_code, 0);
-
- const char *ids[] = {"20", "21", "22"}; // NOLINT
- return_code = caosdb_transaction_transaction_retrieve_by_ids(&transaction, ids, 3);
- EXPECT_EQ(return_code, caosdb::StatusCode::GO_ON);
-
- return_code = caosdb_transaction_transaction_execute(&transaction);
- // Should have an error since entity 22 doesn't exist
- EXPECT_TRUE((return_code > 0));
-
- caosdb_transaction_result_set result_set;
- return_code = caosdb_transaction_transaction_get_result_set(&transaction, &result_set);
- EXPECT_EQ(return_code, 0);
-
- int dummy(-1);
- int *count = &dummy; // NOLINT
- return_code = caosdb_transaction_result_set_size(&result_set, count);
- EXPECT_EQ(return_code, 0);
- EXPECT_EQ(*count, 3);
-
- caosdb_entity_entity entity;
- return_code = caosdb_transaction_result_set_at(&result_set, &entity, 1);
- EXPECT_EQ(return_code, 0);
-
- return_code = caosdb_entity_entity_get_errors_size(&entity, count);
- EXPECT_EQ(return_code, 0);
- EXPECT_EQ(*count, 0);
-
- char *out = nullptr; // NOLINT
- return_code = caosdb_entity_entity_get_name(&entity, &out);
- EXPECT_EQ(return_code, 0);
- EXPECT_STREQ(out, "unit");
-
- caosdb_entity_entity other_entity;
- return_code = caosdb_transaction_result_set_at(&result_set, &other_entity, 2);
- EXPECT_EQ(return_code, 0);
- return_code = caosdb_entity_entity_get_errors_size(&other_entity, count);
- EXPECT_EQ(return_code, 0);
- EXPECT_EQ(*count, 1);
-
- caosdb_entity_message err_msg;
- return_code = caosdb_entity_entity_get_error(&other_entity, &err_msg, 0);
- EXPECT_EQ(return_code, 0);
-
- return_code = caosdb_entity_message_get_code(&err_msg, count);
- EXPECT_EQ(return_code, 0);
- EXPECT_EQ(*count, caosdb::entity::MessageCode::ENTITY_DOES_NOT_EXIST);
-
- return_code = caosdb_transaction_delete_transaction(&transaction);
- EXPECT_EQ(return_code, 0);
-}
-
-TEST_F(test_ccaosdb, test_insert_update_delete) {
-
- caosdb_connection_connection connection;
- caosdb_connection_connection_manager_get_default_connection(&connection);
-
- caosdb_entity_entity original_entity;
- caosdb_entity_create_entity(&original_entity);
- caosdb_entity_entity_set_name(&original_entity, "TestName");
- caosdb_entity_entity_set_role(&original_entity, "PROPERTY");
- caosdb_entity_datatype in_type;
- caosdb_entity_create_atomic_datatype(&in_type, "TEXT");
- caosdb_entity_entity_set_datatype(&original_entity, &in_type);
-
- caosdb_transaction_transaction insert_transaction;
- caosdb_connection_connection_create_transaction(&connection, &insert_transaction);
- caosdb_transaction_transaction_insert_entity(&insert_transaction, &original_entity);
- int return_code(caosdb_transaction_transaction_execute(&insert_transaction));
- EXPECT_EQ(return_code, 0);
-
- // Insert the entity and check results
- caosdb_transaction_result_set insert_result_set;
- caosdb_transaction_transaction_get_result_set(&insert_transaction, &insert_result_set);
- int count[] = {-1}; // NOLINT
- caosdb_transaction_result_set_size(&insert_result_set, count);
- EXPECT_EQ(*count, 1);
- caosdb_entity_entity inserted_entity;
- caosdb_transaction_result_set_at(&insert_result_set, &inserted_entity, 0);
- char *in = nullptr; // NOLINT
- caosdb_entity_entity_get_id(&inserted_entity, &in);
-
- // Retrieve it again for checks and update
- caosdb_transaction_transaction retrieve_transaction_1;
- caosdb_connection_connection_create_transaction(&connection, &retrieve_transaction_1);
- caosdb_transaction_transaction_retrieve_by_id(&retrieve_transaction_1, in);
- return_code = caosdb_transaction_transaction_execute(&retrieve_transaction_1);
- EXPECT_EQ(return_code, 0);
-
- caosdb_transaction_result_set retrieve_results_1;
- caosdb_transaction_transaction_get_result_set(&retrieve_transaction_1, &retrieve_results_1);
- caosdb_transaction_result_set_size(&retrieve_results_1, count);
- EXPECT_EQ(*count, 1);
- caosdb_entity_entity retrieved_entity_1;
- caosdb_transaction_result_set_at(&retrieve_results_1, &retrieved_entity_1, 0);
- char *out = nullptr; // NOLINT
- caosdb_entity_entity_get_id(&retrieved_entity_1, &out);
- EXPECT_EQ(strcmp(in, out), 0);
-
- caosdb_entity_entity_get_name(&original_entity, &in);
- caosdb_entity_entity_get_name(&retrieved_entity_1, &out);
- EXPECT_EQ(strcmp(in, out), 0);
-
- caosdb_entity_entity_get_role(&original_entity, &in);
- caosdb_entity_entity_get_role(&retrieved_entity_1, &out);
- EXPECT_EQ(strcmp(in, out), 0);
-
- caosdb_entity_datatype out_type;
- caosdb_entity_entity_get_datatype(&original_entity, &out_type);
- bool out_is(false);
- caosdb_entity_datatype_is_atomic(&out_type, &out_is);
- EXPECT_TRUE(out_is);
- caosdb_entity_datatype_get_datatype_name(&in_type, &in);
- caosdb_entity_datatype_get_datatype_name(&out_type, &out);
- EXPECT_EQ(strcmp(in, out), 0);
-
- // Change name and update
- return_code = caosdb_entity_entity_set_name(&retrieved_entity_1, "TestNameNew");
- EXPECT_EQ(return_code, 0);
- caosdb_transaction_transaction update_transaction;
- caosdb_connection_connection_create_transaction(&connection, &update_transaction);
- caosdb_transaction_transaction_update_entity(&update_transaction, &retrieved_entity_1);
- return_code = caosdb_transaction_transaction_execute(&update_transaction);
- EXPECT_EQ(return_code, 0);
-
- caosdb_transaction_result_set update_results;
- caosdb_transaction_transaction_get_result_set(&update_transaction, &update_results);
- caosdb_transaction_result_set_size(&update_results, count);
- EXPECT_EQ(*count, 1);
- caosdb_entity_entity updated_entity;
- caosdb_transaction_result_set_at(&update_results, &updated_entity, 0);
- caosdb_entity_entity_get_id(&inserted_entity, &in);
- caosdb_entity_entity_get_id(&updated_entity, &out);
- EXPECT_EQ(strcmp(in, out), 0);
-
- // Retrieve again
- caosdb_transaction_transaction retrieve_transaction_2;
- caosdb_connection_connection_create_transaction(&connection, &retrieve_transaction_2);
- caosdb_transaction_transaction_retrieve_by_id(&retrieve_transaction_2, out);
- return_code = caosdb_transaction_transaction_execute(&retrieve_transaction_2);
- EXPECT_EQ(return_code, 0);
-
- caosdb_transaction_result_set retrieve_results_2;
- caosdb_transaction_transaction_get_result_set(&retrieve_transaction_2, &retrieve_results_2);
- caosdb_transaction_result_set_size(&retrieve_results_2, count);
- EXPECT_EQ(*count, 1);
- caosdb_entity_entity retrieved_entity_2;
- caosdb_transaction_result_set_at(&retrieve_results_2, &retrieved_entity_2, 0);
-
- caosdb_entity_entity_get_id(&retrieved_entity_2, &out);
- EXPECT_EQ(strcmp(in, out), 0);
-
- caosdb_entity_entity_get_name(&retrieved_entity_1, &in);
- caosdb_entity_entity_get_name(&retrieved_entity_2, &out);
- EXPECT_EQ(strcmp(in, out), 0);
-
- // Doesn't have the old name anymore
- caosdb_entity_entity_get_name(&original_entity, &in);
- EXPECT_FALSE((strcmp(in, out) == 0));
-
- // Everything else hasn't changed
- caosdb_entity_entity_get_role(&original_entity, &in);
- caosdb_entity_entity_get_role(&retrieved_entity_2, &out);
- EXPECT_EQ(strcmp(in, out), 0);
-
- caosdb_entity_entity_get_datatype(&retrieved_entity_2, &out_type);
- caosdb_entity_datatype_is_atomic(&out_type, &out_is);
- EXPECT_TRUE(out_is);
- caosdb_entity_datatype_get_datatype_name(&in_type, &in);
- caosdb_entity_datatype_get_datatype_name(&out_type, &out);
- EXPECT_EQ(strcmp(in, out), 0);
-
- // Now delete
- caosdb_transaction_transaction delete_transaction;
- caosdb_connection_connection_create_transaction(&connection, &delete_transaction);
- caosdb_entity_entity_get_id(&retrieved_entity_2, &in);
- caosdb_transaction_transaction_delete_by_id(&delete_transaction, in);
- return_code = caosdb_transaction_transaction_execute(&delete_transaction);
- EXPECT_EQ(return_code, 0);
-
- caosdb_transaction_result_set delete_results;
- caosdb_transaction_transaction_get_result_set(&delete_transaction, &delete_results);
- caosdb_transaction_result_set_size(&delete_results, count);
- EXPECT_EQ(*count, 1);
-
- caosdb_entity_entity deleted_entity;
- caosdb_transaction_result_set_at(&delete_results, &deleted_entity, 0);
- caosdb_entity_entity_get_id(&deleted_entity, &out);
- EXPECT_EQ(strcmp(in, out), 0);
-
- // Try to retrieve again
- caosdb_transaction_transaction retrieve_transaction_3;
- caosdb_connection_connection_create_transaction(&connection, &retrieve_transaction_3);
- caosdb_transaction_transaction_retrieve_by_id(&retrieve_transaction_3, out);
- return_code = caosdb_transaction_transaction_execute(&retrieve_transaction_3);
- EXPECT_TRUE((return_code > 0));
-
- caosdb_transaction_result_set retrieve_results_3;
- caosdb_transaction_transaction_get_result_set(&retrieve_transaction_3, &retrieve_results_3);
- caosdb_transaction_result_set_size(&retrieve_results_3, count);
- EXPECT_EQ(*count, 1);
- caosdb_entity_entity retrieved_entity_3;
- caosdb_transaction_result_set_at(&retrieve_results_3, &retrieved_entity_3, 0);
- caosdb_entity_entity_get_errors_size(&retrieved_entity_3, count);
- EXPECT_EQ(*count, 1);
- caosdb_entity_message err_msg;
- caosdb_entity_entity_get_error(&retrieved_entity_3, &err_msg, 0);
- caosdb_entity_message_get_code(&err_msg, count);
- EXPECT_EQ(*count, caosdb::entity::MessageCode::ENTITY_DOES_NOT_EXIST);
-
- // Delete everything
- caosdb_transaction_delete_transaction(&retrieve_transaction_3);
- caosdb_transaction_delete_transaction(&delete_transaction);
- caosdb_transaction_delete_transaction(&retrieve_transaction_2);
- caosdb_transaction_delete_transaction(&update_transaction);
- caosdb_transaction_delete_transaction(&retrieve_transaction_1);
- caosdb_transaction_delete_transaction(&insert_transaction);
- caosdb_entity_delete_entity(&original_entity);
- caosdb_entity_delete_datatype(&in_type);
-}
-
-TEST_F(test_ccaosdb, test_insert_with_prop_and_parent) {
-
- caosdb_connection_connection connection;
- caosdb_connection_connection_manager_get_default_connection(&connection);
-
- // Create and insert a property, ...
- std::cout << "Creating a property..." << std::endl;
- caosdb_entity_entity original_prop;
- caosdb_entity_create_entity(&original_prop);
-
- caosdb_entity_entity_set_name(&original_prop, "TestProp");
- caosdb_entity_entity_set_role(&original_prop, "PROPERTY");
- caosdb_entity_datatype original_type;
- caosdb_entity_create_atomic_datatype(&original_type, "TEXT");
- caosdb_entity_entity_set_datatype(&original_prop, &original_type);
-
- std::cout << "Inserting a property..." << std::endl;
- caosdb_transaction_transaction prop_insertion;
- caosdb_connection_connection_create_transaction(&connection, &prop_insertion);
- caosdb_transaction_transaction_insert_entity(&prop_insertion, &original_prop);
- int return_code(caosdb_transaction_transaction_execute(&prop_insertion));
- EXPECT_EQ(return_code, 0);
-
- std::cout << "Checking result..." << std::endl;
- caosdb_transaction_result_set prop_results;
- caosdb_transaction_transaction_get_result_set(&prop_insertion, &prop_results);
- caosdb_entity_entity inserted_prop;
- caosdb_transaction_result_set_at(&prop_results, &inserted_prop, 0);
- char *prop_id = nullptr; // NOLINT
- caosdb_entity_entity_get_id(&inserted_prop, &prop_id);
-
- // ... a record type with this property, ...
- caosdb_entity_entity original_rt;
- caosdb_entity_create_entity(&original_rt);
-
- caosdb_entity_entity_set_name(&original_rt, "TestType");
- caosdb_entity_entity_set_role(&original_rt, "RECORD_TYPE");
-
- caosdb_entity_property rt_prop;
- caosdb_entity_create_property(&rt_prop);
- caosdb_entity_property_set_id(&rt_prop, prop_id);
- caosdb_entity_entity_append_property(&original_rt, &rt_prop);
-
- caosdb_transaction_transaction rt_insertion;
- caosdb_connection_connection_create_transaction(&connection, &rt_insertion);
- caosdb_transaction_transaction_insert_entity(&rt_insertion, &original_rt);
- return_code = caosdb_transaction_transaction_execute(&rt_insertion);
- EXPECT_EQ(return_code, 0);
-
- caosdb_transaction_result_set rt_results;
- caosdb_transaction_transaction_get_result_set(&rt_insertion, &rt_results);
- caosdb_entity_entity inserted_rt;
- caosdb_transaction_result_set_at(&rt_results, &inserted_rt, 0);
- char *rt_id = nullptr; // NOLINT
- caosdb_entity_entity_get_id(&inserted_rt, &rt_id);
-
- // ... and a record with this record type as a parent.
- caosdb_entity_entity original_rec;
- caosdb_entity_create_entity(&original_rec);
- caosdb_entity_entity_set_name(&original_rec, "TestRec");
- caosdb_entity_entity_set_role(&original_rec, "RECORD");
- caosdb_entity_parent rec_parent;
- caosdb_entity_create_parent(&rec_parent);
- caosdb_entity_parent_set_id(&rec_parent, rt_id);
- caosdb_entity_entity_append_parent(&original_rec, &rec_parent);
- caosdb_entity_property rec_prop;
- caosdb_entity_create_property(&rec_prop);
- caosdb_entity_property_set_id(&rec_prop, prop_id);
- caosdb_entity_value in_value;
- caosdb_entity_create_string_value(&in_value, "Bla");
- caosdb_entity_property_set_value(&rec_prop, &in_value);
- caosdb_entity_entity_append_property(&original_rec, &rec_prop);
-
- caosdb_transaction_transaction rec_insertion;
- caosdb_connection_connection_create_transaction(&connection, &rec_insertion);
- caosdb_transaction_transaction_insert_entity(&rec_insertion, &original_rec);
- return_code = caosdb_transaction_transaction_execute(&rec_insertion);
- EXPECT_EQ(return_code, 0);
-
- caosdb_transaction_result_set rec_results;
- caosdb_transaction_transaction_get_result_set(&rec_insertion, &rec_results);
- caosdb_entity_entity inserted_rec;
- caosdb_transaction_result_set_at(&rec_results, &inserted_rec, 0);
- char *rec_id = nullptr; // NOLINT
- caosdb_entity_entity_get_id(&inserted_rec, &rec_id);
-
- // Retrieve the record again for comparison
- caosdb_transaction_transaction retrieve_transaction;
- caosdb_connection_connection_create_transaction(&connection, &retrieve_transaction);
- caosdb_transaction_transaction_retrieve_by_id(&retrieve_transaction, rec_id);
- return_code = caosdb_transaction_transaction_execute(&retrieve_transaction);
- EXPECT_EQ(return_code, 0);
-
- caosdb_transaction_result_set retrieve_result;
- caosdb_transaction_transaction_get_result_set(&retrieve_transaction, &retrieve_result);
- caosdb_entity_entity retrieved_rec;
- caosdb_transaction_result_set_at(&retrieve_result, &retrieved_rec, 0);
- char *in = nullptr; // NOLINT
- char *out = nullptr; // NOLINT
- caosdb_entity_entity_get_name(&original_rec, &in);
- caosdb_entity_entity_get_name(&retrieved_rec, &out);
- EXPECT_EQ(strcmp(in, out), 0);
- int count[] = {0}; // NOLINT
- caosdb_entity_entity_get_properties_size(&retrieved_rec, count);
- EXPECT_EQ(*count, 1);
- caosdb_entity_entity_get_parents_size(&retrieved_rec, count);
- EXPECT_EQ(*count, 1);
-
- caosdb_entity_parent retrieved_parent;
- caosdb_entity_entity_get_parent(&retrieved_rec, &retrieved_parent, 0);
- caosdb_entity_entity_get_name(&original_rt, &in);
- caosdb_entity_parent_get_name(&retrieved_parent, &out);
- EXPECT_EQ(strcmp(in, out), 0);
- caosdb_entity_parent_get_id(&retrieved_parent, &out);
- EXPECT_EQ(strcmp(rt_id, out), 0);
-
- caosdb_entity_property retrieved_property;
- caosdb_entity_entity_get_property(&retrieved_rec, &retrieved_property, 0);
- caosdb_entity_entity_get_name(&original_prop, &in);
- caosdb_entity_property_get_name(&retrieved_property, &out);
- EXPECT_EQ(strcmp(in, out), 0);
- caosdb_entity_value out_value;
- caosdb_entity_property_get_value(&retrieved_property, &out_value);
- caosdb_entity_value_get_as_string(&in_value, &in);
- caosdb_entity_value_get_as_string(&out_value, &out);
- EXPECT_EQ(strcmp(in, out), 0);
-
- caosdb_transaction_delete_transaction(&retrieve_transaction);
- caosdb_transaction_delete_transaction(&rec_insertion);
- caosdb_entity_delete_property(&rec_prop);
- caosdb_entity_delete_parent(&rec_parent);
- caosdb_entity_delete_entity(&original_rec);
- caosdb_transaction_delete_transaction(&rt_insertion);
- caosdb_entity_delete_property(&rt_prop);
- caosdb_entity_delete_entity(&original_rt);
- caosdb_transaction_delete_transaction(&prop_insertion);
- caosdb_entity_delete_entity(&original_prop);
- caosdb_entity_delete_datatype(&original_type);
- caosdb_entity_delete_value(&in_value);
-}
-
-TEST_F(test_ccaosdb, test_up_n_download_file) {
-
- caosdb_connection_connection connection;
- caosdb_connection_connection_manager_get_default_connection(&connection);
-
- caosdb_entity_entity original_entity;
- caosdb_entity_create_entity(&original_entity);
- caosdb_entity_entity_set_role(&original_entity, "FILE");
- caosdb_entity_entity_set_local_path(&original_entity, test_upload_file_1.c_str());
- caosdb_entity_entity_set_file_path(&original_entity, "/some/file");
-
- caosdb_transaction_transaction insert_transaction;
- caosdb_connection_connection_create_transaction(&connection, &insert_transaction);
- caosdb_transaction_transaction_insert_entity(&insert_transaction, &original_entity);
- int return_code(caosdb_transaction_transaction_execute(&insert_transaction));
- EXPECT_EQ(return_code, 0);
-
- caosdb_transaction_result_set rec_results;
- caosdb_transaction_transaction_get_result_set(&insert_transaction, &rec_results);
- caosdb_entity_entity inserted_rec;
- caosdb_transaction_result_set_at(&rec_results, &inserted_rec, 0);
- char *rec_id = nullptr; // NOLINT
- caosdb_entity_entity_get_id(&inserted_rec, &rec_id);
-
- caosdb_entity_entity download_entity;
- caosdb_entity_create_entity(&download_entity);
- caosdb_entity_entity_set_role(&download_entity, "FILE");
- caosdb_entity_entity_set_local_path(&download_entity, "lol");
- caosdb_entity_entity_set_file_path(&download_entity, "/some/file");
-
- caosdb_transaction_transaction retrieve_transaction_1;
- caosdb_connection_connection_create_transaction(&connection, &retrieve_transaction_1);
- EXPECT_EQ(return_code, 0);
- // return_code = caosdb_transaction_transaction_retrieve_by_id(
- // &retrieve_transaction_1, rec_id);
- return_code = caosdb_transaction_transaction_retrieve_and_download_file_by_id(
- &retrieve_transaction_1, rec_id, test_download_file_1.c_str());
- EXPECT_EQ(return_code, caosdb::StatusCode::GO_ON);
- return_code = caosdb_transaction_transaction_execute(&retrieve_transaction_1);
- EXPECT_EQ(return_code, 0);
-
- caosdb_transaction_result_set result_set;
- return_code = caosdb_transaction_transaction_get_result_set(&retrieve_transaction_1, &result_set);
- EXPECT_EQ(return_code, 0);
-}
diff --git a/test/test_clinkahead.cpp b/test/test_clinkahead.cpp
new file mode 100644
index 0000000000000000000000000000000000000000..84cddd6ca76afda0352ecf09f4b651ba3497767e
--- /dev/null
+++ b/test/test_clinkahead.cpp
@@ -0,0 +1,630 @@
+/*
+ * This file is a part of the LinkAhead Project.
+ *
+ * Copyright (C) 2021 Timm Fitschen <t.fitschen@indiscale.com>
+ * Copyright (C) 2021 Florian Spreckelsen <f.spreckelsen@indiscale.com>
+ * Copyright (C) 2021 IndiScale GmbH <info@indiscale.com>
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU Affero General Public License as
+ * published by the Free Software Foundation, either version 3 of the
+ * License, or (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * GNU Affero General Public License for more details.
+ *
+ * You should have received a copy of the GNU Affero General Public License
+ * along with this program. If not, see <https://www.gnu.org/licenses/>.
+ */
+#include "linkahead/file_transmission/file_writer.h" // for FileWriter
+#include "linkahead/message_code.h" // for ENTITY_DOES_NOT_EXIST
+#include "linkahead/status_code.h" // for GO_ON, StatusCode
+#include "clinkahead.h" // for linkahead_connection_...
+#include <chrono> // for filesystem
+#include <cstring> // for strcmp
+#include <filesystem> // for remove
+#include <gtest/gtest-message.h> // for Message
+#include <gtest/gtest-test-part.h> // for TestPartResult
+#include <gtest/gtest_pred_impl.h> // for EXPECT_EQ, TestInfo
+#include <iostream> // for operator<<, endl
+#include <string> // for allocator, string
+
+namespace fs = std::filesystem;
+class test_clinkahead : public ::testing::Test {
+protected:
+ fs::path test_upload_file_1;
+ fs::path test_download_file_1;
+
+ void SetUp() override {
+ DeleteEntities();
+ test_upload_file_1 = fs::path("test_upload_file_1_delete_me.dat");
+ test_download_file_1 = fs::path("test_download_file_1_delete_me.dat");
+
+ // fill the file that shall be uploaded
+ linkahead::transaction::FileWriter writer(test_upload_file_1);
+ std::string buffer(1024, 'c');
+ for (int i = 0; i < 20; i++) {
+ writer.write(buffer);
+ }
+ }
+
+ void TearDown() override {
+ // delete files
+ fs::remove(test_upload_file_1);
+ fs::remove(test_download_file_1);
+
+ DeleteEntities();
+ }
+
+ /**
+ * Delete everything with id>99, C style
+ */
+ static void DeleteEntities() {
+ linkahead_connection_connection connection;
+ linkahead_connection_connection_manager_get_default_connection(&connection);
+
+ linkahead_transaction_transaction query_transaction;
+ linkahead_connection_connection_create_transaction(&connection, &query_transaction);
+ linkahead_transaction_transaction_query(&query_transaction, "FIND ENTITY WITH id > 99");
+ linkahead_transaction_transaction_execute(&query_transaction);
+
+ linkahead_transaction_result_set result_set;
+ linkahead_transaction_transaction_get_result_set(&query_transaction, &result_set);
+ int count[] = {-1}; // NOLINT
+ linkahead_transaction_result_set_size(&result_set, count);
+ if (*count > 0) {
+ linkahead_transaction_transaction delete_transaction;
+ linkahead_connection_connection_create_transaction(&connection, &delete_transaction);
+ linkahead_entity_entity entity;
+ char *id = nullptr; // NOLINT
+ for (int i = 0; i < *count; i++) {
+ linkahead_transaction_result_set_at(&result_set, &entity, i);
+ linkahead_entity_entity_get_id(&entity, &id);
+ linkahead_transaction_transaction_delete_by_id(&delete_transaction, id);
+ }
+
+ linkahead_transaction_transaction_execute(&delete_transaction);
+ linkahead_transaction_delete_transaction(&delete_transaction);
+ }
+
+ linkahead_transaction_delete_transaction(&query_transaction);
+ }
+};
+
+TEST_F(test_clinkahead, connection_ssl_authentication_success) {
+
+ linkahead_connection_connection connection;
+ linkahead_connection_connection_manager_get_default_connection(&connection);
+
+ linkahead_info_version_info version_info;
+ linkahead_connection_get_version_info(&version_info, &connection);
+
+ auto major = linkahead_constants_COMPATIBLE_SERVER_VERSION_MAJOR();
+ auto minor = linkahead_constants_COMPATIBLE_SERVER_VERSION_MINOR();
+ auto patch = linkahead_constants_COMPATIBLE_SERVER_VERSION_PATCH();
+ const auto *const pre_release = linkahead_constants_COMPATIBLE_SERVER_VERSION_PRE_RELEASE();
+
+ EXPECT_EQ(major, version_info.major);
+ EXPECT_LE(minor, version_info.minor);
+ if (minor == version_info.minor) {
+ EXPECT_LE(patch, version_info.patch);
+ }
+ if (strcmp(pre_release, "") != 0) {
+ EXPECT_STREQ(pre_release, version_info.pre_release);
+ }
+}
+
+TEST_F(test_clinkahead, test_count_query) {
+
+ linkahead_connection_connection connection;
+ int return_code(linkahead_connection_connection_manager_get_default_connection(&connection));
+ EXPECT_EQ(return_code, 0);
+
+ linkahead_transaction_transaction transaction;
+ return_code = linkahead_connection_connection_create_transaction(&connection, &transaction);
+ EXPECT_EQ(return_code, 0);
+
+ // COUNT query with an empty result
+ return_code = linkahead_transaction_transaction_query(&transaction, "COUNT ENTITY WITH id=-1");
+ EXPECT_EQ(return_code, linkahead::StatusCode::GO_ON);
+
+ return_code = linkahead_transaction_transaction_execute(&transaction);
+ EXPECT_EQ(return_code, 0);
+
+ long dummy(-1); // NOLINT
+ long *count = &dummy; // NOLINT
+ return_code = linkahead_transaction_transaction_get_count_result(&transaction, count);
+ EXPECT_EQ(return_code, 0);
+ EXPECT_EQ(*count, 0);
+
+ return_code = linkahead_transaction_delete_transaction(&transaction);
+ EXPECT_EQ(return_code, 0);
+}
+
+TEST_F(test_clinkahead, test_query) {
+ linkahead_connection_connection connection;
+ int return_code(linkahead_connection_connection_manager_get_default_connection(&connection));
+ EXPECT_EQ(return_code, 0);
+
+ linkahead_transaction_transaction transaction;
+ return_code = linkahead_connection_connection_create_transaction(&connection, &transaction);
+ EXPECT_EQ(return_code, 0);
+
+ return_code = linkahead_transaction_transaction_query(&transaction, "FIND ENTITY WITH id=-1");
+ EXPECT_EQ(return_code, linkahead::StatusCode::GO_ON);
+
+ return_code = linkahead_transaction_transaction_execute(&transaction);
+ EXPECT_EQ(return_code, 0);
+
+ linkahead_transaction_result_set result_set;
+ return_code = linkahead_transaction_transaction_get_result_set(&transaction, &result_set);
+ EXPECT_EQ(return_code, 0);
+
+ int dummy(-1);
+ int *count = &dummy; // NOLINT
+ return_code = linkahead_transaction_result_set_size(&result_set, count);
+ EXPECT_EQ(return_code, 0);
+ EXPECT_EQ(*count, 0);
+
+ return_code = linkahead_transaction_delete_transaction(&transaction);
+ EXPECT_EQ(return_code, 0);
+}
+
+TEST_F(test_clinkahead, test_single_id_retrieve) {
+ linkahead_connection_connection connection;
+ int return_code(linkahead_connection_connection_manager_get_default_connection(&connection));
+ EXPECT_EQ(return_code, 0);
+
+ linkahead_transaction_transaction transaction;
+ return_code = linkahead_connection_connection_create_transaction(&connection, &transaction);
+ EXPECT_EQ(return_code, 0);
+
+ return_code = linkahead_transaction_transaction_retrieve_by_id(&transaction, "21");
+ EXPECT_EQ(return_code, linkahead::StatusCode::GO_ON);
+
+ return_code = linkahead_transaction_transaction_execute(&transaction);
+ EXPECT_EQ(return_code, 0);
+
+ linkahead_transaction_result_set result_set;
+ return_code = linkahead_transaction_transaction_get_result_set(&transaction, &result_set);
+ EXPECT_EQ(return_code, 0);
+
+ int dummy(-1);
+ int *count = &dummy; // NOLINT
+ return_code = linkahead_transaction_result_set_size(&result_set, count);
+ EXPECT_EQ(return_code, 0);
+ EXPECT_EQ(*count, 1);
+
+ linkahead_entity_entity entity;
+ return_code = linkahead_transaction_result_set_at(&result_set, &entity, 0);
+ EXPECT_EQ(return_code, 0);
+
+ return_code = linkahead_entity_entity_get_errors_size(&entity, count);
+ EXPECT_EQ(return_code, 0);
+ EXPECT_EQ(*count, 0);
+
+ char *out = nullptr; // NOLINT
+ return_code = linkahead_entity_entity_get_name(&entity, &out);
+ EXPECT_EQ(return_code, 0);
+ EXPECT_STREQ(out, "unit");
+
+ return_code = linkahead_transaction_delete_transaction(&transaction);
+ EXPECT_EQ(return_code, 0);
+}
+
+TEST_F(test_clinkahead, test_multi_id_retrieve) {
+ linkahead_connection_connection connection;
+ int return_code(linkahead_connection_connection_manager_get_default_connection(&connection));
+ EXPECT_EQ(return_code, 0);
+
+ linkahead_transaction_transaction transaction;
+ return_code = linkahead_connection_connection_create_transaction(&connection, &transaction);
+ EXPECT_EQ(return_code, 0);
+
+ const char *ids[] = {"20", "21", "22"}; // NOLINT
+ return_code = linkahead_transaction_transaction_retrieve_by_ids(&transaction, ids, 3);
+ EXPECT_EQ(return_code, linkahead::StatusCode::GO_ON);
+
+ return_code = linkahead_transaction_transaction_execute(&transaction);
+ // Should have an error since entity 22 doesn't exist
+ EXPECT_TRUE((return_code > 0));
+
+ linkahead_transaction_result_set result_set;
+ return_code = linkahead_transaction_transaction_get_result_set(&transaction, &result_set);
+ EXPECT_EQ(return_code, 0);
+
+ int dummy(-1);
+ int *count = &dummy; // NOLINT
+ return_code = linkahead_transaction_result_set_size(&result_set, count);
+ EXPECT_EQ(return_code, 0);
+ EXPECT_EQ(*count, 3);
+
+ linkahead_entity_entity entity;
+ return_code = linkahead_transaction_result_set_at(&result_set, &entity, 1);
+ EXPECT_EQ(return_code, 0);
+
+ return_code = linkahead_entity_entity_get_errors_size(&entity, count);
+ EXPECT_EQ(return_code, 0);
+ EXPECT_EQ(*count, 0);
+
+ char *out = nullptr; // NOLINT
+ return_code = linkahead_entity_entity_get_name(&entity, &out);
+ EXPECT_EQ(return_code, 0);
+ EXPECT_STREQ(out, "unit");
+
+ linkahead_entity_entity other_entity;
+ return_code = linkahead_transaction_result_set_at(&result_set, &other_entity, 2);
+ EXPECT_EQ(return_code, 0);
+ return_code = linkahead_entity_entity_get_errors_size(&other_entity, count);
+ EXPECT_EQ(return_code, 0);
+ EXPECT_EQ(*count, 1);
+
+ linkahead_entity_message err_msg;
+ return_code = linkahead_entity_entity_get_error(&other_entity, &err_msg, 0);
+ EXPECT_EQ(return_code, 0);
+
+ return_code = linkahead_entity_message_get_code(&err_msg, count);
+ EXPECT_EQ(return_code, 0);
+ EXPECT_EQ(*count, linkahead::entity::MessageCode::ENTITY_DOES_NOT_EXIST);
+
+ return_code = linkahead_transaction_delete_transaction(&transaction);
+ EXPECT_EQ(return_code, 0);
+}
+
+TEST_F(test_clinkahead, test_insert_update_delete) {
+
+ linkahead_connection_connection connection;
+ linkahead_connection_connection_manager_get_default_connection(&connection);
+
+ linkahead_entity_entity original_entity;
+ linkahead_entity_create_entity(&original_entity);
+ linkahead_entity_entity_set_name(&original_entity, "TestName");
+ linkahead_entity_entity_set_role(&original_entity, "PROPERTY");
+ linkahead_entity_datatype in_type;
+ linkahead_entity_create_atomic_datatype(&in_type, "TEXT");
+ linkahead_entity_entity_set_datatype(&original_entity, &in_type);
+
+ linkahead_transaction_transaction insert_transaction;
+ linkahead_connection_connection_create_transaction(&connection, &insert_transaction);
+ linkahead_transaction_transaction_insert_entity(&insert_transaction, &original_entity);
+ int return_code(linkahead_transaction_transaction_execute(&insert_transaction));
+ EXPECT_EQ(return_code, 0);
+
+ // Insert the entity and check results
+ linkahead_transaction_result_set insert_result_set;
+ linkahead_transaction_transaction_get_result_set(&insert_transaction, &insert_result_set);
+ int count[] = {-1}; // NOLINT
+ linkahead_transaction_result_set_size(&insert_result_set, count);
+ EXPECT_EQ(*count, 1);
+ linkahead_entity_entity inserted_entity;
+ linkahead_transaction_result_set_at(&insert_result_set, &inserted_entity, 0);
+ char *in = nullptr; // NOLINT
+ linkahead_entity_entity_get_id(&inserted_entity, &in);
+
+ // Retrieve it again for checks and update
+ linkahead_transaction_transaction retrieve_transaction_1;
+ linkahead_connection_connection_create_transaction(&connection, &retrieve_transaction_1);
+ linkahead_transaction_transaction_retrieve_by_id(&retrieve_transaction_1, in);
+ return_code = linkahead_transaction_transaction_execute(&retrieve_transaction_1);
+ EXPECT_EQ(return_code, 0);
+
+ linkahead_transaction_result_set retrieve_results_1;
+ linkahead_transaction_transaction_get_result_set(&retrieve_transaction_1, &retrieve_results_1);
+ linkahead_transaction_result_set_size(&retrieve_results_1, count);
+ EXPECT_EQ(*count, 1);
+ linkahead_entity_entity retrieved_entity_1;
+ linkahead_transaction_result_set_at(&retrieve_results_1, &retrieved_entity_1, 0);
+ char *out = nullptr; // NOLINT
+ linkahead_entity_entity_get_id(&retrieved_entity_1, &out);
+ EXPECT_EQ(strcmp(in, out), 0);
+
+ linkahead_entity_entity_get_name(&original_entity, &in);
+ linkahead_entity_entity_get_name(&retrieved_entity_1, &out);
+ EXPECT_EQ(strcmp(in, out), 0);
+
+ linkahead_entity_entity_get_role(&original_entity, &in);
+ linkahead_entity_entity_get_role(&retrieved_entity_1, &out);
+ EXPECT_EQ(strcmp(in, out), 0);
+
+ linkahead_entity_datatype out_type;
+ linkahead_entity_entity_get_datatype(&original_entity, &out_type);
+ bool out_is(false);
+ linkahead_entity_datatype_is_atomic(&out_type, &out_is);
+ EXPECT_TRUE(out_is);
+ linkahead_entity_datatype_get_datatype_name(&in_type, &in);
+ linkahead_entity_datatype_get_datatype_name(&out_type, &out);
+ EXPECT_EQ(strcmp(in, out), 0);
+
+ // Change name and update
+ return_code = linkahead_entity_entity_set_name(&retrieved_entity_1, "TestNameNew");
+ EXPECT_EQ(return_code, 0);
+ linkahead_transaction_transaction update_transaction;
+ linkahead_connection_connection_create_transaction(&connection, &update_transaction);
+ linkahead_transaction_transaction_update_entity(&update_transaction, &retrieved_entity_1);
+ return_code = linkahead_transaction_transaction_execute(&update_transaction);
+ EXPECT_EQ(return_code, 0);
+
+ linkahead_transaction_result_set update_results;
+ linkahead_transaction_transaction_get_result_set(&update_transaction, &update_results);
+ linkahead_transaction_result_set_size(&update_results, count);
+ EXPECT_EQ(*count, 1);
+ linkahead_entity_entity updated_entity;
+ linkahead_transaction_result_set_at(&update_results, &updated_entity, 0);
+ linkahead_entity_entity_get_id(&inserted_entity, &in);
+ linkahead_entity_entity_get_id(&updated_entity, &out);
+ EXPECT_EQ(strcmp(in, out), 0);
+
+ // Retrieve again
+ linkahead_transaction_transaction retrieve_transaction_2;
+ linkahead_connection_connection_create_transaction(&connection, &retrieve_transaction_2);
+ linkahead_transaction_transaction_retrieve_by_id(&retrieve_transaction_2, out);
+ return_code = linkahead_transaction_transaction_execute(&retrieve_transaction_2);
+ EXPECT_EQ(return_code, 0);
+
+ linkahead_transaction_result_set retrieve_results_2;
+ linkahead_transaction_transaction_get_result_set(&retrieve_transaction_2, &retrieve_results_2);
+ linkahead_transaction_result_set_size(&retrieve_results_2, count);
+ EXPECT_EQ(*count, 1);
+ linkahead_entity_entity retrieved_entity_2;
+ linkahead_transaction_result_set_at(&retrieve_results_2, &retrieved_entity_2, 0);
+
+ linkahead_entity_entity_get_id(&retrieved_entity_2, &out);
+ EXPECT_EQ(strcmp(in, out), 0);
+
+ linkahead_entity_entity_get_name(&retrieved_entity_1, &in);
+ linkahead_entity_entity_get_name(&retrieved_entity_2, &out);
+ EXPECT_EQ(strcmp(in, out), 0);
+
+ // Doesn't have the old name anymore
+ linkahead_entity_entity_get_name(&original_entity, &in);
+ EXPECT_FALSE((strcmp(in, out) == 0));
+
+ // Everything else hasn't changed
+ linkahead_entity_entity_get_role(&original_entity, &in);
+ linkahead_entity_entity_get_role(&retrieved_entity_2, &out);
+ EXPECT_EQ(strcmp(in, out), 0);
+
+ linkahead_entity_entity_get_datatype(&retrieved_entity_2, &out_type);
+ linkahead_entity_datatype_is_atomic(&out_type, &out_is);
+ EXPECT_TRUE(out_is);
+ linkahead_entity_datatype_get_datatype_name(&in_type, &in);
+ linkahead_entity_datatype_get_datatype_name(&out_type, &out);
+ EXPECT_EQ(strcmp(in, out), 0);
+
+ // Now delete
+ linkahead_transaction_transaction delete_transaction;
+ linkahead_connection_connection_create_transaction(&connection, &delete_transaction);
+ linkahead_entity_entity_get_id(&retrieved_entity_2, &in);
+ linkahead_transaction_transaction_delete_by_id(&delete_transaction, in);
+ return_code = linkahead_transaction_transaction_execute(&delete_transaction);
+ EXPECT_EQ(return_code, 0);
+
+ linkahead_transaction_result_set delete_results;
+ linkahead_transaction_transaction_get_result_set(&delete_transaction, &delete_results);
+ linkahead_transaction_result_set_size(&delete_results, count);
+ EXPECT_EQ(*count, 1);
+
+ linkahead_entity_entity deleted_entity;
+ linkahead_transaction_result_set_at(&delete_results, &deleted_entity, 0);
+ linkahead_entity_entity_get_id(&deleted_entity, &out);
+ EXPECT_EQ(strcmp(in, out), 0);
+
+ // Try to retrieve again
+ linkahead_transaction_transaction retrieve_transaction_3;
+ linkahead_connection_connection_create_transaction(&connection, &retrieve_transaction_3);
+ linkahead_transaction_transaction_retrieve_by_id(&retrieve_transaction_3, out);
+ return_code = linkahead_transaction_transaction_execute(&retrieve_transaction_3);
+ EXPECT_TRUE((return_code > 0));
+
+ linkahead_transaction_result_set retrieve_results_3;
+ linkahead_transaction_transaction_get_result_set(&retrieve_transaction_3, &retrieve_results_3);
+ linkahead_transaction_result_set_size(&retrieve_results_3, count);
+ EXPECT_EQ(*count, 1);
+ linkahead_entity_entity retrieved_entity_3;
+ linkahead_transaction_result_set_at(&retrieve_results_3, &retrieved_entity_3, 0);
+ linkahead_entity_entity_get_errors_size(&retrieved_entity_3, count);
+ EXPECT_EQ(*count, 1);
+ linkahead_entity_message err_msg;
+ linkahead_entity_entity_get_error(&retrieved_entity_3, &err_msg, 0);
+ linkahead_entity_message_get_code(&err_msg, count);
+ EXPECT_EQ(*count, linkahead::entity::MessageCode::ENTITY_DOES_NOT_EXIST);
+
+ // Delete everything
+ linkahead_transaction_delete_transaction(&retrieve_transaction_3);
+ linkahead_transaction_delete_transaction(&delete_transaction);
+ linkahead_transaction_delete_transaction(&retrieve_transaction_2);
+ linkahead_transaction_delete_transaction(&update_transaction);
+ linkahead_transaction_delete_transaction(&retrieve_transaction_1);
+ linkahead_transaction_delete_transaction(&insert_transaction);
+ linkahead_entity_delete_entity(&original_entity);
+ linkahead_entity_delete_datatype(&in_type);
+}
+
+TEST_F(test_clinkahead, test_insert_with_prop_and_parent) {
+
+ linkahead_connection_connection connection;
+ linkahead_connection_connection_manager_get_default_connection(&connection);
+
+ // Create and insert a property, ...
+ std::cout << "Creating a property..." << std::endl;
+ linkahead_entity_entity original_prop;
+ linkahead_entity_create_entity(&original_prop);
+
+ linkahead_entity_entity_set_name(&original_prop, "TestProp");
+ linkahead_entity_entity_set_role(&original_prop, "PROPERTY");
+ linkahead_entity_datatype original_type;
+ linkahead_entity_create_atomic_datatype(&original_type, "TEXT");
+ linkahead_entity_entity_set_datatype(&original_prop, &original_type);
+
+ std::cout << "Inserting a property..." << std::endl;
+ linkahead_transaction_transaction prop_insertion;
+ linkahead_connection_connection_create_transaction(&connection, &prop_insertion);
+ linkahead_transaction_transaction_insert_entity(&prop_insertion, &original_prop);
+ int return_code(linkahead_transaction_transaction_execute(&prop_insertion));
+ EXPECT_EQ(return_code, 0);
+
+ std::cout << "Checking result..." << std::endl;
+ linkahead_transaction_result_set prop_results;
+ linkahead_transaction_transaction_get_result_set(&prop_insertion, &prop_results);
+ linkahead_entity_entity inserted_prop;
+ linkahead_transaction_result_set_at(&prop_results, &inserted_prop, 0);
+ char *prop_id = nullptr; // NOLINT
+ linkahead_entity_entity_get_id(&inserted_prop, &prop_id);
+
+ // ... a record type with this property, ...
+ linkahead_entity_entity original_rt;
+ linkahead_entity_create_entity(&original_rt);
+
+ linkahead_entity_entity_set_name(&original_rt, "TestType");
+ linkahead_entity_entity_set_role(&original_rt, "RECORD_TYPE");
+
+ linkahead_entity_property rt_prop;
+ linkahead_entity_create_property(&rt_prop);
+ linkahead_entity_property_set_id(&rt_prop, prop_id);
+ linkahead_entity_entity_append_property(&original_rt, &rt_prop);
+
+ linkahead_transaction_transaction rt_insertion;
+ linkahead_connection_connection_create_transaction(&connection, &rt_insertion);
+ linkahead_transaction_transaction_insert_entity(&rt_insertion, &original_rt);
+ return_code = linkahead_transaction_transaction_execute(&rt_insertion);
+ EXPECT_EQ(return_code, 0);
+
+ linkahead_transaction_result_set rt_results;
+ linkahead_transaction_transaction_get_result_set(&rt_insertion, &rt_results);
+ linkahead_entity_entity inserted_rt;
+ linkahead_transaction_result_set_at(&rt_results, &inserted_rt, 0);
+ char *rt_id = nullptr; // NOLINT
+ linkahead_entity_entity_get_id(&inserted_rt, &rt_id);
+
+ // ... and a record with this record type as a parent.
+ linkahead_entity_entity original_rec;
+ linkahead_entity_create_entity(&original_rec);
+ linkahead_entity_entity_set_name(&original_rec, "TestRec");
+ linkahead_entity_entity_set_role(&original_rec, "RECORD");
+ linkahead_entity_parent rec_parent;
+ linkahead_entity_create_parent(&rec_parent);
+ linkahead_entity_parent_set_id(&rec_parent, rt_id);
+ linkahead_entity_entity_append_parent(&original_rec, &rec_parent);
+ linkahead_entity_property rec_prop;
+ linkahead_entity_create_property(&rec_prop);
+ linkahead_entity_property_set_id(&rec_prop, prop_id);
+ linkahead_entity_value in_value;
+ linkahead_entity_create_string_value(&in_value, "Bla");
+ linkahead_entity_property_set_value(&rec_prop, &in_value);
+ linkahead_entity_entity_append_property(&original_rec, &rec_prop);
+
+ linkahead_transaction_transaction rec_insertion;
+ linkahead_connection_connection_create_transaction(&connection, &rec_insertion);
+ linkahead_transaction_transaction_insert_entity(&rec_insertion, &original_rec);
+ return_code = linkahead_transaction_transaction_execute(&rec_insertion);
+ EXPECT_EQ(return_code, 0);
+
+ linkahead_transaction_result_set rec_results;
+ linkahead_transaction_transaction_get_result_set(&rec_insertion, &rec_results);
+ linkahead_entity_entity inserted_rec;
+ linkahead_transaction_result_set_at(&rec_results, &inserted_rec, 0);
+ char *rec_id = nullptr; // NOLINT
+ linkahead_entity_entity_get_id(&inserted_rec, &rec_id);
+
+ // Retrieve the record again for comparison
+ linkahead_transaction_transaction retrieve_transaction;
+ linkahead_connection_connection_create_transaction(&connection, &retrieve_transaction);
+ linkahead_transaction_transaction_retrieve_by_id(&retrieve_transaction, rec_id);
+ return_code = linkahead_transaction_transaction_execute(&retrieve_transaction);
+ EXPECT_EQ(return_code, 0);
+
+ linkahead_transaction_result_set retrieve_result;
+ linkahead_transaction_transaction_get_result_set(&retrieve_transaction, &retrieve_result);
+ linkahead_entity_entity retrieved_rec;
+ linkahead_transaction_result_set_at(&retrieve_result, &retrieved_rec, 0);
+ char *in = nullptr; // NOLINT
+ char *out = nullptr; // NOLINT
+ linkahead_entity_entity_get_name(&original_rec, &in);
+ linkahead_entity_entity_get_name(&retrieved_rec, &out);
+ EXPECT_EQ(strcmp(in, out), 0);
+ int count[] = {0}; // NOLINT
+ linkahead_entity_entity_get_properties_size(&retrieved_rec, count);
+ EXPECT_EQ(*count, 1);
+ linkahead_entity_entity_get_parents_size(&retrieved_rec, count);
+ EXPECT_EQ(*count, 1);
+
+ linkahead_entity_parent retrieved_parent;
+ linkahead_entity_entity_get_parent(&retrieved_rec, &retrieved_parent, 0);
+ linkahead_entity_entity_get_name(&original_rt, &in);
+ linkahead_entity_parent_get_name(&retrieved_parent, &out);
+ EXPECT_EQ(strcmp(in, out), 0);
+ linkahead_entity_parent_get_id(&retrieved_parent, &out);
+ EXPECT_EQ(strcmp(rt_id, out), 0);
+
+ linkahead_entity_property retrieved_property;
+ linkahead_entity_entity_get_property(&retrieved_rec, &retrieved_property, 0);
+ linkahead_entity_entity_get_name(&original_prop, &in);
+ linkahead_entity_property_get_name(&retrieved_property, &out);
+ EXPECT_EQ(strcmp(in, out), 0);
+ linkahead_entity_value out_value;
+ linkahead_entity_property_get_value(&retrieved_property, &out_value);
+ linkahead_entity_value_get_as_string(&in_value, &in);
+ linkahead_entity_value_get_as_string(&out_value, &out);
+ EXPECT_EQ(strcmp(in, out), 0);
+
+ linkahead_transaction_delete_transaction(&retrieve_transaction);
+ linkahead_transaction_delete_transaction(&rec_insertion);
+ linkahead_entity_delete_property(&rec_prop);
+ linkahead_entity_delete_parent(&rec_parent);
+ linkahead_entity_delete_entity(&original_rec);
+ linkahead_transaction_delete_transaction(&rt_insertion);
+ linkahead_entity_delete_property(&rt_prop);
+ linkahead_entity_delete_entity(&original_rt);
+ linkahead_transaction_delete_transaction(&prop_insertion);
+ linkahead_entity_delete_entity(&original_prop);
+ linkahead_entity_delete_datatype(&original_type);
+ linkahead_entity_delete_value(&in_value);
+}
+
+TEST_F(test_clinkahead, test_up_n_download_file) {
+
+ linkahead_connection_connection connection;
+ linkahead_connection_connection_manager_get_default_connection(&connection);
+
+ linkahead_entity_entity original_entity;
+ linkahead_entity_create_entity(&original_entity);
+ linkahead_entity_entity_set_role(&original_entity, "FILE");
+ linkahead_entity_entity_set_local_path(&original_entity, test_upload_file_1.c_str());
+ linkahead_entity_entity_set_file_path(&original_entity, "/some/file");
+
+ linkahead_transaction_transaction insert_transaction;
+ linkahead_connection_connection_create_transaction(&connection, &insert_transaction);
+ linkahead_transaction_transaction_insert_entity(&insert_transaction, &original_entity);
+ int return_code(linkahead_transaction_transaction_execute(&insert_transaction));
+ EXPECT_EQ(return_code, 0);
+
+ linkahead_transaction_result_set rec_results;
+ linkahead_transaction_transaction_get_result_set(&insert_transaction, &rec_results);
+ linkahead_entity_entity inserted_rec;
+ linkahead_transaction_result_set_at(&rec_results, &inserted_rec, 0);
+ char *rec_id = nullptr; // NOLINT
+ linkahead_entity_entity_get_id(&inserted_rec, &rec_id);
+
+ linkahead_entity_entity download_entity;
+ linkahead_entity_create_entity(&download_entity);
+ linkahead_entity_entity_set_role(&download_entity, "FILE");
+ linkahead_entity_entity_set_local_path(&download_entity, "lol");
+ linkahead_entity_entity_set_file_path(&download_entity, "/some/file");
+
+ linkahead_transaction_transaction retrieve_transaction_1;
+ linkahead_connection_connection_create_transaction(&connection, &retrieve_transaction_1);
+ EXPECT_EQ(return_code, 0);
+ // return_code = linkahead_transaction_transaction_retrieve_by_id(
+ // &retrieve_transaction_1, rec_id);
+ return_code = linkahead_transaction_transaction_retrieve_and_download_file_by_id(
+ &retrieve_transaction_1, rec_id, test_download_file_1.c_str());
+ EXPECT_EQ(return_code, linkahead::StatusCode::GO_ON);
+ return_code = linkahead_transaction_transaction_execute(&retrieve_transaction_1);
+ EXPECT_EQ(return_code, 0);
+
+ linkahead_transaction_result_set result_set;
+ return_code = linkahead_transaction_transaction_get_result_set(&retrieve_transaction_1, &result_set);
+ EXPECT_EQ(return_code, 0);
+}
diff --git a/test/test_connection.cpp b/test/test_connection.cpp
index f0042f25b2992d98a73d9a3702b060915d491801..a0f2636b3e5751da99f9dedf16e847dcc146968c 100644
--- a/test/test_connection.cpp
+++ b/test/test_connection.cpp
@@ -1,5 +1,5 @@
/*
- * This file is a part of the CaosDB Project.
+ * This file is a part of the LinkAhead Project.
*
* Copyright (C) 2021 Timm Fitschen <t.fitschen@indiscale.com>
* Copyright (C) 2021 IndiScale GmbH <info@indiscale.com>
@@ -18,15 +18,15 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*
*/
-#include "caosdb/authentication.h" // for PlainPasswordAuthenticator
-#include "caosdb/certificate_provider.h" // for PemFileCertificateProvider
-#include "caosdb/configuration.h" // for InsecureConnectionConfigura...
-#include "caosdb/connection.h" // for Connection, VersionInfo, path
-#include "caosdb/constants.h" // for COMPATIBLE_SERVER_VERSION_M...
-#include "caosdb/exceptions.h" // for AuthenticationError, Connec...
-#include "caosdb/info.h" // for VersionInfo
-#include "caosdb/utility.h" // for get_env_fallback
-#include "caosdb_test_utility.h" // for EXPECT_THROW_MESSAGE
+#include "linkahead/authentication.h" // for PlainPasswordAuthenticator
+#include "linkahead/certificate_provider.h" // for PemFileCertificateProvider
+#include "linkahead/configuration.h" // for InsecureConnectionConfigura...
+#include "linkahead/connection.h" // for Connection, VersionInfo, path
+#include "linkahead/constants.h" // for COMPATIBLE_SERVER_VERSION_M...
+#include "linkahead/exceptions.h" // for AuthenticationError, Connec...
+#include "linkahead/info.h" // for VersionInfo
+#include "linkahead/utility.h" // for get_env_fallback
+#include "linkahead_test_utility.h" // for EXPECT_THROW_MESSAGE
#include <filesystem> // for path
#include <gtest/gtest_pred_impl.h> // NOLINT TODO how to fix this? for Test, TestInfo, TEST, EXPEC...
#include <gtest/gtest-message.h> // for Message
@@ -34,13 +34,13 @@
#include <memory> // for allocator, unique_ptr, __sh...
#include <string> // for stoi, string
-namespace caosdb::connection {
-using caosdb::authentication::PlainPasswordAuthenticator;
-using caosdb::configuration::InsecureConnectionConfiguration;
-using caosdb::configuration::PemFileCertificateProvider;
-using caosdb::configuration::TlsConnectionConfiguration;
-using caosdb::exceptions::AuthenticationError;
-using caosdb::exceptions::ConnectionError;
+namespace linkahead::connection {
+using linkahead::authentication::PlainPasswordAuthenticator;
+using linkahead::configuration::InsecureConnectionConfiguration;
+using linkahead::configuration::PemFileCertificateProvider;
+using linkahead::configuration::TlsConnectionConfiguration;
+using linkahead::exceptions::AuthenticationError;
+using linkahead::exceptions::ConnectionError;
TEST(test_connection, config_somehost_25323) {
auto port = 25323;
@@ -61,9 +61,9 @@ TEST(test_connection, connect_somehost_42347_fails) {
}
TEST(test_connection, connection_insecure_authentication_error_anonymous) {
- const auto *port_str = caosdb::utility::get_env_fallback("CAOSDB_SERVER_GRPC_PORT_HTTP", "8080");
+ const auto *port_str = linkahead::utility::get_env_fallback("CAOSDB_SERVER_GRPC_PORT_HTTP", "8080");
auto port = std::stoi(port_str);
- const auto *const host = caosdb::utility::get_env_fallback("CAOSDB_SERVER_HOST", "localhost");
+ const auto *const host = linkahead::utility::get_env_fallback("CAOSDB_SERVER_HOST", "localhost");
auto config = InsecureConnectionConfiguration(host, port);
auto connection = Connection(config);
@@ -72,10 +72,10 @@ TEST(test_connection, connection_insecure_authentication_error_anonymous) {
}
TEST(test_connection, connection_ssl_authentication_error_anonymous) {
- const auto *port_str = caosdb::utility::get_env_fallback("CAOSDB_SERVER_GRPC_PORT_HTTPS", "8443");
+ const auto *port_str = linkahead::utility::get_env_fallback("CAOSDB_SERVER_GRPC_PORT_HTTPS", "8443");
auto port = std::stoi(port_str);
- const auto *const host = caosdb::utility::get_env_fallback("CAOSDB_SERVER_HOST", "localhost");
- const auto path = caosdb::utility::get_env_fallback("CAOSDB_SERVER_CERT", std::string());
+ const auto *const host = linkahead::utility::get_env_fallback("CAOSDB_SERVER_HOST", "localhost");
+ const auto path = linkahead::utility::get_env_fallback("CAOSDB_SERVER_CERT", std::string());
auto cert = PemFileCertificateProvider(path);
auto config = TlsConnectionConfiguration(host, port, cert);
@@ -88,10 +88,10 @@ TEST(test_connection, connection_ssl_authentication_error_anonymous) {
}
TEST(test_connection, connection_ssl_authentication_error_wrong_credentials) {
- const auto *port_str = caosdb::utility::get_env_fallback("CAOSDB_SERVER_GRPC_PORT_HTTPS", "8443");
+ const auto *port_str = linkahead::utility::get_env_fallback("CAOSDB_SERVER_GRPC_PORT_HTTPS", "8443");
auto port = std::stoi(port_str);
- const auto *const host = caosdb::utility::get_env_fallback("CAOSDB_SERVER_HOST", "localhost");
- const auto path = caosdb::utility::get_env_fallback("CAOSDB_SERVER_CERT", std::string());
+ const auto *const host = linkahead::utility::get_env_fallback("CAOSDB_SERVER_HOST", "localhost");
+ const auto path = linkahead::utility::get_env_fallback("CAOSDB_SERVER_CERT", std::string());
const auto *const user = "not-a-user-23461237";
const auto *const password = "very-c-cred";
@@ -109,10 +109,10 @@ TEST(test_connection, connection_ssl_authentication_error_wrong_credentials) {
TEST(test_connection, connection_ssl_authentication_success) {
const auto &connection = ConnectionManager::GetDefaultConnection();
- auto major = caosdb::COMPATIBLE_SERVER_VERSION_MAJOR;
- auto minor = caosdb::COMPATIBLE_SERVER_VERSION_MINOR;
- auto patch = caosdb::COMPATIBLE_SERVER_VERSION_PATCH;
- const auto pre_release = std::string(caosdb::COMPATIBLE_SERVER_VERSION_PRE_RELEASE);
+ auto major = linkahead::COMPATIBLE_SERVER_VERSION_MAJOR;
+ auto minor = linkahead::COMPATIBLE_SERVER_VERSION_MINOR;
+ auto patch = linkahead::COMPATIBLE_SERVER_VERSION_PATCH;
+ const auto pre_release = std::string(linkahead::COMPATIBLE_SERVER_VERSION_PRE_RELEASE);
const auto &v_info = connection->RetrieveVersionInfo();
@@ -126,4 +126,4 @@ TEST(test_connection, connection_ssl_authentication_success) {
}
}
-} // namespace caosdb::connection
+} // namespace linkahead::connection
diff --git a/test/test_issues.cpp b/test/test_issues.cpp
index 9935eb179b3768f736a8ba37bdca5dc58d92a14f..fd2eeb9efd695a5fa951d36999f039c4ce34541c 100644
--- a/test/test_issues.cpp
+++ b/test/test_issues.cpp
@@ -1,5 +1,5 @@
/*
- * This file is a part of the CaosDB Project.
+ * This file is a part of the LinkAhead Project.
*
* Copyright (C) 2021 IndiScale GmbH <info@indiscale.com>
* Copyright (C) 2021 Daniel Hornung <d.hornung@indiscale.com>
@@ -17,11 +17,11 @@
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
-#include "caosdb/connection.h" // for Connection, Connec...
-#include "caosdb/data_type.h" // for AtomicDataType
-#include "caosdb/entity.h" // for Entity, Parent, Role
-#include "caosdb/transaction.h" // for Transaction, Entity
-#include "caosdb/transaction_status.h" // for TransactionStatus
+#include "linkahead/connection.h" // for Connection, Connec...
+#include "linkahead/data_type.h" // for AtomicDataType
+#include "linkahead/entity.h" // for Entity, Parent, Role
+#include "linkahead/transaction.h" // for Transaction, Entity
+#include "linkahead/transaction_status.h" // for TransactionStatus
#include <cstdint> // for int32_t
#include <gtest/gtest-message.h> // for Message
#include <gtest/gtest-spi.h> // for EXPECT_NONFATAL_FA...
@@ -32,11 +32,11 @@
#include <string> // for operator+, operator<<
#include <vector> // for vector
-namespace caosdb::transaction {
-using caosdb::entity::AtomicDataType;
-using caosdb::entity::Entity;
-using caosdb::entity::Parent;
-using caosdb::entity::Role;
+namespace linkahead::transaction {
+using linkahead::entity::AtomicDataType;
+using linkahead::entity::Entity;
+using linkahead::entity::Parent;
+using linkahead::entity::Role;
class test_issues : public ::testing::Test {
public:
@@ -45,7 +45,7 @@ public:
static void DeleteEntities() {
// delete all entities
- const auto &connection = caosdb::connection::ConnectionManager::GetDefaultConnection();
+ const auto &connection = linkahead::connection::ConnectionManager::GetDefaultConnection();
auto query_transaction(connection->CreateTransaction());
query_transaction->Query("FIND ENTITY WITH id > 99");
query_transaction->Execute();
@@ -72,7 +72,7 @@ protected:
* test error-prone updates
*/
TEST_F(test_issues, server_issue_170) {
- const auto &connection = caosdb::connection::ConnectionManager::GetDefaultConnection();
+ const auto &connection = linkahead::connection::ConnectionManager::GetDefaultConnection();
// Insert original
auto insert_transaction(connection->CreateTransaction());
@@ -116,7 +116,7 @@ TEST_F(test_issues, server_issue_170) {
* This must result in a server error.
*/
TEST_F(test_issues, server_issue_171) {
- const auto &connection = caosdb::connection::ConnectionManager::GetDefaultConnection();
+ const auto &connection = linkahead::connection::ConnectionManager::GetDefaultConnection();
auto insert_transaction(connection->CreateTransaction());
@@ -166,7 +166,7 @@ TEST_F(test_issues, server_issue_171) {
* The file attributes should be ignored by the server.
*/
TEST_F(test_issues, server_issue_174) {
- const auto &connection = caosdb::connection::ConnectionManager::GetDefaultConnection();
+ const auto &connection = linkahead::connection::ConnectionManager::GetDefaultConnection();
auto insert_transaction(connection->CreateTransaction());
@@ -183,4 +183,4 @@ TEST_F(test_issues, server_issue_174) {
EXPECT_FALSE(insert_status.IsError());
}
-} // namespace caosdb::transaction
+} // namespace linkahead::transaction
diff --git a/test/test_list_properties.cpp b/test/test_list_properties.cpp
index b60c58fadff358b878108ca72edbb67b1af3f26e..9708e3523a054caa4267a98fcf8f5e9076f8cfc1 100644
--- a/test/test_list_properties.cpp
+++ b/test/test_list_properties.cpp
@@ -1,5 +1,5 @@
/*
- * This file is a part of the CaosDB Project.
+ * This file is a part of the LinkAhead Project.
*
* Copyright (C) 2021 Timm Fitschen <t.fitschen@indiscale.com>
* Copyright (C) 2021 IndiScale GmbH <info@indiscale.com>
@@ -18,12 +18,12 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*
*/
-#include "caosdb/connection.h" // for Connection, ConnectionManager
-#include "caosdb/data_type.h" // for AtomicDataType
-#include "caosdb/entity.h" // for Entity, Messages, Message
-#include "caosdb/transaction.h" // for Entity, Transaction,...
-#include "caosdb/transaction_status.h" // for TransactionStatus, StatusCode
-#include "caosdb/value.h" // for value
+#include "linkahead/connection.h" // for Connection, ConnectionManager
+#include "linkahead/data_type.h" // for AtomicDataType
+#include "linkahead/entity.h" // for Entity, Messages, Message
+#include "linkahead/transaction.h" // for Entity, Transaction,...
+#include "linkahead/transaction_status.h" // for TransactionStatus, StatusCode
+#include "linkahead/value.h" // for value
#include <cstdint> // for int64_t
#include <gtest/gtest-message.h> // for Message
#include <gtest/gtest-test-part.h> // for TestPartResult, SuiteApiResolver
@@ -33,7 +33,7 @@
#include <string> // for string
#include <vector> // for vector
-namespace caosdb::entity {
+namespace linkahead::entity {
class test_list_properties : public ::testing::Test {
protected:
@@ -42,7 +42,7 @@ protected:
void TearDown() override { DeleteEntities(); }
static void DeleteEntities() {
- const auto &connection = caosdb::connection::ConnectionManager::GetDefaultConnection();
+ const auto &connection = linkahead::connection::ConnectionManager::GetDefaultConnection();
auto query_transaction(connection->CreateTransaction());
query_transaction->Query("FIND ENTITY WITH id > 99");
query_transaction->Execute();
@@ -57,7 +57,7 @@ protected:
};
TEST_F(test_list_properties, insert_list_of_text) {
- const auto &connection = caosdb::connection::ConnectionManager::GetDefaultConnection();
+ const auto &connection = linkahead::connection::ConnectionManager::GetDefaultConnection();
auto insertion_prop(connection->CreateTransaction());
@@ -112,7 +112,7 @@ TEST_F(test_list_properties, insert_list_of_text) {
}
TEST_F(test_list_properties, insert_list_of_int) {
- const auto &connection = caosdb::connection::ConnectionManager::GetDefaultConnection();
+ const auto &connection = linkahead::connection::ConnectionManager::GetDefaultConnection();
auto insertion_prop(connection->CreateTransaction());
@@ -167,7 +167,7 @@ TEST_F(test_list_properties, insert_list_of_int) {
}
TEST_F(test_list_properties, insert_list_of_bool) {
- const auto &connection = caosdb::connection::ConnectionManager::GetDefaultConnection();
+ const auto &connection = linkahead::connection::ConnectionManager::GetDefaultConnection();
auto insertion_prop(connection->CreateTransaction());
@@ -222,7 +222,7 @@ TEST_F(test_list_properties, insert_list_of_bool) {
}
TEST_F(test_list_properties, insert_list_non_list_datatype) {
- const auto &connection = caosdb::connection::ConnectionManager::GetDefaultConnection();
+ const auto &connection = linkahead::connection::ConnectionManager::GetDefaultConnection();
auto insertion_prop(connection->CreateTransaction());
@@ -245,4 +245,4 @@ TEST_F(test_list_properties, insert_list_non_list_datatype) {
EXPECT_EQ(query_transaction->GetResultSet().size(), 0);
}
-} // namespace caosdb::entity
+} // namespace linkahead::entity
diff --git a/test/test_properties.cpp b/test/test_properties.cpp
index 95dffb7f0aedea4b8016b332315175ed8a3b1d56..cc3f63d48fd14c0e757d01ffb200d951e4164fd4 100644
--- a/test/test_properties.cpp
+++ b/test/test_properties.cpp
@@ -1,5 +1,5 @@
/*
- * This file is a part of the CaosDB Project.
+ * This file is a part of the LinkAhead Project.
*
* Copyright (C) 2021 Timm Fitschen <t.fitschen@indiscale.com>
* Copyright (C) 2021 IndiScale GmbH <info@indiscale.com>
@@ -18,17 +18,17 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*
*/
-#include "caosdb/connection.h" // for Connection, ConnectionManager
-#include "caosdb/data_type.h" // for AtomicDataType, AtomicDataTyp...
-#include "caosdb/entity.h" // for Entity, Properties, Property
-#include "caosdb/transaction.h" // for Transaction, ResultSet, Resul...
-#include "caosdb/transaction_status.h" // for TransactionStatus
+#include "linkahead/connection.h" // for Connection, ConnectionManager
+#include "linkahead/data_type.h" // for AtomicDataType, AtomicDataTyp...
+#include "linkahead/entity.h" // for Entity, Properties, Property
+#include "linkahead/transaction.h" // for Transaction, ResultSet, Resul...
+#include "linkahead/transaction_status.h" // for TransactionStatus
#include <gtest/gtest-message.h> // for Message
#include <gtest/gtest-test-part.h> // for TestPartResult, SuiteApiResolver
#include <gtest/gtest_pred_impl.h> // for AssertionResult, EXPECT_EQ
#include <memory> // for unique_ptr, allocator, __shar...
-namespace caosdb::entity {
+namespace linkahead::entity {
class test_properties : public ::testing::Test {
protected:
@@ -37,7 +37,7 @@ protected:
void TearDown() override { DeleteEntities(); }
static void DeleteEntities() {
- const auto &connection = caosdb::connection::ConnectionManager::GetDefaultConnection();
+ const auto &connection = linkahead::connection::ConnectionManager::GetDefaultConnection();
auto query_transaction(connection->CreateTransaction());
query_transaction->Query("FIND ENTITY WITH id > 99");
query_transaction->Execute();
@@ -52,7 +52,7 @@ protected:
};
TEST_F(test_properties, retrieve_unit) {
- const auto &connection = caosdb::connection::ConnectionManager::GetDefaultConnection();
+ const auto &connection = linkahead::connection::ConnectionManager::GetDefaultConnection();
auto insertion_prop(connection->CreateTransaction());
@@ -101,4 +101,4 @@ TEST_F(test_properties, retrieve_unit) {
EXPECT_EQ(same_record_type.GetProperties().at(0).GetUnit(), "V");
}
-} // namespace caosdb::entity
+} // namespace linkahead::entity
diff --git a/test/test_select.cpp b/test/test_select.cpp
index fa63eefc69e52a6ebc292495e02f35b45b1e29a1..d8f630279f401905cea921e5156ef674be1c161b 100644
--- a/test/test_select.cpp
+++ b/test/test_select.cpp
@@ -1,5 +1,5 @@
/*
- * This file is a part of the CaosDB Project.
+ * This file is a part of the LinkAhead Project.
*
* Copyright (C) 2022 IndiScale GmbH <info@indiscale.com>
* Copyright (C) 2022 Timm Fitschen <t.fitschen@indiscale.com>
@@ -17,13 +17,13 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*
*/
-#include "caosdb/connection.h" // for Connection, ConnectionManager
-#include "caosdb/data_type.h" // for AtomicDataType
-#include "caosdb/entity.h" // for Entity, Property, Role, Parent
-#include "caosdb/result_set.h" // for Entity, ResultSet, ResultSet::ite...
-#include "caosdb/result_table.h" // for ResultTable::HeaderIterator, Resu...
-#include "caosdb/transaction.h" // for Transaction, ResultTable
-#include "caosdb/value.h" // for Value
+#include "linkahead/connection.h" // for Connection, ConnectionManager
+#include "linkahead/data_type.h" // for AtomicDataType
+#include "linkahead/entity.h" // for Entity, Property, Role, Parent
+#include "linkahead/result_set.h" // for Entity, ResultSet, ResultSet::ite...
+#include "linkahead/result_table.h" // for ResultTable::HeaderIterator, Resu...
+#include "linkahead/transaction.h" // for Transaction, ResultTable
+#include "linkahead/value.h" // for Value
#include <gtest/gtest-message.h> // for Message
#include <gtest/gtest-spi.h> // for EXPECT_NONFATAL_FA...
#include <gtest/gtest-test-part.h> // for SuiteApiResolver, TestFactoryImpl
@@ -32,19 +32,19 @@
#include <memory> // for allocator, unique_ptr, __shared_p...
#include <string> // for string
-namespace caosdb::transaction {
-using caosdb::entity::AtomicDataType;
-using caosdb::entity::DataType;
-using caosdb::entity::Entity;
-using caosdb::entity::Parent;
-using caosdb::entity::Property;
-using caosdb::entity::Role;
-using caosdb::entity::Value;
+namespace linkahead::transaction {
+using linkahead::entity::AtomicDataType;
+using linkahead::entity::DataType;
+using linkahead::entity::Entity;
+using linkahead::entity::Parent;
+using linkahead::entity::Property;
+using linkahead::entity::Role;
+using linkahead::entity::Value;
class test_select : public ::testing::Test {
public:
static void InsertEntity(Entity *entity) {
- const auto &connection = caosdb::connection::ConnectionManager::GetDefaultConnection();
+ const auto &connection = linkahead::connection::ConnectionManager::GetDefaultConnection();
auto insert_transaction(connection->CreateTransaction());
insert_transaction->InsertEntity(entity);
insert_transaction->Execute();
@@ -52,7 +52,7 @@ public:
static void DeleteEntities() {
// delete all entities
- const auto &connection = caosdb::connection::ConnectionManager::GetDefaultConnection();
+ const auto &connection = linkahead::connection::ConnectionManager::GetDefaultConnection();
auto query_transaction(connection->CreateTransaction());
query_transaction->Query("FIND Entity");
query_transaction->Execute();
@@ -119,7 +119,7 @@ protected:
DeleteEntities();
// Test Entities
- const auto &connection = caosdb::connection::ConnectionManager::GetDefaultConnection();
+ const auto &connection = linkahead::connection::ConnectionManager::GetDefaultConnection();
auto insert_transaction(connection->CreateTransaction());
// 1. Two RecordTypes
auto rt = CreateTestRT();
@@ -175,7 +175,7 @@ protected:
*/
TEST_F(test_select, test_select_empty) {
test_select::DeleteEntities();
- const auto &connection = caosdb::connection::ConnectionManager::GetDefaultConnection();
+ const auto &connection = linkahead::connection::ConnectionManager::GetDefaultConnection();
auto query_transaction(connection->CreateTransaction());
query_transaction->Query("SELECT name FROM RecordType TestRT");
@@ -195,7 +195,7 @@ TEST_F(test_select, test_select_empty) {
* Test select name query on record type.
*/
TEST_F(test_select, test_select_name) {
- const auto &connection = caosdb::connection::ConnectionManager::GetDefaultConnection();
+ const auto &connection = linkahead::connection::ConnectionManager::GetDefaultConnection();
auto query_transaction(connection->CreateTransaction());
query_transaction->Query("SELECT name FROM RecordType TestRT");
@@ -215,7 +215,7 @@ TEST_F(test_select, test_select_name) {
* Test select description query on record type.
*/
TEST_F(test_select, test_select_property_description) {
- const auto &connection = caosdb::connection::ConnectionManager::GetDefaultConnection();
+ const auto &connection = linkahead::connection::ConnectionManager::GetDefaultConnection();
auto query_transaction(connection->CreateTransaction());
query_transaction->Query("SELECT TestPropDouble.description FROM Record TestRT2");
@@ -236,7 +236,7 @@ TEST_F(test_select, test_select_property_description) {
* Test select description query on record type.
*/
TEST_F(test_select, test_select_description) {
- const auto &connection = caosdb::connection::ConnectionManager::GetDefaultConnection();
+ const auto &connection = linkahead::connection::ConnectionManager::GetDefaultConnection();
auto query_transaction(connection->CreateTransaction());
query_transaction->Query("SELECT description FROM RecordType TestRT");
@@ -256,7 +256,7 @@ TEST_F(test_select, test_select_description) {
* Test select TestProp query on record.
*/
TEST_F(test_select, test_select_testprop) {
- const auto &connection = caosdb::connection::ConnectionManager::GetDefaultConnection();
+ const auto &connection = linkahead::connection::ConnectionManager::GetDefaultConnection();
auto entity = test_select::CreateRecord("TestProp", Value("val1"));
test_select::InsertEntity(&entity);
@@ -278,7 +278,7 @@ TEST_F(test_select, test_select_testprop) {
* Test select double value query on record.
*/
TEST_F(test_select, test_select_double) {
- const auto &connection = caosdb::connection::ConnectionManager::GetDefaultConnection();
+ const auto &connection = linkahead::connection::ConnectionManager::GetDefaultConnection();
auto entity = test_select::CreateRecord("TestPropDouble", Value(2.123));
test_select::InsertEntity(&entity);
@@ -301,7 +301,7 @@ TEST_F(test_select, test_select_double) {
* Test select double value query on record.
*/
TEST_F(test_select, test_select_value) {
- const auto &connection = caosdb::connection::ConnectionManager::GetDefaultConnection();
+ const auto &connection = linkahead::connection::ConnectionManager::GetDefaultConnection();
auto entity = test_select::CreateRecord("TestPropDouble", Value(2.123));
test_select::InsertEntity(&entity);
@@ -324,7 +324,7 @@ TEST_F(test_select, test_select_value) {
* Test select unit value query on record.
*/
TEST_F(test_select, test_select_unit) {
- const auto &connection = caosdb::connection::ConnectionManager::GetDefaultConnection();
+ const auto &connection = linkahead::connection::ConnectionManager::GetDefaultConnection();
auto query_transaction(connection->CreateTransaction());
query_transaction->Query("SELECT unit FROM PROPERTY TestPropDouble");
@@ -344,7 +344,7 @@ TEST_F(test_select, test_select_unit) {
* Test select unit value query on record.
*/
TEST_F(test_select, test_select_property_unit) {
- const auto &connection = caosdb::connection::ConnectionManager::GetDefaultConnection();
+ const auto &connection = linkahead::connection::ConnectionManager::GetDefaultConnection();
auto entity = test_select::CreateRecord("TestPropDouble", Value(2.123));
test_select::InsertEntity(&entity);
@@ -371,7 +371,7 @@ TEST_F(test_select, test_select_property_unit) {
* Test select int value query on record.
*/
TEST_F(test_select, test_select_int) {
- const auto &connection = caosdb::connection::ConnectionManager::GetDefaultConnection();
+ const auto &connection = linkahead::connection::ConnectionManager::GetDefaultConnection();
auto entity = test_select::CreateRecord("TestPropInt", Value(1234));
test_select::InsertEntity(&entity);
@@ -392,7 +392,7 @@ TEST_F(test_select, test_select_int) {
/* Test select boolean value query on record. */
TEST_F(test_select, test_select_boolean) {
- const auto &connection = caosdb::connection::ConnectionManager::GetDefaultConnection();
+ const auto &connection = linkahead::connection::ConnectionManager::GetDefaultConnection();
auto entity = test_select::CreateRecord("TestPropBool", Value(true));
test_select::InsertEntity(&entity);
@@ -415,7 +415,7 @@ TEST_F(test_select, test_select_boolean) {
* Test select the referenced id.
*/
TEST_F(test_select, test_select_reference) {
- const auto &connection = caosdb::connection::ConnectionManager::GetDefaultConnection();
+ const auto &connection = linkahead::connection::ConnectionManager::GetDefaultConnection();
auto get_id_of_ref_rec(connection->CreateTransaction());
get_id_of_ref_rec->Query("SELECT id FROM RECORD TestRT2");
get_id_of_ref_rec->Execute();
@@ -442,7 +442,7 @@ TEST_F(test_select, test_select_reference) {
* Test select the referenced id.
*/
TEST_F(test_select, test_select_reference_value) {
- const auto &connection = caosdb::connection::ConnectionManager::GetDefaultConnection();
+ const auto &connection = linkahead::connection::ConnectionManager::GetDefaultConnection();
auto get_id_of_ref_rec(connection->CreateTransaction());
get_id_of_ref_rec->Query("SELECT id, version FROM RECORD TestRT2");
get_id_of_ref_rec->Execute();
@@ -471,7 +471,7 @@ TEST_F(test_select, test_select_reference_value) {
* Test select the referenced entity's property.
*/
TEST_F(test_select, test_select_reference_entitys_property) {
- const auto &connection = caosdb::connection::ConnectionManager::GetDefaultConnection();
+ const auto &connection = linkahead::connection::ConnectionManager::GetDefaultConnection();
auto get_id_of_ref_rec(connection->CreateTransaction());
get_id_of_ref_rec->Query("SELECT id FROM RECORD TestRT2");
get_id_of_ref_rec->Execute();
@@ -498,7 +498,7 @@ TEST_F(test_select, test_select_reference_entitys_property) {
* Test select the referenced entity's property's unit.
*/
TEST_F(test_select, test_select_reference_entitys_propertys_unit) {
- const auto &connection = caosdb::connection::ConnectionManager::GetDefaultConnection();
+ const auto &connection = linkahead::connection::ConnectionManager::GetDefaultConnection();
auto get_id_of_ref_rec(connection->CreateTransaction());
get_id_of_ref_rec->Query("SELECT id FROM RECORD TestRT2");
get_id_of_ref_rec->Execute();
@@ -525,7 +525,7 @@ TEST_F(test_select, test_select_reference_entitys_propertys_unit) {
* Test select the referenced entity's property's description.
*/
TEST_F(test_select, test_select_reference_entitys_propertys_description) {
- const auto &connection = caosdb::connection::ConnectionManager::GetDefaultConnection();
+ const auto &connection = linkahead::connection::ConnectionManager::GetDefaultConnection();
auto get_id_of_ref_rec(connection->CreateTransaction());
get_id_of_ref_rec->Query("SELECT id FROM RECORD TestRT2");
get_id_of_ref_rec->Execute();
@@ -553,7 +553,7 @@ TEST_F(test_select, test_select_reference_entitys_propertys_description) {
* Test select the referenced entity's property's name.
*/
TEST_F(test_select, test_select_reference_entitys_propertys_name) {
- const auto &connection = caosdb::connection::ConnectionManager::GetDefaultConnection();
+ const auto &connection = linkahead::connection::ConnectionManager::GetDefaultConnection();
auto get_id_of_ref_rec(connection->CreateTransaction());
get_id_of_ref_rec->Query("SELECT id FROM RECORD TestRT2");
get_id_of_ref_rec->Execute();
@@ -580,7 +580,7 @@ TEST_F(test_select, test_select_reference_entitys_propertys_name) {
* Test select the referenced entity's property's id.
*/
TEST_F(test_select, test_select_reference_entitys_propertys_id) {
- const auto &connection = caosdb::connection::ConnectionManager::GetDefaultConnection();
+ const auto &connection = linkahead::connection::ConnectionManager::GetDefaultConnection();
auto get_id_of_ref_rec(connection->CreateTransaction());
get_id_of_ref_rec->Query("SELECT id FROM RECORD TestRT2");
get_id_of_ref_rec->Execute();
@@ -612,7 +612,7 @@ TEST_F(test_select, test_select_reference_entitys_propertys_id) {
* Test select a list (TEXT).
*/
TEST_F(test_select, test_select_list_of_text) {
- const auto &connection = caosdb::connection::ConnectionManager::GetDefaultConnection();
+ const auto &connection = linkahead::connection::ConnectionManager::GetDefaultConnection();
auto entity = test_select::CreateRecord("TestRT2", Value());
Property listp;
@@ -641,7 +641,7 @@ TEST_F(test_select, test_select_list_of_text) {
* Test select a list (REFERENCE).
*/
TEST_F(test_select, test_select_list_of_reference) {
- const auto &connection = caosdb::connection::ConnectionManager::GetDefaultConnection();
+ const auto &connection = linkahead::connection::ConnectionManager::GetDefaultConnection();
auto get_id_of_ref_rec(connection->CreateTransaction());
get_id_of_ref_rec->Query("SELECT id FROM RECORD TestRT2");
@@ -671,4 +671,4 @@ TEST_F(test_select, test_select_list_of_reference) {
}
}
-} // namespace caosdb::transaction
+} // namespace linkahead::transaction
diff --git a/test/test_transaction.cpp b/test/test_transaction.cpp
index 2b1be4c04250c989a3f2283ad24dab438625df62..34a43486068c1248b7fd2b69d19731ea6fa7c2fd 100644
--- a/test/test_transaction.cpp
+++ b/test/test_transaction.cpp
@@ -1,5 +1,5 @@
/*
- * This file is a part of the CaosDB Project.
+ * This file is a part of the LinkAhead Project.
*
* Copyright (C) 2021 IndiScale GmbH <info@indiscale.com>
* Copyright (C) 2021 Timm Fitschen <t.fitschen@indiscale.com>
@@ -19,17 +19,17 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*
*/
-#include "caosdb/connection.h" // for Connection, Connec...
-#include "caosdb/data_type.h" // for AtomicDataType
-#include "caosdb/entity.h" // for Entity, Property
-#include "caosdb/file_descriptor.h" // for FileDescriptor
-#include "caosdb/file_transmission/file_reader.h" // for path, FileReader
-#include "caosdb/file_transmission/file_writer.h" // for FileWriter
-#include "caosdb/message_code.h" // for MessageCode, ENTIT...
-#include "caosdb/status_code.h" // for StatusCode, SUCCESS
-#include "caosdb/transaction.h" // for Entity, Transaction
-#include "caosdb/transaction_status.h" // for TransactionStatus
-#include "caosdb/value.h" // for Value
+#include "linkahead/connection.h" // for Connection, Connec...
+#include "linkahead/data_type.h" // for AtomicDataType
+#include "linkahead/entity.h" // for Entity, Property
+#include "linkahead/file_descriptor.h" // for FileDescriptor
+#include "linkahead/file_transmission/file_reader.h" // for path, FileReader
+#include "linkahead/file_transmission/file_writer.h" // for FileWriter
+#include "linkahead/message_code.h" // for MessageCode, ENTIT...
+#include "linkahead/status_code.h" // for StatusCode, SUCCESS
+#include "linkahead/transaction.h" // for Entity, Transaction
+#include "linkahead/transaction_status.h" // for TransactionStatus
+#include "linkahead/value.h" // for Value
#include <chrono> // for filesystem
#include <cstddef> // for size_t
#include <cstdint> // for int64_t, int32_t
@@ -46,15 +46,15 @@
#include <vector> // for vector, operator!=
namespace fs = std::filesystem;
-namespace caosdb::transaction {
-using caosdb::entity::AtomicDataType;
-using caosdb::entity::Entity;
-using caosdb::entity::Importance;
-using caosdb::entity::MessageCode;
-using caosdb::entity::Parent;
-using caosdb::entity::Property;
-using caosdb::entity::Role;
-using caosdb::entity::Value;
+namespace linkahead::transaction {
+using linkahead::entity::AtomicDataType;
+using linkahead::entity::Entity;
+using linkahead::entity::Importance;
+using linkahead::entity::MessageCode;
+using linkahead::entity::Parent;
+using linkahead::entity::Property;
+using linkahead::entity::Role;
+using linkahead::entity::Value;
class test_transaction : public ::testing::Test {
public:
@@ -101,7 +101,7 @@ public:
}
static void DeleteEntities() {
// delete all entities
- const auto &connection = caosdb::connection::ConnectionManager::GetDefaultConnection();
+ const auto &connection = linkahead::connection::ConnectionManager::GetDefaultConnection();
auto query_transaction(connection->CreateTransaction());
query_transaction->Query("FIND ENTITY WITH id > 99");
query_transaction->Execute();
@@ -168,7 +168,7 @@ template <> auto test_transaction::getValueAs<bool>(const Value &value) -> bool
* error message
*/
TEST_F(test_transaction, retrieve_non_existing) {
- const auto &connection = caosdb::connection::ConnectionManager::GetDefaultConnection();
+ const auto &connection = linkahead::connection::ConnectionManager::GetDefaultConnection();
auto transaction(connection->CreateTransaction());
@@ -196,7 +196,7 @@ TEST_F(test_transaction, retrieve_non_existing) {
* is set.
*/
TEST_F(test_transaction, insert_without_delete) {
- const auto &connection = caosdb::connection::ConnectionManager::GetDefaultConnection();
+ const auto &connection = linkahead::connection::ConnectionManager::GetDefaultConnection();
auto insert_transaction(connection->CreateTransaction());
@@ -229,7 +229,7 @@ TEST_F(test_transaction, insert_without_delete) {
TEST_F(test_transaction, insert_delete) {
// same as in insert_without_delete
// until marked END SAME
- const auto &connection = caosdb::connection::ConnectionManager::GetDefaultConnection();
+ const auto &connection = linkahead::connection::ConnectionManager::GetDefaultConnection();
auto insert_transaction(connection->CreateTransaction());
@@ -273,7 +273,7 @@ TEST_F(test_transaction, insert_delete) {
TEST_F(test_transaction, insert_delete_with_parent) {
// same as in insert_without_delete
// until marked END SAME
- const auto &connection = caosdb::connection::ConnectionManager::GetDefaultConnection();
+ const auto &connection = linkahead::connection::ConnectionManager::GetDefaultConnection();
auto insert_transaction(connection->CreateTransaction());
@@ -367,7 +367,7 @@ TEST_F(test_transaction, insert_delete_with_parent) {
* insert a property, record type with that property and a record with it
*/
TEST_F(test_transaction, insert_delete_with_property) {
- const auto &connection = caosdb::connection::ConnectionManager::GetDefaultConnection();
+ const auto &connection = linkahead::connection::ConnectionManager::GetDefaultConnection();
// Create and insert Text property
Entity prop_ent;
@@ -559,7 +559,7 @@ TEST_F(test_transaction, insert_delete_with_property) {
* test retrieving multiple entities at once
*/
TEST_F(test_transaction, test_multi_retrieve) {
- const auto &connection = caosdb::connection::ConnectionManager::GetDefaultConnection();
+ const auto &connection = linkahead::connection::ConnectionManager::GetDefaultConnection();
auto transaction(connection->CreateTransaction());
@@ -591,7 +591,7 @@ TEST_F(test_transaction, test_multi_retrieve) {
* test insert, then update and then delete a RecordType
*/
TEST_F(test_transaction, insert_update_delete) {
- const auto &connection = caosdb::connection::ConnectionManager::GetDefaultConnection();
+ const auto &connection = linkahead::connection::ConnectionManager::GetDefaultConnection();
// INSERT
auto insert_transaction(connection->CreateTransaction());
@@ -658,7 +658,7 @@ TEST_F(test_transaction, insert_update_delete) {
* test insert a RecordType and then submit a find and a count query
*/
TEST_F(test_transaction, test_query) {
- const auto &connection = caosdb::connection::ConnectionManager::GetDefaultConnection();
+ const auto &connection = linkahead::connection::ConnectionManager::GetDefaultConnection();
auto insert_transaction(connection->CreateTransaction());
@@ -701,7 +701,7 @@ TEST_F(test_transaction, test_query) {
* Test numeric values (template).
*/
template <typename T, typename S> auto test_numeric_values_impl(AtomicDataType a_type) -> void {
- const auto &connection = caosdb::connection::ConnectionManager::GetDefaultConnection();
+ const auto &connection = linkahead::connection::ConnectionManager::GetDefaultConnection();
// Insert entities
auto values_orig = test_transaction::generateValues<T>();
@@ -765,7 +765,7 @@ TEST_F(test_transaction, test_numeric_values) {
* Test date time values.
*/
TEST_F(test_transaction, test_datetime_values) {
- const auto &connection = caosdb::connection::ConnectionManager::GetDefaultConnection();
+ const auto &connection = linkahead::connection::ConnectionManager::GetDefaultConnection();
// Insert entities
auto values_orig = test_transaction::generateDatetimeValues();
@@ -817,7 +817,7 @@ TEST_F(test_transaction, test_datetime_values) {
}
TEST_F(test_transaction, test_integer_out_of_range) {
- const auto &connection = caosdb::connection::ConnectionManager::GetDefaultConnection();
+ const auto &connection = linkahead::connection::ConnectionManager::GetDefaultConnection();
// Insert entities
std::vector<int64_t> values = {std::numeric_limits<int64_t>::max(),
@@ -852,7 +852,7 @@ TEST_F(test_transaction, test_integer_out_of_range) {
* Insert three record types in a single transaction.
*/
TEST_F(test_transaction, test_multi_insert_transactions) {
- const auto &connection = caosdb::connection::ConnectionManager::GetDefaultConnection();
+ const auto &connection = linkahead::connection::ConnectionManager::GetDefaultConnection();
auto insert_transaction(connection->CreateTransaction());
@@ -885,7 +885,7 @@ TEST_F(test_transaction, test_multi_insert_transactions) {
* Update three record types in a single transaction.
*/
TEST_F(test_transaction, test_multi_update_transactions) {
- const auto &connection = caosdb::connection::ConnectionManager::GetDefaultConnection();
+ const auto &connection = linkahead::connection::ConnectionManager::GetDefaultConnection();
auto insert_transaction(connection->CreateTransaction());
@@ -940,7 +940,7 @@ TEST_F(test_transaction, test_multi_update_transactions) {
* to C), delete B.
*/
TEST_F(test_transaction, test_multi_write_transactions) {
- const auto &connection = caosdb::connection::ConnectionManager::GetDefaultConnection();
+ const auto &connection = linkahead::connection::ConnectionManager::GetDefaultConnection();
Entity entity_a;
Entity entity_b;
@@ -1005,7 +1005,7 @@ TEST_F(test_transaction, test_multi_write_transactions) {
* combinations
*/
TEST_F(test_transaction, test_query_with_retrieve) {
- const auto &connection = caosdb::connection::ConnectionManager::GetDefaultConnection();
+ const auto &connection = linkahead::connection::ConnectionManager::GetDefaultConnection();
// rt1
Entity rt1;
@@ -1118,7 +1118,7 @@ TEST_F(test_transaction, test_query_with_retrieve) {
* create a file object and upload it
*/
TEST_F(test_transaction, test_file_upload) {
- const auto &connection = caosdb::connection::ConnectionManager::GetDefaultConnection();
+ const auto &connection = linkahead::connection::ConnectionManager::GetDefaultConnection();
Entity file;
file.SetRole(Role::FILE);
@@ -1154,7 +1154,7 @@ TEST_F(test_transaction, test_file_upload) {
* create a file object, upload and then download it
*/
TEST_F(test_transaction, test_file_up_n_download) {
- const auto &connection = caosdb::connection::ConnectionManager::GetDefaultConnection();
+ const auto &connection = linkahead::connection::ConnectionManager::GetDefaultConnection();
Entity file;
file.SetRole(Role::FILE);
@@ -1206,7 +1206,7 @@ TEST_F(test_transaction, test_file_up_n_download) {
* Test a small worklfow
*/
TEST_F(test_transaction, test_full_workflow) {
- const auto &connection = caosdb::connection::ConnectionManager::GetDefaultConnection();
+ const auto &connection = linkahead::connection::ConnectionManager::GetDefaultConnection();
// ###### Create Data Model ######
Entity dataRT;
@@ -1329,7 +1329,7 @@ TEST_F(test_transaction, test_full_workflow) {
}
TEST_F(test_transaction, test_delete_string_id) {
- const auto &connection = caosdb::connection::ConnectionManager::GetDefaultConnection();
+ const auto &connection = linkahead::connection::ConnectionManager::GetDefaultConnection();
auto transaction(connection->CreateTransaction());
transaction->DeleteById("20");
@@ -1347,4 +1347,4 @@ TEST_F(test_transaction, test_delete_string_id) {
EXPECT_EQ(results.at(1).GetErrors().at(0).GetDescription(), "Entity does not exist.");
}
-} // namespace caosdb::transaction
+} // namespace linkahead::transaction
diff --git a/test/test_user.cpp b/test/test_user.cpp
index 9f4abe5cd26cd47475c6b8fba1283eaff8ce66ca..7817aff09b180ef38d83bc52a18cd9a516e23b45 100644
--- a/test/test_user.cpp
+++ b/test/test_user.cpp
@@ -1,5 +1,5 @@
/*
- * This file is a part of the CaosDB Project.
+ * This file is a part of the LinkAhead Project.
*
* Copyright (C) 2022 Timm Fitschen <t.fitschen@indiscale.com>
* Copyright (C) 2022 IndiScale GmbH <info@indiscale.com>
@@ -18,24 +18,24 @@
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*
*/
-#include "caosdb/acm/user.h" // for User
-#include "caosdb/connection.h" // for Connection, VersionInfo, path
-#include "caosdb/exceptions.h" // for TransactionError
-#include "caosdb_test_utility.h" // for EXPECT_THROW_MESSAGE
+#include "linkahead/acm/user.h" // for User
+#include "linkahead/connection.h" // for Connection, VersionInfo, path
+#include "linkahead/exceptions.h" // for TransactionError
+#include "linkahead_test_utility.h" // for EXPECT_THROW_MESSAGE
#include <gtest/gtest-message.h> // for Message
#include <gtest/gtest-test-part.h> // for SuiteApiResolver, TestPartR...
#include <gtest/gtest_pred_impl.h> // for Test, TestInfo, TEST, EXPEC...
#include <memory> // for allocator, unique_ptr, __sh...
#include <string> // for stoi, string
-namespace caosdb::connection {
-using caosdb::acm::User;
+namespace linkahead::connection {
+using linkahead::acm::User;
TEST(test_user, test_create_single_user_failure_invalid_name) {
auto connection = ConnectionManager::GetDefaultConnection();
User user("CaosDB", "-user1");
EXPECT_THROW_STARTS_WITH(
- connection->CreateSingleUser(user), caosdb::exceptions::Exception,
+ connection->CreateSingleUser(user), linkahead::exceptions::Exception,
"The attempt to execute this transaction was not successful because an error occured in the "
"transport or RPC protocol layer. Original error: 2 - The user name does not comply with the "
"current policies for user names:");
@@ -46,7 +46,7 @@ TEST(test_user, test_create_single_user_failure_invalid_password) {
User user("CaosDB", "user1");
user.SetPassword("1234");
EXPECT_THROW_STARTS_WITH(
- connection->CreateSingleUser(user), caosdb::exceptions::Exception,
+ connection->CreateSingleUser(user), linkahead::exceptions::Exception,
"The attempt to execute this transaction was not successful because an error occured in the "
"transport or RPC protocol layer. Original error: 2 - The password does not comply with the "
"current policies for passwords: ");
@@ -61,7 +61,7 @@ TEST(test_user, test_create_single_user_success) {
EXPECT_EQ(re.GetName(), user.GetName());
connection->DeleteSingleUser("CaosDB", "user1");
EXPECT_THROW_MESSAGE(
- connection->RetrieveSingleUser("CaosDB", "user1"), caosdb::exceptions::Exception,
+ connection->RetrieveSingleUser("CaosDB", "user1"), linkahead::exceptions::Exception,
"The attempt to execute this transaction was not successful because an error occured in the "
"transport or RPC protocol layer. Original error: 5 - This account does not exist.");
}
@@ -84,4 +84,4 @@ TEST(test_user, test_list_users) {
EXPECT_EQ(users.size(), 1);
}
-} // namespace caosdb::connection
+} // namespace linkahead::connection