<filename>how-tos/robotic_process_automation/main.py
import os
import sys
import json
import asyncio
from typing import Optional

import sirius_sdk

sys.path.insert(0, os.path.abspath(os.path.join(os.path.dirname(__file__), '..')))
from consts import *


BANK = AGENT2
EMPLOYER = AGENT1
DID_EMPLOYER = 'Th7MpTaRZVRYnPiabds81Y'
VERKEY_EMPLOYER = '<KEY>'
DID_BANK = 'T8MtAB98aCkgNLtNfQx6WG'
VERKEY_BANK = '<KEY>'
CONN_KEY_BANK = '<KEY>'
CONN_KEY_EMPLOYER = '<KEY>'
DEMO_SALARY = 3000
DEMO_CURRENCY = 'USD'
EMPLOYER_CRED_DEF_ID = 'Th7MpTaRZVRYnPiabds81Y:3:CL:7518:TAG'


def log(message: str):
    print(f'\t{message}')


async def setup_employer_cred_defs(network_name: str = 'test_network'):
    async with sirius_sdk.context(**EMPLOYER):
        dkms = await sirius_sdk.ledger(network_name)  # Test network is prepared for Demo purposes
        schema_id, anon_schema = await sirius_sdk.AnonCreds.issuer_create_schema(
            DID_EMPLOYER, 'demo_salary', '1.0', ['salary', 'currency']
        )
        # Ensure schema exists on DKMS
        schema_ = await dkms.ensure_schema_exists(anon_schema, DID_EMPLOYER)
        # Ensure CredDefs is stored to DKMS
        cred_def_fetched = await dkms.fetch_cred_defs(tag='TAG', schema_id=schema_.id)
        if cred_def_fetched:
            cred_def_ = cred_def_fetched[0]
        else:
            ok, cred_def_ = await dkms.register_cred_def(
                cred_def=sirius_sdk.CredentialDefinition(tag='TAG', schema=schema_),
                submitter_did=DID_EMPLOYER
            )
            assert ok is True
        print('===========================')
        print('cred def ID: ' + cred_def_.id)
        print('===========================')
    return schema_, cred_def_


async def generate_invitations_qr_codes() -> (str, str):
    # BANK
    async with sirius_sdk.context(**BANK):
        try:
            connection_key = await sirius_sdk.Crypto.create_key(seed='0000000000000000SIRIUS_BANK_CONN')
        except sirius_sdk.indy_exceptions.WalletItemAlreadyExists:
            log(f'Bank: conn key {CONN_KEY_BANK} already exists')
        else:
            log(f'Bank: conn key {connection_key} was created')
            assert connection_key == CONN_KEY_BANK
        endpoints = await sirius_sdk.endpoints()
        simple_endpoint = [e for e in endpoints if e.routing_keys == []][0]
        bank_invitation = sirius_sdk.aries_rfc.Invitation(
            label='Sirius Demo bank',
            recipient_keys=[CONN_KEY_BANK],
            endpoint=simple_endpoint.address,
            did=DID_BANK
        )
        log('Bank: invitation')
        log(json.dumps(bank_invitation, indent=2, sort_keys=True))

        # Sirius SDK provide method to generate URL for QR
        # bank_qr_url = await sirius_sdk.generate_qr_code(bank_invitation.invitation_url)
        # print('BANK QR URL: ' + bank_qr_url)

    # EMPLOYER
    async with sirius_sdk.context(**EMPLOYER):
        try:
            connection_key = await sirius_sdk.Crypto.create_key(seed='000000000000SIRIUS_EMPLOYER_CONN')
        except sirius_sdk.indy_exceptions.WalletItemAlreadyExists:
            log(f'Employer: conn key {CONN_KEY_EMPLOYER} already exists')
        else:
            log(f'Employer: conn key {connection_key} was created')
            assert connection_key == CONN_KEY_EMPLOYER
        endpoints = await sirius_sdk.endpoints()
        simple_endpoint = [e for e in endpoints if e.routing_keys == []][0]
        employer_invitation = sirius_sdk.aries_rfc.Invitation(
            label='Sirius Demo employer',
            recipient_keys=[CONN_KEY_EMPLOYER],
            endpoint=simple_endpoint.address,
            did=DID_EMPLOYER
        )
        log('Employer: invitation')
        log(json.dumps(employer_invitation, indent=2, sort_keys=True))

        # Sirius SDK provide method to generate URL for QR
        # employer_qr_url = await sirius_sdk.generate_qr_code(employer_invitation.invitation_url)
        # print('EMPLOYER QR URL: ' + employer_qr_url)

    return 'https://socialsirius.com' + bank_invitation.invitation_url, \
           'https://socialsirius.com' + employer_invitation.invitation_url


