Feat: Upgrade from tags and fix issue with legacy IssuerRevRegRecords [<=v0.5.2]

UpgradingACA-Py.md

@@ -59,6 +59,25 @@ is high (such as a "resave connections" upgrade to a deployment with many, many
 connections), you may want to do a test upgrade offline first, to see if there
 is likely to be a service disruption during the upgrade. Plan accordingly!
 
+## Tagged upgrades
+Upgrades are defined in the [Upgrade Definition YML file], in addition to specifying upgrade actions by version they can also be specified by named tags. Unlike version based upgrades where all applicable version based actions will be performed based upon sorted order of versions, with named tags only actions corresponding to provided tags will be performed. Note: `--force-upgrade` is required when running name tags based upgrade [i.e. provding `--named-tag`]
+
+Tags are specfied in YML file as below:
+```
+fix_issue_rev_reg:
+  fix_issue_rev_reg_records: true
+```
+
+Example
+```
+ ./scripts/run_docker upgrade --force-upgrade --named-tag fix_issue_rev_reg
+
+In case, running multiple tags [say test1 & test2]:
+ ./scripts/run_docker upgrade --force-upgrade --named-tag test1 --named-tag test2
+```
+
+
+
 ## Exceptions
 
 There are a couple of upgrade exception conditions to consider, as outlined

aries_cloudagent/commands/default_version_upgrade_config.yml

@@ -13,4 +13,6 @@ v0.7.1:
 v0.7.0:
   update_existing_records: false 
 v0.6.0:
-  update_existing_records: false
+  update_existing_records: false
+fix_issue_rev_reg:
+  fix_issue_rev_reg_records: true

aries_cloudagent/commands/tests/test_upgrade.py

@@ -121,6 +121,44 @@ async def test_upgrade_callable(self):
                 }
             )
 
+    async def test_upgrade_callable_named_tag(self):
+        version_storage_record = await self.storage.find_record(
+            type_filter="acapy_version", tag_query={}
+        )
+        await self.storage.delete_record(version_storage_record)
+        with async_mock.patch.object(
+            test_module,
+            "wallet_config",
+            async_mock.CoroutineMock(
+                return_value=(
+                    self.profile,
+                    async_mock.CoroutineMock(did="public DID", verkey="verkey"),
+                )
+            ),
+        ), async_mock.patch.object(
+            test_module.yaml,
+            "safe_load",
+            async_mock.MagicMock(
+                return_value={
+                    "v0.7.2": {
+                        "resave_records": {
+                            "base_record_path": [
+                                "aries_cloudagent.connections.models.conn_record.ConnRecord"
+                            ]
+                        },
+                        "update_existing_records": True,
+                    },
+                    "fix_issue_rev_reg": {"fix_issue_rev_reg_records": True},
+                }
+            ),
+        ):
+            await test_module.upgrade(
+                settings={
+                    "upgrade.named_tags": ["fix_issue_rev_reg"],
+                    "upgrade.force_upgrade": True,
+                }
+            )
+
     async def test_upgrade_x_same_version(self):
         version_storage_record = await self.storage.find_record(
             type_filter="acapy_version", tag_query={}
@@ -169,7 +207,9 @@ async def test_upgrade_missing_from_version(self):
                         "upgrade.config_path": "./aries_cloudagent/commands/default_version_upgrade_config.yml",
                     }
                 )
-            assert "No upgrade from version found in wallet or" in str(ctx.exception)
+            assert "Error during upgrade: No upgrade from version or tags found" in str(
+                ctx.exception
+            )
 
     async def test_upgrade_x_callable_not_set(self):
         version_storage_record = await self.storage.find_record(