weatherfeeder/internal/normalizers/common/finalize.go

// FILE: ./internal/normalizers/common/finalize.go
package common

import (
	"time"

	"gitea.maximumdirect.net/ejr/feedkit/event"
	fknormalize "gitea.maximumdirect.net/ejr/feedkit/processors/normalize"
)

// Finalize builds the output event envelope by copying the input and applying the
// canonical schema/payload, plus an optional effective time.
//
// Important behavior:
//   - ID/Kind/Source/EmittedAt are preserved by copying the input event.
//   - EffectiveAt is only overwritten when the supplied effective time is non-zero.
//     If the supplied time is zero, any existing in.EffectiveAt is preserved.
//   - Payload floats are rounded to a stable wire-friendly precision (see round.go).
func Finalize(in event.Event, outSchema string, outPayload any, effectiveAt time.Time) (*event.Event, error) {
	// Enforce stable numeric presentation for weather payloads before delegating to feedkit's
	// generic envelope finalizer.
	return fknormalize.FinalizeEvent(in, outSchema, RoundFloats(outPayload, DefaultFloatPrecision), effectiveAt)
}