Module `mydata_did.v1_0.handlers.data_agreement_termination_problem_report_handler`

Expand source code

from aries_cloudagent.messaging.base_handler import BaseHandler, BaseResponder, RequestContext
from aries_cloudagent.storage.record import StorageRecord
from aries_cloudagent.wallet.base import BaseWallet
from aries_cloudagent.wallet.indy import IndyWallet

from ..messages.problem_report import DataAgreementTerminationProblemReport
from ..models.exchange_records.data_agreement_record import DataAgreementV1Record
from ..manager import ADAManager

from ...patched_protocols.issue_credential.v1_0.models.credential_exchange import (
    V10CredentialExchange
)

from ...patched_protocols.present_proof.v1_0.models.presentation_exchange import (
    V10PresentationExchange
)

import json


class DataAgreementTerminationProblemReportHandler(BaseHandler):
    """
    Handler for data agreement termination problem report.
    """

    async def handle(self, context: RequestContext, responder: BaseResponder):
        """
        Message handler logic for data agreement termination problem report.
        """

        # Assert if received message is of type DataAgreementTerminationProblemReport
        assert isinstance(context.message, DataAgreementTerminationProblemReport)

        self._logger.info(
            "Received data-agreement-termination/1.0/problem-report message: \n%s",
            json.dumps(context.message.serialize(), indent=4)
        )

        # Check if the connection is ready.
        if not context.connection_ready:
            self._logger.info(
                "Connection not active, skipping data-agreement-termination/1.0/problem-report handler: %s",
                context.message_receipt.sender_did,
            )
            return
        
        data_agreement_termination_problem_report = context.message
        

        # Query data agreement instance metadata

        # Wallet instance from request context
        wallet: IndyWallet = await context.inject(BaseWallet)

        # Initialize ADA manager
        ada_manager = ADAManager(context)

        # Fetch the data agreement instance metadata
        data_agreement_instance_metadata_records = await ada_manager.query_data_agreement_instance_metadata(
            tag_query={
                'data_agreement_id': data_agreement_termination_problem_report.data_agreement_id,
            }
        )

        # Check if there is a data agreement instance metadata record
        if not data_agreement_instance_metadata_records:
            self._logger.info(
                "Data agreement not found; Failed to handle termination problem report for data agreement: %s",
                data_agreement_termination_problem_report.data_agreement_id,
            )
            return
        
        if len(data_agreement_instance_metadata_records) > 1:
            self._logger.info(
                "Duplicate data agreement records found; Failed to handle termination problem report for data agreement: %s",
                data_agreement_termination_problem_report.data_agreement_id,
            )
            return
        
        data_agreement_instance_metadata_record: StorageRecord = data_agreement_instance_metadata_records[0]

        if data_agreement_instance_metadata_record.tags.get("method_of_use") == DataAgreementV1Record.METHOD_OF_USE_DATA_SOURCE:
            # Check method of use and fetch appropriate exchange record

            # Fetch exchange record (credential exchange if method of use is "data-source")
            tag_filter = {}
            post_filter = {
                "data_agreement_id": data_agreement_termination_problem_report.data_agreement_id
            }
            records = await V10CredentialExchange.query(context, tag_filter, post_filter)

            if not records:
                self._logger.info(
                    "Credential exchange record not found; Failed to handle termination problem report for data agreement: %s",
                    data_agreement_termination_problem_report.data_agreement_id,
                )
                return
            
            if len(records) > 1:
                self._logger.info(
                    "Duplicate credential exchange records found; Failed to handle termination problem report for data agreement: %s",
                    data_agreement_termination_problem_report.data_agreement_id,
                )
                return
            
            cred_ex_record: V10CredentialExchange = records[0]

            # Update exchange record data agreement status
            cred_ex_record.data_agreement_status = V10CredentialExchange.DATA_AGREEMENT_PROBLEM_REPORT

            # Add problem report to credential exchange record
            cred_ex_record.data_agreement_problem_report = data_agreement_termination_problem_report.serialize()

            # Save the credential exchange record
            await cred_ex_record.save(context)

        if data_agreement_instance_metadata_record.tags.get("method_of_use") == DataAgreementV1Record.METHOD_OF_USE_DATA_USING_SERVICE:
            # Implement data agreement termination problem report handler for data using service

            # Check method of use and fetch appropriate exchange record

            # Fetch exchange record (presentation exchange if method of use is "data-using-service")
            tag_filter = {}
            post_filter = {
                "data_agreement_id": data_agreement_termination_problem_report.data_agreement_id
            }
            records = await V10PresentationExchange.query(context, tag_filter, post_filter)

            if not records:
                self._logger.info(
                    "Presentation exchange record not found; Failed to handle termination problem report for data agreement: %s",
                    data_agreement_termination_problem_report.data_agreement_id,
                )
                return
            
            if len(records) > 1:
                self._logger.info(
                    "Duplicate presentation exchange records found; Failed to handle termination problem report for data agreement: %s",
                    data_agreement_termination_problem_report.data_agreement_id,
                )
                return
            
            pres_ex_record: V10PresentationExchange = records[0]

            # Update exchange record data agreement status
            pres_ex_record.data_agreement_status = V10PresentationExchange.DATA_AGREEMENT_PROBLEM_REPORT

            # Add problem report to presentation exchange record
            pres_ex_record.data_agreement_problem_report = data_agreement_termination_problem_report.serialize()

            # Save the presentation exchange record
            await pres_ex_record.save(context)

