include token data in transferPrices collection
This commit is contained in:
parent
5c49a5ee9c
commit
1300ead930
|
@ -29,6 +29,12 @@ type TransferPriceDoc struct {
|
||||||
TokenAmount string `bson:"tokenAmount"`
|
TokenAmount string `bson:"tokenAmount"`
|
||||||
// UsdAmount is the value in USD of the token being transferred.
|
// UsdAmount is the value in USD of the token being transferred.
|
||||||
UsdAmount string `bson:"usdAmount"`
|
UsdAmount string `bson:"usdAmount"`
|
||||||
|
// TokenChain is the chain ID of the token being transferred.
|
||||||
|
TokenChain uint16 `bson:"tokenChain"`
|
||||||
|
// TokenAddress is the address of the token being transferred.
|
||||||
|
TokenAddress string `bson:"tokenAddress"`
|
||||||
|
// CoinGeckoID is the CoinGecko ID of the token being transferred.
|
||||||
|
CoinGeckoID string `bson:"coinGeckoId"`
|
||||||
}
|
}
|
||||||
|
|
||||||
func upsertTransferPrices(
|
func upsertTransferPrices(
|
||||||
|
@ -92,10 +98,13 @@ func upsertTransferPrices(
|
||||||
SymbolPriceUsd: notionalUSD.Truncate(8).String(),
|
SymbolPriceUsd: notionalUSD.Truncate(8).String(),
|
||||||
TokenAmount: tokenAmount.Truncate(8).String(),
|
TokenAmount: tokenAmount.Truncate(8).String(),
|
||||||
UsdAmount: usdAmount.Truncate(8).String(),
|
UsdAmount: usdAmount.Truncate(8).String(),
|
||||||
|
TokenChain: uint16(transferredToken.TokenChain),
|
||||||
|
TokenAddress: transferredToken.TokenAddress.String(),
|
||||||
|
CoinGeckoID: tokenMeta.CoingeckoID,
|
||||||
},
|
},
|
||||||
}
|
}
|
||||||
_, err = transferPrices.UpdateByID(
|
_, err = transferPrices.UpdateByID(
|
||||||
context.Background(),
|
ctx,
|
||||||
vaa.MessageID(),
|
vaa.MessageID(),
|
||||||
update,
|
update,
|
||||||
options.Update().SetUpsert(true),
|
options.Update().SetUpsert(true),
|
||||||
|
|
Loading…
Reference in New Issue