houndcore.app package

Subpackages

• houndcore.app.errors package
  • Submodules
  • houndcore.app.errors.incorrect_rpc module
    • IncorrectRPC
  • Module contents
• houndcore.app.scanners package
  • Submodules
  • houndcore.app.scanners.base module
    • Scanner
      • Scanner.connect()
      • Scanner.is_connected
      • Scanner.run()
      • Scanner.subscribe()
      • Scanner.unsubscribe()
  • houndcore.app.scanners.subscription_scanner module
    • SubscriptionScanner
      • SubscriptionScanner.connect()
      • SubscriptionScanner.is_connected
      • SubscriptionScanner.run()
      • SubscriptionScanner.subscribe()
      • SubscriptionScanner.unsubscribe()
  • Module contents
• houndcore.app.types package
  • Submodules
  • houndcore.app.types.context module
    • Context
  • houndcore.app.types.subscription module
    • Subscription
      • Subscription.to_web3()
  • Module contents

Submodules

houndcore.app.dispatcher module

class houndcore.app.dispatcher.Dispatcher

Bases: object

the event manager (dispatcher)

async handle_event(context: EthSubscriptionContext[LogsSubscription, EthSubscriptionResult] | EthSubscriptionContext[PendingTxSubscription, HexBytes | TxData]) → None

handles any new events

Parameters:

context (Union[web3.utils.PendingTxSubscriptionContext, web3.utils.LogsSubscriptionContext]) – the event context

poll(sub_id: str, limit: int) → List[EthSubscriptionContext[LogsSubscription, EthSubscriptionResult] | EthSubscriptionContext[PendingTxSubscription, HexBytes | TxData]] | None

poll any new events using the subscription id

Parameters:

• sub_id (str) – the subscription id

• limit (int) – the limit of returned results

Returns:

Union[List[Context], None]

subscribe(sub_id: str) → None

Subscribe to a subscription using its id

Parameters:

sub_id (str) – the subscription id

unsubscribe(sub_id: str) → None

Un-Subscribe to a subscription using its id

Parameters:

sub_id (str) – the subscription id

Module contents