}
/* Propagate the event to other plugins subscribed to the query */
- manifold.raise_query_event(query_uuid, event_type, new_data);
+ manifold.query_store.recount(query_uuid);
+ manifold.raise_record_event(query_uuid, event_type, new_data);
break;
}
/* Propagate the event to other plugins subscribed to the query */
+ manifold.query_store.recount(query_uuid);
manifold.raise_query_event(query_uuid, event_type, new_data);
break;
}
break;
}
-
+/*
// 3. Inform others about the change
// a) the main query...
manifold.raise_record_event(query_uuid, event_type, data);
});
data.key = value_key;
}
-
- manifold.query_store.recount(cur_query.query_uuid);
manifold.raise_record_event(cur_query.query_uuid, event_type, data);
+*/
break;
return;
case STATE_SET_IN_SUCCESS:
- case STATE_SET_OUT_SUCCESS:
+ action = 'ADD';
msg = 'SUCCESS';
break;
-
case STATE_SET_IN_FAILURE:
+ action = 'ADD';
+ msg = 'FAILURE';
+ break;
+
+ case STATE_SET_OUT_SUCCESS:
+ action = 'REMOVE';
+ msg = 'FAILURE';
+ break;
case STATE_SET_OUT_FAILURE:
+ action = 'REMOVE';
msg = 'FAILURE';
break;