Revive GetLastId messages

This commit is contained in:
Greg Fitzgerald
2018-05-14 09:35:10 -06:00
parent 455050e19c
commit dfb754dd13
3 changed files with 12 additions and 0 deletions

View File

@ -12,6 +12,7 @@ use transaction::Transaction;
pub enum Request { pub enum Request {
Transaction(Transaction), Transaction(Transaction),
GetBalance { key: PublicKey }, GetBalance { key: PublicKey },
GetLastId,
GetTransactionCount, GetTransactionCount,
Subscribe { subscriptions: Vec<Subscription> }, Subscribe { subscriptions: Vec<Subscription> },
} }
@ -41,6 +42,7 @@ impl Request {
#[derive(Serialize, Deserialize, Debug)] #[derive(Serialize, Deserialize, Debug)]
pub enum Response { pub enum Response {
Balance { key: PublicKey, val: Option<i64> }, Balance { key: PublicKey, val: Option<i64> },
LastId { id: Hash },
TransactionCount { transaction_count: u64 }, TransactionCount { transaction_count: u64 },
EntryInfo(EntryInfo), EntryInfo(EntryInfo),
} }

View File

@ -46,6 +46,12 @@ impl RequestProcessor {
info!("Response::Balance {:?}", rsp); info!("Response::Balance {:?}", rsp);
Some(rsp) Some(rsp)
} }
Request::GetLastId => {
let id = self.accountant.last_id();
let rsp = (Response::LastId { id }, rsp_addr);
info!("Response::LastId {:?}", rsp);
Some(rsp)
}
Request::GetTransactionCount => { Request::GetTransactionCount => {
let transaction_count = self.accountant.transaction_count() as u64; let transaction_count = self.accountant.transaction_count() as u64;
let rsp = (Response::TransactionCount { transaction_count }, rsp_addr); let rsp = (Response::TransactionCount { transaction_count }, rsp_addr);

View File

@ -64,6 +64,10 @@ impl ThinClient {
info!("Response balance {:?} {:?}", key, val); info!("Response balance {:?} {:?}", key, val);
self.balances.insert(key, val); self.balances.insert(key, val);
} }
Response::LastId { id } => {
info!("Response last_id {:?}", id);
self.last_id = Some(id);
}
Response::TransactionCount { transaction_count } => { Response::TransactionCount { transaction_count } => {
info!("Response transaction count {:?}", transaction_count); info!("Response transaction count {:?}", transaction_count);
self.transaction_count = transaction_count; self.transaction_count = transaction_count;