Classes

class DataAgreementTerminationProblemReportHandler

Handler for data agreement termination problem report.

Initialize a BaseHandler instance.

Expand source code

class DataAgreementTerminationProblemReportHandler(BaseHandler):
    """
    Handler for data agreement termination problem report.
    """

    async def handle(self, context: RequestContext, responder: BaseResponder):
        """
        Message handler logic for data agreement termination problem report.
        """

        # Assert if received message is of type DataAgreementTerminationProblemReport
        assert isinstance(context.message, DataAgreementTerminationProblemReport)

        self._logger.info(
            "Received data-agreement-termination/1.0/problem-report message: \n%s",
            json.dumps(context.message.serialize(), indent=4)
        )

        # Check if the connection is ready.
        if not context.connection_ready:
            self._logger.info(
                "Connection not active, skipping data-agreement-termination/1.0/problem-report handler: %s",
                context.message_receipt.sender_did,
            )
            return
        
        data_agreement_termination_problem_report = context.message
        

        # Query data agreement instance metadata

        # Wallet instance from request context
        wallet: IndyWallet = await context.inject(BaseWallet)

        # Initialize ADA manager
        ada_manager = ADAManager(context)

        # Fetch the data agreement instance metadata
        data_agreement_instance_metadata_records = await ada_manager.query_data_agreement_instance_metadata(
            tag_query={
                'data_agreement_id': data_agreement_termination_problem_report.data_agreement_id,
            }
        )

        # Check if there is a data agreement instance metadata record
        if not data_agreement_instance_metadata_records:
            self._logger.info(
                "Data agreement not found; Failed to handle termination problem report for data agreement: %s",
                data_agreement_termination_problem_report.data_agreement_id,
            )
            return
        
        if len(data_agreement_instance_metadata_records) > 1:
            self._logger.info(
                "Duplicate data agreement records found; Failed to handle termination problem report for data agreement: %s",
                data_agreement_termination_problem_report.data_agreement_id,
            )
            return
        
        data_agreement_instance_metadata_record: StorageRecord = data_agreement_instance_metadata_records[0]

        if data_agreement_instance_metadata_record.tags.get("method_of_use") == DataAgreementV1Record.METHOD_OF_USE_DATA_SOURCE:
            # Check method of use and fetch appropriate exchange record

            # Fetch exchange record (credential exchange if method of use is "data-source")
            tag_filter = {}
            post_filter = {
                "data_agreement_id": data_agreement_termination_problem_report.data_agreement_id
            }
            records = await V10CredentialExchange.query(context, tag_filter, post_filter)

            if not records:
                self._logger.info(
                    "Credential exchange record not found; Failed to handle termination problem report for data agreement: %s",
                    data_agreement_termination_problem_report.data_agreement_id,
                )
                return
            
            if len(records) > 1:
                self._logger.info(
                    "Duplicate credential exchange records found; Failed to handle termination problem report for data agreement: %s",
                    data_agreement_termination_problem_report.data_agreement_id,
                )
                return
            
            cred_ex_record: V10CredentialExchange = records[0]

            # Update exchange record data agreement status
            cred_ex_record.data_agreement_status = V10CredentialExchange.DATA_AGREEMENT_PROBLEM_REPORT

            # Add problem report to credential exchange record
            cred_ex_record.data_agreement_problem_report = data_agreement_termination_problem_report.serialize()

            # Save the credential exchange record
            await cred_ex_record.save(context)

        if data_agreement_instance_metadata_record.tags.get("method_of_use") == DataAgreementV1Record.METHOD_OF_USE_DATA_USING_SERVICE:
            # Implement data agreement termination problem report handler for data using service

            # Check method of use and fetch appropriate exchange record

            # Fetch exchange record (presentation exchange if method of use is "data-using-service")
            tag_filter = {}
            post_filter = {
                "data_agreement_id": data_agreement_termination_problem_report.data_agreement_id
            }
            records = await V10PresentationExchange.query(context, tag_filter, post_filter)

            if not records:
                self._logger.info(
                    "Presentation exchange record not found; Failed to handle termination problem report for data agreement: %s",
                    data_agreement_termination_problem_report.data_agreement_id,
                )
                return
            
            if len(records) > 1:
                self._logger.info(
                    "Duplicate presentation exchange records found; Failed to handle termination problem report for data agreement: %s",
                    data_agreement_termination_problem_report.data_agreement_id,
                )
                return
            
            pres_ex_record: V10PresentationExchange = records[0]

            # Update exchange record data agreement status
            pres_ex_record.data_agreement_status = V10PresentationExchange.DATA_AGREEMENT_PROBLEM_REPORT

            # Add problem report to presentation exchange record
            pres_ex_record.data_agreement_problem_report = data_agreement_termination_problem_report.serialize()

            # Save the presentation exchange record
            await pres_ex_record.save(context)

