[PRODCRE-792] Per-method onchain config for capabilities V2

Author: bolekk

pkg/capabilities/capabilities.go

@@ -469,11 +469,13 @@ func MustNewRemoteCapabilityInfo(
 }
 
 const (
-	DefaultRegistrationRefresh   = 30 * time.Second
-	DefaultRegistrationExpiry    = 2 * time.Minute
-	DefaultMessageExpiry         = 2 * time.Minute
-	DefaultBatchSize             = 100
-	DefaultBatchCollectionPeriod = 100 * time.Millisecond
+	DefaultRegistrationRefresh       = 30 * time.Second
+	DefaultRegistrationExpiry        = 2 * time.Minute
+	DefaultMessageExpiry             = 2 * time.Minute
+	DefaultBatchSize                 = 100
+	DefaultBatchCollectionPeriod     = 100 * time.Millisecond
+	DefaultExecutableRequestTimeout  = 8 * time.Minute
+	DefaultServerMaxParallelRequests = 1000
 )
 
 type RemoteTriggerConfig struct {
@@ -485,14 +487,19 @@ type RemoteTriggerConfig struct {
 	BatchCollectionPeriod   time.Duration
 }
 
-type RemoteTargetConfig struct {
+type RemoteTargetConfig struct { // deprecated - v1 only
 	RequestHashExcludedAttributes []string
 }
 
 type RemoteExecutableConfig struct {
-	RequestHashExcludedAttributes []string
-	RegistrationRefresh           time.Duration
-	RegistrationExpiry            time.Duration
+	RequestHashExcludedAttributes []string // deprecated - v1 only
+
+	// Fields below are used only by v2 capabilities
+	TransmissionSchedule      uint32
+	DeltaStage                time.Duration
+	RequestTimeout            time.Duration
+	ServerMaxParallelRequests uint32
+	RequestHasherType         uint32
 }
 
 // NOTE: consider splitting this config into values stored in Registry (KS-118)
@@ -522,12 +529,39 @@ func (c *RemoteExecutableConfig) ApplyDefaults() {
 	if c == nil {
 		return
 	}
-	if c.RegistrationRefresh == 0 {
-		c.RegistrationRefresh = DefaultRegistrationRefresh
+	// Default schedule is 0 ("all at once"), default delta stage is 0.
+	if c.RequestTimeout == 0 {
+		c.RequestTimeout = DefaultExecutableRequestTimeout
 	}
-	if c.RegistrationExpiry == 0 {
-		c.RegistrationExpiry = DefaultRegistrationExpiry
+	if c.ServerMaxParallelRequests == 0 {
+		c.ServerMaxParallelRequests = DefaultServerMaxParallelRequests
 	}
+	// Hasher type 0 is the default type.
+}
+
+type AggregatorType int
+type TransmissionSchedule int
+type RequestHasherType int
+
+const (
+	AggregatorType_Mode         AggregatorType = 0
+	AggregatorType_SignedReport AggregatorType = 1
+
+	Schedule_AllAtOnce  TransmissionSchedule = 0
+	Schedule_OneAtATime TransmissionSchedule = 1
+
+	RequestHasherType_Mode         RequestHasherType = 0
+	RequestHasherType_SignedReport RequestHasherType = 1
+)
+
+type AggregatorConfig struct {
+	AggregatorType AggregatorType
+}
+
+type CapabilityMethodConfig struct {
+	RemoteTriggerConfig    *RemoteTriggerConfig
+	RemoteExecutableConfig *RemoteExecutableConfig
+	AggregatorConfig       *AggregatorConfig
 }
 
 type CapabilityConfiguration struct {
@@ -541,4 +575,7 @@ type CapabilityConfiguration struct {
 	RemoteTriggerConfig    *RemoteTriggerConfig
 	RemoteTargetConfig     *RemoteTargetConfig
 	RemoteExecutableConfig *RemoteExecutableConfig
+
+	// v2 / "NoDAG" capabilities
+	CapabilityMethodConfig map[string]CapabilityMethodConfig
 }

pkg/capabilities/capabilities_test.go

@@ -154,8 +154,8 @@ func Test_RemoteExecutableConfig_ApplyDefaults(t *testing.T) {
 	rec := &RemoteExecutableConfig{}
 	rec.ApplyDefaults()
 
-	assert.Equal(t, DefaultRegistrationRefresh, rec.RegistrationRefresh)
-	assert.Equal(t, DefaultRegistrationExpiry, rec.RegistrationExpiry)
+	assert.Equal(t, DefaultExecutableRequestTimeout, rec.RequestTimeout)
+	assert.Equal(t, DefaultServerMaxParallelRequests, rec.ServerMaxParallelRequests)
 }
 
 func TestOCRTriggerEvent_ToMapFromMap(t *testing.T) {