Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 4 additions & 0 deletions deployment/view/feequoter.go
Original file line number Diff line number Diff line change
Expand Up @@ -4,6 +4,7 @@ import (
"context"
"fmt"
"runtime"
"sync"

cldf_ton "github.com/smartcontractkit/chainlink-deployments-framework/chain/ton"
"github.com/xssnick/tonutils-go/address"
Expand Down Expand Up @@ -113,6 +114,7 @@ func fetchDestChainConfigsView(ctx context.Context, c cldf_ton.Chain, block *ton
selectorSlice := parseExecutionResultForDestChainSelectors(result.AsTuple())

var eg errgroup.Group
var mu sync.Mutex
eg.SetLimit(runtime.NumCPU())
output := make(map[uint64]DestChainConfig)
for _, dest := range selectorSlice {
Expand Down Expand Up @@ -148,7 +150,9 @@ func fetchDestChainConfigsView(ctx context.Context, c cldf_ton.Chain, block *ton
NetworkFeeUsdCents: cfg.NetworkFeeUsdCents,
}

mu.Lock()
output[dest] = destConfig
mu.Unlock()
return nil
})
}
Expand Down
4 changes: 4 additions & 0 deletions deployment/view/onramp.go
Original file line number Diff line number Diff line change
Expand Up @@ -4,6 +4,7 @@ import (
"context"
"fmt"
"runtime"
"sync"

cldf_ton "github.com/smartcontractkit/chainlink-deployments-framework/chain/ton"
"github.com/xssnick/tonutils-go/address"
Expand Down Expand Up @@ -94,6 +95,7 @@ func fetchDestChainConfig(ctx context.Context, c cldf_ton.Chain, block *ton.Bloc
var eg errgroup.Group
eg.SetLimit(runtime.NumCPU())
output := make(map[uint64]OnRampDestChainConfig)
var mu sync.Mutex
for _, dest := range chainSelectors {
// On-chain returns *big.Int for selector values, convert to uint64
eg.Go(func() error {
Expand Down Expand Up @@ -128,12 +130,14 @@ func fetchDestChainConfig(ctx context.Context, c cldf_ton.Chain, block *ton.Bloc
allowedSenders[senderAddr.String()] = allowed
}

mu.Lock()
output[dest] = OnRampDestChainConfig{
SequenceNumber: cfg.SequenceNumber,
AllowlistEnabled: cfg.AllowListEnabled,
Router: cfg.Router.String(),
AllowedSenders: allowedSenders,
}
mu.Unlock()

return nil
})
Expand Down
4 changes: 4 additions & 0 deletions deployment/view/router.go
Original file line number Diff line number Diff line change
Expand Up @@ -4,6 +4,7 @@ import (
"context"
"fmt"
"runtime"
"sync"

cldf_ton "github.com/smartcontractkit/chainlink-deployments-framework/chain/ton"
"github.com/xssnick/tonutils-go/address"
Expand Down Expand Up @@ -44,6 +45,7 @@ func FetchRouterView(ctx context.Context, c cldf_ton.Chain, block *ton.BlockIDEx
var onrampSlice *cell.Slice
var onRampAddr *address.Address
var eg errgroup.Group
var mu sync.Mutex
eg.SetLimit(runtime.NumCPU())
onRampAddrMap := make(map[uint64]*address.Address)
for _, dest := range selectorSlice {
Expand All @@ -63,7 +65,9 @@ func FetchRouterView(ctx context.Context, c cldf_ton.Chain, block *ton.BlockIDEx
return fmt.Errorf("failed to load onramp address: %w", err)
}

mu.Lock()
onRampAddrMap[dest] = onRampAddr
mu.Unlock()
return nil
})
}
Expand Down