@@ -1190,7 +1190,7 @@ func (bigtable *Bigtable) TransformContract(blk *types.Eth1Block, cache *freecac
1190
1190
utils .LogError (err , "error generating bigtable isContract timestamp" , 0 )
1191
1191
} else {
1192
1192
mutWrite .Set (ACCOUNT_METADATA_FAMILY , ACCOUNT_IS_CONTRACT , ts , b )
1193
- contractUpdateWrites .Keys = append (contractUpdateWrites .Keys , fmt .Sprintf ("%s:%x" , bigtable .chainId , address ))
1193
+ contractUpdateWrites .Keys = append (contractUpdateWrites .Keys , fmt .Sprintf ("%s:S: %x" , bigtable .chainId , address ))
1194
1194
contractUpdateWrites .Muts = append (contractUpdateWrites .Muts , mutWrite )
1195
1195
}
1196
1196
}
@@ -3661,15 +3661,15 @@ func (bigtable *Bigtable) getAddressIsContractHistories(histories map[string][]i
3661
3661
3662
3662
keys := make ([]string , 0 , len (histories ))
3663
3663
for address := range histories {
3664
- keys = append (keys , fmt .Sprintf ("%s:%s" , bigtable .chainId , address ))
3664
+ keys = append (keys , fmt .Sprintf ("%s:S: %s" , bigtable .chainId , address ))
3665
3665
}
3666
3666
3667
3667
ctx , cancel := context .WithDeadline (context .Background (), time .Now ().Add (time .Second * 30 ))
3668
3668
defer cancel ()
3669
3669
3670
3670
filter := gcp_bigtable .ChainFilters (gcp_bigtable .FamilyFilter (ACCOUNT_METADATA_FAMILY ), gcp_bigtable .ColumnFilter (ACCOUNT_IS_CONTRACT ))
3671
3671
3672
- keyPrefix := fmt .Sprintf ("%s:" , bigtable .chainId )
3672
+ keyPrefix := fmt .Sprintf ("%s:S: " , bigtable .chainId )
3673
3673
err := bigtable .tableMetadata .ReadRows (ctx , gcp_bigtable .RowList (keys ), func (row gcp_bigtable.Row ) bool {
3674
3674
// results are returned in reverse order, so highest ts is first
3675
3675
address := strings .TrimPrefix (row .Key (), keyPrefix )
@@ -4087,7 +4087,7 @@ func (bigtable *Bigtable) DeleteBlock(blockNumber uint64, blockHash []byte) erro
4087
4087
ctx , cancel := context .WithDeadline (context .Background (), time .Now ().Add (time .Second * 30 ))
4088
4088
defer cancel ()
4089
4089
4090
- err = bigtable .tableMetadata .ReadRows (ctx , gcp_bigtable .PrefixRange (bigtable .chainId ), func (row gcp_bigtable.Row ) bool {
4090
+ err = bigtable .tableMetadata .ReadRows (ctx , gcp_bigtable .PrefixRange (fmt . Sprintf ( "%s:S:" , bigtable .chainId ) ), func (row gcp_bigtable.Row ) bool {
4091
4091
mutDelete := gcp_bigtable .NewMutation ()
4092
4092
mutDelete .DeleteTimestampRange (ACCOUNT_METADATA_FAMILY , ACCOUNT_IS_CONTRACT , starttime , endtime )
4093
4093
0 commit comments