fix overlap in calculated streams (#215)

Author: dav009

llo/plugin_outcome.go

@@ -452,7 +452,7 @@ func IsSecondsResolution(reportFormat llotypes.ReportFormat) bool {
 	// TODO: Might be cleaner to expose a TimeResolution() uint64 field on the
 	// ReportCodec so that the plugin doesn't have to have special knowledge of
 	// the report format details
-	case llotypes.ReportFormatEVMPremiumLegacy, llotypes.ReportFormatEVMABIEncodeUnpacked:
+	case llotypes.ReportFormatEVMPremiumLegacy, llotypes.ReportFormatEVMABIEncodeUnpacked, llotypes.ReportFormatEVMABIEncodeUnpackedExpr:
 		return true
 	default:
 		return false

llo/plugin_outcome_test.go

@@ -822,6 +822,34 @@ func Test_Outcome_Methods(t *testing.T) {
 			// if cadence is 5s, if time is < 5s, does not report because cadence hasn't elapsed
 			require.EqualError(t, outcome.IsReportable(cid, 1, uint64(5*time.Second)), "ChannelID: 1; Reason: IsReportable=false; not valid yet (ObservationTimestampNanoseconds=1726670490999999999, validAfterNanoseconds=1726670489999999999, minReportInterval=5000000000); 4.000000 seconds (4000000000ns) until reportable")
 		})
+		t.Run("IsReportable with ReportFormatEVMABIEncodeUnpackedExpr prevents same-second timestamps", func(t *testing.T) {
+			outcome := Outcome{}
+			cid := llotypes.ChannelID(1)
+
+			// Test case from production bug: both timestamps truncate to same second
+			// observationTimestampNanoseconds: 1765173183742021148 → 1765173183 sec
+			// validAfterNanoseconds:           1765173183282997914 → 1765173183 sec
+			outcome.LifeCycleStage = LifeCycleStageProduction
+			outcome.ObservationTimestampNanoseconds = 1765173183742021148
+			outcome.ChannelDefinitions = map[llotypes.ChannelID]llotypes.ChannelDefinition{
+				cid: {ReportFormat: llotypes.ReportFormatEVMABIEncodeUnpackedExpr},
+			}
+			outcome.ValidAfterNanoseconds = map[llotypes.ChannelID]uint64{
+				cid: 1765173183282997914,
+			}
+
+			// Should be unreportable because timestamps are in same second
+			require.EqualError(t, outcome.IsReportable(cid, 1, uint64(0)),
+				"ChannelID: 1; Reason: ChannelID: 1; Reason: IsReportable=false; not valid yet (observationsTimestampSeconds=1765173183, validAfterSeconds=1765173183)")
+
+			// When ValidAfter is at least 1 second before observation, should be reportable
+			outcome.ValidAfterNanoseconds[cid] = 1765173182999999999 // 1ns before previous second
+			assert.Nil(t, outcome.IsReportable(cid, 1, uint64(0)))
+
+			// Test IsSecondsResolution returns true for calculated streams
+			assert.True(t, IsSecondsResolution(llotypes.ReportFormatEVMABIEncodeUnpackedExpr),
+				"IsSecondsResolution should return true for ReportFormatEVMABIEncodeUnpackedExpr")
+		})
 		t.Run("ReportableChannels", func(t *testing.T) {
 			defaultMinReportInterval := uint64(1 * time.Second)