feat: avoid useless sql query to insert already existing accounts

formancehq · May 12, 2023 · d55ebeb · d55ebeb
1 parent faa48e4
commit d55ebeb
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/pkg/ledger/query/worker.go b/pkg/ledger/query/worker.go
@@ -277,7 +277,13 @@ func buildData(
 
 			logsData.transactionsToInsert = append(logsData.transactionsToInsert, expandedTx)
 
-			for account := range txVolumeAggregator.PostCommitVolumes {
+		l:
+			for account, volumes := range txVolumeAggregator.PreCommitVolumes {
+				for _, volume := range volumes {
+					if volume.Output.Cmp(core.Zero) != 0 || volume.Input.Cmp(core.Zero) != 0 {
+						continue l
+					}
+				}
 				logsData.ensureAccountsExist = append(logsData.ensureAccountsExist, account)
 			}