@@ -226,7 +226,8 @@ async fn get_gravity_volume_for_token(
226226 let mut logs = loga;
227227 logs. extend ( logsb) ;
228228 let ( v, i, o) =
229- sum_logs ( logs, gravity_contract_address, decimals, exchange_rate) ?;
229+ sum_logs ( logs, gravity_contract_address, decimals, exchange_rate)
230+ . map_err ( |e| * e) ?;
230231 volume += v;
231232 inflow += i;
232233 outflow += o;
@@ -277,13 +278,15 @@ fn sum_logs(
277278 gravity_contract_address : EthAddress ,
278279 decimals : u32 ,
279280 exchange_rate : f64 ,
280- ) -> Result < ( f64 , f64 , f64 ) , GravityError > {
281+ ) -> Result < ( f64 , f64 , f64 ) , Box < GravityError > > {
281282 let mut volume: f64 = 0u8 . into ( ) ;
282283 let mut inflow: f64 = 0u8 . into ( ) ;
283284 let mut outflow: f64 = 0u8 . into ( ) ;
284285 for l in logs {
285- let from = EthAddress :: from_slice ( & l. topics [ 1 ] [ 12 ..32 ] ) ?;
286- let to = EthAddress :: from_slice ( & l. topics [ 2 ] [ 12 ..32 ] ) ?;
286+ let from = EthAddress :: from_slice ( & l. topics [ 1 ] [ 12 ..32 ] )
287+ . map_err ( |e| Box :: new ( GravityError :: from ( e) ) ) ?;
288+ let to = EthAddress :: from_slice ( & l. topics [ 2 ] [ 12 ..32 ] )
289+ . map_err ( |e| Box :: new ( GravityError :: from ( e) ) ) ?;
287290 let amount = Uint256 :: from_be_bytes ( & l. data [ 0 ..32 ] ) ;
288291 if amount > u128:: MAX . into ( ) {
289292 warn ! ( "Found contract deploy!" ) ;
0 commit comments