 
     @check query
     uid = Package.sha.SHA256 query
-    cached = Neo4jCacheCollection.find uid: uid
+    cached = Meteor.neo4j.cacheCollection.find uid: uid
     if cached.fetch().length == 0 or @isWrite(query)
       if Meteor.isServer
         @run uid, query, opts, new Date

    # @description Listen for all requests to Neo4j
    # if request is writing/changing/removing data
    # we will find all sensitive data and update 
    # all subscribed records at Neo4jCacheCollection
    #
    ###
    Meteor.N4JDB.listen (query, opts) ->
      if Meteor.neo4j.isWrite(query)
        sensitivities = Meteor.neo4j.parseSensitivities(query, opts)
        if sensitivities
          affectedRecords = Neo4jCacheCollection.find(
            sensitivities: '$in': sensitivities
            type: 'READ')
          bound (->

      if Meteor.neo4j.allowClientQuery == true and Meteor.isClient
        if callback
          Tracker.autorun ->
            result = Meteor.neo4j.cacheCollection.findOne(uid: uid)
            if result and result.data
              callback and callback null, result.data
      else
        if callback
          if !Meteor.neo4j.cacheCollection.findOne(uid: uid)
            Meteor.neo4j.cacheCollection.find(uid: uid).observe added: ->
              callback null, Meteor.neo4j.cacheCollection.findOne(uid: uid).data
          else
            callback null, Meteor.neo4j.cacheCollection.findOne(uid: uid).data
      Meteor.neo4j.cache.getObject uid

    ###
