Commit Graph

23 Commits

Author SHA1 Message Date
ftocal 1c075e3745
Add worker pool to process observations from gossip network (#909)
Co-authored-by: walker-16 <agpazos85@gmail.com>
2023-12-18 10:41:07 -03:00
ftocal 7c467f5267
Integrating blockchain watcher data into mongodb (#820)
* Handle log-message-published generated by blockchain-watcher in parser, tx-tracker y analytics

* Add deployment for staging-testnet environment
Improve logs

* Add operation endpoints

---------

Co-authored-by: Agustin Pazos <agpazos85@gmail.com>
2023-11-27 12:31:35 -03:00
ftocal 91bf42971b
Use Redis channel in spy and fly (#753) 2023-10-18 11:18:32 -03:00
agodnic 3c7bab3f8a
Remove duplicated code: MongoDB connection handling (#590)
### Description

This pull request removes duplicated code related to MongoDB connection/disconnection attempts. This code was copied across all 8 microservices.

The functionality is now unified under the `common/dbutil` package.
2023-08-07 16:05:08 -03:00
walker-16 75fffe3ef6
add warning alert and metrics to fly component (#576)
* Add unknown guardian set index alert

* Add prometheus metrics to check if exists observations without txhash

* Add max sequence cache error prometheus metrics
2023-07-25 15:39:27 -03:00
walker-16 914580cfdc
Add critical opsgenie alert to fly (#463) 2023-06-27 12:17:33 -03:00
walker-16 737405054a
446 create prometheus metrics (#457)
* Add vaa metrics

* Add dummy metrics and observations metrics

* Add heartbeat, governorConfig, governorStatus metrics

* fix go.sum

* Add deploy en vars METRICS_ENABLED to fly component

Co-authored-by: ftocal <fert1335@gmail.com>

---------

Co-authored-by: Fernando Torres <fert1335@gmail.com>
2023-06-26 12:47:22 -03:00
walker-16 25b891f6d2
Add opsgenie client + error saving vaa alert in fly component (#442) 2023-06-22 18:59:23 -03:00
ftocal 9381695d37
Fix txHash encoding by chain (#410)
Add txHash encondig backfiller
Handle txHash base58 encoding for solana in tx-tracker
Add temporary field _originTxHash in vaas and vaaIdTxHash collections by backup
Add cobra to fly backfiller

Co-authored-by: walker-16 <agpazos85@gmail.com>
2023-06-15 09:57:39 -03:00
gipsh 2db8f58092
Fly backfiller (#106)
* change repo to support backfill of txhash

* generic backfiller for vaas and txhash

* update deps

* remove unused code

---------

Co-authored-by: gipsh <gipsh@gmail.com>
2023-01-30 10:20:38 -03:00
ftocal 215a00ccc8
fix: use txHash from observation (#100) 2023-01-26 17:58:37 -03:00
ftocal e20e73c636
Add txHash in VAA (#94)
* add vaaId and txHash relation in vaaIdTxHash collection

* add txHash in vaas collection

* add txHash in response vaa and as filter in find vaas endpoints
2023-01-26 11:54:41 -03:00
Fernando Torres 99e895d600 Fix mongo types in Fly 2023-01-02 11:14:13 -03:00
Gabriel Zimmermann 43c529e5d3
Do not store pythnet observations (#49) 2022-12-26 19:30:58 -03:00
walker-16 bfd68061a8
Fix: change sequence type to string (#42)
Co-authored-by: Fernando Torres <fert1335@gmail.com>
2022-12-14 16:26:45 -03:00
walker-16 e245d7a8b0
Add index collections and health/ready kubernetes (#37) 2022-12-05 17:41:37 -03:00
ftocal d7e2cd55fe
Fly: Deduplicate & use persistent queue for incoming VAAs (#28)
* Deduplication of vaas messages
Use persistent queue for vaas messages (except for pyth)
Add local flag for local execution (use a memory queue)

* Improve names for consumers
Add deduplication in memory for all vaas messages and tests
Split incoming vaas (pyth and non pyth) into different channels and tests

* Check if queue message is expired

* Code review updates
2022-11-21 11:18:33 -03:00
walker-16 d4f43e37d6
Adds go rest api (#29)
* Adds api in go

* renames observation import in api

* Add signed_vaa endpoint [guardian api]

* Add governor endpoints to API

* fix devnet/api.yaml to up with a fixed port

Co-authored-by: Gabriel Zimmermann <gabrielemanuel@gmail.com>
2022-11-17 12:37:29 -03:00
ftocal e1e31548ff
Fly: handling for pyth message from pythnet (#23)
* Add support to pyth message without migration

* Refactor MongoDB migration

* Add vaa count collection for quantity of vaa per chainId

* Refactor for code review request

Co-authored-by: Agustin Pazos <agpazos85@gmail.com>
2022-11-08 14:58:22 -03:00
ckeun 5ccd3f9139
Fly: upgrade wormhole dependency & add governor p2p channels (#22)
* Testing new storage changes

* Fixed vaa module dependency

* Added govcfg & gov status upserts

* Update main.go

* Removed unnessarily hack arounds in go.mod
2022-11-08 08:53:12 -06:00
Gabriel Zimmermann 51892ec5b6 adds early exit if obs verification failed, styling fixes, early exit if db connection failed; changes based on code review 2022-11-07 15:18:52 -03:00
Gabriel Zimmermann c37b3c6564 remove invalid vaa storage 2022-11-07 15:18:52 -03:00
Gabriel Zimmermann 2860f34cff refactors storage into separate layer 2022-11-07 15:18:52 -03:00