INNER CODE UNIT · JavaScript

setupChangeStream

riclolsen/json-scada · src/OPC-UA-Server/index.js:907

          function setupChangeStream(rtColl, groups1ToFilter) {
            let csFilterGroup1 = {
              'fullDocument.group1': {
                $exists: true,
              },
            }

            if (groups1ToFilter !== null && groups1ToFilter?.length > 0) {
              csFilterGroup1 = {
                'fullDocument.group1': { $in: groups1ToFilter },
              }
            }

            const csPipeline = [
              {
                $project: { documentKey: false },
              },
              {

View source record →