Hook to ask implementation to determine if it supports regions

Author: nolag

go.mod

@@ -43,7 +43,7 @@ require (
 	github.com/smartcontractkit/chain-selectors v1.0.89
 	github.com/smartcontractkit/chainlink-common/pkg/chipingress v0.0.10
 	github.com/smartcontractkit/chainlink-protos/billing/go v0.0.0-20251024234028-0988426d98f4
-	github.com/smartcontractkit/chainlink-protos/cre/go v0.0.0-20260427170224-3b3204904066
+	github.com/smartcontractkit/chainlink-protos/cre/go v0.0.0-20260430144057-afff7a89f947
 	github.com/smartcontractkit/chainlink-protos/linking-service/go v0.0.0-20251002192024-d2ad9222409b
 	github.com/smartcontractkit/chainlink-protos/node-platform v0.0.0-20260205130626-db2a2aab956b
 	github.com/smartcontractkit/chainlink-protos/storage-service v0.3.0

go.sum

@@ -77,12 +77,12 @@ func (r *requirementSelectingModule) Execute(ctx context.Context, request *sdk.E
 	}
 
 	for i, sub := range result.GetTriggerSubscriptions().GetSubscriptions() {
-		if sub.Requirements == nil || CheckRequirements(r.main.RequirementsHandler, sub.Requirements) {
+		if sub.Requirements == nil || CheckRequirements(ctx, r.main.RequirementsHandler, sub.Requirements) {
 			continue
 		}
 		matched := false
 		for j, m := range r.additional {
-			if CheckRequirements(m.RequirementsHandler, sub.Requirements) {
+			if CheckRequirements(ctx, m.RequirementsHandler, sub.Requirements) {
 				m.ensureStarted()
 				r.cache.Store(uint64(i), j)
 				matched = true

pkg/capabilities/v2/actions/confidentialworkflow/client.pb.go

@@ -106,14 +106,14 @@ func TestRequirementSelectingModule_Close(t *testing.T) {
 				startFn: noop,
 				closeFn: func() { add0Closed = true },
 			},
-			RequirementsHandler: RequirementsHandler{Tee: func(*sdk.Tee) bool { return true }},
+			RequirementsHandler: RequirementsHandler{Tee: func(context.Context, *sdk.Tee) bool { return true }},
 		}
 		add1 := ModuleAndHandler{
 			Module: &stubModule{
 				startFn: noop,
 				closeFn: func() { add1Closed = true },
 			},
-			RequirementsHandler: RequirementsHandler{Tee: func(*sdk.Tee) bool { return false }},
+			RequirementsHandler: RequirementsHandler{Tee: func(context.Context, *sdk.Tee) bool { return false }},
 		}
 
 		m := NewRequirementSelectingModule(main, []ModuleAndHandler{add0, add1})
@@ -172,7 +172,7 @@ func TestRequirementSelectingModule_Execute(t *testing.T) {
 					return nil, nil
 				},
 			},
-			RequirementsHandler: RequirementsHandler{Tee: func(*sdk.Tee) bool { return true }},
+			RequirementsHandler: RequirementsHandler{Tee: func(context.Context, *sdk.Tee) bool { return true }},
 		}
 
 		m := NewRequirementSelectingModule(main, []ModuleAndHandler{add})
@@ -200,7 +200,7 @@ func TestRequirementSelectingModule_Execute(t *testing.T) {
 					return want, nil
 				},
 			},
-			RequirementsHandler: RequirementsHandler{Tee: func(*sdk.Tee) bool { return true }},
+			RequirementsHandler: RequirementsHandler{Tee: func(context.Context, *sdk.Tee) bool { return true }},
 		}
 
 		m := NewRequirementSelectingModule(main, []ModuleAndHandler{add})
@@ -225,7 +225,7 @@ func TestRequirementSelectingModule_Execute(t *testing.T) {
 		}}
 		add := ModuleAndHandler{
 			Module:              &stubModule{startFn: noop},
-			RequirementsHandler: RequirementsHandler{Tee: func(*sdk.Tee) bool { return false }},
+			RequirementsHandler: RequirementsHandler{Tee: func(context.Context, *sdk.Tee) bool { return false }},
 		}
 
 		m := NewRequirementSelectingModule(main, []ModuleAndHandler{add})
@@ -248,7 +248,7 @@ func TestRequirementSelectingModule_Execute(t *testing.T) {
 		}}
 		add0 := ModuleAndHandler{
 			Module:              &stubModule{startFn: noop},
-			RequirementsHandler: RequirementsHandler{Tee: func(*sdk.Tee) bool { return false }},
+			RequirementsHandler: RequirementsHandler{Tee: func(context.Context, *sdk.Tee) bool { return false }},
 		}
 		add1 := ModuleAndHandler{
 			Module: &stubModule{
@@ -258,7 +258,7 @@ func TestRequirementSelectingModule_Execute(t *testing.T) {
 					return want, nil
 				},
 			},
-			RequirementsHandler: RequirementsHandler{Tee: func(*sdk.Tee) bool { return true }},
+			RequirementsHandler: RequirementsHandler{Tee: func(context.Context, *sdk.Tee) bool { return true }},
 		}
 
 		m := NewRequirementSelectingModule(main, []ModuleAndHandler{add0, add1})
