Skip to content

Commit 821dbd9

Browse files
rustyrussellrustyrussell
committed
msggen: add currencyconvert, currencyrate and listcurrencyrates.
I used daywalker's hack to patch.py to make this work: ``` if f.added is None and 'added' not in m: m['added'] = 'v26.04' ``` Signed-off-by: Rusty Russell <rusty@rustcorp.com.au>
1 parent 7cb394c commit 821dbd9

10 files changed

Lines changed: 628 additions & 36 deletions

File tree

‎.msggen.json‎

Lines changed: 71 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1314,6 +1314,19 @@
13141314
"CreateRune.unique_id": 2,
13151315
"CreateRune.warning_unrestricted_rune": 3
13161316
},
1317+
"CurrencyconvertRequest": {
1318+
"CurrencyConvert.amount": 1,
1319+
"CurrencyConvert.currency": 2
1320+
},
1321+
"CurrencyconvertResponse": {
1322+
"CurrencyConvert.msat": 1
1323+
},
1324+
"CurrencyrateRequest": {
1325+
"CurrencyRate.currency": 1
1326+
},
1327+
"CurrencyrateResponse": {
1328+
"CurrencyRate.rate": 1
1329+
},
13171330
"CustomMsgNotification": {
13181331
"custommsg.payload": 2,
13191332
"custommsg.peer_id": 1
@@ -2706,6 +2719,16 @@
27062719
"ListConfigs.wallet": 15,
27072720
"ListConfigs.watchtime-blocks": 31
27082721
},
2722+
"ListcurrencyratesCurrencyrates": {
2723+
"ListCurrencyRates.currencyrates[].amount": 2,
2724+
"ListCurrencyRates.currencyrates[].source": 1
2725+
},
2726+
"ListcurrencyratesRequest": {
2727+
"ListCurrencyRates.currency": 1
2728+
},
2729+
"ListcurrencyratesResponse": {
2730+
"ListCurrencyRates.currencyrates[]": 1
2731+
},
27092732
"ListdatastoreDatastore": {
27102733
"ListDatastore.datastore[].generation": 2,
27112734
"ListDatastore.datastore[].hex": 3,
@@ -6027,6 +6050,34 @@
60276050
"added": "pre-v0.10.1",
60286051
"deprecated": null
60296052
},
6053+
"CurrencyConvert": {
6054+
"added": "v26.04",
6055+
"deprecated": null
6056+
},
6057+
"CurrencyConvert.amount": {
6058+
"added": "v26.04",
6059+
"deprecated": null
6060+
},
6061+
"CurrencyConvert.currency": {
6062+
"added": "v26.04",
6063+
"deprecated": null
6064+
},
6065+
"CurrencyConvert.msat": {
6066+
"added": "v26.04",
6067+
"deprecated": null
6068+
},
6069+
"CurrencyRate": {
6070+
"added": "v26.04",
6071+
"deprecated": null
6072+
},
6073+
"CurrencyRate.currency": {
6074+
"added": "v26.04",
6075+
"deprecated": null
6076+
},
6077+
"CurrencyRate.rate": {
6078+
"added": "v26.04",
6079+
"deprecated": null
6080+
},
60306081
"Datastore": {
60316082
"added": "pre-v0.10.1",
60326083
"deprecated": null
@@ -10147,6 +10198,26 @@
1014710198
"added": "pre-v0.10.1",
1014810199
"deprecated": "v23.08"
1014910200
},
10201+
"ListCurrencyRates": {
10202+
"added": "v26.04",
10203+
"deprecated": null
10204+
},
10205+
"ListCurrencyRates.currency": {
10206+
"added": "v26.04",
10207+
"deprecated": null
10208+
},
10209+
"ListCurrencyRates.currencyrates[]": {
10210+
"added": "v26.04",
10211+
"deprecated": null
10212+
},
10213+
"ListCurrencyRates.currencyrates[].amount": {
10214+
"added": "v26.04",
10215+
"deprecated": null
10216+
},
10217+
"ListCurrencyRates.currencyrates[].source": {
10218+
"added": "v26.04",
10219+
"deprecated": null
10220+
},
1015010221
"ListDatastore": {
1015110222
"added": "pre-v0.10.1",
1015210223
"deprecated": null

‎cln-grpc/proto/node.proto‎

Lines changed: 33 additions & 0 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

‎cln-grpc/src/convert.rs‎

Lines changed: 94 additions & 0 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

‎cln-grpc/src/server.rs‎

Lines changed: 96 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -4626,6 +4626,102 @@ impl Node for Server
46264626

46274627
}
46284628

