siliqua.network.nanovault package

Submodules

siliqua.network.nanovault.rpc module

class siliqua.network.nanovault.rpc.RPCProcessor(*args, **kwargs)

Bases: siliqua.network.nano_node.rpc.RPCProcessor

NanoVault servers work identically to NANO nodes, but miss a few endpoints we can ignore

async check_node_version()

Check the node version in use and return True if the node version is recent enough

async update_active_difficulty()

Check the active difficulty on the network and update accordingly

siliqua.network.nanovault.ws module

class siliqua.network.nanovault.ws.WebSocketProcessor(*args, **kwargs)

Bases: siliqua.network.nano_node.ws.WebSocketProcessor

NanoVault uses its own WebSocket server

KEEPALIVE_INTERVAL_SECONDS = 60

async listen_for_msg()

async loop()

The main event loop that continues endlessly until the shutdown flag is activated

async update_listen_subscription()

Module contents

class siliqua.network.nanovault.NetworkPlugin(*args, **kwargs)

Bases: siliqua.network.nano_node.NetworkPlugin

PLUGIN_NAME = 'nanovault'

siliqua.network.nanovault.run_network_thread(network_plugin)

Start looping asynchronous RPC and WebSocket network tasks

async siliqua.network.nanovault.run_rpc_processor(network_plugin)

async siliqua.network.nanovault.run_websocket_processor(network_plugin)