Skip to content

Adapters

components.payment_gateway.internal.adapters.adyen

register

register_adyen_topic_subscribers 

register_adyen_topic_subscribers(workspace_key)

Register all the Adyen topic subscribers that the Payment Gateway handles directly.

Source code in components/payment_gateway/internal/adapters/adyen/register.py 
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
def register_adyen_topic_subscribers(workspace_key: str) -> None:
    """Register all the Adyen topic subscribers that the Payment Gateway handles directly."""
    from components.payment_gateway.public.connectors.adyen_connectors import (
        adyen_card_order_topic,
        adyen_payment_instrument_topic,
    )
    from components.payment_gateway.subcomponents.cards.adapters.adyen.topic_subscribers import (
        CardOrderTopicSubscriber,
        PaymentInstrumentTopicSubscriber,
    )
    from components.payment_gateway.subcomponents.cards.business_logic.policies.card_order_tracking import (
        CardOrderTrackingPolicy,
    )
    from components.payment_gateway.subcomponents.cards.business_logic.policies.card_status_handling import (
        CardStatusHandlingPolicy,
    )

    payment_instrument_topic_subscriber = PaymentInstrumentTopicSubscriber(
        CardStatusHandlingPolicy(workspace_key)
    )
    adyen_payment_instrument_topic.subscribe(payment_instrument_topic_subscriber)

    card_order_topic_subscriber = CardOrderTopicSubscriber(
        CardOrderTrackingPolicy(workspace_key)
    )
    adyen_card_order_topic.subscribe(card_order_topic_subscriber)

register_authorization_resolvers 

register_authorization_resolvers(
    workspace_key,
    expense_category_resolver,
    line_of_credit_resolver,
)

Connect the application-specific resolvers to the Adyen authorisation relay and transfer topic.

Source code in components/payment_gateway/internal/adapters/adyen/register.py 
 80
 81
 82
 83
 84
 85
 86
 87
 88
 89
 90
 91
 92
 93
 94
 95
 96
 97
 98
 99
100
101
def register_authorization_resolvers(
    workspace_key: str,
    expense_category_resolver: ExpenseCategoryResolver,
    line_of_credit_resolver: LineOfCreditResolver,
) -> None:
    """Connect the application-specific resolvers to the Adyen authorisation relay and transfer topic."""
    from components.payment_gateway.public.connectors.adyen_connectors import (
        adyen_authorisation_relay,
        adyen_transfer_topic,
    )
    from components.payment_gateway.subcomponents.authorizations.business_logic.policies.authorization_request_processing import (
        AuthorizationRequestProcessingPolicy,
    )

    adyen_authorisation_relay.register_policy(
        authorization_request_processing_policy=AuthorizationRequestProcessingPolicy(
            workspace_key=workspace_key,
            expense_category_resolver=expense_category_resolver,
            line_of_credit_resolver=line_of_credit_resolver,
        )
    )
    adyen_transfer_topic.subscribe(adyen_authorisation_relay)

register_transfer_routers 

register_transfer_routers(
    workspace_key,
    card_transfer_router,
    bank_transfer_router,
    account_transfer_router,
)

Connect the application-specific transfer routers to the Adyen transfer topic.

Source code in components/payment_gateway/internal/adapters/adyen/register.py 
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
def register_transfer_routers(
    workspace_key: str,
    card_transfer_router: CardTransferRouter,
    bank_transfer_router: BankTransferRouter,
    account_transfer_router: AccountTransferRouter,
) -> None:
    """Connect the application-specific transfer routers to the Adyen transfer topic."""
    from components.payment_gateway.public.connectors.adyen_connectors import (
        adyen_transfer_topic,
    )
    from components.payment_gateway.subcomponents.transfers.adapters.adyen.policies.account_transfer_processor import (
        AdyenAccountTransferProcessorPolicy,
    )
    from components.payment_gateway.subcomponents.transfers.adapters.adyen.policies.bank_transfer_processor import (
        AdyenBankTransferProcessorPolicy,
    )
    from components.payment_gateway.subcomponents.transfers.adapters.adyen.policies.card_transfer_processor import (
        AdyenCardTransferProcessorPolicy,
    )
    from components.payment_gateway.subcomponents.transfers.adapters.adyen.topic_subscribers import (
        TransferTopicSubscriber,
    )

    transfer_topic_subscriber = TransferTopicSubscriber(
        card_transfer_processor_policy=AdyenCardTransferProcessorPolicy(
            workspace_key=workspace_key,
            card_transfer_router=card_transfer_router,
        ),
        bank_transfer_processor_policy=AdyenBankTransferProcessorPolicy(
            workspace_key=workspace_key,
            bank_transfer_router=bank_transfer_router,
        ),
        account_transfer_processor_policy=AdyenAccountTransferProcessorPolicy(
            workspace_key=workspace_key,
            account_transfer_router=account_transfer_router,
        ),
    )
    adyen_transfer_topic.subscribe(transfer_topic_subscriber)

components.payment_gateway.internal.adapters.jpmorgan

register

register_jpmorgan_topic_subscribers 

register_jpmorgan_topic_subscribers(workspace_key)
Source code in components/payment_gateway/internal/adapters/jpmorgan/register.py 
12
13
14
15
16
17
18
19
def register_jpmorgan_topic_subscribers(workspace_key: str) -> None:
    jpmorgan_transfer_topic.subscribe(
        subscriber=JPMorganBankTransferTopicSubscriber(
            bank_transfer_processor_policy=JPMorganBankTransferProcessorPolicy(
                workspace_key=workspace_key,
            ),
        )
    )

