[wip] feat: implement

Author: gustavogama-cll

pkg/timelock/scheduler.go

@@ -26,6 +26,8 @@ type TimelockCallScheduled interface {
 	Index() int
 	BlockNumber() *big.Int
 	TxHash() string
+	Predecessor() eth.Hash
+	Salt() eth.Hash
 }
 
 type Scheduler interface {

pkg/timelock/scheduler_evm.go

@@ -4,6 +4,7 @@ import (
 	"fmt"
 	"math/big"
 
+	eth "github.com/ethereum/go-ethereum/common"
 	bindings "github.com/smartcontractkit/ccip-owner-contracts/gethwrappers"
 )
 
@@ -34,3 +35,11 @@ func (cs *evmTimelockCallScheduled) BlockNumber() *big.Int {
 func (cs *evmTimelockCallScheduled) TxHash() string {
 	return fmt.Sprintf("%x", cs.callScheduled.Raw.TxHash[:])
 }
+
+func (cs *evmTimelockCallScheduled) Predecessor() eth.Hash {
+	return cs.callScheduled.Predecessor
+}
+
+func (cs *evmTimelockCallScheduled) Salt() eth.Hash {
+	return cs.callScheduled.Salt
+}

pkg/timelock/scheduler_solana.go

@@ -2,6 +2,8 @@ package timelock
 
 import (
 	"math/big"
+
+	eth "github.com/ethereum/go-ethereum/common"
 )
 
 var _ TimelockCallScheduled = NewEVMTimelockCallScheduled(nil)
@@ -31,3 +33,11 @@ func (cs *solanaTimelockCallScheduled) BlockNumber() *big.Int {
 func (cs *solanaTimelockCallScheduled) TxHash() string {
 	return cs.callScheduledEvent.TxHash
 }
+
+func (cs *solanaTimelockCallScheduled) Predecessor() eth.Hash {
+	return cs.callScheduledEvent.Predecessor
+}
+
+func (cs *solanaTimelockCallScheduled) Salt() eth.Hash {
+	return cs.callScheduledEvent.Salt
+}

pkg/timelock/solana_event_types.go

@@ -8,6 +8,7 @@ import (
 	"math/big"
 	"strings"
 
+	eth "github.com/ethereum/go-ethereum/common"
 	bin "github.com/gagliardetto/binary"
 	"github.com/gagliardetto/solana-go"
 	"github.com/gagliardetto/solana-go/rpc"
@@ -34,8 +35,8 @@ type SolanaTimelockCallScheduledEvent struct {
 	ID          operationKey
 	Index       uint64
 	Target      solana.PublicKey
-	Predecessor operationKey
-	Salt        [32]byte
+	Predecessor eth.Hash
+	Salt        eth.Hash
 	Delay       uint64
 	Data        []byte
 	BlockNumber *big.Int `borsh_skip:"true"`

pkg/timelock/worker_solana.go

@@ -12,14 +12,16 @@ import (
 
 	"github.com/gagliardetto/solana-go"
 	"github.com/gagliardetto/solana-go/rpc"
-
 	"go.uber.org/zap"
+
+	mcmssolanasdk "github.com/smartcontractkit/mcms/sdk/solana"
 )
 
 // WorkerSolana represents a solana worker instance. It fetches periodically the latest signatures
 // and transactions from the Solana RPC node and dispatches them to the scheduler.
 type WorkerSolana struct {
 	solanaClient       *rpc.Client
+	timelockAddress    string
 	timelockProgramKey solana.PublicKey
 	pollPeriod         int64
 	listenerPollPeriod int64
@@ -28,6 +30,7 @@ type WorkerSolana struct {
 	logger             *zap.SugaredLogger
 	privateKey         solana.PrivateKey
 	lastSignature      *solana.Signature // last signature processed
+	inspector          *mcmssolanasdk.TimelockInspector
 	scheduler          Scheduler
 }
 
@@ -80,12 +83,13 @@ func NewTimelockWorkerSolana(
 		dryRun:             dryRun,
 		logger:             logger,
 		privateKey:         privateKeySolana,
+		inspector:          mcmssolanasdk.NewTimelockInspector(client),
 	}
 
 	if dryRun {
-		tWorker.scheduler = nil // TODO: add solana nopScheduler implementation
+		tWorker.scheduler = newNopScheduler(logger)
 	} else {
-		tWorker.scheduler = nil // TODO: add solana Scheduler implementation
+		tWorker.scheduler = newScheduler(time.Duration(pollPeriod)*time.Second, logger, tWorker.execute)
 	}
 
 	return tWorker, nil