Implement Service Manager API to set replica mode (#52)

src/fb-cpp/BackupManager.cpp

@@ -24,6 +24,7 @@
 
 #include "BackupManager.h"
 #include "Client.h"
+#include <cassert>
 
 using namespace fbcpp;
 using namespace fbcpp::impl;
@@ -84,6 +85,27 @@ void BackupManager::restore(const RestoreOptions& options)
 	if (const auto parallelWorkers = options.getParallelWorkers())
 		builder->insertInt(&statusWrapper, isc_spb_res_parallel_workers, static_cast<int>(*parallelWorkers));
 
+	if (const auto replicaMode = options.getReplicaMode())
+	{
+		std::uint8_t modeVal = 0;
+		switch (*replicaMode)
+		{
+			case ReplicaMode::NONE:
+				modeVal = isc_spb_res_rm_none;
+				break;
+			case ReplicaMode::READ_ONLY:
+				modeVal = isc_spb_res_rm_readonly;
+				break;
+			case ReplicaMode::READ_WRITE:
+				modeVal = isc_spb_res_rm_readwrite;
+				break;
+			default:
+				assert(false);
+				break;
+		}
+		builder->insertBytes(&statusWrapper, isc_spb_res_replica_mode, &modeVal, 1u);
+	}
+
 	const auto buffer = builder->getBuffer(&statusWrapper);
 	const auto length = builder->getBufferLength(&statusWrapper);
 

src/fb-cpp/BackupManager.h

@@ -296,12 +296,30 @@ namespace fbcpp
 			return *this;
 		}
 
+		///
+		/// Returns the replica mode.
+		///
+		const std::optional<ReplicaMode>& getReplicaMode() const
+		{
+			return replicaMode;
+		}
+
+		///
+		/// Sets the replica mode.
+		///
+		RestoreOptions& setReplicaMode(ReplicaMode value)
+		{
+			replicaMode = value;
+			return *this;
+		}
+
 	private:
 		std::vector<DatabaseFileSpec> databaseFiles;
 		std::vector<std::string> backupFiles;
 		bool replace = false;
 		ServiceManager::VerboseOutput verboseOutput;
 		std::optional<std::uint32_t> parallelWorkers;
+		std::optional<ReplicaMode> replicaMode;
 	};
 
 	///

src/fb-cpp/DatabaseManager.cpp

@@ -0,0 +1,67 @@
+/*
+ * MIT License
+ *
+ * Copyright (c) 2026 Popa Adrian Marius
+ *
+ * Permission is hereby granted, free of charge, to any person obtaining a copy
+ * of this software and associated documentation files (the "Software"), to deal
+ * in the Software without restriction, including without limitation the rights
+ * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+ * copies of the Software, and to permit persons to whom the Software is
+ * furnished to do so, subject to the following conditions:
+ *
+ * The above copyright notice and this permission notice shall be included in all
+ * copies or substantial portions of the Software.
+ *
+ * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+ * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+ * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+ * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+ * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+ * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
+ * SOFTWARE.
+ */
+
+#include "DatabaseManager.h"
+#include "Client.h"
+#include <cassert>
+
+using namespace fbcpp;
+using namespace fbcpp::impl;
+
+
+void DatabaseManager::execute(const DatabaseManagerOptions& options)
+{
+	StatusWrapper statusWrapper{getClient()};
+	auto builder =
+		fbUnique(getClient().getUtil()->getXpbBuilder(&statusWrapper, fb::IXpbBuilder::SPB_START, nullptr, 0));
+	builder->insertTag(&statusWrapper, isc_action_svc_properties);
+	builder->insertString(&statusWrapper, isc_spb_dbname, options.getDatabase().c_str());
+
+	if (const auto replicaMode = options.getReplicaMode())
+	{
+		std::uint8_t modeVal = 0;
+		switch (*replicaMode)
+		{
+			case ReplicaMode::NONE:
+				modeVal = isc_spb_prp_rm_none;
+				break;
+			case ReplicaMode::READ_ONLY:
+				modeVal = isc_spb_prp_rm_readonly;
+				break;
+			case ReplicaMode::READ_WRITE:
+				modeVal = isc_spb_prp_rm_readwrite;
+				break;
+			default:
+				assert(false);
+				break;
+		}
+		builder->insertBytes(&statusWrapper, isc_spb_prp_replica_mode, &modeVal, 1u);
+	}
+
+	const auto buffer = builder->getBuffer(&statusWrapper);
+	const auto length = builder->getBufferLength(&statusWrapper);
+
+	startAction(std::vector<std::uint8_t>(buffer, buffer + length));
+	waitForCompletion();
+}