async def sirius_bank(network_name: str = 'test_network'):
    async with sirius_sdk.context(**BANK):
        listener = await sirius_sdk.subscribe()
        endpoints = await sirius_sdk.endpoints()
        my_endpoint = [e for e in endpoints if e.routing_keys == []][0]
        dkms = await sirius_sdk.ledger(network_name)
        log('Bank: start to listen events')
        async for event in listener:
            dialog_pairwise: Optional[sirius_sdk.Pairwise] = None
            if isinstance(event.message, sirius_sdk.aries_rfc.ConnRequest):
                # Restore invitation request through invitation.connection_key
                # You may use this snippet to encrypt to invitation cookie values for example
                # to link device to browser Web Page
                if event.recipient_verkey == CONN_KEY_BANK:
                    log(f'Bank: received connection request with connection_key: {CONN_KEY_BANK}')
                    if dialog_pairwise is None:
                        log('Bank: unknown participant. Establish new pairwise P2P')
                    else:
                        log(f'Bank: update pairwise for {dialog_pairwise.their.label}')
                    try:
                        conn_request: sirius_sdk.aries_rfc.ConnRequest = event.message
                        feature_0160 = sirius_sdk.aries_rfc.Inviter(
                            me=sirius_sdk.Pairwise.Me(DID_BANK, VERKEY_BANK),  # Public DID
                            connection_key=event.recipient_verkey,
                            my_endpoint=my_endpoint,
                        )
                        success, dialog_pairwise = await feature_0160.create_connection(conn_request)
                    except Exception as e:
                        log('Bank: exception "%s"' % str(e))
                    else:
                        if success:
                            await sirius_sdk.PairwiseList.ensure_exists(dialog_pairwise)
                            log('Bank: pairwise established successfully')
                            log(json.dumps(dialog_pairwise.metadata, indent=2, sort_keys=True))
                        else:
                            log('Bank: error while establish P2P connection')
                            if feature_0160.problem_report:
                                log('problem report')
                                log(json.dumps(feature_0160.problem_report, indent=2, sort_keys=True))
                else:
                    log('Bank: Unknown connection-key')
            elif isinstance(event.message, sirius_sdk.aries_rfc.Message):
                dialog_pairwise = event.pairwise
            # Digital service
            if dialog_pairwise is not None:
                log('Bank: Digital service')
                person_name = dialog_pairwise.their.label
                service1 = 'Loan request'
                service2 = 'Personal offers'
                ask = sirius_sdk.aries_rfc.Question(
                    valid_responses=[service1, service2],
                    question_text=f'{person_name} welcome to personal cabinet',
                    question_detail='We are glad to make personal offer for you!',
                    locale='en'
                )
                ask.set_ttl(60)  # Set timeout for answer
                success, answer = await sirius_sdk.aries_rfc.ask_and_wait_answer(
                    query=ask,
                    to=dialog_pairwise
                )
                if success:
                    log(f'Bank: providing service: {answer.response}')
                    if answer.response == service1:
                        feature_0037 = sirius_sdk.aries_rfc.Verifier(
                            prover=dialog_pairwise,
                            ledger=dkms,
                        )
                        verify_ok = await feature_0037.verify(
                            comment='Prove your salary credentials',
                            locale='en',
                            proof_request={
                                'nonce': await sirius_sdk.AnonCreds.generate_nonce(),
                                "name": "Proof your salary",
                                "version": "0.1",
                                "requested_attributes": {
                                    'attr1_referent': {
                                        "name": "salary",
                                        "restrictions": {
                                            "issuer_did": DID_EMPLOYER
                                        }
                                    },
                                    'attr2_referent': {
                                        "name": "currency",
                                        "restrictions": {
                                            "issuer_did": DID_EMPLOYER
                                        }
                                    }
                                }
                            },
                            translation=[
                                sirius_sdk.aries_rfc.AttribTranslation('salary', 'Your salary'),
                                sirius_sdk.aries_rfc.AttribTranslation('currency', 'Currency'),
                            ]
                        )
                        if verify_ok:
                            txt_msg = sirius_sdk.aries_rfc.Message(
                                content='Loan approved',
                                locale='en'
                            )
                        else:
                            txt_msg = sirius_sdk.aries_rfc.Message(
                                content='Loan declined',
                                locale='en'
                            )
                        await sirius_sdk.send_to(txt_msg, dialog_pairwise)
                    else:
                        txt_msg = sirius_sdk.aries_rfc.Message(
                            content='Demo personal offer content',
                            locale='en'
                        )
                        await sirius_sdk.send_to(txt_msg, dialog_pairwise)


