Function on_lsps_lsps2_approve

plugins/lsps-plugin/src/client.rs:266–298

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

}

async fn on_lsps_lsps2_approve(
    p: cln_plugin::Plugin<State>,
    v: serde_json::Value,
) -> Result<serde_json::Value, anyhow::Error> {
    let req: ClnRpcLsps2Approve = serde_json::from_value(v)?;
    let ds_rec = DatastoreRecord {
        jit_channel_scid: req.jit_channel_scid.clone(),
        client_trusts_lsp: req.client_trusts_lsp.unwrap_or_default(),
    };
    let ds_rec_json = serde_json::to_string(&ds_rec)?;

    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 ds_req = DatastoreRequest {
        generation: None,
        hex: None,
        mode: Some(DatastoreMode::CREATE_OR_REPLACE),
        string: Some(ds_rec_json),
        key: vec!["lsps".to_string(), "client".to_string(), req.lsp_id.clone()],
    };
    let _ds_res = cln_client.call_typed(&ds_req).await?;
    let ds_req = DatastoreRequest {
        generation: None,
        hex: None,
        mode: Some(DatastoreMode::CREATE_OR_REPLACE),
        string: Some(req.lsp_id),
        key: vec!["lsps".to_string(), "invoice".to_string(), req.payment_hash],
    };
    let _ds_res = cln_client.call_typed(&ds_req).await?;
    Ok(serde_json::Value::default())
}

/// RPC Method handler for `lsps-jitchannel`.
/// Calls lsps2.get_info, selects parameters, calculates fee, calls lsps2.buy,