Addressed more PR comments

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 {

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

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