adding admin-holder/0.1/credential-offer-reject

Signed-off-by: Matthew Wright <[email protected]>

Author: farskipper

acapy_plugin_toolbox/holder/__init__.py

@@ -8,6 +8,8 @@
 )
 from aries_cloudagent.protocols.issue_credential.v1_0.messages.inner.credential_preview import \
     CredAttrSpec as CredentialAttributeSpec
+from aries_cloudagent.protocols.issue_credential.v1_0.messages.credential_problem_report import \
+    CredentialProblemReport
 from aries_cloudagent.protocols.issue_credential.v1_0.models.credential_exchange import \
     V10CredentialExchange as CredExRecord
 from aries_cloudagent.protocols.issue_credential.v1_0.models.credential_exchange import \
@@ -37,7 +39,7 @@
 
 __all__ = [
     "issue_credential", "CredentialManager", "CredentialManagerError",
-    "CredentialAttributeSpec", "CredExRecord", "CredExRecordSchema",
+    "CredentialAttributeSpec", "CredExRecord", "CredExRecordSchema", "CredentialProblemReport",
     "CredentialProposalRequestSchema", "present_proof",
     "PresentationManager", "PresentationManagerError",
     "PresentationPreview", "PresExRecord", "PresExRecordSchema", "IndyCredPrecisSchema",

acapy_plugin_toolbox/holder/v0_1.py

@@ -34,7 +34,7 @@
 )
 from . import (
     CredentialAttributeSpec, CredentialManager, CredentialManagerError,
-    CredentialProposalRequestSchema, CredExRecord, CredExRecordSchema,
+    CredentialProposalRequestSchema, CredExRecord, CredExRecordSchema, CredentialProblemReport,
     IndyCredPrecisSchema, PresentationPreview,
     PresentationProposalRequestSchema, PresExRecord, PresExRecordSchema,
     issue_credential, present_proof, PresentationManager,
@@ -317,6 +317,68 @@ class CredRequestSent(AdminHolderMessage):
     fields_from = CredExRecordSchema
 
 
+@expand_message_class
+class CredOfferReject(AdminHolderMessage):
+    """Credential offer reject message."""
+    message_type = "credential-offer-reject"
+
+    class Fields:
+        credential_exchange_id = fields.Str(
+            required=True,
+            description="ID of the credential exchange to reject.",
+            example=UUIDFour.EXAMPLE
+        )
+
+    def __init__(self, credential_exchange_id: str, **kwargs):
+        super().__init__(**kwargs)
+        self.credential_exchange_id = credential_exchange_id
+
+    @log_handling
+    @admin_only
+    async def handle(self, context: RequestContext, responder: BaseResponder):
+        """Handle credential offer reject message."""
+        async with context.session() as session:
+            async with ExceptionReporter(
+                responder,
+                (StorageError, CredentialManagerError, BaseModelError),
+                self
+            ):
+                cred_ex_record = await CredExRecord.retrieve_by_id(
+                    session, self.credential_exchange_id
+                )
+                cred_ex_record = cast(CredExRecord, cred_ex_record)
+                connection_id = cred_ex_record.connection_id
+                connection_record = await get_connection(session, connection_id)
+
+        # TODO add credential_manager.reject(..) to ACA-Py
+
+        cred_ex_record.state = "reject-sent" # TODO add CredExRecord.STATE_REJECT_SENT to ACA-Py
+        async with context.session() as session:
+            await cred_ex_record.save(session, reason="Rejected credential offer.")
+
+        problem_report = CredentialProblemReport(
+            description={
+                "en": "Rejected credential offer.",
+                "code": "rejected", # TODO add ProblemReportReason.REJECTED to ACA-Py
+            }
+        )
+        problem_report.assign_thread_id(cred_ex_record.thread_id)
+
+        sent = CredOfferRejectSent(**cred_ex_record.serialize())
+        sent.assign_thread_from(self)
+
+        await responder.send(problem_report, connection_id=connection_record.connection_id)
+        await responder.send_reply(sent)
+
+
+@with_generic_init
+@expand_message_class
+class CredOfferRejectSent(AdminHolderMessage):
+    """Credential offer reject sent."""
+    message_type = "credential-offer-reject-sent"
+    fields_from = CredExRecordSchema
+
+
 @with_generic_init
 @expand_message_class
 class CredReceived(AdminHolderMessage):
@@ -881,6 +943,7 @@ def __init__(
         CredGetList,
         CredList,
         CredOfferAccept,
+        CredOfferReject,
         CredOfferRecv,
         CredRequestSent,
         CredReceived,