Optimize filter for changestreams for iec60870 server protocols.

riclolsen · May 22, 2024 · e8025a3 · e8025a3
1 parent 2b82ade
commit e8025a3
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/src/lib60870.netcore/iec101server/MongoChangeStream.cs b/src/lib60870.netcore/iec101server/MongoChangeStream.cs
@@ -108,8 +108,8 @@ static async void ProcessMongoCS(JSONSCADAConfig jsConfig)
                         throw new Exception("Error on connection " + jsConfig.mongoConnectionString);
 
                     Log("MongoDB CMD CS - Start listening for realtime data updates via changestream...");
-                    // observe updates and replaces, avoid updates with sourceDataUpdateField (those are handled by cs_data_processor.js)
-                    var filter = "{ $or: [{ $and:[{ 'updateDescription.updatedFields.sourceDataUpdate': { $exists: false } },{ operationType: 'update' }] }, { operationType: 'replace'}] }";
+                    // observe updates and replaces, avoid updates with sourceDataUpdateField (those are handled by cs_data_processor.js), require protocolDestinations not null
+                    var filter = "{ $or: [{ $and:[{ 'fullDocument.protocolDestinations': { $ne: null } },{ 'updateDescription.updatedFields.sourceDataUpdate': { $exists: false } },{ operationType: 'update' }] }, { operationType: 'replace'}] }";
 
                     var pipeline =
                         new EmptyPipelineDefinition<ChangeStreamDocument<rtData

diff --git a/src/lib60870.netcore/iec104server/MongoChangeStream.cs b/src/lib60870.netcore/iec104server/MongoChangeStream.cs
@@ -107,8 +107,8 @@ static async void ProcessMongoCS(JSONSCADAConfig jsConfig)
                         throw new Exception("Error on connection " + jsConfig.mongoConnectionString);
 
                     Log("MongoDB CMD CS - Start listening for realtime data updates via changestream...");
-                    // observe updates and replaces, avoid updates with sourceDataUpdateField (those are handled by cs_data_processor.js)
-                    var filter = "{ $or: [{ $and:[{ 'updateDescription.updatedFields.sourceDataUpdate': { $exists: false } },{ operationType: 'update' }] }, { operationType: 'replace'}] }";
+                    // observe updates and replaces, avoid updates with sourceDataUpdateField (those are handled by cs_data_processor.js), require protocolDestinations not null
+                    var filter = "{ $or: [{ $and:[{ 'fullDocument.protocolDestinations': { $ne: null } },{ 'updateDescription.updatedFields.sourceDataUpdate': { $exists: false } },{ operationType: 'update' }] }, { operationType: 'replace'}] }";
 
                     var pipeline =
                         new EmptyPipelineDefinition<ChangeStreamDocument<rtData