Method handle_buy

plugins/lsps-plugin/src/core/lsps2/handler.rs:350–391

(
        &self,
        peer_id: PublicKey,
        request: Lsps2BuyRequest,
    )

    }

    async fn handle_buy(
        &self,
        peer_id: PublicKey,
        request: Lsps2BuyRequest,
    ) -> core::result::Result<Lsps2BuyResponse, RpcError> {
        let fee_params = request.opening_fee_params;

        // FIXME: In the future we should replace the \`None\` with a meaningful
        // value that reflects the inbound capacity for this node from the
        // public network for a better pre-condition check on the payment_size.
        fee_params.validate(&self.promise_secret, request.payment_size_msat, None)?;

        // Generate a tmp scid to identify jit channel request in htlc.
        let blockheight = self
            .api
            .get_blockheight()
            .await
            .map_err(|_| RpcError::internal_error("internal error"))?;

        // FIXME: Future task: Check that we don't conflict with any jit scid we
        // already handed out -> Check datastore entries.
        let jit_scid = ShortChannelId::from(generate_jit_scid(blockheight));

        let ok = self
            .api
            .store_buy_request(&jit_scid, &peer_id, &fee_params, &request.payment_size_msat)
            .await
            .map_err(|_| RpcError::internal_error("internal error"))?;

        if !ok {
            return Err(RpcError::internal_error("internal error"))?;
        }

        Ok(Lsps2BuyResponse {
            jit_channel_scid: jit_scid,
            // We can make this configurable if necessary.
            lsp_cltv_expiry_delta: DEFAULT_CLTV_EXPIRY_DELTA,
            // We can implement the other mode later on as we might have to do
            // some additional work on core-lightning to enable this.
            client_trusts_lsp: false,
        })
    }
}

fn generate_jit_scid(best_blockheigt: u32) -> u64 {