Function on_lsps_listprotocols

plugins/lsps-plugin/src/client.rs:724–760

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

}

async fn on_lsps_listprotocols(
    p: cln_plugin::Plugin<State>,
    v: serde_json::Value,
) -> Result<serde_json::Value, anyhow::Error> {
    #[derive(Deserialize)]
    struct Request {
        lsp_id: String,
    }
    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 req: Request = serde_json::from_value(v).context("Failed to parse request JSON")?;
    let lsp_id = PublicKey::from_str(&req.lsp_id).context("lsp_id is not a valid public key")?;
    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);
    }

    let client = p.state().client();
    match client.list_protocols(&lsp_id).await?.as_result() {
        Ok(i) => {
            debug!("Received lsps0.list_protocols response: {:?}", i);
            Ok(serde_json::to_value(i)?)
        }
        Err(e) => Ok(serde_json::to_value(e)?),
    }
}

struct PeerLspStatus {
    connected: bool,