Проблемы MongoDB с переводом JS-запроса на C#

У меня есть коллекция, в которой хранится информация о сиренах – уведомлениях. Мне нужно получить сводную статистику пользователей по (длинному) идентификатору пользователя:

1. Количество принадлежащих сирен;
2. Количество подписок;
3. Количество сирен, за которые несет ответственность пользователь.

Структура документа Siren (обязательные поля только для вопросов):

{
  "_id": ObjectId( "65fc94593273fc2ab6ff8960"),
  "ownerid": NumberLong( "99999999"), 
  "listener": [
    NumberLong( "11111111"),
    NumberLong( "00000000")
  ],
  "responsible": [
    NumberLong( "11111111")
    ]
}

После двух дней борьбы я сделал рабочий запрос через JS.

db.sirens.aggregate([
  {
    "$match": {
      "$or": [
        { "ownerid": userId },
        { "listener": userId },
        { "responsible": userId }
      ]}},
  {
    "$group": {
      "_id": null,
      "owner": { "$sum": { "$cond": [{ "$eq": ["$ownerid", userId ] }, 1, 0] }},
      "responsible": { "$sum": { "$cond": [{ "$and": [
                 { "$ne": ["$responsible", null] },
                 { "$isArray": "$responsible" }, 
                 { "$in": [userId, "$responsible"] }
              ] }, 1,0 ] }}
      ,"listener": { "$sum": { "$cond": [{ "$and": [
                 { "$ne": ["$listener", null] },
                 { "$isArray": "$listener" }, 
                 { "$in": [userId, "$listener"] }
              ] }, 1,0 ] }}   
    }
  }
]);

Но вот проблема, которую я не могу решить. поля «слушатель» и «ответственный» могут отсутствовать. А в JS это условие:{ "$isArray": "$responsible" }, обрабатывает ситуацию. Но я не могу сделать то же самое на C#.

Вот код, который у меня есть:

var query = sirens.AsQueryable<SirenRepresentation>()
    .Where(_sirena => _sirena.OwnerId == userId
                      || (_sirena.Listener != null && _sirena.Listener.Any(x => x == userId))
                      || (_sirena.Responsible != null && _sirena.Responsible.Any(x => x == userId)))
    .GroupBy(s => true)
    .Select(g => new UserStatistics
    {
      SirenasCount = g.Sum(_siren => _siren.OwnerId == userId ? 1 : 0),
      Subscriptions = g.Sum(_siren => (_siren.Listener != null && _siren.Listener.Contains(userId)) ? 1 : 0),
      Responsible = g.Sum(_siren => (_siren.Responsible != null && _siren.Responsible.Contains(userId)) ? 1 : 0)
    });
    
public class SirenRepresentation
{
  [BsonId]
  public ObjectId Id { get; set; }
  [BsonElement("ownerid"), BsonRepresentation(BsonType.Int64)]
  public long OwnerId { get; set; }
  [BsonRepresentation(BsonType.Int64)]
  [BsonElement("listener")]
  public long[] Listener { get;  set; } = [];
  [BsonRepresentation(BsonType.Int64)]
  [BsonElement("responsible")]
  public long[] Responsible { get;  set; } = [];
  [BsonElement("requests")]
//...
}

public class UserStatistics{
  public int SirenasCount{get;set;}
  public int Subscriptions{get;set;}
  public int Responsible{get;set;}
}

Когда одно из полей отсутствует, перехватывается исключение:

Произошло исключение: CLR/MongoDB.Driver.MongoCommandException. исключение типа «MongoDB.Driver.MongoCommandException» произошло в System.Private.CoreLib.dll, но не обрабатывался в пользовательском коде: 'Команда Ошибка агрегирования: ошибка PlanExecutor во время агрегации:: вызвана :: $in требует массив в качестве второго аргумента, найдено: отсутствует.'

Обновлять. Фиксированный метод:

public async Task<UserStatistics> Get(long userId)
{
  var query = sirens.AsQueryable()
  .Where(_sirena => _sirena.OwnerId == userId
                    || _sirena.Listener.Any(x => x == userId)
                    || _sirena.Responsible.Any(x => x == userId))
  .GroupBy(keySelector: x => true,
    resultSelector: (_, _sirens) => new UserStatistics
      {
        SirenasCount = _sirens.Sum(x => x.OwnerId == userId ? 1 : 0),
        Subscriptions = _sirens.Sum(_sirena => (_sirena.Listener ?? new long[] { }).Contains(userId) ? 1 : 0),
        Responsible = _sirens.Sum(_sirena => (_sirena.Responsible ?? new long[] { }).Contains(userId) ? 1 : 0)
      })
  .FirstOrDefaultAsync();
  return await query;
}

Большое спасибо Ён Шуну <3

P.S. MongoDB.Driver 2.24 также обеспечивает поведение для перевода some_array is Array, но, к сожалению, в нем есть ошибки. Это переводится is Array как выражение:

"$cond": {
    "if": {
        "$and": [{
                "$or": [{
                        "$eq": ["$some_array._t", "Array"]
                    }, {
                        "$and": [{
                                "$isArray": "$some_array._t"
                            }, {
                                "$in": ["Array", "$some_array._t"]
                            }
                        ...

А в моем случае для MongoDB v.7.0.6 это работает некорректно. Но если мы изменим "$eq": ["$some_array._t", "Array"] -> {"$isArray": "$some_array"}, то всё заработает.