CE-574 Upgrade Logic (#61)

* CE-574 Upgrade Logic

PR URL: https://www.github.com/delphix/couchbase-plugin/pull/61

* plugin version update

Author: ayesharustgi-delphix

.pre-commit-config.yaml

@@ -36,4 +36,5 @@ repos:
                   .isort.cfg|
                   LICENSE|
                   .gitignore|
+                  plugin_config.yml
           )$

plugin_config.yml

@@ -1,7 +1,7 @@
 id: 18f4ff11-b758-4bf2-9a37-719a22f5a4b8
 name: sc:couchbase
-externalVersion: "1.2.2"
-buildNumber: 1.2.2
+externalVersion: "1.3.0"
+buildNumber: 1.3.0
 language: PYTHON38
 hostTypes:
 - UNIX

src/plugin_runner.py

@@ -4,6 +4,7 @@
 #
 
 import logging
+import os
 
 from controller.couchbase_operation import CouchbaseOperation
 from controller.helper_lib import check_server_is_used
@@ -29,6 +30,34 @@
 logger = logging.getLogger(__name__)
 
 
+@plugin.upgrade.linked_source("2023.10.27.01")
+def update_bucket_size(old_linked_source):
+    old_linked_source = dict(old_linked_source)
+    if isinstance(old_linked_source["bucket_size"], int):
+        if old_linked_source["bucket_size"] == 0:
+            old_linked_source["bucket_size"] = []
+        else:
+            d = [{"bname": "*", "bsize": old_linked_source["bucket_size"]}]
+            old_linked_source["bucket_size"] = d
+    return old_linked_source
+
+
+@plugin.upgrade.linked_source("2023.10.27.02")
+def update_archive_name(old_linked_source):
+    old_linked_source = dict(old_linked_source)
+    if "archive_name" not in old_linked_source.keys():
+        if old_linked_source["couchbase_bak_loc"] == "":
+            old_linked_source["archive_name"] = ""
+        else:
+            old_linked_source["archive_name"] = os.path.basename(
+                old_linked_source["couchbase_bak_loc"]
+            )
+            old_linked_source["couchbase_bak_loc"] = os.path.dirname(
+                old_linked_source["couchbase_bak_loc"]
+            )
+    return old_linked_source
+
+
 #
 # Below is an example of the repository discovery operation.
 #