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

fix: use full address (#193)

This commit is contained in:
ftocal 2023-03-16 15:42:34 -03:00 committed by GitHub
parent bf0a18434c
commit db3a54270a
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
5 changed files with 11 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
api/handlers/governor/repository.go
View File

@ -1652,7 +1652,7 @@ func (r *Repository) IsVaaEnqueued(
matchStage6 := bson.D{
{"$match", bson.D{
{"chainid", chainID},
{"emitters.emitteraddress", fmt.Sprintf("0x%s", emitter.ShortHex())},
{"emitters.emitteraddress", fmt.Sprintf("0x%s", emitter.Hex())},
{"emitters.enqueuedvaas.sequence", sequence},
}},
}

6
api/handlers/observations/service.go
View File

@ -42,7 +42,7 @@ func (s *Service) FindByEmitter(
query := Query().
SetChain(chain).
SetEmitter(emitter.ShortHex()).
SetEmitter(emitter.Hex()).
SetPagination(p)
return s.repo.Find(ctx, query)
@ -59,7 +59,7 @@ func (s *Service) FindByVAA(
query := Query().
SetChain(chain).
SetEmitter(emitter.ShortHex()).
SetEmitter(emitter.Hex()).
SetSequence(seq).
SetPagination(p)
@ -78,7 +78,7 @@ func (s *Service) FindOne(
query := Query().
SetChain(chainID).
SetEmitter(emitterAddr.ShortHex()).
SetEmitter(emitterAddr.Hex()).
SetSequence(seq).
SetGuardianAddr(signerAddr.String()).
SetHash(hash)

2
api/handlers/transactions/service.go
View File

@ -31,7 +31,7 @@ func (s *Service) GetChainActivity(ctx context.Context, q *ChainActivityQuery) (
// FindGlobalTransactionByID find a global transaction by id.
func (s *Service) FindGlobalTransactionByID(ctx context.Context, chainID vaa.ChainID, emitter *types.Address, seq string) (*GlobalTransactionDoc, error) {
key := fmt.Sprintf("%d/%s/%s", chainID, emitter.ShortHex(), seq)
key := fmt.Sprintf("%d/%s/%s", chainID, emitter.Hex(), seq)
q := GlobalTransactionQuery{
id: key}
return s.repo.FindGlobalTransactionByID(ctx, q)

8
api/handlers/vaa/service.go
View File

@ -97,7 +97,7 @@ func (s *Service) FindByEmitter(
query := Query().
SetChain(chain).
SetEmitter(emitter.ShortHex()).
SetEmitter(emitter.Hex()).
SetPagination(p)
vaas, err := s.repo.Find(ctx, query)
@ -148,7 +148,7 @@ func (s *Service) findById(
query := Query().
SetChain(chain).
SetEmitter(emitter.ShortHex()).
SetEmitter(emitter.Hex()).
SetSequence(seq)
return s.repo.FindOne(ctx, query)
@ -159,7 +159,7 @@ func (s *Service) findByIdWithPayload(ctx context.Context, chain vaa.ChainID, em
query := Query().
SetChain(chain).
SetEmitter(emitter.ShortHex()).
SetEmitter(emitter.Hex()).
SetSequence(seq)
vaas, err := s.repo.FindVaasWithPayload(ctx, query)
@ -194,7 +194,7 @@ func (s *Service) GetVaaCount(ctx context.Context, p *pagination.Pagination) (*r
// the cached value of the sequence for this chainID, address.
// If the sequence does not exist we can not discard the request.
func (s *Service) discardVaaNotIndexed(ctx context.Context, chain vaa.ChainID, emitter *types.Address, seq string) bool {
key := fmt.Sprintf("%s:%d:%s", "wormscan:vaa-max-sequence", chain, emitter.ShortHex())
key := fmt.Sprintf("%s:%d:%s", "wormscan:vaa-max-sequence", chain, emitter.Hex())
sequence, err := s.getCacheFunc(ctx, key)
if err != nil {
if errors.Is(err, errs.ErrInternalError) {

4
api/routes/wormscan/governor/controller.go
View File

@ -65,7 +65,7 @@ func (c *Controller) FindGovernorConfigurationByGuardianAddress(ctx *fiber.Ctx)
}
// query the database
govConfigs, err := c.srv.FindGovernorConfigByGuardianAddress(ctx.Context(), guardianAddress.ShortHex())
govConfigs, err := c.srv.FindGovernorConfigByGuardianAddress(ctx.Context(), guardianAddress.Hex())
if err != nil {
return err
} else if len(govConfigs) == 0 {
@ -127,7 +127,7 @@ func (c *Controller) FindGovernorStatusByGuardianAddress(ctx *fiber.Ctx) error {
return err
}
govStatus, err := c.srv.FindGovernorStatusByGuardianAddress(ctx.Context(), guardianAddress.ShortHex(), p)
govStatus, err := c.srv.FindGovernorStatusByGuardianAddress(ctx.Context(), guardianAddress.Hex(), p)
if err != nil {
return err
}