Skip to content

Commit b22c5b8

Browse files
committed
removed SpenderLeaf struct
1 parent bfdc4f7 commit b22c5b8

File tree

5 files changed

+25
-29
lines changed

5 files changed

+25
-29
lines changed

primitives/src/balances_map.rs

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -71,6 +71,10 @@ impl<K: Ord, V> Map<K, V> {
7171
pub fn is_empty(&self) -> bool {
7272
self.0.is_empty()
7373
}
74+
75+
pub fn remove(&mut self, key: &K) -> Option<V> {
76+
self.0.remove(key)
77+
}
7478
}
7579

7680
impl<K: Ord, V> FromIterator<(K, V)> for Map<K, V> {

primitives/src/spender.rs

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -1,17 +1,17 @@
11
use crate::{Address, Channel, Deposit, UnifiedNum};
22
use serde::{Deserialize, Serialize};
33

4-
#[derive(Serialize, Deserialize, Debug, Clone, Eq, PartialEq)]
5-
#[serde(rename_all = "camelCase")]
6-
pub struct SpenderLeaf {
7-
pub total_spent: UnifiedNum,
8-
// merkle_proof: [u8; 32], // TODO
9-
}
4+
// #[derive(Serialize, Deserialize, Debug, Clone, Eq, PartialEq)]
5+
// #[serde(rename_all = "camelCase")]
6+
// pub struct SpenderLeaf {
7+
// pub total_spent: UnifiedNum,
8+
// // merkle_proof: [u8; 32], // TODO
9+
// }
1010

1111
#[derive(Debug, Clone, Serialize, Deserialize, Eq, PartialEq)]
1212
pub struct Spender {
1313
pub total_deposited: UnifiedNum,
14-
pub spender_leaf: Option<SpenderLeaf>,
14+
pub total_spent: Option<UnifiedNum>,
1515
}
1616

1717
#[derive(Debug, Clone, PartialEq, Eq)]

sentry/src/routes/channel.rs

Lines changed: 12 additions & 20 deletions
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,7 @@ use primitives::{
1616
channel_list::ChannelListQuery, AccountingResponse, AllSpendersQuery, AllSpendersResponse,
1717
LastApproved, LastApprovedQuery, LastApprovedResponse, SpenderResponse, SuccessResponse,
1818
},
19-
spender::{Spendable, Spender, SpenderLeaf},
19+
spender::{Spendable, Spender},
2020
validator::{MessageTypes, NewState},
2121
Address, Channel, Deposit, UnifiedNum,
2222
};
@@ -190,7 +190,7 @@ fn spender_response_without_leaf(
190190
let res = SpenderResponse {
191191
spender: Spender {
192192
total_deposited,
193-
spender_leaf: None,
193+
total_spent: None,
194194
},
195195
};
196196
Ok(success_response(serde_json::to_string(&res)?))
@@ -235,23 +235,18 @@ pub async fn get_spender_limits<A: Adapter + 'static>(
235235
}
236236
};
237237

238-
let new_state = match get_corresponding_new_state(&app.pool, &app.logger, &channel).await? {
238+
let mut new_state = match get_corresponding_new_state(&app.pool, &app.logger, &channel).await? {
239239
Some(new_state) => new_state,
240240
None => return spender_response_without_leaf(latest_spendable.deposit.total),
241241
};
242242

243-
let total_spent = new_state.balances.spenders.get(&spender);
244-
245-
let spender_leaf = total_spent.map(|total_spent| SpenderLeaf {
246-
total_spent: *total_spent,
247-
//merkle_proof: [u8; 32], // TODO
248-
});
243+
let total_spent = new_state.balances.spenders.remove(&spender);
249244

250245
// returned output
251246
let res = SpenderResponse {
252247
spender: Spender {
253248
total_deposited: latest_spendable.deposit.total,
254-
spender_leaf,
249+
total_spent,
255250
},
256251
};
257252
Ok(success_response(serde_json::to_string(&res)?))
@@ -284,23 +279,20 @@ pub async fn get_all_spender_limits<A: Adapter + 'static>(
284279
// Using for loop to avoid async closures
285280
for spendable in all_spendables {
286281
let spender = spendable.spender;
287-
let spender_leaf = match new_state {
282+
let total_spent = match new_state {
288283
Some(ref new_state) => new_state.balances.spenders.get(&spender).map(|balance| {
289-
SpenderLeaf {
290-
total_spent: spendable
291-
.deposit
292-
.total
293-
.checked_sub(balance)
294-
.unwrap_or_default(),
295-
// merkle_proof: [u8; 32], // TODO
296-
}
284+
spendable
285+
.deposit
286+
.total
287+
.checked_sub(balance)
288+
.unwrap_or_default()
297289
}),
298290
None => None,
299291
};
300292

301293
let spender_info = Spender {
302294
total_deposited: spendable.deposit.total,
303-
spender_leaf,
295+
total_spent,
304296
};
305297

306298
all_spender_limits.insert(spender, spender_info);

test_harness/src/lib.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -606,7 +606,7 @@ mod tests {
606606
Spender {
607607
// Expected: 30 TOKENs
608608
total_deposited: UnifiedNum::from(3_000_000_000),
609-
spender_leaf: None,
609+
total_spent: None,
610610
},
611611
)]
612612
.into_iter()

validator_worker/src/sentry_interface.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -501,7 +501,7 @@ mod test {
501501
let server = MockServer::start().await;
502502
let test_spender = Spender {
503503
total_deposited: UnifiedNum::from(100_000_000),
504-
spender_leaf: None,
504+
total_spent: None,
505505
};
506506
let mut all_spenders = HashMap::new();
507507
all_spenders.insert(ADDRESSES["user"], test_spender.clone());

0 commit comments

Comments
 (0)