Skip to content

Commit c221c3a

Browse files
committed
chore: make client fns take key directly
1 parent 738ddac commit c221c3a

File tree

1 file changed

+4
-11
lines changed

1 file changed

+4
-11
lines changed

crates/tx-cache/src/client.rs

Lines changed: 4 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -93,11 +93,7 @@ impl TxCache {
9393
self.client.post(url).json(&obj).send().await?.error_for_status().map_err(Into::into)
9494
}
9595

96-
async fn get_inner<T>(
97-
&self,
98-
join: &'static str,
99-
query: Option<PaginationParams<T::Key>>,
100-
) -> Result<T, Error>
96+
async fn get_inner<T>(&self, join: &'static str, query: Option<T::Key>) -> Result<T, Error>
10197
where
10298
T: DeserializeOwned + CacheObject,
10399
{
@@ -106,10 +102,7 @@ impl TxCache {
106102
.join(join)
107103
.inspect_err(|e| warn!(%e, "Failed to join URL. Not querying transaction cache."))?;
108104

109-
let request = self
110-
.client
111-
.get(url)
112-
.query(&query.and_then(|q| q.cursor().map(|c| c.to_query_object())));
105+
let request = self.client.get(url).query(&query);
113106

114107
// Get the result.
115108
request
@@ -149,7 +142,7 @@ impl TxCache {
149142
#[instrument(skip_all)]
150143
pub async fn get_transactions(
151144
&self,
152-
query: Option<PaginationParams<TxKey>>,
145+
query: Option<TxKey>,
153146
) -> Result<CacheResponse<TxCacheTransactionsResponse>, Error> {
154147
self.get_inner(TRANSACTIONS, query).await
155148
}
@@ -158,7 +151,7 @@ impl TxCache {
158151
#[instrument(skip_all)]
159152
pub async fn get_orders(
160153
&self,
161-
query: Option<PaginationParams<OrderKey>>,
154+
query: Option<OrderKey>,
162155
) -> Result<CacheResponse<TxCacheOrdersResponse>, Error> {
163156
self.get_inner(ORDERS, query).await
164157
}

0 commit comments

Comments
 (0)