Skip to content
Merged
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
2 changes: 1 addition & 1 deletion go.mod
Original file line number Diff line number Diff line change
Expand Up @@ -26,7 +26,7 @@ require (
github.com/smartcontractkit/chain-selectors v1.0.91
github.com/smartcontractkit/chainlink-common v0.9.6-0.20260206011444-ed1fb0284e5d
github.com/smartcontractkit/chainlink-evm/gethwrappers v0.0.0-20251222115927-36a18321243c
github.com/smartcontractkit/chainlink-protos/cre/go v0.0.0-20260206000552-087e235a7963
github.com/smartcontractkit/chainlink-protos/cre/go v0.0.0-20260211172625-dff40e83b3c9
github.com/smartcontractkit/chainlink-protos/workflows/go v0.0.0-20260106052706-6dd937cb5ec6
github.com/smartcontractkit/chainlink-testing-framework/seth v1.51.3
github.com/smartcontractkit/chainlink/deployment v0.0.0-20260109210342-7c60a208545f
Expand Down
4 changes: 2 additions & 2 deletions go.sum
Original file line number Diff line number Diff line change
Expand Up @@ -1135,8 +1135,8 @@ github.com/smartcontractkit/chainlink-protos/chainlink-ccv/message-discovery v0.
github.com/smartcontractkit/chainlink-protos/chainlink-ccv/message-discovery v0.0.0-20251211142334-5c3421fe2c8d/go.mod h1:ATjAPIVJibHRcIfiG47rEQkUIOoYa6KDvWj3zwCAw6g=
github.com/smartcontractkit/chainlink-protos/chainlink-ccv/verifier v0.0.0-20251211142334-5c3421fe2c8d h1:AJy55QJ/pBhXkZjc7N+ATnWfxrcjq9BI9DmdtdjwDUQ=
github.com/smartcontractkit/chainlink-protos/chainlink-ccv/verifier v0.0.0-20251211142334-5c3421fe2c8d/go.mod h1:5JdppgngCOUS76p61zCinSCgOhPeYQ+OcDUuome5THQ=
github.com/smartcontractkit/chainlink-protos/cre/go v0.0.0-20260206000552-087e235a7963 h1:DCLvEn4KkFzYbK/AYl4vJmf6EHaskPYvGDGdd0kOma0=
github.com/smartcontractkit/chainlink-protos/cre/go v0.0.0-20260206000552-087e235a7963/go.mod h1:Jqt53s27Tr0jDl8mdBXg1xhu6F8Fci8JOuq43tgHOM8=
github.com/smartcontractkit/chainlink-protos/cre/go v0.0.0-20260211172625-dff40e83b3c9 h1:tp3AN+zX8dboiugE005O3rY/HBWKmSdN9LhNbZGhNWY=
github.com/smartcontractkit/chainlink-protos/cre/go v0.0.0-20260211172625-dff40e83b3c9/go.mod h1:Jqt53s27Tr0jDl8mdBXg1xhu6F8Fci8JOuq43tgHOM8=
github.com/smartcontractkit/chainlink-protos/job-distributor v0.17.0 h1:xHPmFDhff7QpeFxKsZfk+24j4AlnQiFjjRh5O87Peu4=
github.com/smartcontractkit/chainlink-protos/job-distributor v0.17.0/go.mod h1:/dVVLXrsp+V0AbcYGJo3XMzKg3CkELsweA/TTopCsKE=
github.com/smartcontractkit/chainlink-protos/linking-service/go v0.0.0-20251002192024-d2ad9222409b h1:QuI6SmQFK/zyUlVWEf0GMkiUYBPY4lssn26nKSd/bOM=
Expand Down
4 changes: 2 additions & 2 deletions test/test_project/por_workflow/go.mod
Original file line number Diff line number Diff line change
Expand Up @@ -5,10 +5,10 @@ go 1.25.3
require (
github.com/ethereum/go-ethereum v1.16.4
github.com/shopspring/decimal v1.4.0
github.com/smartcontractkit/chainlink-protos/cre/go v0.0.0-20260209203401-a488315d180f
github.com/smartcontractkit/chainlink-protos/cre/go v0.0.0-20260211172625-dff40e83b3c9
github.com/smartcontractkit/cre-sdk-go v1.1.3
github.com/smartcontractkit/cre-sdk-go/capabilities/blockchain/evm v1.0.0-beta.0
github.com/smartcontractkit/cre-sdk-go/capabilities/networking/confidentialhttp v0.0.0-20260210160211-a76237545074
github.com/smartcontractkit/cre-sdk-go/capabilities/networking/confidentialhttp v0.0.0-20260211203328-1f3721436119
github.com/smartcontractkit/cre-sdk-go/capabilities/networking/http v1.0.0-beta.0
github.com/smartcontractkit/cre-sdk-go/capabilities/scheduler/cron v1.0.0-beta.0
google.golang.org/protobuf v1.36.8
Expand Down
8 changes: 4 additions & 4 deletions test/test_project/por_workflow/go.sum
Original file line number Diff line number Diff line change
Expand Up @@ -173,14 +173,14 @@ github.com/shirou/gopsutil v3.21.4-0.20210419000835-c7a38de76ee5+incompatible h1
github.com/shirou/gopsutil v3.21.4-0.20210419000835-c7a38de76ee5+incompatible/go.mod h1:5b4v6he4MtMOwMlS0TUMTu2PcXUg8+E1lC7eC3UO/RA=
github.com/shopspring/decimal v1.4.0 h1:bxl37RwXBklmTi0C79JfXCEBD1cqqHt0bbgBAGFp81k=
github.com/shopspring/decimal v1.4.0/go.mod h1:gawqmDU56v4yIKSwfBSFip1HdCCXN8/+DMd9qYNcwME=
github.com/smartcontractkit/chainlink-protos/cre/go v0.0.0-20260209203401-a488315d180f h1:YBpKK0O7IcbkMyhPRXxA4HGh9OYt+N5Qicx28z8NMvE=
github.com/smartcontractkit/chainlink-protos/cre/go v0.0.0-20260209203401-a488315d180f/go.mod h1:Jqt53s27Tr0jDl8mdBXg1xhu6F8Fci8JOuq43tgHOM8=
github.com/smartcontractkit/chainlink-protos/cre/go v0.0.0-20260211172625-dff40e83b3c9 h1:tp3AN+zX8dboiugE005O3rY/HBWKmSdN9LhNbZGhNWY=
github.com/smartcontractkit/chainlink-protos/cre/go v0.0.0-20260211172625-dff40e83b3c9/go.mod h1:Jqt53s27Tr0jDl8mdBXg1xhu6F8Fci8JOuq43tgHOM8=
github.com/smartcontractkit/cre-sdk-go v1.1.3 h1:uNtAuLAgJbe4I5ThuI627opA0ruopMvVCdbhIefyUIE=
github.com/smartcontractkit/cre-sdk-go v1.1.3/go.mod h1:sgiRyHUiPcxp1e/EMnaJ+ddMFL4MbE3UMZ2MORAAS9U=
github.com/smartcontractkit/cre-sdk-go/capabilities/blockchain/evm v1.0.0-beta.0 h1:t2bzRHnqkyxvcrJKSsKPmCGLMjGO97ESgrtLCnTIEQw=
github.com/smartcontractkit/cre-sdk-go/capabilities/blockchain/evm v1.0.0-beta.0/go.mod h1:VVJ4mvA7wOU1Ic5b/vTaBMHEUysyxd0gdPPXkAu8CmY=
github.com/smartcontractkit/cre-sdk-go/capabilities/networking/confidentialhttp v0.0.0-20260210160211-a76237545074 h1:7YRF8i27mvt6zNaylOrWFteMbGdOTyzY7piT0APippA=
github.com/smartcontractkit/cre-sdk-go/capabilities/networking/confidentialhttp v0.0.0-20260210160211-a76237545074/go.mod h1:U+r6lxSMrOfl9RTo9FWGCNQoDIptN6scEzBlRq0P2Ao=
github.com/smartcontractkit/cre-sdk-go/capabilities/networking/confidentialhttp v0.0.0-20260211203328-1f3721436119 h1:P69M59tBeLevOldspLxedrYNyAu+vtaD6wnpWwhstxM=
github.com/smartcontractkit/cre-sdk-go/capabilities/networking/confidentialhttp v0.0.0-20260211203328-1f3721436119/go.mod h1:KOn3NK4AbtvuMs2oKlNRxL2fACSuuGI114xPqO5igtQ=
github.com/smartcontractkit/cre-sdk-go/capabilities/networking/http v1.0.0-beta.0 h1:E3S3Uk4O2/cEJtgh+mDhakK3HFcDI2zeqJIsTxUWeS8=
github.com/smartcontractkit/cre-sdk-go/capabilities/networking/http v1.0.0-beta.0/go.mod h1:M83m3FsM1uqVu06OO58mKUSZJjjH8OGJsmvFpFlRDxI=
github.com/smartcontractkit/cre-sdk-go/capabilities/scheduler/cron v1.0.0-beta.0 h1:Tui4xQVln7Qtk3CgjBRgDfihgEaAJy2t2MofghiGIDA=
Expand Down
60 changes: 27 additions & 33 deletions test/test_project/por_workflow/main.go
Original file line number Diff line number Diff line change
Expand Up @@ -105,40 +105,34 @@ func doPOR(config *Config, runtime cre.Runtime, runTime time.Time) (string, erro

logger.Info("ReserveInfo", "reserveInfo", reserveInfo)

porResp, err := cre.RunInNodeMode(*config, runtime,
func(config Config, nodeRuntime cre.NodeRuntime) (PORResponse, error) {
confHttpClient := confidentialhttp.Client{}
confOutput, err := confHttpClient.SendRequest(nodeRuntime, &confidentialhttp.ConfidentialHTTPRequest{
Request: &confidentialhttp.HTTPRequest{
Url: config.URL,
Method: "GET",
MultiHeaders: map[string]*confidentialhttp.HeaderValues{
"Authorization": {
Values: []string{"Basic {{.API_KEY}}"},
},
},
EncryptOutput: true,
confHttpClient := confidentialhttp.Client{}
confOutput, err := confHttpClient.SendRequest(runtime, &confidentialhttp.ConfidentialHTTPRequest{
Request: &confidentialhttp.HTTPRequest{
Url: config.URL,
Method: "GET",
MultiHeaders: map[string]*confidentialhttp.HeaderValues{
"Authorization": {
Values: []string{"Basic {{.API_KEY}}"},
},
VaultDonSecrets: []*confidentialhttp.SecretIdentifier{
{
Key: "API_KEY",
},
},
}).Await()
if err != nil {
logger.Error("error fetching conf por", "err", err)
return PORResponse{}, err
}
logger.Info("Conf POR response", "response", confOutput)

porResp := &PORResponse{}
if err = json.Unmarshal(confOutput.Body, porResp); err != nil {
return PORResponse{}, err
}

return *porResp, nil
}, cre.ConsensusIdenticalAggregation[PORResponse](),
).Await()
},
EncryptOutput: true,
},
VaultDonSecrets: []*confidentialhttp.SecretIdentifier{
{
Key: "API_KEY",
},
},
}).Await()
if err != nil {
logger.Error("error fetching conf por", "err", err)
return "", err
}
logger.Info("Conf POR response", "response", confOutput)

porResp := &PORResponse{}
if err = json.Unmarshal(confOutput.Body, porResp); err != nil {
return "", err
}

if porResp.Ripcord {
return "", errors.New("ripcord is true")
Expand Down
Loading