adding missing files, makegomodtidy

Author: patrickhuie19

go.sum

@@ -0,0 +1,38 @@
+package loop
+
+import (
+	"github.com/smartcontractkit/chainlink-common/pkg/resourcemanager"
+)
+
+// MeteringConfig maps this resolved EnvConfig to a resourcemanager.Config, so
+// the loop-env -> metering mapping lives here instead of being copy-pasted
+// into every producer main. The CL_METER_* fields it reads are populated by
+// EnvConfig.AsCmdEnv from the core node's TOML [Metering] config; env is only
+// the LOOP transport.
+//
+// emitter is injected by the caller (can be process global durableemitter.GetGlobalEmitter())
+// rather than looked up here, so this mapping stays a pure function of its
+// inputs. A nil emitter is valid: the ResourceManager treats it as a no-op —
+// fail-open, so metering never blocks startup. A nil EnvConfig yields a zero
+// Config (metering disabled).
+func (e *EnvConfig) MeteringConfig(emitter resourcemanager.Emitter) resourcemanager.Config {
+	if e == nil {
+		return resourcemanager.Config{}
+	}
+	return resourcemanager.Config{
+		ResourceManagerConfig: resourcemanager.ResourceManagerConfig{
+			MeterRecordsEnabled:   e.MeterRecordsEnabled,
+			MeterSnapshotsEnabled: e.MeterSnapshotsEnabled,
+			Emitter:               emitter,
+			SnapshotInterval:      resourcemanager.DefaultSnapshotInterval,
+		},
+		DeploymentIdentity: resourcemanager.DeploymentIdentity{
+			Product:         e.MeterProduct,
+			Tenant:          e.MeterTenant,
+			NumericTenantID: e.MeterNumericTenantID,
+			Environment:     e.MeterEnvironment,
+			Zone:            e.MeterZone,
+			NodeID:          e.MeterNodeID,
+		},
+	}
+}

pkg/loop/metering_config.go

@@ -0,0 +1,57 @@
+package loop
+
+import (
+	"context"
+	"testing"
+
+	"github.com/stretchr/testify/assert"
+	"github.com/stretchr/testify/require"
+
+	"github.com/smartcontractkit/chainlink-common/pkg/resourcemanager"
+)
+
+type fakeMeteringEmitter struct{}
+
+func (fakeMeteringEmitter) Emit(context.Context, []byte, ...any) error { return nil }
+
+func TestEnvConfig_MeteringConfig(t *testing.T) {
+	t.Run("nil env yields zero config", func(t *testing.T) {
+		var e *EnvConfig
+		cfg := e.MeteringConfig(nil)
+		assert.False(t, cfg.MeterRecordsEnabled)
+		assert.Nil(t, cfg.Emitter)
+	})
+
+	t.Run("nil emitter is a valid no-op", func(t *testing.T) {
+		e := &EnvConfig{MeterRecordsEnabled: true}
+		cfg := e.MeteringConfig(nil)
+		assert.Nil(t, cfg.Emitter)
+	})
+
+	t.Run("maps env fields and injects the given emitter", func(t *testing.T) {
+		e := &EnvConfig{
+			MeterRecordsEnabled:   true,
+			MeterSnapshotsEnabled: true,
+			MeterProduct:          "cre",
+			MeterTenant:           "mainline",
+			MeterNumericTenantID:  "42",
+			MeterEnvironment:      "production",
+			MeterZone:             "wf-zone-a",
+			MeterNodeID:           "clp-cre-wf-zone-a-1",
+		}
+		emitter := fakeMeteringEmitter{}
+
+		cfg := e.MeteringConfig(emitter)
+		assert.True(t, cfg.MeterRecordsEnabled)
+		assert.True(t, cfg.MeterSnapshotsEnabled)
+		assert.Equal(t, resourcemanager.DefaultSnapshotInterval, cfg.SnapshotInterval)
+		require.NotNil(t, cfg.Emitter)
+		assert.Equal(t, resourcemanager.Emitter(emitter), cfg.Emitter)
+		assert.Equal(t, "cre", cfg.DeploymentIdentity.Product)
+		assert.Equal(t, "mainline", cfg.DeploymentIdentity.Tenant)
+		assert.Equal(t, "42", cfg.DeploymentIdentity.NumericTenantID)
+		assert.Equal(t, "production", cfg.DeploymentIdentity.Environment)
+		assert.Equal(t, "wf-zone-a", cfg.DeploymentIdentity.Zone)
+		assert.Equal(t, "clp-cre-wf-zone-a-1", cfg.DeploymentIdentity.NodeID)
+	})
+}