async def sirius_employer(network_name: str = 'test_network'):
    async with sirius_sdk.context(**EMPLOYER):
        listener = await sirius_sdk.subscribe()
        endpoints = await sirius_sdk.endpoints()
        my_endpoint = [e for e in endpoints if e.routing_keys == []][0]
        dkms = await sirius_sdk.ledger(network_name)
        log('Employer: start to listen events')
        async for event in listener:
            dialog_pairwise: Optional[sirius_sdk.Pairwise] = None
            if isinstance(event.message, sirius_sdk.aries_rfc.ConnRequest):
                # Restore invitation request through invitation.connection_key
                # You may use this snippet to encrypt to invitation cookie values for example
                # to link device to browser Web Page
                if event.recipient_verkey == CONN_KEY_EMPLOYER:
                    log(f'Employer: received connection request with connection_key: {CONN_KEY_BANK}')
                    if dialog_pairwise is None:
                        log('Employer: unknown participant. Establish new pairwise P2P')
                    else:
                        log(f'Employer: update pairwise for {dialog_pairwise.their.label}')
                    try:
                        conn_request: sirius_sdk.aries_rfc.ConnRequest = event.message
                        feature_0160 = sirius_sdk.aries_rfc.Inviter(
                            me=sirius_sdk.Pairwise.Me(DID_EMPLOYER, VERKEY_EMPLOYER),  # Public DID
                            connection_key=event.recipient_verkey,
                            my_endpoint=my_endpoint,
                        )
                        success, dialog_pairwise = await feature_0160.create_connection(conn_request)
                    except Exception as e:
                        log('Employer: exception "%s"' % str(e))
                    else:
                        if success:
                            await sirius_sdk.PairwiseList.ensure_exists(dialog_pairwise)
                            log('Employer: pairwise established successfully')
                            log(json.dumps(dialog_pairwise.metadata, indent=2, sort_keys=True))
                        else:
                            log('Employer: error while establish P2P connection')
                            if feature_0160.problem_report:
                                log('problem report')
                                log(json.dumps(feature_0160.problem_report, indent=2, sort_keys=True))
                else:
                    log('Employer: Unknown connection-key')
            elif isinstance(event.message, sirius_sdk.aries_rfc.Message):
                dialog_pairwise = event.pairwise
            # Digital service
            if dialog_pairwise is not None:
                log('Employer: Digital service')
                person_name = dialog_pairwise.their.label
                service1 = 'Get Salary credentials'
                service2 = 'Request for holiday'
                service3 = 'Go to WebSite'
                ask = sirius_sdk.aries_rfc.Question(
                    valid_responses=[service1, service2, service3],
                    question_text=f'{person_name} welcome!',
                    question_detail='I am your employer Virtual Assistant.',
                    locale='en'
                )
                ask.set_ttl(60)  # Set timeout for answer
                success, answer = await sirius_sdk.aries_rfc.ask_and_wait_answer(
                    query=ask,
                    to=dialog_pairwise
                )
                if success:
                    log(f'Employer: providing service: {answer.response}')
                    if answer.response == service1:
                        log('Employer: starting to issue Salary credential')
                        cred_def = await dkms.load_cred_def(EMPLOYER_CRED_DEF_ID, DID_EMPLOYER)
                        feature_0036 = sirius_sdk.aries_rfc.Issuer(
                            holder=dialog_pairwise,
                        )
                        success = await feature_0036.issue(
                            values={'salary': DEMO_SALARY, 'currency': DEMO_CURRENCY},
                            schema=cred_def.schema,
                            cred_def=cred_def,
                            comment='You may prove your salary in Bank',
                            locale='en',
                            preview=[
                                sirius_sdk.aries_rfc.ProposedAttrib('salary', 'Your salary'),
                                sirius_sdk.aries_rfc.ProposedAttrib('currency', 'Currency')
                            ],
                            cred_id=f'salary-cred-id-for-{dialog_pairwise.their.did}'
                        )
                        if success:
                            log(f'Employer: salary cred successfully finished')
                        else:
                            log('Employer: error while issuing salary credential')
                            if feature_0036.problem_report:
                                log('problem report')
                                log(json.dumps(feature_0036.problem_report, indent=2, sort_keys=True))
                    else:
                        txt_msg = sirius_sdk.aries_rfc.Message(
                            content=f'You selected "{answer.response}" service',
                            locale='en'
                        )
                        await sirius_sdk.send_to(txt_msg, dialog_pairwise)


