better queries in websockets

This commit is contained in:
MilosKozak
2017-02-23 22:32:49 +01:00
parent 225ca1f8e1
commit 4788eaf955
+18 -8
View File
@@ -262,11 +262,16 @@ function init (env, ctx, server) {
// treatments deduping
if (data.collection === 'treatments') {
var query = {
created_at: data.data.created_at
, eventType: data.data.eventType
};
var query;
if (data.data.NSCLIENT_ID) {
query = { NSCLIENT_ID: data.data.NSCLIENT_ID };
} else {
query = {
created_at: data.data.created_at
, eventType: data.data.eventType
};
}
// try to find exact match
ctx.store.collection(collection).find(query).toArray(function findResult (err, array) {
if (err || array.length > 0) {
@@ -337,9 +342,14 @@ function init (env, ctx, server) {
});
// devicestatus deduping
} else if (data.collection === 'devicestatus') {
var queryDev = {
created_at: data.data.created_at
};
var queryDev;
if (data.data.NSCLIENT_ID) {
queryDev = { NSCLIENT_ID: data.data.NSCLIENT_ID };
} else {
queryDev = {
created_at: data.data.created_at
};
}
// try to find exact match
ctx.store.collection(collection).find(queryDev).toArray(function findResult (err, array) {