Function on_lsps_lsps2_getinfo

plugins/lsps-plugin/src/client.rs:139–176

Rpc Method handler for `lsps-lsps2-getinfo`.

(
    p: cln_plugin::Plugin<State>,
    v: serde_json::Value,
)

/// Rpc Method handler for `lsps-lsps2-getinfo`.
async fn on_lsps_lsps2_getinfo(
    p: cln_plugin::Plugin<State>,
    v: serde_json::Value,
) -> Result<serde_json::Value, anyhow::Error> {
    let req: ClnRpcLsps2GetinfoRequest =
        serde_json::from_value(v).context("Failed to parse request JSON")?;
    debug!(
        "Requesting opening fee menu from lsp {} with token {:?}",
        req.lsp_id, req.token
    );

    let lsp_id = PublicKey::from_str(&req.lsp_id).context("lsp_id is not a valid public key")?;

    let dir = p.configuration().lightning_dir;
    let rpc_path = Path::new(&dir).join(&p.configuration().rpc_file);
    let mut cln_client = cln_rpc::ClnRpc::new(rpc_path.clone()).await?;

    let lsp_status = check_peer_lsp_status(&mut cln_client, &req.lsp_id).await?;

    // Fail early: Check that we are connected to the peer.
    if !lsp_status.connected {
        bail!("Not connected to peer {}", &req.lsp_id);
    };

    // From Blip52: LSPs MAY set the features bit numbered 729
    // (option_supports_lsps)...
    // We only log that it is not set but don't fail.
    if !lsp_status.has_lsp_feature {
        debug!("Peer {} doesn't have the LSP feature bit set.", &req.lsp_id);
    }

    // 1. Call lsps2.get_info.
    let client = p.state().client();
    match client.get_info(&lsp_id, req.token).await?.as_result() {
        Ok(i) => Ok(serde_json::to_value(i)?),
        Err(e) => Ok(serde_json::to_value(e)?),
    }
}

/// Rpc Method handler for `lsps-lsps2-buy`.
async fn on_lsps_lsps2_buy(