Skip to content

Commit f7df4c1

Browse files
committed
Use treefmt to format rust code
1 parent f288dd7 commit f7df4c1

File tree

12 files changed

+53
-35
lines changed

12 files changed

+53
-35
lines changed

ldk-server-cli/src/main.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,7 @@ use ldk_server_client::ldk_server_protos::api::{
1111
OpenChannelRequest,
1212
};
1313
use ldk_server_client::ldk_server_protos::types::{
14-
bolt11_invoice_description, Bolt11InvoiceDescription, PageToken, Payment,
14+
Bolt11InvoiceDescription, PageToken, Payment, bolt11_invoice_description,
1515
};
1616
use std::fmt::Debug;
1717

ldk-server-client/src/client.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,8 +14,8 @@ use ldk_server_protos::api::{
1414
OpenChannelRequest, OpenChannelResponse,
1515
};
1616
use ldk_server_protos::error::{ErrorCode, ErrorResponse};
17-
use reqwest::header::CONTENT_TYPE;
1817
use reqwest::Client;
18+
use reqwest::header::CONTENT_TYPE;
1919

2020
const APPLICATION_OCTET_STREAM: &str = "application/octet-stream";
2121

ldk-server/src/api/close_channel.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,8 +1,8 @@
11
use crate::api::error::LdkServerError;
22
use crate::api::error::LdkServerErrorCode::InvalidRequestError;
33
use crate::service::Context;
4-
use ldk_node::bitcoin::secp256k1::PublicKey;
54
use ldk_node::UserChannelId;
5+
use ldk_node::bitcoin::secp256k1::PublicKey;
66
use ldk_server_protos::api::{
77
CloseChannelRequest, CloseChannelResponse, ForceCloseChannelRequest, ForceCloseChannelResponse,
88
};

ldk-server/src/api/onchain_send.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -33,7 +33,7 @@ pub(crate) fn handle_onchain_send_request(
3333
return Err(LdkServerError::new(
3434
InvalidRequestError,
3535
"Must specify either `send_all` or `amount_sats`, but not both or neither",
36-
))
36+
));
3737
},
3838
};
3939
let response = OnchainSendResponse { txid: txid.to_string() };

ldk-server/src/api/update_channel_config.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,9 +1,9 @@
11
use crate::api::error::LdkServerError;
22
use crate::api::error::LdkServerErrorCode::{InvalidRequestError, LightningError};
33
use crate::service::Context;
4+
use ldk_node::UserChannelId;
45
use ldk_node::bitcoin::secp256k1::PublicKey;
56
use ldk_node::config::{ChannelConfig, MaxDustHTLCExposure};
6-
use ldk_node::UserChannelId;
77
use ldk_server_protos::api::{UpdateChannelConfigRequest, UpdateChannelConfigResponse};
88
use ldk_server_protos::types::channel_config::MaxDustHtlcExposure;
99
use std::str::FromStr;

