Merge pull request #355 from dbluhm/preserve-exchange-records

Add CLI arg for preserving exchange records
openwallet-foundation · Feb 26, 2020 · 2f6164f · 2f6164f
2 parents 317b09f + 499d36f
commit 2f6164f
Show file tree

Hide file tree

Showing 2 changed files with 13 additions and 4 deletions.
diff --git a/aries_cloudagent/config/argparse.py b/aries_cloudagent/config/argparse.py
@@ -561,6 +561,11 @@ def add_arguments(self, parser: ArgumentParser):
             metavar="<log-path>",
             help="Write timing information to a given log file.",
         )
+        parser.add_argument(
+            "--preserve-exchange-records",
+            action="store_true",
+            help="Keep credential exchange records after exchange has completed."
+        )
 
     def get_settings(self, args: Namespace) -> dict:
         """Get protocol settings."""
@@ -577,6 +582,8 @@ def get_settings(self, args: Namespace) -> dict:
             settings["timing.enabled"] = True
         if args.timing_log:
             settings["timing.log_file"] = args.timing_log
+        if args.preserve_exchange_records:
+            settings["preserve_exchange_records"] = True
         return settings
 
 

diff --git a/aries_cloudagent/protocols/issue_credential/v1_0/manager.py b/aries_cloudagent/protocols/issue_credential/v1_0/manager.py
@@ -571,8 +571,9 @@ async def store_credential(
             credential_exchange_record.parent_thread_id,
         )
 
-        # Delete the exchange record since we're done with it
-        await credential_exchange_record.delete_record(self.context)
+        if not self.context.settings.get("preserve_exchange_records"):
+            # Delete the exchange record since we're done with it
+            await credential_exchange_record.delete_record(self.context)
         return (credential_exchange_record, credential_ack_message)
 
     async def receive_credential_ack(self) -> V10CredentialExchange:
@@ -595,7 +596,8 @@ async def receive_credential_ack(self) -> V10CredentialExchange:
         credential_exchange_record.state = V10CredentialExchange.STATE_ACKED
         await credential_exchange_record.save(self.context, reason="credential acked")
 
-        # We're done with the exchange so delete
-        await credential_exchange_record.delete_record(self.context)
+        if not self.context.settings.get("preserve_exchange_records"):
+            # We're done with the exchange so delete
+            await credential_exchange_record.delete_record(self.context)
 
         return credential_exchange_record