mutable_subscription_set_handle.dart

// Copyright 2024 MongoDB, Inc.
// SPDX-License-Identifier: Apache-2.0

part of 'realm_core.dart';

class MutableSubscriptionSetHandle extends SubscriptionSetHandle {
  MutableSubscriptionSetHandle._(Pointer<realm_flx_sync_mutable_subscription_set> pointer, RealmHandle root) : super._(pointer.cast(), root);

  Pointer<realm_flx_sync_mutable_subscription_set> get _mutablePointer => super._pointer.cast();

  SubscriptionSetHandle commit() => SubscriptionSetHandle._(invokeGetPointer(() => _realmLib.realm_sync_subscription_set_commit(_mutablePointer)), _root);

  SubscriptionHandle insertOrAssignSubscription(RealmResults results, String? name, bool update) {
    if (!update) {
      if (name != null && findByName(name) != null) {
        throw RealmException('Duplicate subscription with name: $name');
      }
    }
    return using((arena) {
      final outIndex = arena<Size>();
      final outInserted = arena<Bool>();
      invokeGetBool(() => _realmLib.realm_sync_subscription_set_insert_or_assign_results(
            _mutablePointer,
            results.handle._pointer,
            name?.toCharPtr(arena) ?? nullptr,
            outIndex,
            outInserted,
          ));
      return this[outIndex.value];
    });
  }

  bool erase(Subscription subscription) {
    return using((arena) {
      final outErased = arena<Bool>();
      invokeGetBool(() => _realmLib.realm_sync_subscription_set_erase_by_id(
            _mutablePointer,
            subscription.id.toNative(arena),
            outErased,
          ));
      return outErased.value;
    });
  }

  bool eraseByName(String name) {
    return using((arena) {
      final outErased = arena<Bool>();
      invokeGetBool(() => _realmLib.realm_sync_subscription_set_erase_by_name(
            _mutablePointer,
            name.toCharPtr(arena),
            outErased,
          ));
      return outErased.value;
    });
  }

  bool eraseByResults(RealmResults results) {
    return using((arena) {
      final outErased = arena<Bool>();
      invokeGetBool(() => _realmLib.realm_sync_subscription_set_erase_by_results(
            _mutablePointer,
            results.handle._pointer,
            outErased,
          ));
      return outErased.value;
    });
  }

  void clear() => invokeGetBool(() => _realmLib.realm_sync_subscription_set_clear(_mutablePointer));
}