workspace_mapping

get_jpmorgan_business_account_name 

get_jpmorgan_business_account_name(workspace_key)

Resolve a workspace key to its corresponding JPMorgan business account name.

Source code in components/payment_gateway/internal/adapters/jpmorgan/workspace_mapping.py 
10
11
12
13
14
15
16
17
18
19
def get_jpmorgan_business_account_name(
    workspace_key: str,
) -> JPMorganBusinessAccountName:
    """Resolve a workspace key to its corresponding JPMorgan business account name."""
    config = get_provider_config_for_workspace(workspace_key)
    if not isinstance(config, JpmorganWorkspaceConfig):
        raise ValueError(
            f"No JPMorgan business account configured for workspace '{workspace_key}'"
        )
    return config.business_account_name

components.payment_gateway.internal.adapters.revolut

register

register_revolut_topic_subscribers 

register_revolut_topic_subscribers(workspace_key)

Register all the Revolut topic subscribers that the Payment Gateway handles directly.

Source code in components/payment_gateway/internal/adapters/revolut/register.py 
 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
def register_revolut_topic_subscribers(
    workspace_key: str,
) -> None:
    """Register all the Revolut topic subscribers that the Payment Gateway handles directly."""
    from components.payment_gateway.internal.adapters.revolut.workspace_mapping import (
        get_revolut_business_account_name,
    )
    from components.payment_gateway.public.connectors.revolut_connectors import (
        transaction_created_topic,
        transaction_state_changed_topic,
    )
    from components.payment_gateway.subcomponents.transfers.adapters.revolut.policies.bank_transfer_processor import (
        RevolutBankTransferProcessorPolicy,
    )
    from components.payment_gateway.subcomponents.transfers.adapters.revolut.topic_subscribers import (
        TransactionCreatedSubscriber,
        TransactionStateChangedSubscriber,
    )

    # Raw webhook logging is handled by the global webhook subscriber

    business_account_name = get_revolut_business_account_name(workspace_key)
    bank_transfer_processor_policy = RevolutBankTransferProcessorPolicy.create(
        workspace_key=workspace_key,
    )

    # Subscribe to Revolut transfer events
    transaction_created_topic.subscribe(
        subscriber=TransactionCreatedSubscriber(
            bank_transfer_processor_policy=bank_transfer_processor_policy,
            business_account_name=business_account_name,
        )
    )
    transaction_state_changed_topic.subscribe(
        subscriber=TransactionStateChangedSubscriber(
            bank_transfer_processor_policy=bank_transfer_processor_policy,
            business_account_name=business_account_name,
        )
    )

workspace_mapping

get_revolut_business_account_name 

get_revolut_business_account_name(workspace_key)

Resolve a workspace key to its corresponding Revolut business account name.

Source code in components/payment_gateway/internal/adapters/revolut/workspace_mapping.py 
10
11
12
13
14
15
16
17
18
19
def get_revolut_business_account_name(
    workspace_key: str,
) -> RevolutBusinessAccountName:
    """Resolve a workspace key to its corresponding Revolut business account name."""
    config = get_provider_config_for_workspace(workspace_key)
    if not isinstance(config, RevolutWorkspaceConfig):
        raise ValueError(
            f"No Revolut business account configured for workspace '{workspace_key}'"
        )
    return config.business_account_name

components.payment_gateway.internal.adapters.swan

register

register_swan_authorization_resolvers 

register_swan_authorization_resolvers(
    workspace_key,
    expense_category_resolver,
    line_of_credit_resolver,
)

Wire application-specific resolvers into the Swan Payment Control connector.

Source code in components/payment_gateway/internal/adapters/swan/register.py 
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
def register_swan_authorization_resolvers(
    workspace_key: str,
    expense_category_resolver: ExpenseCategoryResolver,
    line_of_credit_resolver: LineOfCreditResolver,
) -> None:
    """Wire application-specific resolvers into the Swan Payment Control connector."""
    from components.payment_gateway.public.connectors.swan_connectors import (
        swan_payment_control,
    )
    from components.payment_gateway.subcomponents.authorizations.business_logic.policies.authorization_request_processing import (
        AuthorizationRequestProcessingPolicy,
    )

    swan_payment_control.register_policy(
        AuthorizationRequestProcessingPolicy(
            workspace_key=workspace_key,
            expense_category_resolver=expense_category_resolver,
            line_of_credit_resolver=line_of_credit_resolver,
        )
    )

components.payment_gateway.internal.adapters.webhook_subscribers

Generic webhook topic subscribers for payment providers.

RawWebhookTopicSubscriber

Bases: Subscriber

Subscribes to raw webhook topic messages and logs them in the database.

Works for any payment provider.

receive 

receive(message)
Source code in components/payment_gateway/internal/adapters/webhook_subscribers.py 
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
@override
@obs.event_subscriber()
def receive(self, message: RawWebhook) -> None:
    try:
        current_rq.get_queue(LOW_PRIORITY_QUEUE).enqueue(
            _record_webhook_log,
            source=message.source,
            status=message.status,
            payload=message.payload,
        )
    except Exception as e:
        current_logger.exception(
            "Exception while enqueuing WebhookLog",
            exception=e,
        )

raw_webhook_topic_subscriber module-attribute 

raw_webhook_topic_subscriber = RawWebhookTopicSubscriber()