Merge pull request eclipse-score#20 from joshualicht/cpp_implementation

Initial Implementation of the CPP KVS

Author: vinodreddy-g

.bazelrc

@@ -2,6 +2,7 @@ build --java_language_version=17
 build --tool_java_language_version=17
 build --java_runtime_version=remotejdk_17
 build --tool_java_runtime_version=remotejdk_17
+build --@score-baselibs//score/json:base_library=nlohmann
 
 test --test_output=errors
 

BUILD

@@ -41,3 +41,15 @@ use_format_targets()
 exports_files([
     "MODULE.bazel",
 ])
+
+alias(
+    name = "kvs_cpp",
+    actual = "//src/cpp:kvs_cpp",
+    visibility = ["//visibility:public"],
+)
+
+test_suite(
+    name = "test_kvs_cpp",
+    tests = ["//tests/cpp:test_kvs_cpp"],
+    visibility = ["//visibility:public"],
+)

Cargo.toml

@@ -1,7 +1,7 @@
 [workspace]
 resolver = "2"
 members=[
-    "src",
+    "src/rust",
 ]
 
 [workspace.package]
@@ -10,8 +10,8 @@ edition = "2021"
 
 
 [workspace.dependencies]
-rust-kvs = { path = "src" }
+rust-kvs = { path = "src/rust" }
 
 adler32 = "1.2.0"
 tinyjson = "2.5.1"
-pico-args = "0.5"
+pico-args = "0.5"

MODULE.bazel

@@ -76,7 +76,21 @@ crate.from_cargo(
     cargo_lockfile = "//:Cargo.lock",
     manifests = [
         "//:Cargo.toml",
-        "//src:Cargo.toml",
+        "//src/rust:Cargo.toml",
     ],
 )
 use_repo(crate, "crates")
+
+#bazel_dep on module 'rules_boost' has no version -> override needed
+archive_override(
+    module_name = "rules_boost",
+    strip_prefix = "rules_boost-master",
+    urls = ["https://github.com/nelhage/rules_boost/archive/refs/heads/master.tar.gz"],
+)
+
+bazel_dep(name = "score-baselibs", version = "0.0.0")
+git_override(
+    module_name = "score-baselibs",
+    commit = "f0a394a602986ddf7abac6a238b9d44535a4b597",
+    remote = "git@github.com:eclipse-score/baselibs.git",
+)

src/cpp/BUILD

@@ -0,0 +1,40 @@
+# *******************************************************************************
+# Copyright (c) 2025 Contributors to the Eclipse Foundation
+#
+# See the NOTICE file(s) distributed with this work for additional
+# information regarding copyright ownership.
+#
+# This program and the accompanying materials are made available under the
+# terms of the Apache License Version 2.0 which is available at
+# https://www.apache.org/licenses/LICENSE-2.0
+#
+# SPDX-License-Identifier: Apache-2.0
+# *******************************************************************************
+
+# The filegroup is used to collect all source files for the tests.
+filegroup(
+    name = "kvs_srcs",
+    srcs = glob([
+        "src/*.cpp",
+        "inc/**/*.hpp",
+    ]),
+    visibility = [
+        "//tests/cpp:__pkg__",
+    ],
+)
+
+cc_library(
+    name = "kvs_cpp",
+    srcs = glob(["src/*.cpp"]),
+    hdrs = glob([
+        "inc/**/*.hpp",
+    ]),
+    includes = ["inc"],
+    visibility = ["//:__pkg__"],
+    deps = [
+        "@score-baselibs//score/filesystem:filesystem",
+        "@score-baselibs//score/json:interface",
+        "@score-baselibs//score/json:json_parser",
+        "@score-baselibs//score/result:result",
+    ],
+)

src/cpp/inc/internal/kvs_helper.hpp

@@ -0,0 +1,34 @@
+/********************************************************************************
+* Copyright (c) 2025 Contributors to the Eclipse Foundation
+*
+* See the NOTICE file(s) distributed with this work for additional
+* information regarding copyright ownership.
+*
+* This program and the accompanying materials are made available under the
+* terms of the Apache License Version 2.0 which is available at
+* https://www.apache.org/licenses/LICENSE-2.0
+*
+* SPDX-License-Identifier: Apache-2.0
+********************************************************************************/
+#ifndef SCORE_LIB_KVS_INTERNAL_KVS_HELPER_HPP
+#define SCORE_LIB_KVS_INTERNAL_KVS_HELPER_HPP
+
+#include <sstream>
+#include <string>
+
+/* 
+ * This header defines helper functions used internally by the Key-Value Store (KVS) implementation.
+ * It exists to allow unit tests to access these internal functions.
+ */
+
+uint32_t parse_hash_adler32(std::istream& in);
+uint32_t calculate_hash_adler32(const std::string& data);
+std::array<uint8_t,4> get_hash_bytes_adler32(uint32_t hash);
+std::array<uint8_t,4> get_hash_bytes(const std::string& data);
+score::Result<std::unordered_map<std::string, KvsValue>> parse_json_data(const std::string& data);
+score::Result<std::unordered_map<std::string, KvsValue>> open_json(const std::string& prefix, OpenJsonNeedFile need_file);
+score::ResultBlank write_json_data(const std::string& filename_prefix, const std::string& buf);
+score::Result<KvsValue> any_to_kvsvalue(const score::json::Any& any);
+score::Result<score::json::Any> kvsvalue_to_any(const KvsValue& kv);
+
+#endif // SCORE_LIB_KVS_INTERNAL_KVS_HELPER_HPP