Events and Callbacks

from firmngin import AsyncClient, ClientConfig, Event, Payment

config = ClientConfig.from_file("keys.json")

async with AsyncClient(config) as client:
    @client.on(Event.PAYMENT)
    async def handle_payment(payment: Payment) -> None:
        if payment.is_success:
            print("paid:", payment.order_id)

from firmngin import Event, Init

@client.on(Event.INIT)
def on_init(init: Init) -> None:
    if init.is_vending_mode:
        print("vending mode")
    if init.is_service_mode:
        print("service mode")

from firmngin import Dispense, Event

@client.on(Event.DISPENSE)
def on_dispense(dispense: Dispense) -> None:
    if not dispense.is_valid:
        return
    for sku in dispense.skus:
        print("dispense:", sku)

client.off(Event.PAYMENT, handle_payment)
client.clear_handlers()

import json

@client.on(Event.METADATA_PENDING)
def on_pending(raw_json: str) -> None:
    data = json.loads(raw_json)

from firmngin import Event, Usage

@client.on(Event.USAGE)
def on_usage(usage: Usage) -> None:
    print(usage.used, usage.limit, usage.near_limit, usage.limit_exceeded)

from firmngin import Entity, EntityCommand

@client.on_entity(Entity("relay"))
def handle_relay(command: EntityCommand) -> None:
    print(command.value)

@client.on(Event.ACTIVE_SESSION)
async def handle_session(session: ActiveSession) -> None:
    if session.can_run:
        await session.end_session()

@client.on(Event.ERROR)
async def handle_error(error: Exception) -> None:
    print("error:", error)