@@ -287,7 +287,7 @@ func TestRequirementSelectingModule_Execute(t *testing.T) {
 				startFn: func() { atomic.AddInt32(&addStartCount, 1) },
 				closeFn: noopClose,
 			},
-			RequirementsHandler: RequirementsHandler{Tee: func(*sdk.Tee) bool { return true }},
+			RequirementsHandler: RequirementsHandler{Tee: func(context.Context, *sdk.Tee) bool { return true }},
 		}
 
 		m := NewRequirementSelectingModule(main, []ModuleAndHandler{add})
@@ -338,7 +338,7 @@ func TestRequirementSelectingModule_Execute(t *testing.T) {
 					return subscribeResult(subWithReqs(teeReqs)), nil
 				},
 			},
-			RequirementsHandler: RequirementsHandler{Tee: func(*sdk.Tee) bool { return true }},
+			RequirementsHandler: RequirementsHandler{Tee: func(context.Context, *sdk.Tee) bool { return true }},
 		}
 		add := ModuleAndHandler{
 			Module: &stubModule{
@@ -348,7 +348,7 @@ func TestRequirementSelectingModule_Execute(t *testing.T) {
 					return nil, nil
 				},
 			},
-			RequirementsHandler: RequirementsHandler{Tee: func(*sdk.Tee) bool { return true }},
+			RequirementsHandler: RequirementsHandler{Tee: func(context.Context, *sdk.Tee) bool { return true }},
 		}
 
 		m := NewRequirementSelectingModule(main, []ModuleAndHandler{add})
@@ -386,7 +386,7 @@ func TestRequirementSelectingModule_TriggerCache(t *testing.T) {
 					return &sdk.ExecutionResult{}, nil
 				},
 			},
-			RequirementsHandler: RequirementsHandler{Tee: func(*sdk.Tee) bool { return true }},
+			RequirementsHandler: RequirementsHandler{Tee: func(context.Context, *sdk.Tee) bool { return true }},
 		}
 
 		m := NewRequirementSelectingModule(main, []ModuleAndHandler{add})
@@ -427,7 +427,7 @@ func TestRequirementSelectingModule_TriggerCache(t *testing.T) {
 					return &sdk.ExecutionResult{}, nil
 				},
 			},
-			RequirementsHandler: RequirementsHandler{Tee: func(*sdk.Tee) bool { return true }},
+			RequirementsHandler: RequirementsHandler{Tee: func(context.Context, *sdk.Tee) bool { return true }},
 		}
 
 		m := NewRequirementSelectingModule(main, []ModuleAndHandler{add})
@@ -469,7 +469,7 @@ func TestRequirementSelectingModule_TriggerCache(t *testing.T) {
 					return wantAdditional, nil
 				},
 			},
-			RequirementsHandler: RequirementsHandler{Tee: func(*sdk.Tee) bool { return true }},
+			RequirementsHandler: RequirementsHandler{Tee: func(context.Context, *sdk.Tee) bool { return true }},
 		}
 
 		m := NewRequirementSelectingModule(main, []ModuleAndHandler{add})

pkg/capabilities/v2/actions/confidentialworkflow/server/client_server_gen.go

@@ -1,24 +1,26 @@
 package host
 
+import "ctx"
+
 // RequirementsHandler contains a callback for each public field in sdk.Requirements.
 // Each callback receives the field value and returns a list of strings or an error.
 type RequirementsHandler struct {
 {{- range .Fields}}
-	{{.Name}} func({{.Type}}) bool
+	{{.Name}} func(context.Context, {{.Type}}) bool
 {{- end}}
 }
 
-// CheckRequirements calls each non-nil callback in handler for the corresponding
+// CheckRequirements calls each non-nil callback in the handler for the corresponding
 // non-nil field in req, returning false if any are false, or if the handler is nil.
 // Unknown fields on the proto also result in a false return value.
-func CheckRequirements(handler RequirementsHandler, req *sdk.Requirements) bool {
+func CheckRequirements(ctx context.Context, handler RequirementsHandler, req *sdk.Requirements) bool {
 	if len(req.ProtoReflect().GetUnknown()) != 0 {
 		return false
 	}
 
 {{range .Fields}}
 	if req.{{.Name}} != nil {
-		if handler.{{.Name}} == nil || !handler.{{.Name}}(req.{{.Name}})  {
+		if handler.{{.Name}} == nil || !handler.{{.Name}}(ctx, req.{{.Name}})  {
 			return false
 		}