I'm getting this error when executing the following code:
getAggregatedRatings(query).then(ratings=>{
    if(ratings){
        return res.json(ratings);
    }else{
        return res.send(200);
    }        
}).catch((error)=>{
    return res.send(500); 
});
function getAggregatedRatings(query){
    movieRating.aggregate(query)
    .exec((err, ratings)=> {
        if (err || !ratings) {
            return Promise.reject(err);
        }
        else {
            return Promise.resolve(ratings);
        }
    });
}
Please note that 'getAggregatedRatings' returns the query results as expected. Please advise what I'm doing wrong.
 
     
    