msggen: add missing rpc commands new to 24.11

Changelog-None
This commit is contained in:
daywalker90 2024-11-09 16:47:17 +01:00 committed by Rusty Russell
parent 703c11515d
commit 2ba05ef2b8
9 changed files with 6928 additions and 809 deletions

File diff suppressed because it is too large Load diff

View file

@ -28,6 +28,8 @@ service Node {
rpc DelInvoice(DelinvoiceRequest) returns (DelinvoiceResponse) {}
rpc DevForgetChannel(DevforgetchannelRequest) returns (DevforgetchannelResponse) {}
rpc EmergencyRecover(EmergencyrecoverRequest) returns (EmergencyrecoverResponse) {}
rpc GetEmergencyRecoverData(GetemergencyrecoverdataRequest) returns (GetemergencyrecoverdataResponse) {}
rpc ExposeSecret(ExposesecretRequest) returns (ExposesecretResponse) {}
rpc Recover(RecoverRequest) returns (RecoverResponse) {}
rpc RecoverChannel(RecoverchannelRequest) returns (RecoverchannelResponse) {}
rpc Invoice(InvoiceRequest) returns (InvoiceResponse) {}
@ -62,6 +64,7 @@ service Node {
rpc DelPay(DelpayRequest) returns (DelpayResponse) {}
rpc DelForward(DelforwardRequest) returns (DelforwardResponse) {}
rpc DisableOffer(DisableofferRequest) returns (DisableofferResponse) {}
rpc EnableOffer(EnableofferRequest) returns (EnableofferResponse) {}
rpc Disconnect(DisconnectRequest) returns (DisconnectResponse) {}
rpc Feerates(FeeratesRequest) returns (FeeratesResponse) {}
rpc FetchInvoice(FetchinvoiceRequest) returns (FetchinvoiceResponse) {}
@ -72,6 +75,7 @@ service Node {
rpc GetLog(GetlogRequest) returns (GetlogResponse) {}
rpc FunderUpdate(FunderupdateRequest) returns (FunderupdateResponse) {}
rpc GetRoute(GetrouteRequest) returns (GetrouteResponse) {}
rpc ListAddresses(ListaddressesRequest) returns (ListaddressesResponse) {}
rpc ListForwards(ListforwardsRequest) returns (ListforwardsResponse) {}
rpc ListOffers(ListoffersRequest) returns (ListoffersResponse) {}
rpc ListPays(ListpaysRequest) returns (ListpaysResponse) {}
@ -99,6 +103,7 @@ service Node {
rpc Splice_Init(Splice_initRequest) returns (Splice_initResponse) {}
rpc Splice_Signed(Splice_signedRequest) returns (Splice_signedResponse) {}
rpc Splice_Update(Splice_updateRequest) returns (Splice_updateResponse) {}
rpc DevSplice(DevspliceRequest) returns (DevspliceResponse) {}
rpc UnreserveInputs(UnreserveinputsRequest) returns (UnreserveinputsResponse) {}
rpc UpgradeWallet(UpgradewalletRequest) returns (UpgradewalletResponse) {}
rpc WaitBlockHeight(WaitblockheightRequest) returns (WaitblockheightResponse) {}
@ -115,10 +120,27 @@ service Node {
rpc BkprListAccountEvents(BkprlistaccounteventsRequest) returns (BkprlistaccounteventsResponse) {}
rpc BkprListBalances(BkprlistbalancesRequest) returns (BkprlistbalancesResponse) {}
rpc BkprListIncome(BkprlistincomeRequest) returns (BkprlistincomeResponse) {}
rpc BkprEditDescriptionByPaymentId(BkpreditdescriptionbypaymentidRequest) returns (BkpreditdescriptionbypaymentidResponse) {}
rpc BkprEditDescriptionByOutpoint(BkpreditdescriptionbyoutpointRequest) returns (BkpreditdescriptionbyoutpointResponse) {}
rpc BlacklistRune(BlacklistruneRequest) returns (BlacklistruneResponse) {}
rpc CheckRune(CheckruneRequest) returns (CheckruneResponse) {}
rpc CreateRune(CreateruneRequest) returns (CreateruneResponse) {}
rpc ShowRunes(ShowrunesRequest) returns (ShowrunesResponse) {}
rpc AskReneUnreserve(AskreneunreserveRequest) returns (AskreneunreserveResponse) {}
rpc AskReneListLayers(AskrenelistlayersRequest) returns (AskrenelistlayersResponse) {}
rpc AskReneCreateLayer(AskrenecreatelayerRequest) returns (AskrenecreatelayerResponse) {}
rpc AskReneRemoveLayer(AskreneremovelayerRequest) returns (AskreneremovelayerResponse) {}
rpc AskReneReserve(AskrenereserveRequest) returns (AskrenereserveResponse) {}
rpc AskReneAge(AskreneageRequest) returns (AskreneageResponse) {}
rpc GetRoutes(GetroutesRequest) returns (GetroutesResponse) {}
rpc AskReneDisableNode(AskrenedisablenodeRequest) returns (AskrenedisablenodeResponse) {}
rpc AskReneInformChannel(AskreneinformchannelRequest) returns (AskreneinformchannelResponse) {}
rpc AskReneCreateChannel(AskrenecreatechannelRequest) returns (AskrenecreatechannelResponse) {}
rpc AskReneUpdateChannel(AskreneupdatechannelRequest) returns (AskreneupdatechannelResponse) {}
rpc AskReneBiasChannel(AskrenebiaschannelRequest) returns (AskrenebiaschannelResponse) {}
rpc AskReneListReservations(AskrenelistreservationsRequest) returns (AskrenelistreservationsResponse) {}
rpc InjectPaymentOnion(InjectpaymentonionRequest) returns (InjectpaymentonionResponse) {}
rpc Xpay(XpayRequest) returns (XpayResponse) {}
rpc SubscribeBlockAdded(StreamBlockAddedRequest) returns (stream BlockAddedNotification) {}
rpc SubscribeChannelOpenFailed(StreamChannelOpenFailedRequest) returns (stream ChannelOpenFailedNotification) {}
@ -699,6 +721,23 @@ message EmergencyrecoverResponse {
repeated bytes stubs = 1;
}
message GetemergencyrecoverdataRequest {
}
message GetemergencyrecoverdataResponse {
bytes filedata = 1;
}
message ExposesecretRequest {
string passphrase = 1;
optional string identifier = 2;
}
message ExposesecretResponse {
string identifier = 1;
string codex32 = 2;
}
message RecoverRequest {
string hsmsecret = 1;
}
@ -1803,6 +1842,19 @@ message DisableofferResponse {
optional string label = 6;
}
message EnableofferRequest {
bytes offer_id = 1;
}
message EnableofferResponse {
bytes offer_id = 1;
bool active = 2;
bool single_use = 3;
string bolt12 = 4;
bool used = 5;
optional string label = 6;
}
message DisconnectRequest {
bytes id = 1;
optional bool force = 2;
@ -2105,6 +2157,22 @@ message GetrouteRoute {
GetrouteRouteStyle style = 6;
}
message ListaddressesRequest {
optional string address = 1;
optional uint64 start = 2;
optional uint32 limit = 3;
}
message ListaddressesResponse {
repeated ListaddressesAddresses addresses = 1;
}
message ListaddressesAddresses {
uint64 keyidx = 1;
optional string bech32 = 2;
optional string p2tr = 3;
}
message ListforwardsRequest {
// ListForwards.status
enum ListforwardsStatus {
@ -2692,6 +2760,22 @@ message Splice_updateResponse {
optional bool signatures_secured = 3;
}
message DevspliceRequest {
string script_or_json = 1;
optional bool dryrun = 2;
optional bool force_feerate = 3;
optional bool debug_log = 4;
optional bool dev_wetrun = 5;
}
message DevspliceResponse {
repeated string dryrun = 1;
optional string psbt = 2;
optional string tx = 3;
optional string txid = 4;
repeated string log = 5;
}
message UnreserveinputsRequest {
string psbt = 1;
optional uint32 reserve = 2;
@ -3540,6 +3624,72 @@ message BkprlistincomeIncome_events {
optional bytes payment_id = 10;
}
message BkpreditdescriptionbypaymentidRequest {
string payment_id = 1;
string description = 2;
}
message BkpreditdescriptionbypaymentidResponse {
repeated BkpreditdescriptionbypaymentidUpdated updated = 1;
}
message BkpreditdescriptionbypaymentidUpdated {
// Bkpr-EditDescriptionByPaymentId.updated[].type
enum BkpreditdescriptionbypaymentidUpdatedType {
CHAIN = 0;
CHANNEL = 1;
}
string account = 1;
BkpreditdescriptionbypaymentidUpdatedType item_type = 2;
string tag = 3;
Amount credit_msat = 4;
Amount debit_msat = 5;
string currency = 6;
uint32 timestamp = 7;
string description = 8;
optional string outpoint = 9;
optional uint32 blockheight = 10;
optional string origin = 11;
optional bytes payment_id = 12;
optional bytes txid = 13;
optional Amount fees_msat = 14;
optional bool is_rebalance = 15;
optional uint32 part_id = 16;
}
message BkpreditdescriptionbyoutpointRequest {
string outpoint = 1;
string description = 2;
}
message BkpreditdescriptionbyoutpointResponse {
repeated BkpreditdescriptionbyoutpointUpdated updated = 1;
}
message BkpreditdescriptionbyoutpointUpdated {
// Bkpr-EditDescriptionByOutpoint.updated[].type
enum BkpreditdescriptionbyoutpointUpdatedType {
CHAIN = 0;
CHANNEL = 1;
}
string account = 1;
BkpreditdescriptionbyoutpointUpdatedType item_type = 2;
string tag = 3;
Amount credit_msat = 4;
Amount debit_msat = 5;
string currency = 6;
uint32 timestamp = 7;
string description = 8;
optional string outpoint = 9;
optional uint32 blockheight = 10;
optional string origin = 11;
optional bytes payment_id = 12;
optional bytes txid = 13;
optional Amount fees_msat = 14;
optional bool is_rebalance = 15;
optional uint32 part_id = 16;
}
message BlacklistruneRequest {
optional uint64 start = 1;
optional uint64 end = 2;
@ -3607,6 +3757,297 @@ message ShowrunesRunesRestrictionsAlternatives {
string english = 4;
}
message AskreneunreserveRequest {
repeated AskreneunreservePath path = 1;
}
message AskreneunreserveResponse {
}
message AskreneunreservePath {
Amount amount_msat = 3;
optional string short_channel_id_dir = 4;
}
message AskrenelistlayersRequest {
optional string layer = 1;
}
message AskrenelistlayersResponse {
repeated AskrenelistlayersLayers layers = 1;
}
message AskrenelistlayersLayers {
string layer = 1;
repeated bytes disabled_nodes = 2;
repeated AskrenelistlayersLayersCreated_channels created_channels = 3;
repeated AskrenelistlayersLayersConstraints constraints = 4;
optional bool persistent = 5;
repeated string disabled_channels = 6;
repeated AskrenelistlayersLayersChannel_updates channel_updates = 7;
repeated AskrenelistlayersLayersBiases biases = 8;
}
message AskrenelistlayersLayersCreated_channels {
bytes source = 1;
bytes destination = 2;
string short_channel_id = 3;
Amount capacity_msat = 4;
}
message AskrenelistlayersLayersChannel_updates {
string short_channel_id_dir = 1;
optional bool enabled = 2;
optional Amount htlc_minimum_msat = 3;
optional Amount htlc_maximum_msat = 4;
optional Amount fee_base_msat = 5;
optional uint32 fee_proportional_millionths = 6;
optional uint32 cltv_expiry_delta = 7;
}
message AskrenelistlayersLayersConstraints {
optional Amount maximum_msat = 3;
optional Amount minimum_msat = 4;
optional string short_channel_id_dir = 5;
optional uint64 timestamp = 6;
}
message AskrenelistlayersLayersBiases {
string short_channel_id_dir = 1;
sint64 bias = 2;
optional string description = 3;
}
message AskrenecreatelayerRequest {
string layer = 1;
optional bool persistent = 2;
}
message AskrenecreatelayerResponse {
repeated AskrenecreatelayerLayers layers = 1;
}
message AskrenecreatelayerLayers {
string layer = 1;
bool persistent = 2;
repeated bytes disabled_nodes = 3;
repeated string disabled_channels = 4;
repeated AskrenecreatelayerLayersCreated_channels created_channels = 5;
repeated AskrenecreatelayerLayersChannel_updates channel_updates = 6;
repeated AskrenecreatelayerLayersConstraints constraints = 7;
repeated AskrenecreatelayerLayersBiases biases = 8;
}
message AskrenecreatelayerLayersCreated_channels {
bytes source = 1;
bytes destination = 2;
string short_channel_id = 3;
Amount capacity_msat = 4;
}
message AskrenecreatelayerLayersChannel_updates {
optional Amount htlc_minimum_msat = 1;
optional Amount htlc_maximum_msat = 2;
optional Amount fee_base_msat = 3;
optional uint32 fee_proportional_millionths = 4;
optional uint32 delay = 5;
}
message AskrenecreatelayerLayersConstraints {
string short_channel_id = 1;
uint32 direction = 2;
optional Amount maximum_msat = 3;
optional Amount minimum_msat = 4;
}
message AskrenecreatelayerLayersBiases {
string short_channel_id_dir = 1;
sint64 bias = 2;
optional string description = 3;
}
message AskreneremovelayerRequest {
string layer = 1;
}
message AskreneremovelayerResponse {
}
message AskrenereserveRequest {
repeated AskrenereservePath path = 1;
}
message AskrenereserveResponse {
}
message AskrenereservePath {
Amount amount_msat = 3;
optional string short_channel_id_dir = 4;
}
message AskreneageRequest {
string layer = 1;
uint64 cutoff = 2;
}
message AskreneageResponse {
string layer = 1;
uint64 num_removed = 2;
}
message GetroutesRequest {
bytes source = 1;
bytes destination = 2;
Amount amount_msat = 3;
repeated string layers = 4;
Amount maxfee_msat = 5;
optional uint32 final_cltv = 7;
}
message GetroutesResponse {
uint64 probability_ppm = 1;
repeated GetroutesRoutes routes = 2;
}
message GetroutesRoutes {
uint64 probability_ppm = 1;
Amount amount_msat = 2;
repeated GetroutesRoutesPath path = 3;
optional uint32 final_cltv = 4;
}
message GetroutesRoutesPath {
Amount amount_msat = 3;
bytes next_node_id = 4;
uint32 delay = 5;
optional string short_channel_id_dir = 6;
}
message AskrenedisablenodeRequest {
string layer = 1;
bytes node = 2;
}
message AskrenedisablenodeResponse {
}
message AskreneinformchannelRequest {
// AskRene-Inform-Channel.inform
enum AskreneinformchannelInform {
CONSTRAINED = 0;
UNCONSTRAINED = 1;
SUCCEEDED = 2;
}
string layer = 1;
optional string short_channel_id_dir = 6;
optional Amount amount_msat = 7;
optional AskreneinformchannelInform inform = 8;
}
message AskreneinformchannelResponse {
repeated AskreneinformchannelConstraints constraints = 2;
}
message AskreneinformchannelConstraints {
string short_channel_id_dir = 1;
string layer = 2;
uint64 timestamp = 3;
optional Amount maximum_msat = 4;
optional Amount minimum_msat = 5;
}
message AskrenecreatechannelRequest {
string layer = 1;
bytes source = 2;
bytes destination = 3;
string short_channel_id = 4;
Amount capacity_msat = 5;
}
message AskrenecreatechannelResponse {
}
message AskreneupdatechannelRequest {
string layer = 1;
string short_channel_id_dir = 2;
optional bool enabled = 3;
optional Amount htlc_minimum_msat = 4;
optional Amount htlc_maximum_msat = 5;
optional Amount fee_base_msat = 6;
optional uint32 fee_proportional_millionths = 7;
optional uint32 cltv_expiry_delta = 8;
}
message AskreneupdatechannelResponse {
}
message AskrenebiaschannelRequest {
string layer = 1;
string short_channel_id_dir = 2;
sint64 bias = 3;
optional string description = 4;
}
message AskrenebiaschannelResponse {
repeated AskrenebiaschannelBiases biases = 1;
}
message AskrenebiaschannelBiases {
string layer = 1;
string short_channel_id_dir = 2;
sint64 bias = 3;
optional string description = 4;
}
message AskrenelistreservationsRequest {
}
message AskrenelistreservationsResponse {
repeated AskrenelistreservationsReservations reservations = 1;
}
message AskrenelistreservationsReservations {
string short_channel_id_dir = 1;
Amount amount_msat = 2;
uint64 age_in_seconds = 3;
string command_id = 4;
}
message InjectpaymentonionRequest {
bytes onion = 1;
bytes payment_hash = 2;
Amount amount_msat = 3;
uint32 cltv_expiry = 4;
uint64 partid = 5;
uint64 groupid = 6;
optional string label = 7;
optional string invstring = 8;
optional bytes localinvreqid = 9;
}
message InjectpaymentonionResponse {
uint64 created_at = 1;
uint64 completed_at = 2;
uint64 created_index = 3;
}
message XpayRequest {
string invstring = 1;
optional Amount amount_msat = 2;
optional Amount maxfee = 3;
repeated string layers = 4;
optional uint32 retry_for = 5;
optional Amount partial_msat = 6;
}
message XpayResponse {
bytes payment_preimage = 1;
uint64 failed_parts = 2;
uint64 successful_parts = 3;
Amount amount_msat = 4;
Amount amount_sent_msat = 5;
}
message StreamBlockAddedRequest {
}

1014
cln-grpc/src/convert.rs generated

File diff suppressed because it is too large Load diff

View file

@ -722,6 +722,70 @@ impl Node for Server
}
async fn get_emergency_recover_data(
&self,
request: tonic::Request<pb::GetemergencyrecoverdataRequest>,
) -> Result<tonic::Response<pb::GetemergencyrecoverdataResponse>, tonic::Status> {
let req = request.into_inner();
let req: requests::GetemergencyrecoverdataRequest = req.into();
debug!("Client asked for get_emergency_recover_data");
trace!("get_emergency_recover_data request: {:?}", req);
let mut rpc = ClnRpc::new(&self.rpc_path)
.await
.map_err(|e| Status::new(Code::Internal, e.to_string()))?;
let result = rpc.call(Request::GetEmergencyRecoverData(req))
.await
.map_err(|e| Status::new(
Code::Unknown,
format!("Error calling method GetEmergencyRecoverData: {:?}", e)))?;
match result {
Response::GetEmergencyRecoverData(r) => {
trace!("get_emergency_recover_data response: {:?}", r);
Ok(tonic::Response::new(r.into()))
},
r => Err(Status::new(
Code::Internal,
format!(
"Unexpected result {:?} to method call GetEmergencyRecoverData",
r
)
)),
}
}
async fn expose_secret(
&self,
request: tonic::Request<pb::ExposesecretRequest>,
) -> Result<tonic::Response<pb::ExposesecretResponse>, tonic::Status> {
let req = request.into_inner();
let req: requests::ExposesecretRequest = req.into();
debug!("Client asked for expose_secret");
trace!("expose_secret request: {:?}", req);
let mut rpc = ClnRpc::new(&self.rpc_path)
.await
.map_err(|e| Status::new(Code::Internal, e.to_string()))?;
let result = rpc.call(Request::ExposeSecret(req))
.await
.map_err(|e| Status::new(
Code::Unknown,
format!("Error calling method ExposeSecret: {:?}", e)))?;
match result {
Response::ExposeSecret(r) => {
trace!("expose_secret response: {:?}", r);
Ok(tonic::Response::new(r.into()))
},
r => Err(Status::new(
Code::Internal,
format!(
"Unexpected result {:?} to method call ExposeSecret",
r
)
)),
}
}
async fn recover(
&self,
request: tonic::Request<pb::RecoverRequest>,
@ -1810,6 +1874,38 @@ impl Node for Server
}
async fn enable_offer(
&self,
request: tonic::Request<pb::EnableofferRequest>,
) -> Result<tonic::Response<pb::EnableofferResponse>, tonic::Status> {
let req = request.into_inner();
let req: requests::EnableofferRequest = req.into();
debug!("Client asked for enable_offer");
trace!("enable_offer request: {:?}", req);
let mut rpc = ClnRpc::new(&self.rpc_path)
.await
.map_err(|e| Status::new(Code::Internal, e.to_string()))?;
let result = rpc.call(Request::EnableOffer(req))
.await
.map_err(|e| Status::new(
Code::Unknown,
format!("Error calling method EnableOffer: {:?}", e)))?;
match result {
Response::EnableOffer(r) => {
trace!("enable_offer response: {:?}", r);
Ok(tonic::Response::new(r.into()))
},
r => Err(Status::new(
Code::Internal,
format!(
"Unexpected result {:?} to method call EnableOffer",
r
)
)),
}
}
async fn disconnect(
&self,
request: tonic::Request<pb::DisconnectRequest>,
@ -2130,6 +2226,38 @@ impl Node for Server
}
async fn list_addresses(
&self,
request: tonic::Request<pb::ListaddressesRequest>,
) -> Result<tonic::Response<pb::ListaddressesResponse>, tonic::Status> {
let req = request.into_inner();
let req: requests::ListaddressesRequest = req.into();
debug!("Client asked for list_addresses");
trace!("list_addresses request: {:?}", req);
let mut rpc = ClnRpc::new(&self.rpc_path)
.await
.map_err(|e| Status::new(Code::Internal, e.to_string()))?;
let result = rpc.call(Request::ListAddresses(req))
.await
.map_err(|e| Status::new(
Code::Unknown,
format!("Error calling method ListAddresses: {:?}", e)))?;
match result {
Response::ListAddresses(r) => {
trace!("list_addresses response: {:?}", r);
Ok(tonic::Response::new(r.into()))
},
r => Err(Status::new(
Code::Internal,
format!(
"Unexpected result {:?} to method call ListAddresses",
r
)
)),
}
}
async fn list_forwards(
&self,
request: tonic::Request<pb::ListforwardsRequest>,
@ -2994,6 +3122,38 @@ impl Node for Server
}
async fn dev_splice(
&self,
request: tonic::Request<pb::DevspliceRequest>,
) -> Result<tonic::Response<pb::DevspliceResponse>, tonic::Status> {
let req = request.into_inner();
let req: requests::DevspliceRequest = req.into();
debug!("Client asked for dev_splice");
trace!("dev_splice request: {:?}", req);
let mut rpc = ClnRpc::new(&self.rpc_path)
.await
.map_err(|e| Status::new(Code::Internal, e.to_string()))?;
let result = rpc.call(Request::DevSplice(req))
.await
.map_err(|e| Status::new(
Code::Unknown,
format!("Error calling method DevSplice: {:?}", e)))?;
match result {
Response::DevSplice(r) => {
trace!("dev_splice response: {:?}", r);
Ok(tonic::Response::new(r.into()))
},
r => Err(Status::new(
Code::Internal,
format!(
"Unexpected result {:?} to method call DevSplice",
r
)
)),
}
}
async fn unreserve_inputs(
&self,
request: tonic::Request<pb::UnreserveinputsRequest>,
@ -3506,6 +3666,70 @@ impl Node for Server
}
async fn bkpr_edit_description_by_payment_id(
&self,
request: tonic::Request<pb::BkpreditdescriptionbypaymentidRequest>,
) -> Result<tonic::Response<pb::BkpreditdescriptionbypaymentidResponse>, tonic::Status> {
let req = request.into_inner();
let req: requests::BkpreditdescriptionbypaymentidRequest = req.into();
debug!("Client asked for bkpr_edit_description_by_payment_id");
trace!("bkpr_edit_description_by_payment_id request: {:?}", req);
let mut rpc = ClnRpc::new(&self.rpc_path)
.await
.map_err(|e| Status::new(Code::Internal, e.to_string()))?;
let result = rpc.call(Request::BkprEditDescriptionByPaymentId(req))
.await
.map_err(|e| Status::new(
Code::Unknown,
format!("Error calling method BkprEditDescriptionByPaymentId: {:?}", e)))?;
match result {
Response::BkprEditDescriptionByPaymentId(r) => {
trace!("bkpr_edit_description_by_payment_id response: {:?}", r);
Ok(tonic::Response::new(r.into()))
},
r => Err(Status::new(
Code::Internal,
format!(
"Unexpected result {:?} to method call BkprEditDescriptionByPaymentId",
r
)
)),
}
}
async fn bkpr_edit_description_by_outpoint(
&self,
request: tonic::Request<pb::BkpreditdescriptionbyoutpointRequest>,
) -> Result<tonic::Response<pb::BkpreditdescriptionbyoutpointResponse>, tonic::Status> {
let req = request.into_inner();
let req: requests::BkpreditdescriptionbyoutpointRequest = req.into();
debug!("Client asked for bkpr_edit_description_by_outpoint");
trace!("bkpr_edit_description_by_outpoint request: {:?}", req);
let mut rpc = ClnRpc::new(&self.rpc_path)
.await
.map_err(|e| Status::new(Code::Internal, e.to_string()))?;
let result = rpc.call(Request::BkprEditDescriptionByOutpoint(req))
.await
.map_err(|e| Status::new(
Code::Unknown,
format!("Error calling method BkprEditDescriptionByOutpoint: {:?}", e)))?;
match result {
Response::BkprEditDescriptionByOutpoint(r) => {
trace!("bkpr_edit_description_by_outpoint response: {:?}", r);
Ok(tonic::Response::new(r.into()))
},
r => Err(Status::new(
Code::Internal,
format!(
"Unexpected result {:?} to method call BkprEditDescriptionByOutpoint",
r
)
)),
}
}
async fn blacklist_rune(
&self,
request: tonic::Request<pb::BlacklistruneRequest>,
@ -3634,6 +3858,486 @@ impl Node for Server
}
async fn ask_rene_unreserve(
&self,
request: tonic::Request<pb::AskreneunreserveRequest>,
) -> Result<tonic::Response<pb::AskreneunreserveResponse>, tonic::Status> {
let req = request.into_inner();
let req: requests::AskreneunreserveRequest = req.into();
debug!("Client asked for ask_rene_unreserve");
trace!("ask_rene_unreserve request: {:?}", req);
let mut rpc = ClnRpc::new(&self.rpc_path)
.await
.map_err(|e| Status::new(Code::Internal, e.to_string()))?;
let result = rpc.call(Request::AskReneUnreserve(req))
.await
.map_err(|e| Status::new(
Code::Unknown,
format!("Error calling method AskReneUnreserve: {:?}", e)))?;
match result {
Response::AskReneUnreserve(r) => {
trace!("ask_rene_unreserve response: {:?}", r);
Ok(tonic::Response::new(r.into()))
},
r => Err(Status::new(
Code::Internal,
format!(
"Unexpected result {:?} to method call AskReneUnreserve",
r
)
)),
}
}
async fn ask_rene_list_layers(
&self,
request: tonic::Request<pb::AskrenelistlayersRequest>,
) -> Result<tonic::Response<pb::AskrenelistlayersResponse>, tonic::Status> {
let req = request.into_inner();
let req: requests::AskrenelistlayersRequest = req.into();
debug!("Client asked for ask_rene_list_layers");
trace!("ask_rene_list_layers request: {:?}", req);
let mut rpc = ClnRpc::new(&self.rpc_path)
.await
.map_err(|e| Status::new(Code::Internal, e.to_string()))?;
let result = rpc.call(Request::AskReneListLayers(req))
.await
.map_err(|e| Status::new(
Code::Unknown,
format!("Error calling method AskReneListLayers: {:?}", e)))?;
match result {
Response::AskReneListLayers(r) => {
trace!("ask_rene_list_layers response: {:?}", r);
Ok(tonic::Response::new(r.into()))
},
r => Err(Status::new(
Code::Internal,
format!(
"Unexpected result {:?} to method call AskReneListLayers",
r
)
)),
}
}
async fn ask_rene_create_layer(
&self,
request: tonic::Request<pb::AskrenecreatelayerRequest>,
) -> Result<tonic::Response<pb::AskrenecreatelayerResponse>, tonic::Status> {
let req = request.into_inner();
let req: requests::AskrenecreatelayerRequest = req.into();
debug!("Client asked for ask_rene_create_layer");
trace!("ask_rene_create_layer request: {:?}", req);
let mut rpc = ClnRpc::new(&self.rpc_path)
.await
.map_err(|e| Status::new(Code::Internal, e.to_string()))?;
let result = rpc.call(Request::AskReneCreateLayer(req))
.await
.map_err(|e| Status::new(
Code::Unknown,
format!("Error calling method AskReneCreateLayer: {:?}", e)))?;
match result {
Response::AskReneCreateLayer(r) => {
trace!("ask_rene_create_layer response: {:?}", r);
Ok(tonic::Response::new(r.into()))
},
r => Err(Status::new(
Code::Internal,
format!(
"Unexpected result {:?} to method call AskReneCreateLayer",
r
)
)),
}
}
async fn ask_rene_remove_layer(
&self,
request: tonic::Request<pb::AskreneremovelayerRequest>,
) -> Result<tonic::Response<pb::AskreneremovelayerResponse>, tonic::Status> {
let req = request.into_inner();
let req: requests::AskreneremovelayerRequest = req.into();
debug!("Client asked for ask_rene_remove_layer");
trace!("ask_rene_remove_layer request: {:?}", req);
let mut rpc = ClnRpc::new(&self.rpc_path)
.await
.map_err(|e| Status::new(Code::Internal, e.to_string()))?;
let result = rpc.call(Request::AskReneRemoveLayer(req))
.await
.map_err(|e| Status::new(
Code::Unknown,
format!("Error calling method AskReneRemoveLayer: {:?}", e)))?;
match result {
Response::AskReneRemoveLayer(r) => {
trace!("ask_rene_remove_layer response: {:?}", r);
Ok(tonic::Response::new(r.into()))
},
r => Err(Status::new(
Code::Internal,
format!(
"Unexpected result {:?} to method call AskReneRemoveLayer",
r
)
)),
}
}
async fn ask_rene_reserve(
&self,
request: tonic::Request<pb::AskrenereserveRequest>,
) -> Result<tonic::Response<pb::AskrenereserveResponse>, tonic::Status> {
let req = request.into_inner();
let req: requests::AskrenereserveRequest = req.into();
debug!("Client asked for ask_rene_reserve");
trace!("ask_rene_reserve request: {:?}", req);
let mut rpc = ClnRpc::new(&self.rpc_path)
.await
.map_err(|e| Status::new(Code::Internal, e.to_string()))?;
let result = rpc.call(Request::AskReneReserve(req))
.await
.map_err(|e| Status::new(
Code::Unknown,
format!("Error calling method AskReneReserve: {:?}", e)))?;
match result {
Response::AskReneReserve(r) => {
trace!("ask_rene_reserve response: {:?}", r);
Ok(tonic::Response::new(r.into()))
},
r => Err(Status::new(
Code::Internal,
format!(
"Unexpected result {:?} to method call AskReneReserve",
r
)
)),
}
}
async fn ask_rene_age(
&self,
request: tonic::Request<pb::AskreneageRequest>,
) -> Result<tonic::Response<pb::AskreneageResponse>, tonic::Status> {
let req = request.into_inner();
let req: requests::AskreneageRequest = req.into();
debug!("Client asked for ask_rene_age");
trace!("ask_rene_age request: {:?}", req);
let mut rpc = ClnRpc::new(&self.rpc_path)
.await
.map_err(|e| Status::new(Code::Internal, e.to_string()))?;
let result = rpc.call(Request::AskReneAge(req))
.await
.map_err(|e| Status::new(
Code::Unknown,
format!("Error calling method AskReneAge: {:?}", e)))?;
match result {
Response::AskReneAge(r) => {
trace!("ask_rene_age response: {:?}", r);
Ok(tonic::Response::new(r.into()))
},
r => Err(Status::new(
Code::Internal,
format!(
"Unexpected result {:?} to method call AskReneAge",
r
)
)),
}
}
async fn get_routes(
&self,
request: tonic::Request<pb::GetroutesRequest>,
) -> Result<tonic::Response<pb::GetroutesResponse>, tonic::Status> {
let req = request.into_inner();
let req: requests::GetroutesRequest = req.into();
debug!("Client asked for get_routes");
trace!("get_routes request: {:?}", req);
let mut rpc = ClnRpc::new(&self.rpc_path)
.await
.map_err(|e| Status::new(Code::Internal, e.to_string()))?;
let result = rpc.call(Request::GetRoutes(req))
.await
.map_err(|e| Status::new(
Code::Unknown,
format!("Error calling method GetRoutes: {:?}", e)))?;
match result {
Response::GetRoutes(r) => {
trace!("get_routes response: {:?}", r);
Ok(tonic::Response::new(r.into()))
},
r => Err(Status::new(
Code::Internal,
format!(
"Unexpected result {:?} to method call GetRoutes",
r
)
)),
}
}
async fn ask_rene_disable_node(
&self,
request: tonic::Request<pb::AskrenedisablenodeRequest>,
) -> Result<tonic::Response<pb::AskrenedisablenodeResponse>, tonic::Status> {
let req = request.into_inner();
let req: requests::AskrenedisablenodeRequest = req.into();
debug!("Client asked for ask_rene_disable_node");
trace!("ask_rene_disable_node request: {:?}", req);
let mut rpc = ClnRpc::new(&self.rpc_path)
.await
.map_err(|e| Status::new(Code::Internal, e.to_string()))?;
let result = rpc.call(Request::AskReneDisableNode(req))
.await
.map_err(|e| Status::new(
Code::Unknown,
format!("Error calling method AskReneDisableNode: {:?}", e)))?;
match result {
Response::AskReneDisableNode(r) => {
trace!("ask_rene_disable_node response: {:?}", r);
Ok(tonic::Response::new(r.into()))
},
r => Err(Status::new(
Code::Internal,
format!(
"Unexpected result {:?} to method call AskReneDisableNode",
r
)
)),
}
}
async fn ask_rene_inform_channel(
&self,
request: tonic::Request<pb::AskreneinformchannelRequest>,
) -> Result<tonic::Response<pb::AskreneinformchannelResponse>, tonic::Status> {
let req = request.into_inner();
let req: requests::AskreneinformchannelRequest = req.into();
debug!("Client asked for ask_rene_inform_channel");
trace!("ask_rene_inform_channel request: {:?}", req);
let mut rpc = ClnRpc::new(&self.rpc_path)
.await
.map_err(|e| Status::new(Code::Internal, e.to_string()))?;
let result = rpc.call(Request::AskReneInformChannel(req))
.await
.map_err(|e| Status::new(
Code::Unknown,
format!("Error calling method AskReneInformChannel: {:?}", e)))?;
match result {
Response::AskReneInformChannel(r) => {
trace!("ask_rene_inform_channel response: {:?}", r);
Ok(tonic::Response::new(r.into()))
},
r => Err(Status::new(
Code::Internal,
format!(
"Unexpected result {:?} to method call AskReneInformChannel",
r
)
)),
}
}
async fn ask_rene_create_channel(
&self,
request: tonic::Request<pb::AskrenecreatechannelRequest>,
) -> Result<tonic::Response<pb::AskrenecreatechannelResponse>, tonic::Status> {
let req = request.into_inner();
let req: requests::AskrenecreatechannelRequest = req.into();
debug!("Client asked for ask_rene_create_channel");
trace!("ask_rene_create_channel request: {:?}", req);
let mut rpc = ClnRpc::new(&self.rpc_path)
.await
.map_err(|e| Status::new(Code::Internal, e.to_string()))?;
let result = rpc.call(Request::AskReneCreateChannel(req))
.await
.map_err(|e| Status::new(
Code::Unknown,
format!("Error calling method AskReneCreateChannel: {:?}", e)))?;
match result {
Response::AskReneCreateChannel(r) => {
trace!("ask_rene_create_channel response: {:?}", r);
Ok(tonic::Response::new(r.into()))
},
r => Err(Status::new(
Code::Internal,
format!(
"Unexpected result {:?} to method call AskReneCreateChannel",
r
)
)),
}
}
async fn ask_rene_update_channel(
&self,
request: tonic::Request<pb::AskreneupdatechannelRequest>,
) -> Result<tonic::Response<pb::AskreneupdatechannelResponse>, tonic::Status> {
let req = request.into_inner();
let req: requests::AskreneupdatechannelRequest = req.into();
debug!("Client asked for ask_rene_update_channel");
trace!("ask_rene_update_channel request: {:?}", req);
let mut rpc = ClnRpc::new(&self.rpc_path)
.await
.map_err(|e| Status::new(Code::Internal, e.to_string()))?;
let result = rpc.call(Request::AskReneUpdateChannel(req))
.await
.map_err(|e| Status::new(
Code::Unknown,
format!("Error calling method AskReneUpdateChannel: {:?}", e)))?;
match result {
Response::AskReneUpdateChannel(r) => {
trace!("ask_rene_update_channel response: {:?}", r);
Ok(tonic::Response::new(r.into()))
},
r => Err(Status::new(
Code::Internal,
format!(
"Unexpected result {:?} to method call AskReneUpdateChannel",
r
)
)),
}
}
async fn ask_rene_bias_channel(
&self,
request: tonic::Request<pb::AskrenebiaschannelRequest>,
) -> Result<tonic::Response<pb::AskrenebiaschannelResponse>, tonic::Status> {
let req = request.into_inner();
let req: requests::AskrenebiaschannelRequest = req.into();
debug!("Client asked for ask_rene_bias_channel");
trace!("ask_rene_bias_channel request: {:?}", req);
let mut rpc = ClnRpc::new(&self.rpc_path)
.await
.map_err(|e| Status::new(Code::Internal, e.to_string()))?;
let result = rpc.call(Request::AskReneBiasChannel(req))
.await
.map_err(|e| Status::new(
Code::Unknown,
format!("Error calling method AskReneBiasChannel: {:?}", e)))?;
match result {
Response::AskReneBiasChannel(r) => {
trace!("ask_rene_bias_channel response: {:?}", r);
Ok(tonic::Response::new(r.into()))
},
r => Err(Status::new(
Code::Internal,
format!(
"Unexpected result {:?} to method call AskReneBiasChannel",
r
)
)),
}
}
async fn ask_rene_list_reservations(
&self,
request: tonic::Request<pb::AskrenelistreservationsRequest>,
) -> Result<tonic::Response<pb::AskrenelistreservationsResponse>, tonic::Status> {
let req = request.into_inner();
let req: requests::AskrenelistreservationsRequest = req.into();
debug!("Client asked for ask_rene_list_reservations");
trace!("ask_rene_list_reservations request: {:?}", req);
let mut rpc = ClnRpc::new(&self.rpc_path)
.await
.map_err(|e| Status::new(Code::Internal, e.to_string()))?;
let result = rpc.call(Request::AskReneListReservations(req))
.await
.map_err(|e| Status::new(
Code::Unknown,
format!("Error calling method AskReneListReservations: {:?}", e)))?;
match result {
Response::AskReneListReservations(r) => {
trace!("ask_rene_list_reservations response: {:?}", r);
Ok(tonic::Response::new(r.into()))
},
r => Err(Status::new(
Code::Internal,
format!(
"Unexpected result {:?} to method call AskReneListReservations",
r
)
)),
}
}
async fn inject_payment_onion(
&self,
request: tonic::Request<pb::InjectpaymentonionRequest>,
) -> Result<tonic::Response<pb::InjectpaymentonionResponse>, tonic::Status> {
let req = request.into_inner();
let req: requests::InjectpaymentonionRequest = req.into();
debug!("Client asked for inject_payment_onion");
trace!("inject_payment_onion request: {:?}", req);
let mut rpc = ClnRpc::new(&self.rpc_path)
.await
.map_err(|e| Status::new(Code::Internal, e.to_string()))?;
let result = rpc.call(Request::InjectPaymentOnion(req))
.await
.map_err(|e| Status::new(
Code::Unknown,
format!("Error calling method InjectPaymentOnion: {:?}", e)))?;
match result {
Response::InjectPaymentOnion(r) => {
trace!("inject_payment_onion response: {:?}", r);
Ok(tonic::Response::new(r.into()))
},
r => Err(Status::new(
Code::Internal,
format!(
"Unexpected result {:?} to method call InjectPaymentOnion",
r
)
)),
}
}
async fn xpay(
&self,
request: tonic::Request<pb::XpayRequest>,
) -> Result<tonic::Response<pb::XpayResponse>, tonic::Status> {
let req = request.into_inner();
let req: requests::XpayRequest = req.into();
debug!("Client asked for xpay");
trace!("xpay request: {:?}", req);
let mut rpc = ClnRpc::new(&self.rpc_path)
.await
.map_err(|e| Status::new(Code::Internal, e.to_string()))?;
let result = rpc.call(Request::Xpay(req))
.await
.map_err(|e| Status::new(
Code::Unknown,
format!("Error calling method Xpay: {:?}", e)))?;
match result {
Response::Xpay(r) => {
trace!("xpay response: {:?}", r);
Ok(tonic::Response::new(r.into()))
},
r => Err(Status::new(
Code::Internal,
format!(
"Unexpected result {:?} to method call Xpay",
r
)
)),
}
}
type SubscribeBlockAddedStream = NotificationStream<pb::BlockAddedNotification>;

1339
cln-rpc/src/model.rs generated

File diff suppressed because it is too large Load diff

View file

@ -26,6 +26,8 @@ grpc_method_names = [
"DelInvoice",
"Dev-Forget-Channel",
"EmergencyRecover",
"GetEmergencyRecoverData",
"ExposeSecret",
"Recover",
"RecoverChannel",
"Invoice",
@ -60,6 +62,7 @@ grpc_method_names = [
"DelPay",
"DelForward",
"DisableOffer",
"EnableOffer",
"Disconnect",
"Feerates",
"FetchInvoice",
@ -70,6 +73,7 @@ grpc_method_names = [
"GetLog",
"FunderUpdate",
"GetRoute",
"ListAddresses",
"ListForwards",
"ListOffers",
"ListPays",
@ -98,6 +102,7 @@ grpc_method_names = [
"Splice_Init",
"Splice_Signed",
"Splice_Update",
"Dev-Splice",
"UnreserveInputs",
"UpgradeWallet",
"WaitBlockHeight",
@ -116,10 +121,27 @@ grpc_method_names = [
"Bkpr-ListAccountEvents",
"Bkpr-ListBalances",
"Bkpr-ListIncome",
"Bkpr-EditDescriptionByPaymentId",
"Bkpr-EditDescriptionByOutpoint",
"BlacklistRune",
"CheckRune",
"CreateRune",
"ShowRunes",
"AskRene-Unreserve",
"AskRene-ListLayers",
"AskRene-Create-Layer",
"AskRene-Remove-Layer",
"AskRene-Reserve",
"AskRene-Age",
"GetRoutes",
"AskRene-Disable-Node",
"AskRene-Inform-Channel",
"AskRene-Create-Channel",
"AskRene-Update-Channel",
"AskRene-Bias-Channel",
"AskRene-ListReservations",
"InjectPaymentOnion",
"Xpay",
]
grpc_notification_names = [

File diff suppressed because one or more lines are too long

View file

@ -114,6 +114,16 @@ class NodeStub(object):
request_serializer=node__pb2.EmergencyrecoverRequest.SerializeToString,
response_deserializer=node__pb2.EmergencyrecoverResponse.FromString,
)
self.GetEmergencyRecoverData = channel.unary_unary(
'/cln.Node/GetEmergencyRecoverData',
request_serializer=node__pb2.GetemergencyrecoverdataRequest.SerializeToString,
response_deserializer=node__pb2.GetemergencyrecoverdataResponse.FromString,
)
self.ExposeSecret = channel.unary_unary(
'/cln.Node/ExposeSecret',
request_serializer=node__pb2.ExposesecretRequest.SerializeToString,
response_deserializer=node__pb2.ExposesecretResponse.FromString,
)
self.Recover = channel.unary_unary(
'/cln.Node/Recover',
request_serializer=node__pb2.RecoverRequest.SerializeToString,
@ -284,6 +294,11 @@ class NodeStub(object):
request_serializer=node__pb2.DisableofferRequest.SerializeToString,
response_deserializer=node__pb2.DisableofferResponse.FromString,
)
self.EnableOffer = channel.unary_unary(
'/cln.Node/EnableOffer',
request_serializer=node__pb2.EnableofferRequest.SerializeToString,
response_deserializer=node__pb2.EnableofferResponse.FromString,
)
self.Disconnect = channel.unary_unary(
'/cln.Node/Disconnect',
request_serializer=node__pb2.DisconnectRequest.SerializeToString,
@ -334,6 +349,11 @@ class NodeStub(object):
request_serializer=node__pb2.GetrouteRequest.SerializeToString,
response_deserializer=node__pb2.GetrouteResponse.FromString,
)
self.ListAddresses = channel.unary_unary(
'/cln.Node/ListAddresses',
request_serializer=node__pb2.ListaddressesRequest.SerializeToString,
response_deserializer=node__pb2.ListaddressesResponse.FromString,
)
self.ListForwards = channel.unary_unary(
'/cln.Node/ListForwards',
request_serializer=node__pb2.ListforwardsRequest.SerializeToString,
@ -469,6 +489,11 @@ class NodeStub(object):
request_serializer=node__pb2.Splice_updateRequest.SerializeToString,
response_deserializer=node__pb2.Splice_updateResponse.FromString,
)
self.DevSplice = channel.unary_unary(
'/cln.Node/DevSplice',
request_serializer=node__pb2.DevspliceRequest.SerializeToString,
response_deserializer=node__pb2.DevspliceResponse.FromString,
)
self.UnreserveInputs = channel.unary_unary(
'/cln.Node/UnreserveInputs',
request_serializer=node__pb2.UnreserveinputsRequest.SerializeToString,
@ -549,6 +574,16 @@ class NodeStub(object):
request_serializer=node__pb2.BkprlistincomeRequest.SerializeToString,
response_deserializer=node__pb2.BkprlistincomeResponse.FromString,
)
self.BkprEditDescriptionByPaymentId = channel.unary_unary(
'/cln.Node/BkprEditDescriptionByPaymentId',
request_serializer=node__pb2.BkpreditdescriptionbypaymentidRequest.SerializeToString,
response_deserializer=node__pb2.BkpreditdescriptionbypaymentidResponse.FromString,
)
self.BkprEditDescriptionByOutpoint = channel.unary_unary(
'/cln.Node/BkprEditDescriptionByOutpoint',
request_serializer=node__pb2.BkpreditdescriptionbyoutpointRequest.SerializeToString,
response_deserializer=node__pb2.BkpreditdescriptionbyoutpointResponse.FromString,
)
self.BlacklistRune = channel.unary_unary(
'/cln.Node/BlacklistRune',
request_serializer=node__pb2.BlacklistruneRequest.SerializeToString,
@ -569,6 +604,81 @@ class NodeStub(object):
request_serializer=node__pb2.ShowrunesRequest.SerializeToString,
response_deserializer=node__pb2.ShowrunesResponse.FromString,
)
self.AskReneUnreserve = channel.unary_unary(
'/cln.Node/AskReneUnreserve',
request_serializer=node__pb2.AskreneunreserveRequest.SerializeToString,
response_deserializer=node__pb2.AskreneunreserveResponse.FromString,
)
self.AskReneListLayers = channel.unary_unary(
'/cln.Node/AskReneListLayers',
request_serializer=node__pb2.AskrenelistlayersRequest.SerializeToString,
response_deserializer=node__pb2.AskrenelistlayersResponse.FromString,
)
self.AskReneCreateLayer = channel.unary_unary(
'/cln.Node/AskReneCreateLayer',
request_serializer=node__pb2.AskrenecreatelayerRequest.SerializeToString,
response_deserializer=node__pb2.AskrenecreatelayerResponse.FromString,
)
self.AskReneRemoveLayer = channel.unary_unary(
'/cln.Node/AskReneRemoveLayer',
request_serializer=node__pb2.AskreneremovelayerRequest.SerializeToString,
response_deserializer=node__pb2.AskreneremovelayerResponse.FromString,
)
self.AskReneReserve = channel.unary_unary(
'/cln.Node/AskReneReserve',
request_serializer=node__pb2.AskrenereserveRequest.SerializeToString,
response_deserializer=node__pb2.AskrenereserveResponse.FromString,
)
self.AskReneAge = channel.unary_unary(
'/cln.Node/AskReneAge',
request_serializer=node__pb2.AskreneageRequest.SerializeToString,
response_deserializer=node__pb2.AskreneageResponse.FromString,
)
self.GetRoutes = channel.unary_unary(
'/cln.Node/GetRoutes',
request_serializer=node__pb2.GetroutesRequest.SerializeToString,
response_deserializer=node__pb2.GetroutesResponse.FromString,
)
self.AskReneDisableNode = channel.unary_unary(
'/cln.Node/AskReneDisableNode',
request_serializer=node__pb2.AskrenedisablenodeRequest.SerializeToString,
response_deserializer=node__pb2.AskrenedisablenodeResponse.FromString,
)
self.AskReneInformChannel = channel.unary_unary(
'/cln.Node/AskReneInformChannel',
request_serializer=node__pb2.AskreneinformchannelRequest.SerializeToString,
response_deserializer=node__pb2.AskreneinformchannelResponse.FromString,
)
self.AskReneCreateChannel = channel.unary_unary(
'/cln.Node/AskReneCreateChannel',
request_serializer=node__pb2.AskrenecreatechannelRequest.SerializeToString,
response_deserializer=node__pb2.AskrenecreatechannelResponse.FromString,
)
self.AskReneUpdateChannel = channel.unary_unary(
'/cln.Node/AskReneUpdateChannel',
request_serializer=node__pb2.AskreneupdatechannelRequest.SerializeToString,
response_deserializer=node__pb2.AskreneupdatechannelResponse.FromString,
)
self.AskReneBiasChannel = channel.unary_unary(
'/cln.Node/AskReneBiasChannel',
request_serializer=node__pb2.AskrenebiaschannelRequest.SerializeToString,
response_deserializer=node__pb2.AskrenebiaschannelResponse.FromString,
)
self.AskReneListReservations = channel.unary_unary(
'/cln.Node/AskReneListReservations',
request_serializer=node__pb2.AskrenelistreservationsRequest.SerializeToString,
response_deserializer=node__pb2.AskrenelistreservationsResponse.FromString,
)
self.InjectPaymentOnion = channel.unary_unary(
'/cln.Node/InjectPaymentOnion',
request_serializer=node__pb2.InjectpaymentonionRequest.SerializeToString,
response_deserializer=node__pb2.InjectpaymentonionResponse.FromString,
)
self.Xpay = channel.unary_unary(
'/cln.Node/Xpay',
request_serializer=node__pb2.XpayRequest.SerializeToString,
response_deserializer=node__pb2.XpayResponse.FromString,
)
self.SubscribeBlockAdded = channel.unary_stream(
'/cln.Node/SubscribeBlockAdded',
request_serializer=node__pb2.StreamBlockAddedRequest.SerializeToString,
@ -719,6 +829,18 @@ class NodeServicer(object):
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def GetEmergencyRecoverData(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def ExposeSecret(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def Recover(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
@ -923,6 +1045,12 @@ class NodeServicer(object):
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def EnableOffer(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def Disconnect(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
@ -983,6 +1111,12 @@ class NodeServicer(object):
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def ListAddresses(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def ListForwards(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
@ -1145,6 +1279,12 @@ class NodeServicer(object):
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def DevSplice(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def UnreserveInputs(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
@ -1241,6 +1381,18 @@ class NodeServicer(object):
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def BkprEditDescriptionByPaymentId(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def BkprEditDescriptionByOutpoint(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def BlacklistRune(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
@ -1265,6 +1417,96 @@ class NodeServicer(object):
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def AskReneUnreserve(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def AskReneListLayers(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def AskReneCreateLayer(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def AskReneRemoveLayer(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def AskReneReserve(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def AskReneAge(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def GetRoutes(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def AskReneDisableNode(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def AskReneInformChannel(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def AskReneCreateChannel(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def AskReneUpdateChannel(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def AskReneBiasChannel(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def AskReneListReservations(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def InjectPaymentOnion(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def Xpay(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
def SubscribeBlockAdded(self, request, context):
"""Missing associated documentation comment in .proto file."""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
@ -1398,6 +1640,16 @@ def add_NodeServicer_to_server(servicer, server):
request_deserializer=node__pb2.EmergencyrecoverRequest.FromString,
response_serializer=node__pb2.EmergencyrecoverResponse.SerializeToString,
),
'GetEmergencyRecoverData': grpc.unary_unary_rpc_method_handler(
servicer.GetEmergencyRecoverData,
request_deserializer=node__pb2.GetemergencyrecoverdataRequest.FromString,
response_serializer=node__pb2.GetemergencyrecoverdataResponse.SerializeToString,
),
'ExposeSecret': grpc.unary_unary_rpc_method_handler(
servicer.ExposeSecret,
request_deserializer=node__pb2.ExposesecretRequest.FromString,
response_serializer=node__pb2.ExposesecretResponse.SerializeToString,
),
'Recover': grpc.unary_unary_rpc_method_handler(
servicer.Recover,
request_deserializer=node__pb2.RecoverRequest.FromString,
@ -1568,6 +1820,11 @@ def add_NodeServicer_to_server(servicer, server):
request_deserializer=node__pb2.DisableofferRequest.FromString,
response_serializer=node__pb2.DisableofferResponse.SerializeToString,
),
'EnableOffer': grpc.unary_unary_rpc_method_handler(
servicer.EnableOffer,
request_deserializer=node__pb2.EnableofferRequest.FromString,
response_serializer=node__pb2.EnableofferResponse.SerializeToString,
),
'Disconnect': grpc.unary_unary_rpc_method_handler(
servicer.Disconnect,
request_deserializer=node__pb2.DisconnectRequest.FromString,
@ -1618,6 +1875,11 @@ def add_NodeServicer_to_server(servicer, server):
request_deserializer=node__pb2.GetrouteRequest.FromString,
response_serializer=node__pb2.GetrouteResponse.SerializeToString,
),
'ListAddresses': grpc.unary_unary_rpc_method_handler(
servicer.ListAddresses,
request_deserializer=node__pb2.ListaddressesRequest.FromString,
response_serializer=node__pb2.ListaddressesResponse.SerializeToString,
),
'ListForwards': grpc.unary_unary_rpc_method_handler(
servicer.ListForwards,
request_deserializer=node__pb2.ListforwardsRequest.FromString,
@ -1753,6 +2015,11 @@ def add_NodeServicer_to_server(servicer, server):
request_deserializer=node__pb2.Splice_updateRequest.FromString,
response_serializer=node__pb2.Splice_updateResponse.SerializeToString,
),
'DevSplice': grpc.unary_unary_rpc_method_handler(
servicer.DevSplice,
request_deserializer=node__pb2.DevspliceRequest.FromString,
response_serializer=node__pb2.DevspliceResponse.SerializeToString,
),
'UnreserveInputs': grpc.unary_unary_rpc_method_handler(
servicer.UnreserveInputs,
request_deserializer=node__pb2.UnreserveinputsRequest.FromString,
@ -1833,6 +2100,16 @@ def add_NodeServicer_to_server(servicer, server):
request_deserializer=node__pb2.BkprlistincomeRequest.FromString,
response_serializer=node__pb2.BkprlistincomeResponse.SerializeToString,
),
'BkprEditDescriptionByPaymentId': grpc.unary_unary_rpc_method_handler(
servicer.BkprEditDescriptionByPaymentId,
request_deserializer=node__pb2.BkpreditdescriptionbypaymentidRequest.FromString,
response_serializer=node__pb2.BkpreditdescriptionbypaymentidResponse.SerializeToString,
),
'BkprEditDescriptionByOutpoint': grpc.unary_unary_rpc_method_handler(
servicer.BkprEditDescriptionByOutpoint,
request_deserializer=node__pb2.BkpreditdescriptionbyoutpointRequest.FromString,
response_serializer=node__pb2.BkpreditdescriptionbyoutpointResponse.SerializeToString,
),
'BlacklistRune': grpc.unary_unary_rpc_method_handler(
servicer.BlacklistRune,
request_deserializer=node__pb2.BlacklistruneRequest.FromString,
@ -1853,6 +2130,81 @@ def add_NodeServicer_to_server(servicer, server):
request_deserializer=node__pb2.ShowrunesRequest.FromString,
response_serializer=node__pb2.ShowrunesResponse.SerializeToString,
),
'AskReneUnreserve': grpc.unary_unary_rpc_method_handler(
servicer.AskReneUnreserve,
request_deserializer=node__pb2.AskreneunreserveRequest.FromString,
response_serializer=node__pb2.AskreneunreserveResponse.SerializeToString,
),
'AskReneListLayers': grpc.unary_unary_rpc_method_handler(
servicer.AskReneListLayers,
request_deserializer=node__pb2.AskrenelistlayersRequest.FromString,
response_serializer=node__pb2.AskrenelistlayersResponse.SerializeToString,
),
'AskReneCreateLayer': grpc.unary_unary_rpc_method_handler(
servicer.AskReneCreateLayer,
request_deserializer=node__pb2.AskrenecreatelayerRequest.FromString,
response_serializer=node__pb2.AskrenecreatelayerResponse.SerializeToString,
),
'AskReneRemoveLayer': grpc.unary_unary_rpc_method_handler(
servicer.AskReneRemoveLayer,
request_deserializer=node__pb2.AskreneremovelayerRequest.FromString,
response_serializer=node__pb2.AskreneremovelayerResponse.SerializeToString,
),
'AskReneReserve': grpc.unary_unary_rpc_method_handler(
servicer.AskReneReserve,
request_deserializer=node__pb2.AskrenereserveRequest.FromString,
response_serializer=node__pb2.AskrenereserveResponse.SerializeToString,
),
'AskReneAge': grpc.unary_unary_rpc_method_handler(
servicer.AskReneAge,
request_deserializer=node__pb2.AskreneageRequest.FromString,
response_serializer=node__pb2.AskreneageResponse.SerializeToString,
),
'GetRoutes': grpc.unary_unary_rpc_method_handler(
servicer.GetRoutes,
request_deserializer=node__pb2.GetroutesRequest.FromString,
response_serializer=node__pb2.GetroutesResponse.SerializeToString,
),
'AskReneDisableNode': grpc.unary_unary_rpc_method_handler(
servicer.AskReneDisableNode,
request_deserializer=node__pb2.AskrenedisablenodeRequest.FromString,
response_serializer=node__pb2.AskrenedisablenodeResponse.SerializeToString,
),
'AskReneInformChannel': grpc.unary_unary_rpc_method_handler(
servicer.AskReneInformChannel,
request_deserializer=node__pb2.AskreneinformchannelRequest.FromString,
response_serializer=node__pb2.AskreneinformchannelResponse.SerializeToString,
),
'AskReneCreateChannel': grpc.unary_unary_rpc_method_handler(
servicer.AskReneCreateChannel,
request_deserializer=node__pb2.AskrenecreatechannelRequest.FromString,
response_serializer=node__pb2.AskrenecreatechannelResponse.SerializeToString,
),
'AskReneUpdateChannel': grpc.unary_unary_rpc_method_handler(
servicer.AskReneUpdateChannel,
request_deserializer=node__pb2.AskreneupdatechannelRequest.FromString,
response_serializer=node__pb2.AskreneupdatechannelResponse.SerializeToString,
),
'AskReneBiasChannel': grpc.unary_unary_rpc_method_handler(
servicer.AskReneBiasChannel,
request_deserializer=node__pb2.AskrenebiaschannelRequest.FromString,
response_serializer=node__pb2.AskrenebiaschannelResponse.SerializeToString,
),
'AskReneListReservations': grpc.unary_unary_rpc_method_handler(
servicer.AskReneListReservations,
request_deserializer=node__pb2.AskrenelistreservationsRequest.FromString,
response_serializer=node__pb2.AskrenelistreservationsResponse.SerializeToString,
),
'InjectPaymentOnion': grpc.unary_unary_rpc_method_handler(
servicer.InjectPaymentOnion,
request_deserializer=node__pb2.InjectpaymentonionRequest.FromString,
response_serializer=node__pb2.InjectpaymentonionResponse.SerializeToString,
),
'Xpay': grpc.unary_unary_rpc_method_handler(
servicer.Xpay,
request_deserializer=node__pb2.XpayRequest.FromString,
response_serializer=node__pb2.XpayResponse.SerializeToString,
),
'SubscribeBlockAdded': grpc.unary_stream_rpc_method_handler(
servicer.SubscribeBlockAdded,
request_deserializer=node__pb2.StreamBlockAddedRequest.FromString,
@ -2228,6 +2580,40 @@ class Node(object):
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def GetEmergencyRecoverData(request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/cln.Node/GetEmergencyRecoverData',
node__pb2.GetemergencyrecoverdataRequest.SerializeToString,
node__pb2.GetemergencyrecoverdataResponse.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def ExposeSecret(request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/cln.Node/ExposeSecret',
node__pb2.ExposesecretRequest.SerializeToString,
node__pb2.ExposesecretResponse.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def Recover(request,
target,
@ -2806,6 +3192,23 @@ class Node(object):
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def EnableOffer(request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/cln.Node/EnableOffer',
node__pb2.EnableofferRequest.SerializeToString,
node__pb2.EnableofferResponse.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def Disconnect(request,
target,
@ -2976,6 +3379,23 @@ class Node(object):
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def ListAddresses(request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/cln.Node/ListAddresses',
node__pb2.ListaddressesRequest.SerializeToString,
node__pb2.ListaddressesResponse.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def ListForwards(request,
target,
@ -3435,6 +3855,23 @@ class Node(object):
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def DevSplice(request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/cln.Node/DevSplice',
node__pb2.DevspliceRequest.SerializeToString,
node__pb2.DevspliceResponse.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def UnreserveInputs(request,
target,
@ -3707,6 +4144,40 @@ class Node(object):
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def BkprEditDescriptionByPaymentId(request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/cln.Node/BkprEditDescriptionByPaymentId',
node__pb2.BkpreditdescriptionbypaymentidRequest.SerializeToString,
node__pb2.BkpreditdescriptionbypaymentidResponse.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def BkprEditDescriptionByOutpoint(request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/cln.Node/BkprEditDescriptionByOutpoint',
node__pb2.BkpreditdescriptionbyoutpointRequest.SerializeToString,
node__pb2.BkpreditdescriptionbyoutpointResponse.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def BlacklistRune(request,
target,
@ -3775,6 +4246,261 @@ class Node(object):
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def AskReneUnreserve(request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/cln.Node/AskReneUnreserve',
node__pb2.AskreneunreserveRequest.SerializeToString,
node__pb2.AskreneunreserveResponse.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def AskReneListLayers(request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/cln.Node/AskReneListLayers',
node__pb2.AskrenelistlayersRequest.SerializeToString,
node__pb2.AskrenelistlayersResponse.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def AskReneCreateLayer(request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/cln.Node/AskReneCreateLayer',
node__pb2.AskrenecreatelayerRequest.SerializeToString,
node__pb2.AskrenecreatelayerResponse.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def AskReneRemoveLayer(request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/cln.Node/AskReneRemoveLayer',
node__pb2.AskreneremovelayerRequest.SerializeToString,
node__pb2.AskreneremovelayerResponse.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def AskReneReserve(request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/cln.Node/AskReneReserve',
node__pb2.AskrenereserveRequest.SerializeToString,
node__pb2.AskrenereserveResponse.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def AskReneAge(request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/cln.Node/AskReneAge',
node__pb2.AskreneageRequest.SerializeToString,
node__pb2.AskreneageResponse.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def GetRoutes(request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/cln.Node/GetRoutes',
node__pb2.GetroutesRequest.SerializeToString,
node__pb2.GetroutesResponse.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def AskReneDisableNode(request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/cln.Node/AskReneDisableNode',
node__pb2.AskrenedisablenodeRequest.SerializeToString,
node__pb2.AskrenedisablenodeResponse.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def AskReneInformChannel(request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/cln.Node/AskReneInformChannel',
node__pb2.AskreneinformchannelRequest.SerializeToString,
node__pb2.AskreneinformchannelResponse.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def AskReneCreateChannel(request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/cln.Node/AskReneCreateChannel',
node__pb2.AskrenecreatechannelRequest.SerializeToString,
node__pb2.AskrenecreatechannelResponse.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def AskReneUpdateChannel(request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/cln.Node/AskReneUpdateChannel',
node__pb2.AskreneupdatechannelRequest.SerializeToString,
node__pb2.AskreneupdatechannelResponse.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def AskReneBiasChannel(request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/cln.Node/AskReneBiasChannel',
node__pb2.AskrenebiaschannelRequest.SerializeToString,
node__pb2.AskrenebiaschannelResponse.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def AskReneListReservations(request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/cln.Node/AskReneListReservations',
node__pb2.AskrenelistreservationsRequest.SerializeToString,
node__pb2.AskrenelistreservationsResponse.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def InjectPaymentOnion(request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/cln.Node/InjectPaymentOnion',
node__pb2.InjectpaymentonionRequest.SerializeToString,
node__pb2.InjectpaymentonionResponse.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def Xpay(request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/cln.Node/Xpay',
node__pb2.XpayRequest.SerializeToString,
node__pb2.XpayResponse.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def SubscribeBlockAdded(request,
target,

View file

@ -441,6 +441,19 @@ def emergencyrecover2py(m):
})
def getemergencyrecoverdata2py(m):
return remove_default({
"filedata": hexlify(m.filedata), # PrimitiveField in generate_composite
})
def exposesecret2py(m):
return remove_default({
"codex32": m.codex32, # PrimitiveField in generate_composite
"identifier": m.identifier, # PrimitiveField in generate_composite
})
def recover2py(m):
return remove_default({
"result": str(m.result), # EnumField in generate_composite
@ -1387,6 +1400,17 @@ def disableoffer2py(m):
})
def enableoffer2py(m):
return remove_default({
"active": m.active, # PrimitiveField in generate_composite
"bolt12": m.bolt12, # PrimitiveField in generate_composite
"label": m.label, # PrimitiveField in generate_composite
"offer_id": hexlify(m.offer_id), # PrimitiveField in generate_composite
"single_use": m.single_use, # PrimitiveField in generate_composite
"used": m.used, # PrimitiveField in generate_composite
})
def disconnect2py(m):
return remove_default({
})
@ -1591,6 +1615,20 @@ def getroute2py(m):
})
def listaddresses_addresses2py(m):
return remove_default({
"bech32": m.bech32, # PrimitiveField in generate_composite
"keyidx": m.keyidx, # PrimitiveField in generate_composite
"p2tr": m.p2tr, # PrimitiveField in generate_composite
})
def listaddresses2py(m):
return remove_default({
"addresses": [listaddresses_addresses2py(i) for i in m.addresses], # ArrayField[composite] in generate_composite
})
def listforwards_forwards2py(m):
return remove_default({
"status": str(m.status), # EnumField in generate_composite
@ -1988,6 +2026,16 @@ def splice_update2py(m):
})
def dev_splice2py(m):
return remove_default({
"dryrun": [m.dryrun for i in m.dryrun], # ArrayField[primitive] in generate_composite
"log": [m.log for i in m.log], # ArrayField[primitive] in generate_composite
"psbt": m.psbt, # PrimitiveField in generate_composite
"tx": m.tx, # PrimitiveField in generate_composite
"txid": m.txid, # PrimitiveField in generate_composite
})
def unreserveinputs_reservations2py(m):
return remove_default({
"reserved": m.reserved, # PrimitiveField in generate_composite
@ -2829,6 +2877,60 @@ def bkpr_listincome2py(m):
})
def bkpr_editdescriptionbypaymentid_updated2py(m):
return remove_default({
"type": str(m.item_type), # EnumField in generate_composite
"account": m.account, # PrimitiveField in generate_composite
"blockheight": m.blockheight, # PrimitiveField in generate_composite
"credit_msat": amount2msat(m.credit_msat), # PrimitiveField in generate_composite
"currency": m.currency, # PrimitiveField in generate_composite
"debit_msat": amount2msat(m.debit_msat), # PrimitiveField in generate_composite
"description": m.description, # PrimitiveField in generate_composite
"fees_msat": amount2msat(m.fees_msat), # PrimitiveField in generate_composite
"is_rebalance": m.is_rebalance, # PrimitiveField in generate_composite
"origin": m.origin, # PrimitiveField in generate_composite
"outpoint": m.outpoint, # PrimitiveField in generate_composite
"part_id": m.part_id, # PrimitiveField in generate_composite
"payment_id": hexlify(m.payment_id), # PrimitiveField in generate_composite
"tag": m.tag, # PrimitiveField in generate_composite
"timestamp": m.timestamp, # PrimitiveField in generate_composite
"txid": hexlify(m.txid), # PrimitiveField in generate_composite
})
def bkpr_editdescriptionbypaymentid2py(m):
return remove_default({
"updated": [bkpr_editdescriptionbypaymentid_updated2py(i) for i in m.updated], # ArrayField[composite] in generate_composite
})
def bkpr_editdescriptionbyoutpoint_updated2py(m):
return remove_default({
"type": str(m.item_type), # EnumField in generate_composite
"account": m.account, # PrimitiveField in generate_composite
"blockheight": m.blockheight, # PrimitiveField in generate_composite
"credit_msat": amount2msat(m.credit_msat), # PrimitiveField in generate_composite
"currency": m.currency, # PrimitiveField in generate_composite
"debit_msat": amount2msat(m.debit_msat), # PrimitiveField in generate_composite
"description": m.description, # PrimitiveField in generate_composite
"fees_msat": amount2msat(m.fees_msat), # PrimitiveField in generate_composite
"is_rebalance": m.is_rebalance, # PrimitiveField in generate_composite
"origin": m.origin, # PrimitiveField in generate_composite
"outpoint": m.outpoint, # PrimitiveField in generate_composite
"part_id": m.part_id, # PrimitiveField in generate_composite
"payment_id": hexlify(m.payment_id), # PrimitiveField in generate_composite
"tag": m.tag, # PrimitiveField in generate_composite
"timestamp": m.timestamp, # PrimitiveField in generate_composite
"txid": hexlify(m.txid), # PrimitiveField in generate_composite
})
def bkpr_editdescriptionbyoutpoint2py(m):
return remove_default({
"updated": [bkpr_editdescriptionbyoutpoint_updated2py(i) for i in m.updated], # ArrayField[composite] in generate_composite
})
def blacklistrune_blacklist2py(m):
return remove_default({
"end": m.end, # PrimitiveField in generate_composite
@ -2891,6 +2993,244 @@ def showrunes2py(m):
})
def askrene_unreserve2py(m):
return remove_default({
})
def askrene_listlayers_layers_biases2py(m):
return remove_default({
"bias": m.bias, # PrimitiveField in generate_composite
"description": m.description, # PrimitiveField in generate_composite
"short_channel_id_dir": m.short_channel_id_dir, # PrimitiveField in generate_composite
})
def askrene_listlayers_layers_channel_updates2py(m):
return remove_default({
"cltv_expiry_delta": m.cltv_expiry_delta, # PrimitiveField in generate_composite
"enabled": m.enabled, # PrimitiveField in generate_composite
"fee_base_msat": amount2msat(m.fee_base_msat), # PrimitiveField in generate_composite
"fee_proportional_millionths": m.fee_proportional_millionths, # PrimitiveField in generate_composite
"htlc_maximum_msat": amount2msat(m.htlc_maximum_msat), # PrimitiveField in generate_composite
"htlc_minimum_msat": amount2msat(m.htlc_minimum_msat), # PrimitiveField in generate_composite
"short_channel_id_dir": m.short_channel_id_dir, # PrimitiveField in generate_composite
})
def askrene_listlayers_layers_constraints2py(m):
return remove_default({
"maximum_msat": amount2msat(m.maximum_msat), # PrimitiveField in generate_composite
"minimum_msat": amount2msat(m.minimum_msat), # PrimitiveField in generate_composite
"short_channel_id_dir": m.short_channel_id_dir, # PrimitiveField in generate_composite
"timestamp": m.timestamp, # PrimitiveField in generate_composite
})
def askrene_listlayers_layers_created_channels2py(m):
return remove_default({
"capacity_msat": amount2msat(m.capacity_msat), # PrimitiveField in generate_composite
"destination": hexlify(m.destination), # PrimitiveField in generate_composite
"short_channel_id": m.short_channel_id, # PrimitiveField in generate_composite
"source": hexlify(m.source), # PrimitiveField in generate_composite
})
def askrene_listlayers_layers2py(m):
return remove_default({
"biases": [askrene_listlayers_layers_biases2py(i) for i in m.biases], # ArrayField[composite] in generate_composite
"channel_updates": [askrene_listlayers_layers_channel_updates2py(i) for i in m.channel_updates], # ArrayField[composite] in generate_composite
"constraints": [askrene_listlayers_layers_constraints2py(i) for i in m.constraints], # ArrayField[composite] in generate_composite
"created_channels": [askrene_listlayers_layers_created_channels2py(i) for i in m.created_channels], # ArrayField[composite] in generate_composite
"disabled_channels": [m.disabled_channels for i in m.disabled_channels], # ArrayField[primitive] in generate_composite
"disabled_nodes": [hexlify(m.disabled_nodes) for i in hexlify(m.disabled_nodes)], # ArrayField[primitive] in generate_composite
"layer": m.layer, # PrimitiveField in generate_composite
"persistent": m.persistent, # PrimitiveField in generate_composite
})
def askrene_listlayers2py(m):
return remove_default({
"layers": [askrene_listlayers_layers2py(i) for i in m.layers], # ArrayField[composite] in generate_composite
})
def askrene_create_layer_layers_biases2py(m):
return remove_default({
"bias": m.bias, # PrimitiveField in generate_composite
"description": m.description, # PrimitiveField in generate_composite
"short_channel_id_dir": m.short_channel_id_dir, # PrimitiveField in generate_composite
})
def askrene_create_layer_layers_channel_updates2py(m):
return remove_default({
"delay": m.delay, # PrimitiveField in generate_composite
"fee_base_msat": amount2msat(m.fee_base_msat), # PrimitiveField in generate_composite
"fee_proportional_millionths": m.fee_proportional_millionths, # PrimitiveField in generate_composite
"htlc_maximum_msat": amount2msat(m.htlc_maximum_msat), # PrimitiveField in generate_composite
"htlc_minimum_msat": amount2msat(m.htlc_minimum_msat), # PrimitiveField in generate_composite
})
def askrene_create_layer_layers_constraints2py(m):
return remove_default({
"direction": m.direction, # PrimitiveField in generate_composite
"maximum_msat": amount2msat(m.maximum_msat), # PrimitiveField in generate_composite
"minimum_msat": amount2msat(m.minimum_msat), # PrimitiveField in generate_composite
"short_channel_id": m.short_channel_id, # PrimitiveField in generate_composite
})
def askrene_create_layer_layers_created_channels2py(m):
return remove_default({
"capacity_msat": amount2msat(m.capacity_msat), # PrimitiveField in generate_composite
"destination": hexlify(m.destination), # PrimitiveField in generate_composite
"short_channel_id": m.short_channel_id, # PrimitiveField in generate_composite
"source": hexlify(m.source), # PrimitiveField in generate_composite
})
def askrene_create_layer_layers2py(m):
return remove_default({
"biases": [askrene_create_layer_layers_biases2py(i) for i in m.biases], # ArrayField[composite] in generate_composite
"channel_updates": [askrene_create_layer_layers_channel_updates2py(i) for i in m.channel_updates], # ArrayField[composite] in generate_composite
"constraints": [askrene_create_layer_layers_constraints2py(i) for i in m.constraints], # ArrayField[composite] in generate_composite
"created_channels": [askrene_create_layer_layers_created_channels2py(i) for i in m.created_channels], # ArrayField[composite] in generate_composite
"disabled_channels": [m.disabled_channels for i in m.disabled_channels], # ArrayField[primitive] in generate_composite
"disabled_nodes": [hexlify(m.disabled_nodes) for i in hexlify(m.disabled_nodes)], # ArrayField[primitive] in generate_composite
"layer": m.layer, # PrimitiveField in generate_composite
"persistent": m.persistent, # PrimitiveField in generate_composite
})
def askrene_create_layer2py(m):
return remove_default({
"layers": [askrene_create_layer_layers2py(i) for i in m.layers], # ArrayField[composite] in generate_composite
})
def askrene_remove_layer2py(m):
return remove_default({
})
def askrene_reserve2py(m):
return remove_default({
})
def askrene_age2py(m):
return remove_default({
"layer": m.layer, # PrimitiveField in generate_composite
"num_removed": m.num_removed, # PrimitiveField in generate_composite
})
def getroutes_routes_path2py(m):
return remove_default({
"amount_msat": amount2msat(m.amount_msat), # PrimitiveField in generate_composite
"delay": m.delay, # PrimitiveField in generate_composite
"next_node_id": hexlify(m.next_node_id), # PrimitiveField in generate_composite
"short_channel_id_dir": m.short_channel_id_dir, # PrimitiveField in generate_composite
})
def getroutes_routes2py(m):
return remove_default({
"path": [getroutes_routes_path2py(i) for i in m.path], # ArrayField[composite] in generate_composite
"amount_msat": amount2msat(m.amount_msat), # PrimitiveField in generate_composite
"final_cltv": m.final_cltv, # PrimitiveField in generate_composite
"probability_ppm": m.probability_ppm, # PrimitiveField in generate_composite
})
def getroutes2py(m):
return remove_default({
"routes": [getroutes_routes2py(i) for i in m.routes], # ArrayField[composite] in generate_composite
"probability_ppm": m.probability_ppm, # PrimitiveField in generate_composite
})
def askrene_disable_node2py(m):
return remove_default({
})
def askrene_inform_channel_constraints2py(m):
return remove_default({
"layer": m.layer, # PrimitiveField in generate_composite
"maximum_msat": amount2msat(m.maximum_msat), # PrimitiveField in generate_composite
"minimum_msat": amount2msat(m.minimum_msat), # PrimitiveField in generate_composite
"short_channel_id_dir": m.short_channel_id_dir, # PrimitiveField in generate_composite
"timestamp": m.timestamp, # PrimitiveField in generate_composite
})
def askrene_inform_channel2py(m):
return remove_default({
"constraints": [askrene_inform_channel_constraints2py(i) for i in m.constraints], # ArrayField[composite] in generate_composite
})
def askrene_create_channel2py(m):
return remove_default({
})
def askrene_update_channel2py(m):
return remove_default({
})
def askrene_bias_channel_biases2py(m):
return remove_default({
"bias": m.bias, # PrimitiveField in generate_composite
"description": m.description, # PrimitiveField in generate_composite
"layer": m.layer, # PrimitiveField in generate_composite
"short_channel_id_dir": m.short_channel_id_dir, # PrimitiveField in generate_composite
})
def askrene_bias_channel2py(m):
return remove_default({
"biases": [askrene_bias_channel_biases2py(i) for i in m.biases], # ArrayField[composite] in generate_composite
})
def askrene_listreservations_reservations2py(m):
return remove_default({
"age_in_seconds": m.age_in_seconds, # PrimitiveField in generate_composite
"amount_msat": amount2msat(m.amount_msat), # PrimitiveField in generate_composite
"command_id": m.command_id, # PrimitiveField in generate_composite
"short_channel_id_dir": m.short_channel_id_dir, # PrimitiveField in generate_composite
})
def askrene_listreservations2py(m):
return remove_default({
"reservations": [askrene_listreservations_reservations2py(i) for i in m.reservations], # ArrayField[composite] in generate_composite
})
def injectpaymentonion2py(m):
return remove_default({
"completed_at": m.completed_at, # PrimitiveField in generate_composite
"created_at": m.created_at, # PrimitiveField in generate_composite
"created_index": m.created_index, # PrimitiveField in generate_composite
})
def xpay2py(m):
return remove_default({
"amount_msat": amount2msat(m.amount_msat), # PrimitiveField in generate_composite
"amount_sent_msat": amount2msat(m.amount_sent_msat), # PrimitiveField in generate_composite
"failed_parts": m.failed_parts, # PrimitiveField in generate_composite
"payment_preimage": hexlify(m.payment_preimage), # PrimitiveField in generate_composite
"successful_parts": m.successful_parts, # PrimitiveField in generate_composite
})
def decodekeysend_routes2py(m): # manual override
return remove_default({
"expirydelta": m.expirydelta,