Как применить фильтр к операциям агрегации в шаблоне mongodb ⇐ JAVA

[Anonymous]

Я использую Spring Data mongodb версии 4.3.6
И фильтр не работает в следующем коде.
// filter
ArrayOperators.Filter filter = ArrayOperators.Filter.filter("messages")
.as("message")
.by(ComparisonOperators.Gt.valueOf("message._id").greaterThanValue(new ObjectId(startObjectId)));
// Apply only 1 condition due to testing

Aggregation aggregation = Aggregation.newAggregation(
Aggregation.match(Criteria.where("roomId").is(roomId)),
Aggregation.project("messages").and(filter)
);

RoomMessage roomMsg = mongoTemplate.aggregate(aggregation, "room_msg", RoomMessage.class).getUniqueMappedResult();

for (Message roomMessage : roomMsg.getMessageList()) {
System.out.println("roomMessage.getContent() = " + roomMessage.getContent());
}

▲ Операция сопоставления работает, но фильтр не работает
Статус фактического документа коллекции:
[
{
roomId: 1
messages: [ {_id: , content: , .. } ]
},

{
roomId: 2
messages: [ {_id: , content: , .. } ]
}
.
.
]

Я хочу получать только те сообщения, которые соответствуют условиям в поле сообщений.

Я хочу применить следующий запрос:
db.room_msg.aggregate([
{ $match: { roomId: 1 } },
{ $project: {
messages: {
$filter: {
input: "$messages",
as: "message",
cond: {
$and: [
{ $gt: [ "$$message._id", ObjectId("67622277a31d5f6390658340") ] },
{ $lt: [ "$$message._id", ObjectId("67622277a31d5f6390658345") ] }
]
}
}
}
}
}
])



Подробнее здесь: https://stackoverflow.com/questions/792 ... b-template