if __name__ == '__main__':
    qr_bank, qr_employer = asyncio.get_event_loop().run_until_complete(generate_invitations_qr_codes())
    print('invitation URLs')
    print(f'Bank: {qr_bank}')
    print(f'Employer: {qr_employer}')
    print('-------------')
    schema_employer, cred_def_employer = asyncio.get_event_loop().run_until_complete(setup_employer_cred_defs())
    print('*************')
    asyncio.ensure_future(sirius_bank())
    print('#1')
    asyncio.ensure_future(sirius_employer())
    print('#2')
    asyncio.get_event_loop().run_forever()

<filename>how-tos/robotic_process_automation/main.py
import os
import sys
import json
import asyncio
from typing import Optional

import sirius_sdk

sys.path.insert(0, os.path.abspath(os.path.join(os.path.dirname(__file__), '..')))
from consts import *


BANK = AGENT2
EMPLOYER = AGENT1
DID_EMPLOYER = 'Th7MpTaRZVRYnPiabds81Y'
VERKEY_EMPLOYER = '<KEY>'
DID_BANK = 'T8MtAB98aCkgNLtNfQx6WG'
VERKEY_BANK = '<KEY>'
CONN_KEY_BANK = '<KEY>'
CONN_KEY_EMPLOYER = '<KEY>'
DEMO_SALARY = 3000
DEMO_CURRENCY = 'USD'
EMPLOYER_CRED_DEF_ID = 'Th7MpTaRZVRYnPiabds81Y:3:CL:7518:TAG'


def log(message: str):
    print(f'\t{message}')


async def setup_employer_cred_defs(network_name: str = 'test_network'):
    async with sirius_sdk.context(**EMPLOYER):
        dkms = await sirius_sdk.ledger(network_name)  # Test network is prepared for Demo purposes
        schema_id, anon_schema = await sirius_sdk.AnonCreds.issuer_create_schema(
            DID_EMPLOYER, 'demo_salary', '1.0', ['salary', 'currency']
        )
        # Ensure schema exists on DKMS
        schema_ = await dkms.ensure_schema_exists(anon_schema, DID_EMPLOYER)
        # Ensure CredDefs is stored to DKMS
        cred_def_fetched = await dkms.fetch_cred_defs(tag='TAG', schema_id=schema_.id)
        if cred_def_fetched:
            cred_def_ = cred_def_fetched[0]
        else:
            ok, cred_def_ = await dkms.register_cred_def(
                cred_def=sirius_sdk.CredentialDefinition(tag='TAG', schema=schema_),
                submitter_did=DID_EMPLOYER
            )
            assert ok is True
        print('===========================')
        print('cred def ID: ' + cred_def_.id)
        print('===========================')
    return schema_, cred_def_


