| 123456789101112131415161718192021222324252627282930 |
- package algorand
- import (
- "context"
- "github.com/certusone/wormhole/node/pkg/common"
- "github.com/certusone/wormhole/node/pkg/readiness"
- )
- type (
- // Watcher is responsible for looking over Algorand blockchain and reporting new transactions to the contract
- Watcher struct {
- urlRPC string
- urlToken string
- contract string
- msgChan chan *common.MessagePublication
- setChan chan *common.GuardianSet
- }
- )
- // NewWatcher creates a new Algorand contract watcher
- func NewWatcher(urlRPC string, urlToken string, contract string, lockEvents chan *common.MessagePublication, setEvents chan *common.GuardianSet) *Watcher {
- return &Watcher{urlRPC: urlRPC, urlToken: urlToken, contract: contract, msgChan: lockEvents, setChan: setEvents}
- }
- func (e *Watcher) Run(ctx context.Context) error {
- readiness.SetReady(common.ReadinessAlgorandSyncing)
- select {}
- }
|