ldk-server/src/io/events/rabbitmq/mod.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -148,12 +148,12 @@ impl EventPublisher for RabbitMqEventPublisher {
148148
mod integration_tests_events_rabbitmq {
149149
use super::*;
150150
use lapin::{
151+
Channel, Connection,
151152
options::{BasicAckOptions, BasicConsumeOptions, QueueBindOptions, QueueDeclareOptions},
152153
types::FieldTable,
153-
Channel, Connection,
154154
};
155-
use ldk_server_protos::events::event_envelope::Event;
156155
use ldk_server_protos::events::PaymentForwarded;
156+
use ldk_server_protos::events::event_envelope::Event;
157157
use std::io;
158158
use std::time::Duration;
159159
use tokio;

ldk-server/src/io/persist/sqlite_store/mod.rs

Lines changed: 10 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
use crate::io::persist::paginated_kv_store::{ListResponse, PaginatedKVStore};
22
use crate::io::utils::check_namespace_key_validity;
33
use ldk_node::lightning::types::string::PrintableString;
4-
use rusqlite::{named_params, Connection};
4+
use rusqlite::{Connection, named_params};
55
use std::path::PathBuf;
66
use std::sync::{Arc, Mutex};
77
use std::{fs, io};
@@ -123,9 +123,10 @@ impl SqliteStore {
123123
check_namespace_key_validity(primary_namespace, secondary_namespace, Some(key), "read")?;
124124

125125
let locked_conn = self.connection.lock().unwrap();
126-
let sql =
127-
format!("SELECT value FROM {} WHERE primary_namespace=:primary_namespace AND secondary_namespace=:secondary_namespace AND key=:key;",
128-
kv_table_name);
126+
let sql = format!(
127+
"SELECT value FROM {} WHERE primary_namespace=:primary_namespace AND secondary_namespace=:secondary_namespace AND key=:key;",
128+
kv_table_name
129+
);
129130

130131
let mut stmt = locked_conn.prepare_cached(&sql).map_err(|e| {
131132
let msg = format!("Failed to prepare statement: {}", e);
@@ -172,7 +173,10 @@ impl SqliteStore {
172173

173174
let locked_conn = self.connection.lock().unwrap();
174175

175-
let sql = format!("DELETE FROM {} WHERE primary_namespace=:primary_namespace AND secondary_namespace=:secondary_namespace AND key=:key;", kv_table_name);
176+
let sql = format!(
177+
"DELETE FROM {} WHERE primary_namespace=:primary_namespace AND secondary_namespace=:secondary_namespace AND key=:key;",
178+
kv_table_name
179+
);
176180

177181
let mut stmt = locked_conn.prepare_cached(&sql).map_err(|e| {
178182
let msg = format!("Failed to prepare statement: {}", e);
@@ -330,7 +334,7 @@ mod tests {
330334
use super::*;
331335
use ldk_node::lightning::util::persist::KVSTORE_NAMESPACE_KEY_MAX_LEN;
332336
use rand::distributions::Alphanumeric;
333-
use rand::{thread_rng, Rng};
337+
use rand::{Rng, thread_rng};
334338
use std::panic::RefUnwindSafe;
335339

336340
impl Drop for SqliteStore {

ldk-server/src/io/utils.rs

Lines changed: 8 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -20,8 +20,11 @@ pub(crate) fn check_namespace_key_validity(
2020

2121
if primary_namespace.is_empty() && !secondary_namespace.is_empty() {
2222
let msg = format!(
23-
"Failed to {} {}/{}/{}: primary namespace may not be empty if a non-empty secondary namespace is given.", operation,
24-
PrintableString(primary_namespace), PrintableString(secondary_namespace), PrintableString(key)
23+
"Failed to {} {}/{}/{}: primary namespace may not be empty if a non-empty secondary namespace is given.",
24+
operation,
25+
PrintableString(primary_namespace),
26+
PrintableString(secondary_namespace),
27+
PrintableString(key)
2528
);
2629
return Err(std::io::Error::new(std::io::ErrorKind::Other, msg));
2730
}
@@ -43,7 +46,9 @@ pub(crate) fn check_namespace_key_validity(
4346
if primary_namespace.is_empty() && !secondary_namespace.is_empty() {
4447
let msg = format!(
4548
"Failed to {} {}/{}: primary namespace may not be empty if a non-empty secondary namespace is given.",
46-
operation, PrintableString(primary_namespace), PrintableString(secondary_namespace)
49+
operation,
50+
PrintableString(primary_namespace),
51+
PrintableString(secondary_namespace)
4752
);
4853
return Err(std::io::Error::new(std::io::ErrorKind::Other, msg));
4954
}

ldk-server/src/main.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,7 @@ use ldk_node::lightning::ln::channelmanager::PaymentId;
3232
#[cfg(feature = "experimental-lsps2-support")]
3333
use ldk_node::liquidity::LSPS2ServiceConfig;
3434
use ldk_server_protos::events;
35-
use ldk_server_protos::events::{event_envelope, EventEnvelope};
35+
use ldk_server_protos::events::{EventEnvelope, event_envelope};
3636
use ldk_server_protos::types::Payment;
3737
use prost::Message;
3838
use rand::Rng;

ldk-server/src/service.rs

Lines changed: 16 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -7,31 +7,31 @@ use hyper::{Request, Response, StatusCode};
77

88
use prost::Message;
99

10-
use crate::api::bolt11_receive::{handle_bolt11_receive_request, BOLT11_RECEIVE_PATH};
11-
use crate::api::bolt11_send::{handle_bolt11_send_request, BOLT11_SEND_PATH};
12-
use crate::api::bolt12_receive::{handle_bolt12_receive_request, BOLT12_RECEIVE_PATH};
13-
use crate::api::bolt12_send::{handle_bolt12_send_request, BOLT12_SEND_PATH};
10+
use crate::api::bolt11_receive::{BOLT11_RECEIVE_PATH, handle_bolt11_receive_request};
11+
use crate::api::bolt11_send::{BOLT11_SEND_PATH, handle_bolt11_send_request};
12+
use crate::api::bolt12_receive::{BOLT12_RECEIVE_PATH, handle_bolt12_receive_request};
13+
use crate::api::bolt12_send::{BOLT12_SEND_PATH, handle_bolt12_send_request};
1414
use crate::api::close_channel::{
15-
handle_close_channel_request, handle_force_close_channel_request, CLOSE_CHANNEL_PATH,
16-
FORCE_CLOSE_CHANNEL_PATH,
15+
CLOSE_CHANNEL_PATH, FORCE_CLOSE_CHANNEL_PATH, handle_close_channel_request,
16+
handle_force_close_channel_request,
1717
};
1818
use crate::api::error::LdkServerError;
1919
use crate::api::error::LdkServerErrorCode::InvalidRequestError;
20-
use crate::api::get_balances::{handle_get_balances_request, GET_BALANCES};
21-
use crate::api::get_node_info::{handle_get_node_info_request, GET_NODE_INFO};
20+
use crate::api::get_balances::{GET_BALANCES, handle_get_balances_request};
21+
use crate::api::get_node_info::{GET_NODE_INFO, handle_get_node_info_request};
2222
use crate::api::get_payment_details::{
23-
handle_get_payment_details_request, GET_PAYMENT_DETAILS_PATH,
23+
GET_PAYMENT_DETAILS_PATH, handle_get_payment_details_request,
2424
};
25-
use crate::api::list_channels::{handle_list_channels_request, LIST_CHANNELS_PATH};
25+
use crate::api::list_channels::{LIST_CHANNELS_PATH, handle_list_channels_request};
2626
use crate::api::list_forwarded_payments::{
27-
handle_list_forwarded_payments_request, LIST_FORWARDED_PAYMENTS_PATH,
27+
LIST_FORWARDED_PAYMENTS_PATH, handle_list_forwarded_payments_request,
2828
};
29-
use crate::api::list_payments::{handle_list_payments_request, LIST_PAYMENTS_PATH};
30-
use crate::api::onchain_receive::{handle_onchain_receive_request, ONCHAIN_RECEIVE_PATH};
31-
use crate::api::onchain_send::{handle_onchain_send_request, ONCHAIN_SEND_PATH};
32-
use crate::api::open_channel::{handle_open_channel, OPEN_CHANNEL_PATH};
29+
use crate::api::list_payments::{LIST_PAYMENTS_PATH, handle_list_payments_request};
30+
use crate::api::onchain_receive::{ONCHAIN_RECEIVE_PATH, handle_onchain_receive_request};
31+
use crate::api::onchain_send::{ONCHAIN_SEND_PATH, handle_onchain_send_request};
32+
use crate::api::open_channel::{OPEN_CHANNEL_PATH, handle_open_channel};
3333
use crate::api::update_channel_config::{
34-
handle_update_channel_config_request, UPDATE_CHANNEL_CONFIG_PATH,
34+
UPDATE_CHANNEL_CONFIG_PATH, handle_update_channel_config_request,
3535
};
3636
use crate::io::persist::paginated_kv_store::PaginatedKVStore;
3737
use crate::util::proto_adapter::to_error_response;

0 commit comments

Comments
 (0)