@@ -20,7 +20,7 @@ use serde_json::Value;
2020
2121use super :: DatabaseClient ;
2222
23- const BQ_RECEIPTS_TABLE_ID : & str = "receipts " ;
23+ const BQ_EXE_RESULTS_TABLE_ID : & str = "exe_results " ;
2424const BQ_BLOCKS_TABLE_ID : & str = "blocks" ;
2525const BQ_TRANSACTIONS_TABLE_ID : & str = "transactions" ;
2626
@@ -131,10 +131,10 @@ impl BigQueryDbClient {
131131 ] ,
132132 ) ,
133133 (
134- BQ_RECEIPTS_TABLE_ID ,
134+ BQ_EXE_RESULTS_TABLE_ID ,
135135 vec ! [
136136 TableFieldSchema :: string( "tx_hash" ) ,
137- TableFieldSchema :: json( "receipt " ) ,
137+ TableFieldSchema :: json( "exe_result " ) ,
138138 ] ,
139139 ) ,
140140 (
@@ -208,7 +208,7 @@ impl DatabaseClient for BigQueryDbClient {
208208 } ;
209209
210210 delete_table ( BQ_BLOCKS_TABLE_ID . to_owned ( ) ) . await ?;
211- delete_table ( BQ_RECEIPTS_TABLE_ID . to_owned ( ) ) . await ?;
211+ delete_table ( BQ_EXE_RESULTS_TABLE_ID . to_owned ( ) ) . await ?;
212212 delete_table ( BQ_TRANSACTIONS_TABLE_ID . to_owned ( ) ) . await ?;
213213
214214 Ok ( ( ) )
@@ -328,7 +328,7 @@ impl DatabaseClient for BigQueryDbClient {
328328
329329 log:: debug!( "Inserting {} receipts" , receipts. len( ) ) ;
330330
331- self . insert_batch_data ( BQ_RECEIPTS_TABLE_ID , receipts)
331+ self . insert_batch_data ( BQ_EXE_RESULTS_TABLE_ID , receipts)
332332 . await ?;
333333 }
334334
@@ -400,10 +400,10 @@ impl DatabaseClient for BigQueryDbClient {
400400 } ,
401401 ] ) ,
402402 query : format ! (
403- "SELECT receipt FROM `{project_id}.{dataset_id}.{table_id}` WHERE tx_hash = @tx_hash" ,
403+ "SELECT exe_result FROM `{project_id}.{dataset_id}.{table_id}` WHERE tx_hash = @tx_hash" ,
404404 project_id = self . project_id,
405405 dataset_id = self . dataset_id,
406- table_id = BQ_RECEIPTS_TABLE_ID ,
406+ table_id = BQ_EXE_RESULTS_TABLE_ID ,
407407 ) ,
408408 ..Default :: default ( )
409409 } ;
0 commit comments