Skip to content

Update to use the new SDK and the new protos generated in common #18488

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
nolag merged 13 commits into from
Jul 7, 2025
Merged

Update to use the new SDK and the new protos generated in common #18488

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
13 commits
Select commit Hold shift + click to select a range
8b64bb1
Update to use the new SDK and the new protos generated in common
nolag Jul 4, 2025
6ffde3e
Merge branch 'develop' into rtinianov_updateSdkAndServer
nolag Jul 4, 2025
9e7b0c2
Regenerate to fix md and fix evm_chain
nolag Jul 4, 2025
6bf4d64
Passes v2 test
nolag Jul 7, 2025
e892c82
Merge branch 'develop' into rtinianov_updateSdkAndServer
nolag Jul 7, 2025
5185ede
Fix md with generate...?
nolag Jul 7, 2025
3da663a
Fix lint
nolag Jul 7, 2025
fa87480
attempt to fix lint
nolag Jul 7, 2025
81f5d45
Fix ref to test capabilities
nolag Jul 7, 2025
cf11fe0
Fix consensus no dag
nolag Jul 7, 2025
a130fb4
Fix lint for real
nolag Jul 7, 2025
bd6dfe6
imports again after removing all lines...
nolag Jul 7, 2025
d5d255c
remove duplicate import
nolag Jul 7, 2025
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
3 changes: 2 additions & 1 deletion core/capabilities/fakes/consensus_nodag.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -12,14 +12,15 @@ import (

ocr2types "github.com/smartcontractkit/libocr/offchainreporting2/types"

"github.com/smartcontractkit/cre-sdk-go/sdk"

"github.com/smartcontractkit/chainlink-common/pkg/capabilities"
consensustypes "github.com/smartcontractkit/chainlink-common/pkg/capabilities/consensus/ocr3/types"
consensusserver "github.com/smartcontractkit/chainlink-common/pkg/capabilities/v2/consensus/server"
"github.com/smartcontractkit/chainlink-common/pkg/logger"
"github.com/smartcontractkit/chainlink-common/pkg/services"
"github.com/smartcontractkit/chainlink-common/pkg/types/core"
valuespb "github.com/smartcontractkit/chainlink-common/pkg/values/pb"
"github.com/smartcontractkit/chainlink-common/pkg/workflows/sdk/v2"
sdkpb "github.com/smartcontractkit/chainlink-common/pkg/workflows/sdk/v2/pb"
"github.com/smartcontractkit/chainlink/v2/core/services/keystore/keys/ocr2key"
"github.com/smartcontractkit/chainlink/v2/core/services/relay/evm"
Expand Down
4 changes: 2 additions & 2 deletions core/capabilities/fakes/evm_chain.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -111,9 +111,9 @@ func (fc *FakeEVMChain) WriteReport(ctx context.Context, metadata commonCap.Requ
fc.eng.Infow("EVM Chain WriteReport Finished")

return &evmcappb.WriteReportReply{
TxStatus: evmcappb.TxStatus_TX_SUCCESS,
TxStatus: evmcappb.TxStatus_TX_STATUS_SUCCESS,
TxHash: []byte{},
ReceiverContractExecutionStatus: evmcappb.ReceiverContractExecutionStatus_SUCCESS.Enum(),
ReceiverContractExecutionStatus: evmcappb.ReceiverContractExecutionStatus_RECEIVER_CONTRACT_EXECUTION_STATUS_SUCCESS.Enum(),
TransactionFee: pb.NewBigIntFromInt(big.NewInt(0)), // TODO: add transaction fee
ErrorMessage: nil,
}, nil
Expand Down
5 changes: 3 additions & 2 deletions core/scripts/go.mod
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -40,8 +40,8 @@ require (
github.com/smartcontractkit/chain-selectors v1.0.62-0.20250630182638-8bd9c28cf772
github.com/smartcontractkit/chainlink-automation v0.8.1
github.com/smartcontractkit/chainlink-ccip v0.0.0-20250703172708-3dacb811e668
github.com/smartcontractkit/chainlink-common v0.7.1-0.20250704132534-297ef736ccd7
github.com/smartcontractkit/chainlink-common/pkg/values v0.0.0-20250702175503-91331140edc3
github.com/smartcontractkit/chainlink-common v0.7.1-0.20250707133321-27faefc9ce45
github.com/smartcontractkit/chainlink-common/pkg/values v0.0.0-20250707133321-27faefc9ce45
github.com/smartcontractkit/chainlink-data-streams v0.1.1-0.20250604171706-a98fa6515eae
github.com/smartcontractkit/chainlink-deployments-framework v0.17.0
github.com/smartcontractkit/chainlink-evm v0.0.0-20250707113334-93191f4c5ff4
Expand Down Expand Up @@ -451,6 +451,7 @@ require (
github.com/smartcontractkit/ccip-owner-contracts v0.1.0 // indirect
github.com/smartcontractkit/chainlink-aptos v0.0.0-20250626122206-319db248496a // indirect
github.com/smartcontractkit/chainlink-ccip/chains/solana v0.0.0-20250609091505-5c8cd74b92ed // indirect
github.com/smartcontractkit/chainlink-common/pkg/workflows/sdk/v2/pb v0.0.0-20250707133321-27faefc9ce45 // indirect
github.com/smartcontractkit/chainlink-feeds v0.1.2-0.20250227211209-7cd000095135 // indirect
github.com/smartcontractkit/chainlink-framework/capabilities v0.0.0-20250702183345-3f9ae622e391 // indirect
github.com/smartcontractkit/chainlink-framework/chains v0.0.0-20250627121608-e7b52913fae2 // indirect
Expand Down
12 changes: 8 additions & 4 deletions core/scripts/go.sum
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -1511,12 +1511,14 @@ github.com/smartcontractkit/chainlink-ccip v0.0.0-20250703172708-3dacb811e668 h1
github.com/smartcontractkit/chainlink-ccip v0.0.0-20250703172708-3dacb811e668/go.mod h1:zPpo78Fv3zQE3WVZFEqRiRNER9QHaCzl+HNeTSaS0kE=
github.com/smartcontractkit/chainlink-ccip/chains/solana v0.0.0-20250609091505-5c8cd74b92ed h1:rjtXQLTCLa/+AmMwMTP5WwJUdPBeBAF3Ivwc1GXetBw=
github.com/smartcontractkit/chainlink-ccip/chains/solana v0.0.0-20250609091505-5c8cd74b92ed/go.mod h1:k3/Z6AvwurPUlfuDFEonRbkkiTSgNSrtVNhJEWNlUZA=
github.com/smartcontractkit/chainlink-common v0.7.1-0.20250704132534-297ef736ccd7 h1:IESBnxL/0TOs9nR31RVMxddgoO3pP0qwgWi06+0vm2A=
github.com/smartcontractkit/chainlink-common v0.7.1-0.20250704132534-297ef736ccd7/go.mod h1:mIJBT+bsThlr9GCiWAXMiKuEVckQfc9JUM1g4azZEis=
github.com/smartcontractkit/chainlink-common v0.7.1-0.20250707133321-27faefc9ce45 h1:EPlVedH4Sxm3R5iNvy160+stnFIYJR+iPHnU2XYOZVY=
github.com/smartcontractkit/chainlink-common v0.7.1-0.20250707133321-27faefc9ce45/go.mod h1:SrzacsyKxhRg/U0fNJc1aMwiZJLq064dZ4Pk5dWCNrg=
github.com/smartcontractkit/chainlink-common/pkg/monitoring v0.0.0-20250415235644-8703639403c7 h1:9wh1G+WbXwPVqf0cfSRSgwIcaXTQgvYezylEAfwmrbw=
github.com/smartcontractkit/chainlink-common/pkg/monitoring v0.0.0-20250415235644-8703639403c7/go.mod h1:yaDOAZF6MNB+NGYpxGCUc+owIdKrjvFW0JODdTcQ3V0=
github.com/smartcontractkit/chainlink-common/pkg/values v0.0.0-20250702175503-91331140edc3 h1:r2bveTQfaijoqR/WUXpbVfhux+G39SphMyUB7As6HoY=
github.com/smartcontractkit/chainlink-common/pkg/values v0.0.0-20250702175503-91331140edc3/go.mod h1:QUEPHdSkH19Or+E1iMGG+rDQ6jpCTIbm//9Osa6MXDE=
github.com/smartcontractkit/chainlink-common/pkg/values v0.0.0-20250707133321-27faefc9ce45 h1:T+yPdzVifh/oVrfVUXYhNqgJG4ubB+yVODtBxVT6esQ=
github.com/smartcontractkit/chainlink-common/pkg/values v0.0.0-20250707133321-27faefc9ce45/go.mod h1:U1UAbPhy6D7Qz0wHKGPoQO+dpR0hsYjgUz8xwRrmKwI=
github.com/smartcontractkit/chainlink-common/pkg/workflows/sdk/v2/pb v0.0.0-20250707133321-27faefc9ce45 h1:ii/BXtlqSwl8dlgRFoDYiZNTDCNcSgZJyfFwiWyYmsg=
github.com/smartcontractkit/chainlink-common/pkg/workflows/sdk/v2/pb v0.0.0-20250707133321-27faefc9ce45/go.mod h1:2w3TPI7vLgJfFmhhxWjtkwoQzoo8AQT8zsp90TqJ+mM=
github.com/smartcontractkit/chainlink-data-streams v0.1.1-0.20250604171706-a98fa6515eae h1:BmqiIDbA9FB/uOCOHi/shgL7P0XmjFxhfRtJHdKPLE4=
github.com/smartcontractkit/chainlink-data-streams v0.1.1-0.20250604171706-a98fa6515eae/go.mod h1:2MggrMtbhqr0u4U2pcYa21lvAtvaeSawjxdIy1ytHWE=
github.com/smartcontractkit/chainlink-deployments-framework v0.17.0 h1:o/Lu+ynF11wxGf5lVks31bmkmO1+m2KVXWbwn6g80HM=
Expand Down Expand Up @@ -1561,6 +1563,8 @@ github.com/smartcontractkit/chainlink-tron/relayer v0.0.11-0.20250701132001-f8be
github.com/smartcontractkit/chainlink-tron/relayer v0.0.11-0.20250701132001-f8be142155b6/go.mod h1:EQl7VcrSvpSNOL8qWkc2CV/2cOII5CIkKTeIqzqCWKk=
github.com/smartcontractkit/chainlink-tron/relayer/gotron-sdk v0.0.5-0.20250422175525-b7575d96bd4d h1:qLmSOOtB/Ogn79eIDkuujOu8M5Jd747V1H7Brk/nTvo=
github.com/smartcontractkit/chainlink-tron/relayer/gotron-sdk v0.0.5-0.20250422175525-b7575d96bd4d/go.mod h1:4WhGgCA0smBbBud5mK+jnDb2wwndMvoqaWBJ3OV/7Bw=
github.com/smartcontractkit/cre-sdk-go v0.0.0-20250707153600-4506f1b6b342 h1:77BqCILtcSbUff/XY2qzFBc3e5q8+5pUZ+prOsQk8ig=
github.com/smartcontractkit/cre-sdk-go v0.0.0-20250707153600-4506f1b6b342/go.mod h1:ZZ2aIxhdKsk2l1az3UklGLDOD1gj+jtJK7qTrn1lsNo=
github.com/smartcontractkit/freeport v0.1.1 h1:B5fhEtmgomdIhw03uPVbVTP6oPv27fBhZsoZZMSIS8I=
github.com/smartcontractkit/freeport v0.1.1/go.mod h1:T4zH9R8R8lVWKfU7tUvYz2o2jMv1OpGCdpY2j2QZXzU=
github.com/smartcontractkit/grpc-proxy v0.0.0-20240830132753-a7e17fec5ab7 h1:12ijqMM9tvYVEm+nR826WsrNi6zCKpwBhuApq127wHs=
Expand Down
4 changes: 2 additions & 2 deletions core/services/workflows/cmd/cre/examples/v2/empty/main.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -3,8 +3,8 @@
package main

import (
"github.com/smartcontractkit/chainlink-common/pkg/workflows/sdk/v2"
"github.com/smartcontractkit/chainlink-common/pkg/workflows/wasm/v2"
"github.com/smartcontractkit/cre-sdk-go/sdk"
"github.com/smartcontractkit/cre-sdk-go/sdk/wasm"
)

func RunEmptyWorkflow(_ *sdk.Environment[struct{}]) (sdk.Workflow[struct{}], error) {
Expand Down
8 changes: 4 additions & 4 deletions core/services/workflows/cmd/cre/examples/v2/http_read/main.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -3,10 +3,10 @@
package main

import (
"github.com/smartcontractkit/chainlink-common/pkg/capabilities/v2/actions/http"
"github.com/smartcontractkit/chainlink-common/pkg/capabilities/v2/triggers/cron"
"github.com/smartcontractkit/chainlink-common/pkg/workflows/sdk/v2"
"github.com/smartcontractkit/chainlink-common/pkg/workflows/wasm/v2"
"github.com/smartcontractkit/cre-sdk-go/capabilities/networking/http"
"github.com/smartcontractkit/cre-sdk-go/capabilities/scheduler/cron"
"github.com/smartcontractkit/cre-sdk-go/sdk"
"github.com/smartcontractkit/cre-sdk-go/sdk/wasm"
)

func RunSimpleCronWorkflow(_ *sdk.Environment[struct{}]) (sdk.Workflow[struct{}], error) {
Expand Down
6 changes: 3 additions & 3 deletions core/services/workflows/cmd/cre/examples/v2/simple_cron/main.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -3,9 +3,9 @@
package main

import (
"github.com/smartcontractkit/chainlink-common/pkg/capabilities/v2/triggers/cron"
"github.com/smartcontractkit/chainlink-common/pkg/workflows/sdk/v2"
"github.com/smartcontractkit/chainlink-common/pkg/workflows/wasm/v2"
"github.com/smartcontractkit/cre-sdk-go/capabilities/scheduler/cron"
"github.com/smartcontractkit/cre-sdk-go/sdk"
"github.com/smartcontractkit/cre-sdk-go/sdk/wasm"
)

func RunSimpleCronWorkflow(_ *sdk.Environment[struct{}]) (sdk.Workflow[struct{}], error) {
Expand Down
6 changes: 3 additions & 3 deletions core/services/workflows/cmd/cre/examples/v2/simple_cron_with_config/main.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -5,9 +5,9 @@ package main
import (
"fmt"

"github.com/smartcontractkit/chainlink-common/pkg/capabilities/v2/triggers/cron"
"github.com/smartcontractkit/chainlink-common/pkg/workflows/sdk/v2"
"github.com/smartcontractkit/chainlink-common/pkg/workflows/wasm/v2"
"github.com/smartcontractkit/cre-sdk-go/capabilities/scheduler/cron"
"github.com/smartcontractkit/cre-sdk-go/sdk"
"github.com/smartcontractkit/cre-sdk-go/sdk/wasm"
"gopkg.in/yaml.v3"
)

Expand Down
4 changes: 2 additions & 2 deletions core/services/workflows/cmd/cre/examples/v2/simple_cron_with_secrets/main.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,9 +6,9 @@ import (
"fmt"

"github.com/smartcontractkit/chainlink-common/pkg/capabilities/v2/triggers/cron"
"github.com/smartcontractkit/chainlink-common/pkg/workflows/sdk/v2"
"github.com/smartcontractkit/chainlink-common/pkg/workflows/sdk/v2/pb"
"github.com/smartcontractkit/chainlink-common/pkg/workflows/wasm/v2"
"github.com/smartcontractkit/cre-sdk-go/sdk"
"github.com/smartcontractkit/cre-sdk-go/sdk/wasm"
"gopkg.in/yaml.v3"
)

Expand Down
6 changes: 3 additions & 3 deletions core/services/workflows/test/wasm/v2/cmd/main.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -3,10 +3,10 @@
package main

import (
"github.com/smartcontractkit/chainlink-common/pkg/workflows/testhelpers/v2"
"github.com/smartcontractkit/chainlink-common/pkg/workflows/wasm/v2"
"github.com/smartcontractkit/cre-sdk-go/sdk/testutils"
"github.com/smartcontractkit/cre-sdk-go/sdk/wasm"
)

func main() {
testhelpers.RunTestWorkflow(wasm.NewRunner(func(b []byte) (string, error) { return string(b), nil }))
testutils.RunTestWorkflow(wasm.NewRunner(func(b []byte) (string, error) { return string(b), nil }))
}
6 changes: 3 additions & 3 deletions core/services/workflows/test/wasm/v2/cmd/with_config/main.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -3,9 +3,9 @@
package main

import (
"github.com/smartcontractkit/chainlink-common/pkg/capabilities/v2/protoc/pkg/test_capabilities/basictrigger"
"github.com/smartcontractkit/chainlink-common/pkg/workflows/sdk/v2"
"github.com/smartcontractkit/chainlink-common/pkg/workflows/wasm/v2"
"github.com/smartcontractkit/cre-sdk-go/internal_testing/capabilities/basictrigger"
"github.com/smartcontractkit/cre-sdk-go/sdk"
"github.com/smartcontractkit/cre-sdk-go/sdk/wasm"
"gopkg.in/yaml.v3"
)

Expand Down
6 changes: 3 additions & 3 deletions core/services/workflows/test/wasm/v2/cmd/with_secrets/main.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -3,10 +3,10 @@
package main

import (
"github.com/smartcontractkit/chainlink-common/pkg/capabilities/v2/protoc/pkg/test_capabilities/basictrigger"
"github.com/smartcontractkit/chainlink-common/pkg/workflows/sdk/v2"
"github.com/smartcontractkit/chainlink-common/pkg/workflows/sdk/v2/pb"
"github.com/smartcontractkit/chainlink-common/pkg/workflows/wasm/v2"
"github.com/smartcontractkit/cre-sdk-go/internal_testing/capabilities/basictrigger"
"github.com/smartcontractkit/cre-sdk-go/sdk"
"github.com/smartcontractkit/cre-sdk-go/sdk/wasm"
"gopkg.in/yaml.v3"
)

Expand Down
97 changes: 83 additions & 14 deletions core/services/workflows/v2/engine_test.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -11,29 +11,28 @@ import (
"testing"
"time"

"github.com/smartcontractkit/cre-sdk-go/internal_testing/capabilities/basicaction"
basicactionmock "github.com/smartcontractkit/cre-sdk-go/internal_testing/capabilities/basicaction/mock"
"github.com/smartcontractkit/cre-sdk-go/internal_testing/capabilities/basictrigger"
basictriggermock "github.com/smartcontractkit/cre-sdk-go/internal_testing/capabilities/basictrigger/mock"
"github.com/smartcontractkit/cre-sdk-go/sdk/testutils/registry"
ragetypes "github.com/smartcontractkit/libocr/ragep2p/types"
"github.com/stretchr/testify/assert"
"github.com/stretchr/testify/mock"
"github.com/stretchr/testify/require"
"google.golang.org/protobuf/proto"
"google.golang.org/protobuf/types/known/emptypb"

"github.com/stretchr/testify/assert"
"github.com/stretchr/testify/require"

ragetypes "github.com/smartcontractkit/libocr/ragep2p/types"

"github.com/smartcontractkit/chainlink-common/pkg/beholder/beholdertest"
beholderpb "github.com/smartcontractkit/chainlink-common/pkg/beholder/pb"
"github.com/smartcontractkit/chainlink-common/pkg/capabilities"
"github.com/smartcontractkit/chainlink-common/pkg/capabilities/actions/vault"
vaultMock "github.com/smartcontractkit/chainlink-common/pkg/capabilities/actions/vault/mock"
"github.com/smartcontractkit/chainlink-common/pkg/capabilities/v2/protoc/pkg/test_capabilities/basicaction"
basicactionmock "github.com/smartcontractkit/chainlink-common/pkg/capabilities/v2/protoc/pkg/test_capabilities/basicaction/basic_actionmock"
"github.com/smartcontractkit/chainlink-common/pkg/capabilities/v2/protoc/pkg/test_capabilities/basictrigger"
basictriggermock "github.com/smartcontractkit/chainlink-common/pkg/capabilities/v2/protoc/pkg/test_capabilities/basictrigger/basic_triggermock"
capabilitiespb "github.com/smartcontractkit/chainlink-common/pkg/capabilities/pb"
"github.com/smartcontractkit/chainlink-common/pkg/custmsg"
regmocks "github.com/smartcontractkit/chainlink-common/pkg/types/core/mocks"
"github.com/smartcontractkit/chainlink-common/pkg/values"
sdkpb "github.com/smartcontractkit/chainlink-common/pkg/workflows/sdk/v2/pb"
"github.com/smartcontractkit/chainlink-common/pkg/workflows/sdk/v2/testutils/registry"
"github.com/smartcontractkit/chainlink-common/pkg/workflows/wasm/host"
modulemocks "github.com/smartcontractkit/chainlink-common/pkg/workflows/wasm/host/mocks"
billing "github.com/smartcontractkit/chainlink-protos/billing/go"
Expand Down Expand Up @@ -578,10 +577,10 @@ func TestEngine_WASMBinary_Simple(t *testing.T) {
}

triggerMock, basicActionMock := setupExpectedCalls(t)
wrappedTriggerMock := &registry.CapabilityWrapper{
wrappedTriggerMock := &CapabilityWrapper{
Capability: triggerMock,
}
wrappedActionMock := &registry.CapabilityWrapper{
wrappedActionMock := &CapabilityWrapper{
Capability: basicActionMock,
}

Expand Down Expand Up @@ -696,7 +695,7 @@ func TestEngine_WASMBinary_With_Config(t *testing.T) {
require.Equal(t, giveNum, input.Number)
return &basictrigger.Outputs{CoolOutput: "Hello, "}, nil
}
wrappedTriggerMock := &registry.CapabilityWrapper{
wrappedTriggerMock := &CapabilityWrapper{
Capability: triggerMock,
}
beholderObserver := beholdertest.NewObserver(t)
Expand Down Expand Up @@ -823,7 +822,7 @@ func TestSecretsFetcher_Integration(t *testing.T) {
require.Equal(t, giveNum, input.Number)
return &basictrigger.Outputs{CoolOutput: "Hello, "}, nil
}
wrappedTriggerMock := &registry.CapabilityWrapper{
wrappedTriggerMock := &CapabilityWrapper{
Capability: triggerMock,
}

Expand Down Expand Up @@ -986,3 +985,73 @@ func newNode(t *testing.T) capabilities.Node {
PeerID: &peerID,
}
}

type CapabilityWrapper struct {
registry.Capability
}

var _ capabilities.ExecutableAndTriggerCapability = (*CapabilityWrapper)(nil)

func (c *CapabilityWrapper) RegisterTrigger(ctx context.Context, request capabilities.TriggerRegistrationRequest) (<-chan capabilities.TriggerResponse, error) {
ch := make(chan capabilities.TriggerResponse, 1)
defer close(ch)
trigger, err := c.InvokeTrigger(ctx, &sdkpb.TriggerSubscription{
Id: request.TriggerID,
Payload: request.Payload,
Method: request.Method,
})
if err != nil {
ch <- capabilities.TriggerResponse{Err: err}
}

if trigger == nil {
return nil, nil
}

ch <- capabilities.TriggerResponse{
Event: capabilities.TriggerEvent{
TriggerType: request.TriggerID,
Payload: trigger.Payload,
},
}

return ch, nil
}

func (c *CapabilityWrapper) UnregisterTrigger(_ context.Context, _ capabilities.TriggerRegistrationRequest) error {
return nil
}

func (c *CapabilityWrapper) RegisterToWorkflow(_ context.Context, _ capabilities.RegisterToWorkflowRequest) error {
return nil
}

func (c *CapabilityWrapper) UnregisterFromWorkflow(_ context.Context, _ capabilities.UnregisterFromWorkflowRequest) error {
return nil
}

func (c *CapabilityWrapper) Execute(ctx context.Context, request capabilities.CapabilityRequest) (capabilities.CapabilityResponse, error) {
v1Request := capabilitiespb.CapabilityRequestToProto(request)
v2Request := &sdkpb.CapabilityRequest{
Id: v1Request.Metadata.ReferenceId,
Payload: v1Request.Payload,
Method: v1Request.Method,
}

v2Response := c.Invoke(ctx, v2Request)
switch r := v2Response.Response.(type) {
case *sdkpb.CapabilityResponse_Error:
return capabilities.CapabilityResponse{}, errors.New(r.Error)
case *sdkpb.CapabilityResponse_Payload:
return capabilities.CapabilityResponse{
Payload: r.Payload,
}, nil
default:
return capabilities.CapabilityResponse{}, fmt.Errorf("unknown capability response type: %T", r)
}
}

func (c *CapabilityWrapper) Info(_ context.Context) (capabilities.CapabilityInfo, error) {
return capabilities.NewCapabilityInfo(
c.ID(), capabilities.CapabilityTypeCombined, "Mock of capability %s"+c.ID())
}
5 changes: 3 additions & 2 deletions deployment/go.mod
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -33,8 +33,8 @@ require (
github.com/smartcontractkit/chainlink-aptos v0.0.0-20250626122206-319db248496a
github.com/smartcontractkit/chainlink-ccip v0.0.0-20250703172708-3dacb811e668
github.com/smartcontractkit/chainlink-ccip/chains/solana v0.0.0-20250609091505-5c8cd74b92ed
github.com/smartcontractkit/chainlink-common v0.7.1-0.20250704132534-297ef736ccd7
github.com/smartcontractkit/chainlink-common/pkg/values v0.0.0-20250702175503-91331140edc3
github.com/smartcontractkit/chainlink-common v0.7.1-0.20250707133321-27faefc9ce45
github.com/smartcontractkit/chainlink-common/pkg/values v0.0.0-20250707133321-27faefc9ce45
github.com/smartcontractkit/chainlink-deployments-framework v0.17.0
github.com/smartcontractkit/chainlink-evm v0.0.0-20250707113334-93191f4c5ff4
github.com/smartcontractkit/chainlink-framework/multinode v0.0.0-20250522110034-65c54665034a
Expand Down Expand Up @@ -379,6 +379,7 @@ require (
github.com/sigurn/crc16 v0.0.0-20211026045750-20ab5afb07e3 // indirect
github.com/sirupsen/logrus v1.9.3 // indirect
github.com/smartcontractkit/chainlink-automation v0.8.1 // indirect
github.com/smartcontractkit/chainlink-common/pkg/workflows/sdk/v2/pb v0.0.0-20250707133321-27faefc9ce45 // indirect
github.com/smartcontractkit/chainlink-data-streams v0.1.1-0.20250604171706-a98fa6515eae // indirect
github.com/smartcontractkit/chainlink-feeds v0.1.2-0.20250227211209-7cd000095135 // indirect
github.com/smartcontractkit/chainlink-framework/capabilities v0.0.0-20250702183345-3f9ae622e391 // indirect
Expand Down
Loading
Loading