async def generate_invitations_qr_codes() -> (str, str):
    # BANK
    async with sirius_sdk.context(**BANK):
        try:
            connection_key = await sirius_sdk.Crypto.create_key(seed='0000000000000000SIRIUS_BANK_CONN')
        except sirius_sdk.indy_exceptions.WalletItemAlreadyExists:
            log(f'Bank: conn key {CONN_KEY_BANK} already exists')
        else:
            log(f'Bank: conn key {connection_key} was created')
            assert connection_key == CONN_KEY_BANK
        endpoints = await sirius_sdk.endpoints()
        simple_endpoint = [e for e in endpoints if e.routing_keys == []][0]
        bank_invitation = sirius_sdk.aries_rfc.Invitation(
            label='Sirius Demo bank',
            recipient_keys=[CONN_KEY_BANK],
            endpoint=simple_endpoint.address,
            did=DID_BANK
        )
        log('Bank: invitation')
        log(json.dumps(bank_invitation, indent=2, sort_keys=True))

        # Sirius SDK provide method to generate URL for QR
        # bank_qr_url = await sirius_sdk.generate_qr_code(bank_invitation.invitation_url)
        # print('BANK QR URL: ' + bank_qr_url)

    # EMPLOYER
    async with sirius_sdk.context(**EMPLOYER):
        try:
            connection_key = await sirius_sdk.Crypto.create_key(seed='000000000000SIRIUS_EMPLOYER_CONN')
        except sirius_sdk.indy_exceptions.WalletItemAlreadyExists:
            log(f'Employer: conn key {CONN_KEY_EMPLOYER} already exists')
        else:
            log(f'Employer: conn key {connection_key} was created')
            assert connection_key == CONN_KEY_EMPLOYER
        endpoints = await sirius_sdk.endpoints()
        simple_endpoint = [e for e in endpoints if e.routing_keys == []][0]
        employer_invitation = sirius_sdk.aries_rfc.Invitation(
            label='Sirius Demo employer',
            recipient_keys=[CONN_KEY_EMPLOYER],
            endpoint=simple_endpoint.address,
            did=DID_EMPLOYER
        )
        log('Employer: invitation')
        log(json.dumps(employer_invitation, indent=2, sort_keys=True))

        # Sirius SDK provide method to generate URL for QR
        # employer_qr_url = await sirius_sdk.generate_qr_code(employer_invitation.invitation_url)
        # print('EMPLOYER QR URL: ' + employer_qr_url)

    return 'https://socialsirius.com' + bank_invitation.invitation_url, \
           'https://socialsirius.com' + employer_invitation.invitation_url


