Mohamed Sohail
2793d92343
* breaking: use event router, adsd telegram notifier, update indexer schema * fix: early ack on handler not found * fix: jetstream switch to new API, discard buffer on close * remove telegram dependency, rely on log alters instead, which indirectly connect to telegram via uptrace * feat (breaking): switch to self contained auto bootstrapper
34 lines
777 B
Go
34 lines
777 B
Go
package handler
|
|
|
|
import (
|
|
"context"
|
|
"math/big"
|
|
|
|
"github.com/grassrootseconomics/eth-tracker/pkg/event"
|
|
"github.com/lmittmann/w3"
|
|
"github.com/lmittmann/w3/module/eth"
|
|
)
|
|
|
|
const balanceThreshold = 5
|
|
|
|
func (h *Handler) IndexFaucetGive(ctx context.Context, event event.Event) error {
|
|
return h.store.InsertFaucetGive(ctx, event)
|
|
}
|
|
|
|
func (h *Handler) FaucetHealthCheck(ctx context.Context, event event.Event) error {
|
|
var balance *big.Int
|
|
|
|
if err := h.chainProvider.Client.CallCtx(
|
|
ctx,
|
|
eth.Balance(w3.A(event.ContractAddress), nil).Returns(&balance),
|
|
); err != nil {
|
|
return err
|
|
}
|
|
|
|
if balance.Cmp(new(big.Int).Mul(w3.BigEther, big.NewInt(balanceThreshold))) < 0 {
|
|
h.logg.Warn("faucet balance is less than 5 ether", "faucet", event.ContractAddress)
|
|
}
|
|
|
|
return nil
|
|
}
|