Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
12 changes: 10 additions & 2 deletions src/io/vss_store.rs
Original file line number Diff line number Diff line change
Expand Up @@ -421,7 +421,8 @@ impl VssStoreInner {

async fn list_keys(
&self, client: &VssClient<CustomRetryPolicy>, primary_namespace: &str,
secondary_namespace: &str, key_prefix: String, page_token: Option<String>, page_size: Option<i32>,
secondary_namespace: &str, key_prefix: String, page_token: Option<String>,
page_size: Option<i32>,
) -> io::Result<(Vec<String>, Option<String>)> {
let request = ListKeyVersionsRequest {
store_id: self.store_id.clone(),
Expand Down Expand Up @@ -574,7 +575,14 @@ impl VssStoreInner {
let mut keys = vec![];
loop {
let (page_keys, next_page_token) = self
.list_keys(client, &primary_namespace, &secondary_namespace, key_prefix.clone(), page_token, None)
.list_keys(
client,
&primary_namespace,
&secondary_namespace,
key_prefix.clone(),
page_token,
None,
)
.await?;
keys.extend(page_keys);
match next_page_token {
Expand Down
22 changes: 11 additions & 11 deletions src/liquidity/client/mod.rs
Original file line number Diff line number Diff line change
@@ -1,11 +1,11 @@
// This file is Copyright its original authors, visible in version control history.
//
// This file is licensed under the Apache License, Version 2.0 <LICENSE-APACHE or
// http://www.apache.org/licenses/LICENSE-2.0> or the MIT license <LICENSE-MIT or
// http://opensource.org/licenses/MIT>, at your option. You may not use this file except in
// accordance with one or both of these licenses.
pub(crate) mod lsps1;
pub(crate) mod lsps2;
pub use lsps1::LSPS1OrderStatus;
// This file is Copyright its original authors, visible in version control history.
//
// This file is licensed under the Apache License, Version 2.0 <LICENSE-APACHE or
// http://www.apache.org/licenses/LICENSE-2.0> or the MIT license <LICENSE-MIT or
// http://opensource.org/licenses/MIT>, at your option. You may not use this file except in
// accordance with one or both of these licenses.

pub(crate) mod lsps1;
pub(crate) mod lsps2;

pub use lsps1::LSPS1OrderStatus;
7 changes: 3 additions & 4 deletions src/liquidity/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -10,24 +10,23 @@
pub(crate) mod client;
pub(crate) mod service;

pub use client::lsps1::LSPS1Liquidity;
pub use client::LSPS1OrderStatus;
pub use service::lsps2::LSPS2ServiceConfig;

use std::collections::hash_map::Entry;
use std::collections::HashMap;
use std::ops::Deref;
use std::sync::{Arc, Mutex, RwLock};
use std::time::Duration;

use bitcoin::secp256k1::PublicKey;
pub use client::lsps1::LSPS1Liquidity;
pub use client::LSPS1OrderStatus;
use lightning::ln::msgs::SocketAddress;
use lightning_liquidity::events::LiquidityEvent;
use lightning_liquidity::lsps0::event::LSPS0ClientEvent;
use lightning_liquidity::lsps1::client::LSPS1ClientConfig as LdkLSPS1ClientConfig;
use lightning_liquidity::lsps2::client::LSPS2ClientConfig as LdkLSPS2ClientConfig;
use lightning_liquidity::lsps2::service::LSPS2ServiceConfig as LdkLSPS2ServiceConfig;
use lightning_liquidity::{LiquidityClientConfig, LiquidityServiceConfig};
pub use service::lsps2::LSPS2ServiceConfig;
use tokio::sync::oneshot;

use crate::builder::BuildError;
Expand Down
Loading