             if err
                 return cb err
 
+            subscriptions = subscriptions.filter @filterSubscription
             subscriptions = rsm.cropResults subscriptions, 'user'
             cb null, subscriptions
 

                   listeners.indexOf(update.user) < 0
                    listeners.push update.user

            async.forEach listeners, (listener, cb3) =>
                notification = Object.create(@req)
                notification.listener = listener
                @router.notify notification
                cb3()
            , cb2
        ], cb

class ModeratorNotify extends ModelOperation

                    cb3()
            , cb2
        , (cb2) =>
            # Then, retrieve all listeners
            # (assuming all updates pertain one single node)

            # TODO: walk in batches
            logger.debug "notifyNotification: #{inspect @req}"
            t.getNodeListeners @req.node, cb2
