Struct Gateway

pub struct Gateway { /* private fields */ }

Implementations

impl Gateway

pub async fn new_with_custom_registry( lightning_builder: Arc<dyn LightningBuilder + Sync + Send>, client_builder: GatewayClientBuilder, listen: SocketAddr, api_addr: SafeUrl, cli_password: Option<String>, network: Option<Network>, fees: RoutingFees, num_route_hints: u32, gateway_db: Database, gateway_state: GatewayState, ) -> Result<Gateway, Error>

Creates a new gateway but with a custom module registry provided inside client_builder. Currently only used for testing.

pub async fn new_with_default_modules() -> Result<Gateway, Error>

Default function for creating a gateway with the Mint, Wallet, and Gateway modules.

pub fn gateway_id(&self) -> PublicKey

pub fn versioned_api(&self) -> &SafeUrl

pub async fn clone_gateway_config(&self) -> Option<GatewayConfiguration>

pub async fn get_state(&self) -> GatewayState

pub async fn dump_database<'a>( dbtx: &mut DatabaseTransaction<'_>, prefix_names: Vec<String>, ) -> Box<dyn Iterator<Item = (String, Box<dyn Serialize + Send>)> + 'a>

Reads and serializes structures from the Gateway’s database for the purpose for serializing to JSON for inspection.

pub async fn run(self, tg: &TaskGroup) -> Result<TaskShutdownToken, Error>

Main entrypoint into the gateway that starts the client registration timer, loads the federation clients from the persisted config, begins listening for intercepted HTLCs, and starts the webserver to service requests.

pub async fn handle_htlc_stream( &self, stream: Pin<Box<dyn Stream<Item = Result<InterceptHtlcRequest, Status>> + Send + '_>>, handle: TaskHandle, )

Blocks waiting for intercepted HTLCs to be sent over the stream. Spawns a state machine to either forward, cancel, or complete the HTLC depending on if the gateway is able to acquire the preimage from the federation.

pub async fn handle_get_info(&self) -> Result<GatewayInfo, GatewayError>

Returns information about the Gateway back to the client when requested via the webserver.

pub async fn handle_get_federation_config( &self, federation_id_or: Option<FederationId>, ) -> Result<GatewayFedConfig, GatewayError>

If the Gateway is connected to the Lightning node, returns the ClientConfig for each federation that the Gateway is connected to.

pub async fn handle_balance_msg( &self, payload: BalancePayload, ) -> Result<Amount, GatewayError>

Returns the balance of the requested federation that the Gateway is connected to.

pub async fn handle_address_msg( &self, payload: DepositAddressPayload, ) -> Result<Address, GatewayError>

Returns a Bitcoin deposit on-chain address for pegging in Bitcoin for a specific connected federation.

pub async fn handle_withdraw_msg( &self, payload: WithdrawPayload, ) -> Result<Txid, GatewayError>

Returns a Bitcoin TXID from a peg-out transaction for a specific connected federation.

pub async fn handle_connect_federation( &self, payload: ConnectFedPayload, ) -> Result<FederationInfo, GatewayError>

Handles a connection request to join a new federation. The gateway will download the federation’s client configuration, construct a new client, registers, the gateway with the federation, and persists the necessary config to reconstruct the client when restarting the gateway.

pub async fn handle_leave_federation( &self, payload: LeaveFedPayload, ) -> Result<FederationInfo, GatewayError>

Handle a request to have the Gateway leave a federation. The Gateway will request the federation to remove the registration record and the gateway will remove the configuration needed to construct the federation client.

pub fn handle_backup_msg(&self, _: BackupPayload) -> Result<(), GatewayError>

Handles a request for the gateway to backup a connected federation’s ecash. Not currently supported.

pub fn handle_restore_msg(&self, _: RestorePayload) -> Result<(), GatewayError>

Handles a request for the gateway to restore a connected federation’s ecash. Not currently supported.

pub async fn handle_set_configuration_msg( &self, __arg1: SetConfigurationPayload, ) -> Result<(), GatewayError>

Handle a request to change a connected federation’s configuration or gateway metadata. If num_route_hints is changed, the Gateway will re-register with all connected federations. If per_federation_routing_fees is changed, the Gateway will only re-register with the specified federation.

pub async fn handle_get_funding_address_msg( &self, ) -> Result<Address, GatewayError>

pub async fn handle_open_channel_msg( &self, __arg1: OpenChannelPayload, ) -> Result<(), GatewayError>

Instructs the Gateway’s Lightning node to open a channel to a peer specified by pubkey.

pub async fn handle_close_channels_with_peer_msg( &self, __arg1: CloseChannelsWithPeerPayload, ) -> Result<CloseChannelsWithPeerResponse, GatewayError>

Instructs the Gateway’s Lightning node to close all channels with a peer specified by pubkey.

pub async fn handle_list_active_channels_msg( &self, ) -> Result<Vec<ChannelInfo>, GatewayError>

Returns a list of Lightning network channels from the Gateway’s Lightning node.

pub async fn select_client( &self, federation_id: FederationId, ) -> Result<Spanned<Arc<ClientHandle>>, GatewayError>

Retrieves a ClientHandleArc from the Gateway’s in memory structures that keep track of available clients, given a federation_id.

pub async fn get_lightning_context( &self, ) -> Result<LightningContext, LightningRpcError>

Checks the Gateway’s current state and returns the proper LightningContext if it is available. Sometimes the lightning node will not be connected and this will return an error.

pub async fn unannounce_from_all_federations(&self)

Iterates through all of the federations the gateway is registered with and requests to remove the registration record.

impl Gateway

pub async fn routing_info_v2( &self, federation_id: &FederationId, ) -> Option<RoutingInfo>

Returns payment information that LNv2 clients can use to instruct this Gateway to pay an invoice or receive a payment.

pub async fn select_client_v2( &self, federation_id: FederationId, ) -> Result<Arc<ClientHandle>, Error>

pub async fn create_invoice_via_lnrpc_v2( &self, payment_hash: Hash, amount: Amount, description: Bolt11InvoiceDescription, expiry_time: u32, ) -> Result<Bolt11Invoice, String>

Retrieves a BOLT11 invoice from the connected Lightning node with a specific payment_hash.

pub async fn get_registered_incoming_contract_and_client_v2( &self, payment_hash: [u8; 32], amount_msats: u64, ) -> Result<(IncomingContract, Arc<ClientHandle>), Error>

Retrieves the persisted CreateInvoicePayload from the database specified by the payment_hash and the ClientHandleArc specified by the payload’s federation_id.

Trait Implementations

impl Clone for Gateway

fn clone(&self) -> Gateway

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Gateway

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.