Você não pode fazer isso com o pipeline de agregação. Você deve entender que a agregação do MongoDB é uma série de operadores especiais aplicados a uma coleção. Quando você executa um pipeline de agregação, o MongoDB canaliza os operadores uns para os outros, ou seja, a saída de um operador se torna a entrada do seguinte operador. O resultado de cada operador é uma nova coleção de documentos.
Portanto, o que você está tentando alcançar acima pode ser simplesmente reescrito como o seguinte pipeline sem a necessidade de criar uma matriz de documentos primeiro:
var collection = db.collection('member'),
pipeline = [
{ "$match": { createdDate: currentDate, country: 'BD' } },
{
"$group": {
"_id": { "memberType": "$memberType", "country": "$country" },
"memberCount": {
"$sum": { "$cond":[ { "$gt": ["$numberOfInvitees", 0] }, 1, 0 ] }
},
"sameCount": { "$sum": 1 }
}
}
];
collection.aggregate(pipeline, function(err, result){
if (err) throw err;
console.log(result);
});
ATUALIZAÇÃO
O acompanhamento das alterações em sua pergunta, executando o seguinte pipeline de agregação, fornecerá o resultado desejado:
var collection = db.collection('member'),
pipeline = [
{ "$match": { createdDate: currentDate, country: 'BD' } },
{
"$group": {
"_id": {
"memberType": "$memberType",
"country": "$country"
},
"invitees":{
"$push": {
"memberID": "$memberID",
"count": "$numberOfInvitees"
}
},
"inviteesList": { "$push": "$numberOfInvitees" },
"memberCount": { "$sum": 1 }
}
},
{ "$unwind": "$invitees" },
{ "$unwind": "$inviteesList" },
{
"$group": {
"_id": "$invitees.memberID",
"sameInviteesCount": {
"$sum": {
"$cond": [
{ "$eq": ["$inviteesList", "$invitees.count"] },
1, 0
]
}
},
"lessInviteesCount": {
"$sum": {
"$cond":[
{ "$lt": ["$inviteesList", "$invitees.count"] },
1, 0
]
}
},
"memberCount": { "$first": "$memberCount" }
}
}
];
collection.aggregate(pipeline, function(err, result){
if (err) throw err;
console.log(result);
});
