db/Interface: add virtual method Update()

For database plugins that don't use the UpdateService.

2 files changed, 36 insertions, 0 deletions

diff --git a/src/command/OtherCommands.cxx b/src/command/OtherCommands.cxx
index 4f149e58e..a924f77b5 100644
--- a/src/command/OtherCommands.cxx
+++ b/src/command/OtherCommands.cxx
@@ -49,6 +49,7 @@
 
 #ifdef ENABLE_DATABASE
 #include "DatabaseCommands.hxx"
+#include "db/Interface.hxx"
 #include "db/update/Service.hxx"
 #endif
 
@@ -242,6 +243,25 @@ handle_update(Client &client, UpdateService &update,
 	}
 }
 
+static CommandResult
+handle_update(Client &client, Database &db,
+	      const char *uri_utf8, bool discard)
+{
+	Error error;
+	unsigned id = db.Update(uri_utf8, discard, error);
+	if (id > 0) {
+		client_printf(client, "updating_db: %i\n", id);
+		return CommandResult::OK;
+	} else if (error.IsDefined()) {
+		return print_error(client, error);
+	} else {
+		/* Database::Update() has returned 0 without setting
+		   the Error: the method is not implemented */
+		command_error(client, ACK_ERROR_NO_EXIST, "Not implemented");
+		return CommandResult::ERROR;
+	}
+}
+
 #endif
 
 static CommandResult
@@ -267,6 +287,10 @@ handle_update(Client &client, unsigned argc, char *argv[], bool discard)
 	UpdateService *update = client.partition.instance.update;
 	if (update != nullptr)
 		return handle_update(client, *update, path, discard);
+
+	Database *db = client.partition.instance.database;
+	if (db != nullptr)
+		return handle_update(client, *db, path, discard);
 #else
 	(void)argc;
 	(void)argv;
diff --git a/src/db/Interface.hxx b/src/db/Interface.hxx
index 5fc9265e2..152928c79 100644
--- a/src/db/Interface.hxx
+++ b/src/db/Interface.hxx
@@ -116,6 +116,18 @@ public:
 			      Error &error) const = 0;
 
 	/**
+	 * Update the database.  Returns the job id on success, 0 on
+	 * error (with #Error set) and 0 if not implemented (#Error
+	 * not set).
+	 */
+	virtual unsigned Update(gcc_unused const char *uri_utf8,
+				gcc_unused bool discard,
+				gcc_unused Error &error) {
+		/* not implemented: return 0 and don't set an Error */
+		return 0;
+	}
+
+	/**
 	 * Returns the time stamp of the last database update.
 	 * Returns 0 if that is not not known/available.
 	 */