react-native-firebase/packages/database/lib/DatabaseOnDisconnect.js

/* eslint-disable no-console */
/*
 * Copyright (c) 2016-present Invertase Limited & Contributors
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this library except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *   http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 *
 */

import {
  isFunction,
  isNull,
  isNumber,
  isObject,
  isString,
  isUndefined,
  promiseWithOptionalCallback,
} from '@react-native-firebase/common';

export default class DatabaseOnDisconnect {
  constructor(reference) {
    this._ref = reference;
  }

  /**
   * @url https://firebase.google.com/docs/reference/js/firebase.database.OnDisconnect#cancel
   */
  cancel(onComplete) {
    if (!isUndefined(onComplete) && !isFunction(onComplete)) {
      throw new Error(
        `firebase.database().ref().onDisconnect().cancel(*) 'onComplete' must be a function if provided.`,
      );
    }

    return promiseWithOptionalCallback(
      this._ref._database.native.onDisconnectCancel(this._ref.path),
      onComplete,
    );
  }

  /**
   * @url https://firebase.google.com/docs/reference/js/firebase.database.OnDisconnect#remove
   */
  remove(onComplete) {
    if (!isUndefined(onComplete) && !isFunction(onComplete)) {
      throw new Error(
        `firebase.database().ref().onDisconnect().remove(*) 'onComplete' must be a function if provided.`,
      );
    }

    return promiseWithOptionalCallback(
      this._ref._database.native.onDisconnectRemove(this._ref.path),
      onComplete,
    );
  }

  /**
   * @url https://firebase.google.com/docs/reference/js/firebase.database.OnDisconnect#set
   */
  set(value, onComplete) {
    if (isUndefined(value)) {
      throw new Error(`firebase.database().ref().value(*) 'value' must be defined.`);
    }

    if (!isUndefined(onComplete) && !isFunction(onComplete)) {
      throw new Error(
        `firebase.database().ref().onDisconnect().set(_, *) 'onComplete' must be a function if provided.`,
      );
    }

    return promiseWithOptionalCallback(
      this._ref._database.native.onDisconnectSet(this._ref.path, { value }),
      onComplete,
    );
  }

  /**
   * @url https://firebase.google.com/docs/reference/js/firebase.database.OnDisconnect#setwithpriority
   */
  setWithPriority(value, priority, onComplete) {
    if (isUndefined(value)) {
      throw new Error(`firebase.database().ref().setWithPriority(*) 'value' must be defined.`);
    }

    if (!isNumber(priority) && !isString(priority) && !isNull(priority)) {
      throw new Error(
        `firebase.database().ref().onDisconnect().setWithPriority(_, *) 'priority' must be a number, string or null value.`,
      );
    }

    if (!isUndefined(onComplete) && !isFunction(onComplete)) {
      throw new Error(
        `firebase.database().ref().onDisconnect().setWithPriority(_, _, *) 'onComplete' must be a function if provided.`,
      );
    }

    return promiseWithOptionalCallback(
      this._ref._database.native.onDisconnectSetWithPriority(this._ref.path, { value, priority }),
      onComplete,
    );
  }

  /**
   * @url https://firebase.google.com/docs/reference/js/firebase.database.OnDisconnect#update
   */
  update(values, onComplete) {
    if (!isObject(values)) {
      throw new Error(
        `firebase.database().ref().onDisconnect().update(*) 'values' must be an object.`,
      );
    }

    if (!Object.keys(values).length) {
      throw new Error(
        `firebase.database().ref().onDisconnect().update(*) 'values' must be an object containing multiple values.`,
      );
    }

    // TODO validate keys; / . # $ |

    if (!isUndefined(onComplete) && !isFunction(onComplete)) {
      throw new Error(
        `firebase.database().ref().onDisconnect().update(_, *) 'onComplete' must be a function if provided.`,
      );
    }

    return promiseWithOptionalCallback(
      this._ref._database.native.onDisconnectUpdate(this._ref.path, { values }),
      onComplete,
    );
  }
}