Fixed issue with timing out queries on mongo db (#210)

block-core · Apr 25, 2024 · b4e8b49 · b4e8b49
1 parent 69f420e
commit b4e8b49
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 8 deletions.
diff --git a/src/Blockcore.Indexer.Angor/Storage/Mongo/AngorMongoBuilder.cs b/src/Blockcore.Indexer.Angor/Storage/Mongo/AngorMongoBuilder.cs
@@ -48,6 +48,10 @@ public override Task OnExecute()
          .CreateOne(new CreateIndexModel<Project>(Builders<Project>
             .IndexKeys.Descending(x => x.BlockIndex)));
 
+      AngorMongoDb.ProjectTable.Indexes
+         .CreateOne(new CreateIndexModel<Project>(Builders<Project>
+            .IndexKeys.Ascending(x => x.AddressOnFeeOutput)));
+
       //TODO move this to the block indexer task runner, but we'll need to move the indexes in there to a different class for each project/blockchain
       AngorMongoDb.InvestmentTable.Indexes
          .CreateOne(new CreateIndexModel<Investment>(Builders<Investment>

diff --git a/src/Blockcore.Indexer.Angor/Sync/SyncTasks/ProjectTransactionsSyncRunner.cs b/src/Blockcore.Indexer.Angor/Sync/SyncTasks/ProjectTransactionsSyncRunner.cs
@@ -184,7 +184,6 @@ private BsonDocument[] MongoDbLookupForInvestments()
                   new BsonDocument
                   {
                      { "address", "$AddressOnFeeOutput" },
-                     { "trx", "$TransactionId" },
                      { "projectMaxBlockScanned", "$projectMaxBlockScanned" }
                   }
                },
@@ -197,13 +196,12 @@ private BsonDocument[] MongoDbLookupForInvestments()
                               new BsonArray { "$Address", "$$address" }))),
                      new BsonDocument("$match",
                         new BsonDocument("$expr",
-                           new BsonDocument("$and", new BsonArray
-                           {
-                              new BsonDocument("$gt",
-                                 new BsonArray { "$BlockIndex", "$$projectMaxBlockScanned" }),
-                              new BsonDocument("$ne",
-                                 new BsonArray { "$$trx", "$Outpoint.TransactionId" })
-                           })))
+                           new BsonDocument("$gt",
+                              new BsonArray { "$BlockIndex", "$$projectMaxBlockScanned" }))),
+                     new BsonDocument("$match",
+                        new BsonDocument("$expr",
+                           new BsonDocument("$eq",
+                              new BsonArray { "$Outpoint.OutputIndex", 0 }))),
                   }
                },
                { "as", "o" }