certusone
/
wormhole
mirror of https://github.com/certusone/wormhole.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

add token info to transfer data 

commit-id:7d73cb43
This commit is contained in:
justinschuldt 2022-02-23 12:17:33 -06:00 committed by Justin Schuldt
parent d6d04f61bb
commit ccfc7fd13e
1 changed files with 20 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
event_database/cloud_functions/notional-transferred-to.go
View File

@ -31,11 +31,15 @@ var warmTransfersToCacheFilePath = "/notional-transferred-to-cache.json"
type TransferData struct { type TransferData struct {
TokenSymbol string TokenSymbol string
TokenName string
TokenAddress string
TokenAmount float64 TokenAmount float64
CoinGeckoCoinId string
OriginChain string OriginChain string
LeavingChain string LeavingChain string
DestinationChain string DestinationChain string
Notional float64 Notional float64
TokenPrice float64
} }
// finds all the TokenTransfer rows within the specified period // finds all the TokenTransfer rows within the specified period
@ -57,8 +61,21 @@ func fetchTransferRowsInInterval(tbl *bigtable.Table, ctx context.Context, prefi
log.Fatalf("failed to read NotionalUSD of row: %v. err %v ", row.Key(), err) log.Fatalf("failed to read NotionalUSD of row: %v. err %v ", row.Key(), err)
} }
t.Notional = notionalFloat t.Notional = notionalFloat
case "TokenTransferDetails:TokenPriceUSD":
reader := bytes.NewReader(item.Value)
var tokenPriceFloat float64
if err := binary.Read(reader, binary.BigEndian, &tokenPriceFloat); err != nil {
log.Fatalf("failed to read TokenPriceUSD of row: %v. err %v ", row.Key(), err)
}
t.TokenPrice = tokenPriceFloat
case "TokenTransferDetails:OriginSymbol": case "TokenTransferDetails:OriginSymbol":
t.TokenSymbol = string(item.Value) t.TokenSymbol = string(item.Value)
case "TokenTransferDetails:OriginName":
t.TokenName = string(item.Value)
case "TokenTransferDetails:OriginTokenAddress":
t.TokenAddress = string(item.Value)
case "TokenTransferDetails:CoinGeckoCoinId":
t.CoinGeckoCoinId = string(item.Value)
} }
} }
@ -90,7 +107,7 @@ func fetchTransferRowsInInterval(tbl *bigtable.Table, ctx context.Context, prefi
), ),
bigtable.ChainFilters( bigtable.ChainFilters(
bigtable.FamilyFilter(fmt.Sprintf("%v|%v", columnFamilies[2], columnFamilies[5])), bigtable.FamilyFilter(fmt.Sprintf("%v|%v", columnFamilies[2], columnFamilies[5])),
bigtable.ColumnFilter("Amount|NotionalUSD|OriginSymbol|OriginChain|TargetChain"), bigtable.ColumnFilter("Amount|NotionalUSD|OriginSymbol|OriginName|OriginChain|TargetChain|CoinGeckoCoinId|OriginTokenAddress|TokenPriceUSD"),
bigtable.LatestNFilter(1), bigtable.LatestNFilter(1),
), ),
bigtable.BlockAllFilter(), bigtable.BlockAllFilter(),
@ -145,7 +162,7 @@ func amountsTransferredToInInterval(tbl *bigtable.Table, ctx context.Context, pr
if dates, ok := warmTransfersToCache[cachePrefix]; ok { if dates, ok := warmTransfersToCache[cachePrefix]; ok {
// have a cache for this query // have a cache for this query
if dateCache, ok := dates[dateStr]; ok && len(dateCache) > 1 { if dateCache, ok := dates[dateStr]; ok && len(dateCache) > 1 && useCache(dateStr) {
// have a cache for this date // have a cache for this date
if daysAgo >= 1 { if daysAgo >= 1 {
// only use the cache for yesterday and older // only use the cache for yesterday and older
@ -182,7 +199,7 @@ func amountsTransferredToInInterval(tbl *bigtable.Table, ctx context.Context, pr
if daysAgo >= 1 { if daysAgo >= 1 {
// set the result in the cache // set the result in the cache
muWarmTransfersToCache.Lock() muWarmTransfersToCache.Lock()
if cacheData, ok := warmTransfersToCache[cachePrefix][dateStr]; !ok || len(cacheData) <= 1 { if cacheData, ok := warmTransfersToCache[cachePrefix][dateStr]; !ok || len(cacheData) <= 1 || !useCache(dateStr) {
// cache does not have this date, persist it for other instances. // cache does not have this date, persist it for other instances.
warmTransfersToCache[cachePrefix][dateStr] = results[dateStr] warmTransfersToCache[cachePrefix][dateStr] = results[dateStr]
cacheNeedsUpdate = true cacheNeedsUpdate = true