         if not user_query[primary_key]? and user_query[primary_key] != null
             cb("changefeed MUST include primary key (='#{primary_key}') in query")
             return
-
         watch  = []
         select = {}
         init_tracker = tracker = undefined

                _query_opts.query = @_user_get_query_query(delete_option, table, opts.query)
                x = @_user_get_query_options(delete_option, opts.options, opts.multi, client_query.all?.options)
                if x.err
                    cb(err)
                    return
                misc.merge(_query_opts, x)



    _user_get_query_changefeed: (changes, table, primary_key, user_query,
                                 where, json_fields, account_id, client_query, cb) =>
        dbg = @_dbg("_user_get_query_changefeed(table='#{table}')")
        dbg()
        if not misc.is_object(changes)
            cb("changes must be an object with keys id and cb")
            return
