diff --git a/core/capabilities/triggers/logevent/service.go b/core/capabilities/triggers/logevent/service.go index 007a9d7385..0e46258c4a 100644 --- a/core/capabilities/triggers/logevent/service.go +++ b/core/capabilities/triggers/logevent/service.go @@ -19,12 +19,6 @@ const defaultSendChannelBufferSize = 1000 type Input struct { } -// Log Event Trigger Capability Payload -type Payload struct { - // Time that Log Event Trigger's task execution occurred (RFC3339Nano formatted) - ActualExecutionTime string -} - // Log Event Trigger Capabilities Manager // Manages different log event triggers using an underlying triggerStore type TriggerService struct { diff --git a/core/capabilities/triggers/logevent/service_test.go b/core/capabilities/triggers/logevent/service_test.go index c2e75d8948..d4c5280452 100644 --- a/core/capabilities/triggers/logevent/service_test.go +++ b/core/capabilities/triggers/logevent/service_test.go @@ -62,6 +62,7 @@ func TestLogEventTriggerEVMHappyPath(t *testing.T) { require.NoError(t, err) th.BackendTH.Backend.Commit() th.BackendTH.Backend.Commit() + th.BackendTH.Backend.Commit() }() // Wait for logs with a timeout diff --git a/core/capabilities/triggers/logevent/trigger.go b/core/capabilities/triggers/logevent/trigger.go index 37670c9927..472c2b249c 100644 --- a/core/capabilities/triggers/logevent/trigger.go +++ b/core/capabilities/triggers/logevent/trigger.go @@ -150,7 +150,7 @@ func (l *logEventTrigger) listen() { query.KeyFilter{ Key: l.reqConfig.ContractEventName, Expressions: []query.Expression{ - query.Confidence(primitives.Unconfirmed), + query.Confidence(primitives.Finalized), query.Block(fmt.Sprintf("%d", l.startBlockNum), primitives.Gte), }, }, @@ -170,6 +170,9 @@ func (l *logEventTrigger) listen() { continue } for _, log := range logs { + if log.Cursor == cursor { + continue + } triggerResp := createTriggerResponse(log, l.logEventConfig.Version(ID)) l.ch <- triggerResp cursor = log.Cursor