diff --git a/process/elasticproc/logsevents/informativeLogsProcessor.go b/process/elasticproc/logsevents/informativeLogsProcessor.go index 3706f708..a92fd3ca 100644 --- a/process/elasticproc/logsevents/informativeLogsProcessor.go +++ b/process/elasticproc/logsevents/informativeLogsProcessor.go @@ -61,6 +61,11 @@ func processEventNoTx(args *argsProcessEvent) argOutputProcessEvent { processed: true, } } + if scr.OriginalTxHash == "" { + return argOutputProcessEvent{ + processed: true, + } + } record := &outport.StatusInfo{} switch string(args.event.GetIdentifier()) { diff --git a/process/elasticproc/transactions/scrsDataToTransactions.go b/process/elasticproc/transactions/scrsDataToTransactions.go index f18aa741..77ba1f5b 100644 --- a/process/elasticproc/transactions/scrsDataToTransactions.go +++ b/process/elasticproc/transactions/scrsDataToTransactions.go @@ -54,7 +54,7 @@ func (st *scrsDataToTransactions) processTransactionsAfterSCRsWereAttached(trans func (st *scrsDataToTransactions) processSCRsWithoutTx(scrs []*data.ScResult) map[string]*data.FeeData { txHashRefund := make(map[string]*data.FeeData) for _, scr := range scrs { - if scr.InitialTxGasUsed == 0 { + if scr.InitialTxGasUsed == 0 || scr.OriginalTxHash == "" { continue }