addressed feedback

Author: silaslenihan

capabilities/go.mod

@@ -7,7 +7,7 @@ toolchain go1.24.3
 require (
 	github.com/google/uuid v1.6.0
 	github.com/jpillora/backoff v1.0.0
-	github.com/smartcontractkit/chainlink-common v0.7.1-0.20250611184338-e845ca66dba0
+	github.com/smartcontractkit/chainlink-common v0.7.1-0.20250617133454-9f01f00e6ea8
 	github.com/stretchr/testify v1.10.0
 	go.opentelemetry.io/otel v1.35.0
 	go.opentelemetry.io/otel/metric v1.35.0

capabilities/go.sum

@@ -89,8 +89,8 @@ github.com/santhosh-tekuri/jsonschema/v5 v5.2.0 h1:WCcC4vZDS1tYNxjWlwRJZQy28r8CM
 github.com/santhosh-tekuri/jsonschema/v5 v5.2.0/go.mod h1:FKdcjfQW6rpZSnxxUvEA5H/cDPdvJ/SZJQLWWXWGrZ0=
 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-common v0.7.1-0.20250611184338-e845ca66dba0 h1:IgP7CRbAAz6d18byQH/4ozrKwHSTa3G9Ut592R6inH4=
-github.com/smartcontractkit/chainlink-common v0.7.1-0.20250611184338-e845ca66dba0/go.mod h1:H7gOuN4Jzf+DWllfP5Pb7AiCWBMQrDX1D1KYXAEhdnw=
+github.com/smartcontractkit/chainlink-common v0.7.1-0.20250617133454-9f01f00e6ea8 h1:b9g3M6Re82Kf82eXWL6OafKzQ/DmGt479zrSvdpVRMM=
+github.com/smartcontractkit/chainlink-common v0.7.1-0.20250617133454-9f01f00e6ea8/go.mod h1:1ntZ0rtQpPx6h+xlcOJp0ccqHFaxTzW2Z62FJG358q0=
 github.com/smartcontractkit/libocr v0.0.0-20250328171017-609ec10a5510 h1:gm8Jli0sdkrZYnrWBngAkPSDzFDkdNCy1/Dj86kVtYk=
 github.com/smartcontractkit/libocr v0.0.0-20250328171017-609ec10a5510/go.mod h1:Mb7+/LC4edz7HyHxX4QkE42pSuov4AV68+AxBXAap0o=
 github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=

capabilities/writetarget/__debug_bin4176497639

@@ -6,12 +6,12 @@ import (
 
 // Config defines the write target component configuration.
 type Config struct {
-	ConfirmerPollPeriod time.Duration
-	ConfirmerTimeout    time.Duration
+	PollPeriod        time.Duration
+	AcceptanceTimeout time.Duration
 }
 
 // DefaultConfigSet is the default configuration for the write target component.
 var DefaultConfigSet = Config{
-	ConfirmerPollPeriod: 1 * time.Second,
-	ConfirmerTimeout:    10 * time.Second,
+	PollPeriod:        1 * time.Second,
+	AcceptanceTimeout: 10 * time.Second,
 }

capabilities/writetarget/__debug_bin633733685

@@ -11,6 +11,11 @@ import (
 	"github.com/smartcontractkit/chainlink-framework/capabilities/writetarget/monitoring/pb/platform/on-chain/forwarder"
 )
 
+const WriteTargetProcessorName = "writetarget"
+const KeystoneProcessorName = "keystone"
+
+var PlatformDefaultProcessors = []string{WriteTargetProcessorName, KeystoneProcessorName}
+
 // Product-agnostic processors to be injected into WriteTarget Monitor
 func NewPlatformProcessors(emitter beholder.ProtoEmitter) (map[string]beholder.ProtoProcessor, error) {
 	forwarderMetrics, err := forwarder.NewMetrics()
@@ -33,10 +38,6 @@ func NewPlatformProcessors(emitter beholder.ProtoEmitter) (map[string]beholder.P
 	}, nil
 }
 
-func GetDefaultPlatformProcessors() []string {
-	return []string{"writetarget", "keystone"}
-}
-
 // Write-Target specific processor decodes write messages to derive metrics
 type wtProcessor struct {
 	metrics *wt.Metrics

capabilities/writetarget/config.go

@@ -369,12 +369,12 @@ func (c *writeTarget) acceptAndConfirmWrite(ctx context.Context, info requestInf
 	lggr := logger.Named(c.lggr, "write-confirmer")
 
 	// Timeout for the confirmation process
-	timeout := c.config.ConfirmerTimeout
+	timeout := c.config.AcceptanceTimeout
 	ctx, cancel := context.WithTimeout(ctx, timeout)
 	defer cancel()
 
 	// Retry interval for the confirmation process
-	interval := c.config.ConfirmerPollPeriod
+	interval := c.config.PollPeriod
 	ticker := services.NewTicker(interval)
 	defer ticker.Stop()
 
@@ -443,7 +443,7 @@ func (c *writeTarget) acceptAndConfirmWrite(ctx context.Context, info requestInf
 // Polls transaction status until it reaches one of terminal states [Finalized, Failed, Fatal]
 func (c *writeTarget) waitTxReachesTerminalStatus(ctx context.Context, lggr logger.Logger, txID string) (finalized bool, err error) {
 	// Retry interval for the confirmation process
-	interval := c.config.ConfirmerPollPeriod
+	interval := c.config.PollPeriod
 	ticker := time.NewTicker(interval)
 	defer ticker.Stop()
 

capabilities/writetarget/report/platform/processor/processor.go

@@ -43,7 +43,7 @@ func setupWriteTarget(
 	if productSpecificProcessor {
 		platformProcessors["test"] = newMockProductSpecificProcessor(t)
 	}
-	monClient, err := writetarget.NewMonitor(writetarget.MonitorOpts{lggr, platformProcessors, processor.GetDefaultPlatformProcessors(), emitter})
+	monClient, err := writetarget.NewMonitor(writetarget.MonitorOpts{lggr, platformProcessors, processor.PlatformDefaultProcessors, emitter})
 	require.NoError(t, err)
 
 	pollPeriod := 100 * time.Millisecond
@@ -53,8 +53,8 @@ func setupWriteTarget(
 	opts := writetarget.WriteTargetOpts{
 		ID: "[email protected]",
 		Config: writetarget.Config{
-			ConfirmerPollPeriod: pollPeriod,
-			ConfirmerTimeout:    timeout,
+			PollPeriod:        pollPeriod,
+			AcceptanceTimeout: timeout,
 		},
 		ChainInfo:            monitor.ChainInfo{},
 		Logger:               lggr,