src/fb-cpp/DatabaseManager.h

@@ -0,0 +1,100 @@
+/*
+ * MIT License
+ *
+ * Copyright (c) 2026 Popa Adrian Marius
+ *
+ * Permission is hereby granted, free of charge, to any person obtaining a copy
+ * of this software and associated documentation files (the "Software"), to deal
+ * in the Software without restriction, including without limitation the rights
+ * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+ * copies of the Software, and to permit persons to whom the Software is
+ * furnished to do so, subject to the following conditions:
+ *
+ * The above copyright notice and this permission notice shall be included in all
+ * copies or substantial portions of the Software.
+ *
+ * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+ * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+ * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+ * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+ * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+ * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
+ * SOFTWARE.
+ */
+
+#ifndef FBCPP_DATABASE_MANAGER_H
+#define FBCPP_DATABASE_MANAGER_H
+
+#include "ServiceManager.h"
+#include <optional>
+#include <string>
+
+
+///
+/// fb-cpp namespace.
+///
+namespace fbcpp
+{
+	///
+	/// Represents options used to configure database properties through the service manager.
+	///
+	class DatabaseManagerOptions final
+	{
+	public:
+		///
+		/// Returns the database path to be configured.
+		///
+		const std::string& getDatabase() const
+		{
+			return database;
+		}
+
+		///
+		/// Sets the database path to be configured.
+		///
+		DatabaseManagerOptions& setDatabase(const std::string& value)
+		{
+			database = value;
+			return *this;
+		}
+
+		///
+		/// Returns the replica mode.
+		///
+		const std::optional<ReplicaMode>& getReplicaMode() const
+		{
+			return replicaMode;
+		}
+
+		///
+		/// Sets the replica mode.
+		///
+		DatabaseManagerOptions& setReplicaMode(ReplicaMode value)
+		{
+			replicaMode = value;
+			return *this;
+		}
+
+	private:
+		std::string database;
+		std::optional<ReplicaMode> replicaMode;
+	};
+
+	///
+	/// Executes configuration and maintenance operations through the Firebird service manager.
+	///
+	class DatabaseManager final : public ServiceManager
+	{
+	public:
+		using ServiceManager::ServiceManager;
+
+	public:
+		///
+		/// Configures database properties using the provided options.
+		///
+		void execute(const DatabaseManagerOptions& options);
+	};
+}  // namespace fbcpp
+
+
+#endif  // FBCPP_DATABASE_MANAGER_H

src/fb-cpp/ServiceManager.h

@@ -42,6 +42,27 @@
 ///
 namespace fbcpp
 {
+	///
+	/// Replica mode.
+	///
+	enum class ReplicaMode
+	{
+		///
+		/// The database is not a replica (operates as primary).
+		///
+		NONE,
+
+		///
+		/// Read-only replica.
+		///
+		READ_ONLY,
+
+		///
+		/// Read-write replica.
+		///
+		READ_WRITE
+	};
+
 	class Client;
 
 	///

src/fb-cpp/fb-cpp.h

@@ -36,5 +36,6 @@
 #include "EventListener.h"
 #include "ServiceManager.h"
 #include "BackupManager.h"
+#include "DatabaseManager.h"
 
 #endif  // FBCPP_H