feat: adds a new feature flag for an OCR queue

Author: MStreet3

pkg/settings/cresettings/README.md

@@ -47,6 +47,10 @@ flowchart
 %%    TODO unused
 %%    PerOrg.ZeroBalancePruningTimeout
 
+    subgraph FeatureFlags[FeatureFlags]
+        FeatureFlags.EnableOCRQueue[/FeatureFlags.EnableOCRQueue\]:::gate
+    end
+
     subgraph Store.FetchWorkflowArtifacts
         PerWorkflow.WASMConfigSizeLimit{{PerWorkflow.WASMConfigSizeLimit}}:::bound
         PerWorkflow.WASMBinarySizeLimit{{PerWorkflow.WASMBinarySizeLimit}}:::bound

pkg/settings/cresettings/defaults.json

@@ -110,5 +110,8 @@
 			"CallLimit": "5"
 		},
 		"FeatureMultiTriggerExecutionIDsActiveAt": "2100-01-01 00:00:00 +0000 UTC"
+	},
+	"FeatureFlags": {
+		"EnableOCRQueue": "false"
 	}
 }

pkg/settings/cresettings/defaults.toml

@@ -110,3 +110,6 @@ ResponseSizeLimit = '100kb'
 
 [PerWorkflow.Secrets]
 CallLimit = '5'
+
+[FeatureFlags]
+EnableOCRQueue = 'false'

pkg/settings/cresettings/settings.go

@@ -111,6 +111,10 @@ var Default = Schema{
 	VaultMaxPerOracleUnexpiredBlobCumulativePayloadSizeLimit: Size(31457280 * config.Byte),
 	VaultMaxPerOracleUnexpiredBlobCount:                      Int(1000),
 
+	FeatureFlags: FeatureFlags{
+		EnableOCRQueue: Bool(false),
+	},
+
 	PerOrg: Orgs{
 		ZeroBalancePruningTimeout: Duration(24 * time.Hour),
 	},
@@ -239,7 +243,14 @@ type Schema struct {
 	PerOrg      Orgs      `scope:"org"`
 	PerOwner    Owners    `scope:"owner"`
 	PerWorkflow Workflows `scope:"workflow"`
+
+	FeatureFlags FeatureFlags
 }
+
+type FeatureFlags struct {
+	EnableOCRQueue Setting[bool]
+}
+
 type Orgs struct {
 	ZeroBalancePruningTimeout Setting[time.Duration]
 }

pkg/settings/cresettings/settings_test.go

@@ -71,6 +71,9 @@ func TestSchema_Unmarshal(t *testing.T) {
 	"GatewayUnauthenticatedRequestRateLimitPerIP": "1rps:100",
 	"GatewayIncomingPayloadSizeLimit": "14kb",
     "GatewayVaultManagementEnabled": "true",
+	"FeatureFlags": {
+		"EnableOCRQueue": "true"
+	},
 	"PerOrg": {
 		"ZeroBalancePruningTimeout": "48h"
 	},
@@ -122,6 +125,7 @@ func TestSchema_Unmarshal(t *testing.T) {
 	assert.Equal(t, 500, cfg.WorkflowLimit.DefaultValue)
 	assert.Equal(t, 14*config.KByte, cfg.GatewayIncomingPayloadSizeLimit.DefaultValue)
 	assert.Equal(t, true, cfg.GatewayVaultManagementEnabled.DefaultValue)
+	assert.Equal(t, true, cfg.FeatureFlags.EnableOCRQueue.DefaultValue)
 	assert.Equal(t, 48*time.Hour, cfg.PerOrg.ZeroBalancePruningTimeout.DefaultValue)
 	assert.Equal(t, 99, cfg.PerOwner.WorkflowExecutionConcurrencyLimit.DefaultValue)
 	assert.Equal(t, 250*config.MByte, cfg.PerWorkflow.WASMMemoryLimit.DefaultValue)
@@ -141,6 +145,14 @@ func TestSchema_Unmarshal(t *testing.T) {
 	assert.Equal(t, config.Timestamp(time.Date(2025, 6, 15, 0, 0, 0, 0, time.UTC).Unix()), cfg.PerWorkflow.FeatureMultiTriggerExecutionIDsActiveAt.DefaultValue)
 }
 
+func TestFeatureFlags_EnableOCRQueue(t *testing.T) {
+	assert.False(t, Default.FeatureFlags.EnableOCRQueue.DefaultValue, "default should be false")
+
+	got, err := Default.FeatureFlags.EnableOCRQueue.GetOrDefault(t.Context(), nil)
+	require.NoError(t, err)
+	assert.False(t, got, "GetOrDefault with nil getter should return default false")
+}
+
 func TestDefaultGetter(t *testing.T) {
 	limit := Default.PerWorkflow.HTTPAction.CallLimit