async def sirius_bank(network_name: str = 'test_network'):
    async with sirius_sdk.context(**BANK):
        listener = await sirius_sdk.subscribe()
        endpoints = await sirius_sdk.endpoints()
        my_endpoint = [e for e in endpoints if e.routing_keys == []][0]
        dkms = await sirius_sdk.ledger(network_name)
        log('Bank: start to listen events')
        async for event in listener:
            dialog_pairwise: Optional[sirius_sdk.Pairwise] = None
            if isinstance(event.message, sirius_sdk.aries_rfc.ConnRequest):
                # Restore invitation request through invitation.connection_key
                # You may use this snippet to encrypt to invitation cookie values for example
                # to link device to browser Web Page
                if event.recipient_verkey == CONN_KEY_BANK:
                    log(f'Bank: received connection request with connection_key: {CONN_KEY_BANK}')
                    if dialog_pairwise is None:
                        log('Bank: unknown participant. Establish new pairwise P2P')
                    else:
                        log(f'Bank: update pairwise for {dialog_pairwise.their.label}')
                    try:
                        conn_request: sirius_sdk.aries_rfc.ConnRequest = event.message
                        feature_0160 = sirius_sdk.aries_rfc.Inviter(
                            me=sirius_sdk.Pairwise.Me(DID_BANK, VERKEY_BANK),  # Public DID
                            connection_key=event.recipient_verkey,
                            my_endpoint=my_endpoint,
                        )
                        success, dialog_pairwise = await feature_0160.create_connection(conn_request)
                    except Exception as e:
                        log('Bank: exception "%s"' % str(e))
                    else:
                        if success:
                            await sirius_sdk.PairwiseList.ensure_exists(dialog_pairwise)
                            log('Bank: pairwise established successfully')
                            log(json.dumps(dialog_pairwise.metadata, indent=2, sort_keys=True))
                        else:
                            log('Bank: error while establish P2P connection')
                            if feature_0160.problem_report:
                                log('problem report')
                                log(json.dumps(feature_0160.problem_report, indent=2, sort_keys=True))
                else:
                    log('Bank: Unknown connection-key')
            elif isinstance(event.message, sirius_sdk.aries_rfc.Message):
                dialog_pairwise = event.pairwise
            # Digital service
            if dialog_pairwise is not None:
                log('Bank: Digital service')
                person_name = dialog_pairwise.their.label
                service1 = 'Loan request'
                service2 = 'Personal offers'
                ask = sirius_sdk.aries_rfc.Question(
                    valid_responses=[service1, service2],
                    question_text=f'{person_name} welcome to personal cabinet',
                    question_detail='We are glad to make personal offer for you!',
                    locale='en'
                )
                ask.set_ttl(60)  # Set timeout for answer
                success, answer = await sirius_sdk.aries_rfc.ask_and_wait_answer(
                    query=ask,
                    to=dialog_pairwise
                )
                if success:
                    log(f'Bank: providing service: {answer.response}')
                    if answer.response == service1:
                        feature_0037 = sirius_sdk.aries_rfc.Verifier(
                            prover=dialog_pairwise,
                            ledger=dkms,
                        )
                        verify_ok = await feature_0037.verify(
                            comment='Prove your salary credentials',
                            locale='en',
                            proof_request={
                                'nonce': await sirius_sdk.AnonCreds.generate_nonce(),
                                "name": "Proof your salary",
                                "version": "0.1",
                                "requested_attributes": {
                                    'attr1_referent': {
                                        "name": "salary",
                                        "restrictions": {
                                            "issuer_did": DID_EMPLOYER
                                        }
                                    },
                                    'attr2_referent': {
                                        "name": "currency",
                                        "restrictions": {
                                            "issuer_did": DID_EMPLOYER
                                        }
                                    }
                                }
                            },
                            translation=[
                                sirius_sdk.aries_rfc.AttribTranslation('salary', 'Your salary'),
                                sirius_sdk.aries_rfc.AttribTranslation('currency', 'Currency'),
                            ]
                        )
                        if verify_ok:
                            txt_msg = sirius_sdk.aries_rfc.Message(
                                content='Loan approved',
                                locale='en'
                            )
                        else:
                            txt_msg = sirius_sdk.aries_rfc.Message(
                                content='Loan declined',
                                locale='en'
                            )
                        await sirius_sdk.send_to(txt_msg, dialog_pairwise)
                    else:
                        txt_msg = sirius_sdk.aries_rfc.Message(
                            content='Demo personal offer content',
                            locale='en'
                        )
                        await sirius_sdk.send_to(txt_msg, dialog_pairwise)