Ancestors

aries_cloudagent.messaging.base_handler.BaseHandler
abc.ABC

Methods

async def handle(self, context: aries_cloudagent.messaging.request_context.RequestContext, responder: aries_cloudagent.messaging.responder.BaseResponder)

Message handler logic for data agreement termination problem report.

Expand source code

async def handle(self, context: RequestContext, responder: BaseResponder):
    """
    Message handler logic for data agreement termination problem report.
    """

    # Assert if received message is of type DataAgreementTerminationProblemReport
    assert isinstance(context.message, DataAgreementTerminationProblemReport)

    self._logger.info(
        "Received data-agreement-termination/1.0/problem-report message: \n%s",
        json.dumps(context.message.serialize(), indent=4)
    )

    # Check if the connection is ready.
    if not context.connection_ready:
        self._logger.info(
            "Connection not active, skipping data-agreement-termination/1.0/problem-report handler: %s",
            context.message_receipt.sender_did,
        )
        return
    
    data_agreement_termination_problem_report = context.message
    

    # Query data agreement instance metadata

    # Wallet instance from request context
    wallet: IndyWallet = await context.inject(BaseWallet)

    # Initialize ADA manager
    ada_manager = ADAManager(context)

    # Fetch the data agreement instance metadata
    data_agreement_instance_metadata_records = await ada_manager.query_data_agreement_instance_metadata(
        tag_query={
            'data_agreement_id': data_agreement_termination_problem_report.data_agreement_id,
        }
    )

    # Check if there is a data agreement instance metadata record
    if not data_agreement_instance_metadata_records:
        self._logger.info(
            "Data agreement not found; Failed to handle termination problem report for data agreement: %s",
            data_agreement_termination_problem_report.data_agreement_id,
        )
        return
    
    if len(data_agreement_instance_metadata_records) > 1:
        self._logger.info(
            "Duplicate data agreement records found; Failed to handle termination problem report for data agreement: %s",
            data_agreement_termination_problem_report.data_agreement_id,
        )
        return
    
    data_agreement_instance_metadata_record: StorageRecord = data_agreement_instance_metadata_records[0]

    if data_agreement_instance_metadata_record.tags.get("method_of_use") == DataAgreementV1Record.METHOD_OF_USE_DATA_SOURCE:
        # Check method of use and fetch appropriate exchange record

        # Fetch exchange record (credential exchange if method of use is "data-source")
        tag_filter = {}
        post_filter = {
            "data_agreement_id": data_agreement_termination_problem_report.data_agreement_id
        }
        records = await V10CredentialExchange.query(context, tag_filter, post_filter)

        if not records:
            self._logger.info(
                "Credential exchange record not found; Failed to handle termination problem report for data agreement: %s",
                data_agreement_termination_problem_report.data_agreement_id,
            )
            return
        
        if len(records) > 1:
            self._logger.info(
                "Duplicate credential exchange records found; Failed to handle termination problem report for data agreement: %s",
                data_agreement_termination_problem_report.data_agreement_id,
            )
            return
        
        cred_ex_record: V10CredentialExchange = records[0]

        # Update exchange record data agreement status
        cred_ex_record.data_agreement_status = V10CredentialExchange.DATA_AGREEMENT_PROBLEM_REPORT

        # Add problem report to credential exchange record
        cred_ex_record.data_agreement_problem_report = data_agreement_termination_problem_report.serialize()

        # Save the credential exchange record
        await cred_ex_record.save(context)

    if data_agreement_instance_metadata_record.tags.get("method_of_use") == DataAgreementV1Record.METHOD_OF_USE_DATA_USING_SERVICE:
        # Implement data agreement termination problem report handler for data using service

        # Check method of use and fetch appropriate exchange record

        # Fetch exchange record (presentation exchange if method of use is "data-using-service")
        tag_filter = {}
        post_filter = {
            "data_agreement_id": data_agreement_termination_problem_report.data_agreement_id
        }
        records = await V10PresentationExchange.query(context, tag_filter, post_filter)

        if not records:
            self._logger.info(
                "Presentation exchange record not found; Failed to handle termination problem report for data agreement: %s",
                data_agreement_termination_problem_report.data_agreement_id,
            )
            return
        
        if len(records) > 1:
            self._logger.info(
                "Duplicate presentation exchange records found; Failed to handle termination problem report for data agreement: %s",
                data_agreement_termination_problem_report.data_agreement_id,
            )
            return
        
        pres_ex_record: V10PresentationExchange = records[0]

        # Update exchange record data agreement status
        pres_ex_record.data_agreement_status = V10PresentationExchange.DATA_AGREEMENT_PROBLEM_REPORT

        # Add problem report to presentation exchange record
        pres_ex_record.data_agreement_problem_report = data_agreement_termination_problem_report.serialize()

        # Save the presentation exchange record
        await pres_ex_record.save(context)