4629+
async fn list_currency_rates(
4630+
&self,
4631+
request: tonic::Request<pb::ListcurrencyratesRequest>,
4632+
) -> Result<tonic::Response<pb::ListcurrencyratesResponse>, tonic::Status> {
4633+
let req = request.into_inner();
4634+
let req: requests::ListcurrencyratesRequest = req.into();
4635+
debug!("Client asked for list_currency_rates");
4636+
trace!("list_currency_rates request: {:?}", req);
4637+
let mut rpc = ClnRpc::new(&self.rpc_path)
4638+
.await
4639+
.map_err(|e| Status::new(Code::Internal, e.to_string()))?;
4640+
let result = rpc.call(Request::ListCurrencyRates(req))
4641+
.await
4642+
.map_err(|e| Status::new(
4643+
Code::Unknown,
4644+
format!("Error calling method ListCurrencyRates: {:?}", e)))?;
4645+
match result {
4646+
Response::ListCurrencyRates(r) => {
4647+
trace!("list_currency_rates response: {:?}", r);
4648+
Ok(tonic::Response::new(r.into()))
4649+
},
4650+
r => Err(Status::new(
4651+
Code::Internal,
4652+
format!(
4653+
"Unexpected result {:?} to method call ListCurrencyRates",
4654+
r
4655+
)
4656+
)),
4657+
}
4658+
4659+
}
4660+
4661+
async fn currency_convert(
4662+
&self,
4663+
request: tonic::Request<pb::CurrencyconvertRequest>,
4664+
) -> Result<tonic::Response<pb::CurrencyconvertResponse>, tonic::Status> {
4665+
let req = request.into_inner();
4666+
let req: requests::CurrencyconvertRequest = req.into();
4667+
debug!("Client asked for currency_convert");
4668+
trace!("currency_convert request: {:?}", req);
4669+
let mut rpc = ClnRpc::new(&self.rpc_path)
4670+
.await
4671+
.map_err(|e| Status::new(Code::Internal, e.to_string()))?;
4672+
let result = rpc.call(Request::CurrencyConvert(req))
4673+
.await
4674+
.map_err(|e| Status::new(
4675+
Code::Unknown,
4676+
format!("Error calling method CurrencyConvert: {:?}", e)))?;
4677+
match result {
4678+
Response::CurrencyConvert(r) => {
4679+
trace!("currency_convert response: {:?}", r);
4680+
Ok(tonic::Response::new(r.into()))
4681+
},
4682+
r => Err(Status::new(
4683+
Code::Internal,
4684+
format!(
4685+
"Unexpected result {:?} to method call CurrencyConvert",
4686+
r
4687+
)
4688+
)),
4689+
}
4690+
4691+
}
4692+
4693+
async fn currency_rate(
4694+
&self,
4695+
request: tonic::Request<pb::CurrencyrateRequest>,
4696+
) -> Result<tonic::Response<pb::CurrencyrateResponse>, tonic::Status> {
4697+
let req = request.into_inner();
4698+
let req: requests::CurrencyrateRequest = req.into();
4699+
debug!("Client asked for currency_rate");
4700+
trace!("currency_rate request: {:?}", req);
4701+
let mut rpc = ClnRpc::new(&self.rpc_path)
4702+
.await
4703+
.map_err(|e| Status::new(Code::Internal, e.to_string()))?;
4704+
let result = rpc.call(Request::CurrencyRate(req))
4705+
.await
4706+
.map_err(|e| Status::new(
4707+
Code::Unknown,
4708+
format!("Error calling method CurrencyRate: {:?}", e)))?;
4709+
match result {
4710+
Response::CurrencyRate(r) => {
4711+
trace!("currency_rate response: {:?}", r);
4712+
Ok(tonic::Response::new(r.into()))
4713+
},
4714+
r => Err(Status::new(
4715+
Code::Internal,
4716+
format!(
4717+
"Unexpected result {:?} to method call CurrencyRate",
4718+
r
4719+
)
4720+
)),
4721+
}
4722+
4723+
}
4724+
46294725

46304726

46314727
type SubscribeBlockAddedStream = NotificationStream<pb::BlockAddedNotification>;

0 commit comments

Comments
 (0)