async def sirius_employer(network_name: str = 'test_network'):
    async with sirius_sdk.context(**EMPLOYER):
        listener = await sirius_sdk.subscribe()
        endpoints = await sirius_sdk.endpoints()
        my_endpoint = [e for e in endpoints if e.routing_keys == []][0]
        dkms = await sirius_sdk.ledger(network_name)
        log('Employer: start to listen events')
        async for event in listener:
            dialog_pairwise: Optional[sirius_sdk.Pairwise] = None
            if isinstance(event.message, sirius_sdk.aries_rfc.ConnRequest):
                # Restore invitation request through invitation.connection_key
                # You may use this snippet to encrypt to invitation cookie values for example
                # to link device to browser Web Page
                if event.recipient_verkey == CONN_KEY_EMPLOYER:
                    log(f'Employer: received connection request with connection_key: {CONN_KEY_BANK}')
                    if dialog_pairwise is None:
                        log('Employer: unknown participant. Establish new pairwise P2P')
                    else:
                        log(f'Employer: update pairwise for {dialog_pairwise.their.label}')
                    try:
                        conn_request: sirius_sdk.aries_rfc.ConnRequest = event.message
                        feature_0160 = sirius_sdk.aries_rfc.Inviter(
                            me=sirius_sdk.Pairwise.Me(DID_EMPLOYER, VERKEY_EMPLOYER),  # Public DID
                            connection_key=event.recipient_verkey,
                            my_endpoint=my_endpoint,
                        )
                        success, dialog_pairwise = await feature_0160.create_connection(conn_request)
                    except Exception as e:
                        log('Employer: exception "%s"' % str(e))
                    else:
                        if success:
                            await sirius_sdk.PairwiseList.ensure_exists(dialog_pairwise)
                            log('Employer: pairwise established successfully')
                            log(json.dumps(dialog_pairwise.metadata, indent=2, sort_keys=True))
                        else:
                            log('Employer: error while establish P2P connection')
                            if feature_0160.problem_report:
                                log('problem report')
                                log(json.dumps(feature_0160.problem_report, indent=2, sort_keys=True))
                else:
                    log('Employer: Unknown connection-key')
            elif isinstance(event.message, sirius_sdk.aries_rfc.Message):
                dialog_pairwise = event.pairwise
            # Digital service
            if dialog_pairwise is not None:
                log('Employer: Digital service')
                person_name = dialog_pairwise.their.label
                service1 = 'Get Salary credentials'
                service2 = 'Request for holiday'
                service3 = 'Go to WebSite'
                ask = sirius_sdk.aries_rfc.Question(
                    valid_responses=[service1, service2, service3],
                    question_text=f'{person_name} welcome!',
                    question_detail='I am your employer Virtual Assistant.',
                    locale='en'
                )
                ask.set_ttl(60)  # Set timeout for answer
                success, answer = await sirius_sdk.aries_rfc.ask_and_wait_answer(
                    query=ask,
                    to=dialog_pairwise
                )
                if success:
                    log(f'Employer: providing service: {answer.response}')
                    if answer.response == service1:
                        log('Employer: starting to issue Salary credential')
                        cred_def = await dkms.load_cred_def(EMPLOYER_CRED_DEF_ID, DID_EMPLOYER)
                        feature_0036 = sirius_sdk.aries_rfc.Issuer(
                            holder=dialog_pairwise,
                        )
                        success = await feature_0036.issue(
                            values={'salary': DEMO_SALARY, 'currency': DEMO_CURRENCY},
                            schema=cred_def.schema,
                            cred_def=cred_def,
                            comment='You may prove your salary in Bank',
                            locale='en',
                            preview=[
                                sirius_sdk.aries_rfc.ProposedAttrib('salary', 'Your salary'),
                                sirius_sdk.aries_rfc.ProposedAttrib('currency', 'Currency')
                            ],
                            cred_id=f'salary-cred-id-for-{dialog_pairwise.their.did}'
                        )
                        if success:
                            log(f'Employer: salary cred successfully finished')
                        else:
                            log('Employer: error while issuing salary credential')
                            if feature_0036.problem_report:
                                log('problem report')
                                log(json.dumps(feature_0036.problem_report, indent=2, sort_keys=True))
                    else:
                        txt_msg = sirius_sdk.aries_rfc.Message(
                            content=f'You selected "{answer.response}" service',
                            locale='en'
                        )
                        await sirius_sdk.send_to(txt_msg, dialog_pairwise)


if __name__ == '__main__':
    qr_bank, qr_employer = asyncio.get_event_loop().run_until_complete(generate_invitations_qr_codes())
    print('invitation URLs')
    print(f'Bank: {qr_bank}')
    print(f'Employer: {qr_employer}')
    print('-------------')
    schema_employer, cred_def_employer = asyncio.get_event_loop().run_until_complete(setup_employer_cred_defs())
    print('*************')
    asyncio.ensure_future(sirius_bank())
    print('#1')
    asyncio.ensure_future(sirius_employer())
    print('#2')
    asyncio.get_event_loop().run_forever()

# Test network is prepared for Demo purposes # Ensure schema exists on DKMS # Ensure CredDefs is stored to DKMS # BANK # Sirius SDK provide method to generate URL for QR # bank_qr_url = await sirius_sdk.generate_qr_code(bank_invitation.invitation_url) # print('BANK QR URL: ' + bank_qr_url) # EMPLOYER # Sirius SDK provide method to generate URL for QR # employer_qr_url = await sirius_sdk.generate_qr_code(employer_invitation.invitation_url) # print('EMPLOYER QR URL: ' + employer_qr_url) # Restore invitation request through invitation.connection_key # You may use this snippet to encrypt to invitation cookie values for example # to link device to browser Web Page # Public DID # Digital service # Set timeout for answer # Restore invitation request through invitation.connection_key # You may use this snippet to encrypt to invitation cookie values for example # to link device to browser Web Page # Public DID # Digital service # Set timeout for answer