index.android.ts

import { FunctionsErrorCode, HttpsCallable, HttpsCallableOptions, HttpsErrorCode, IFunctions } from './common';
import { deserialize, firebase, FirebaseApp, serialize } from '@nativescript/firebase-core';

let defaultFunctions: Functions;

const fb = firebase();
Object.defineProperty(fb, 'functions', {
	value: (app?: FirebaseApp) => {
		if (!app) {
			if (!defaultFunctions) {
				defaultFunctions = new Functions();
			}
			return defaultFunctions;
		}

		return new Functions(app);
	},
	writable: false,
});
/**
  Firebase Functions Region - Region for which to run HttpsCallable method
  Set parameter using firebase().app().functions(regionOrCustomDomain: string)
  @see https://firebase.google.com/docs/reference/android/com/google/firebase/functions/FirebaseFunctions
  @note If not set, default region is used ("us-central1")
  */
let defaultRegionOrCustomDomain: string;
/**
  Add 'functions' method to FirebaseApp class
  @see https://firebase.google.com/docs/reference/node/firebase.app.App
  @see https://firebase.google.com/docs/functions/locations
  @param regionOrCustomDomain(string)(Optional): Name of the region for which to Functions results
  @return Functions
  */
const fbApp = FirebaseApp;
Object.defineProperty(fbApp.prototype, 'functions', {
	value: (regionOrCustomDomain?: string) => {
		defaultRegionOrCustomDomain = regionOrCustomDomain;
		if (!defaultFunctions) {
			defaultFunctions = new Functions();
		}
		return defaultFunctions;
	},
	writable: false,
});

function errorToCode(error: com.google.firebase.functions.FirebaseFunctionsException.Code) {
	let code = HttpsErrorCode.UNKNOWN;
	switch (error) {
		case com.google.firebase.functions.FirebaseFunctionsException.Code.OK:
			code = HttpsErrorCode.OK;
			break;
		case com.google.firebase.functions.FirebaseFunctionsException.Code.CANCELLED:
			code = HttpsErrorCode.CANCELLED;
			break;
		case com.google.firebase.functions.FirebaseFunctionsException.Code.UNKNOWN:
			code = HttpsErrorCode.UNKNOWN;
			break;
		case com.google.firebase.functions.FirebaseFunctionsException.Code.INVALID_ARGUMENT:
			code = HttpsErrorCode.INVALID_ARGUMENT;
			break;
		case com.google.firebase.functions.FirebaseFunctionsException.Code.DEADLINE_EXCEEDED:
			code = HttpsErrorCode.DEADLINE_EXCEEDED;
			break;
		case com.google.firebase.functions.FirebaseFunctionsException.Code.NOT_FOUND:
			code = HttpsErrorCode.NOT_FOUND;
			break;
		case com.google.firebase.functions.FirebaseFunctionsException.Code.ALREADY_EXISTS:
			code = HttpsErrorCode.ALREADY_EXISTS;
			break;
		case com.google.firebase.functions.FirebaseFunctionsException.Code.PERMISSION_DENIED:
			code = HttpsErrorCode.PERMISSION_DENIED;
			break;
		case com.google.firebase.functions.FirebaseFunctionsException.Code.RESOURCE_EXHAUSTED:
			code = HttpsErrorCode.RESOURCE_EXHAUSTED;
			break;
		case com.google.firebase.functions.FirebaseFunctionsException.Code.FAILED_PRECONDITION:
			code = HttpsErrorCode.FAILED_PRECONDITION;
			break;
		case com.google.firebase.functions.FirebaseFunctionsException.Code.ABORTED:
			code = HttpsErrorCode.ABORTED;
			break;
		case com.google.firebase.functions.FirebaseFunctionsException.Code.OUT_OF_RANGE:
			code = HttpsErrorCode.OUT_OF_RANGE;
			break;
		case com.google.firebase.functions.FirebaseFunctionsException.Code.UNIMPLEMENTED:
			code = HttpsErrorCode.UNIMPLEMENTED;
			break;
		case com.google.firebase.functions.FirebaseFunctionsException.Code.INTERNAL:
			code = HttpsErrorCode.INTERNAL;
			break;
		case com.google.firebase.functions.FirebaseFunctionsException.Code.UNAVAILABLE:
			code = HttpsErrorCode.UNAVAILABLE;
			break;
		case com.google.firebase.functions.FirebaseFunctionsException.Code.DATA_LOSS:
			code = HttpsErrorCode.DATA_LOSS;
			break;
		case com.google.firebase.functions.FirebaseFunctionsException.Code.UNAUTHENTICATED:
			code = HttpsErrorCode.UNAUTHENTICATED;
			break;
		default:
			break;
	}

	return code;
}

export class HttpsError extends Error {
	readonly code: FunctionsErrorCode;
	readonly details?: any;
	readonly native: any;

	constructor(code: FunctionsErrorCode, message: string, details = null, native = null) {
		super(message);
		this.code = code;
		this.details = details;
		this.native = native;
	}
}

function toHttpsError(error: any) {
	let details = null;
	let message = error.getMessage?.();
	let code = HttpsErrorCode.UNKNOWN;
	const cause = error.getCause();
	if (cause instanceof com.google.firebase.functions.FirebaseFunctionsException) {
		const functionsException = cause;
		details = functionsException.getDetails();
		code = errorToCode(functionsException.getCode());
		message = (functionsException as any).getMessage?.();
		const isTimeout = code === HttpsErrorCode.DEADLINE_EXCEEDED;

		if ((functionsException as any).getCause?.() instanceof java.io.IOException && !isTimeout) {
			code = HttpsErrorCode.UNAVAILABLE;
			message = HttpsErrorCode.UNAVAILABLE;
		}
	}

	return new HttpsError(code, message, details, error);
}

export class Functions implements IFunctions {
	_native: com.google.firebase.functions.FirebaseFunctions;
	_app: FirebaseApp;

	constructor(app?: FirebaseApp) {
		if (app?.native) {
			this._native = defaultRegionOrCustomDomain ? com.google.firebase.functions.FirebaseFunctions.getInstance(app.native, defaultRegionOrCustomDomain) : com.google.firebase.functions.FirebaseFunctions.getInstance(app.native);
		} else {
			if (defaultFunctions) {
				return defaultFunctions;
			}
			defaultFunctions = this;
			// If defaultRegionOrCustomDomain is set, get FirebaseFunctions instance using that parameter
			// @see https://firebase.google.com/docs/functions/locations_client-side_location_selection_for_callable_functions
			this._native = defaultRegionOrCustomDomain ? com.google.firebase.functions.FirebaseFunctions.getInstance(defaultRegionOrCustomDomain) : com.google.firebase.functions.FirebaseFunctions.getInstance();
		}
	}

	httpsCallable(name: string, options?: HttpsCallableOptions): HttpsCallable {
		const callable = this.native.getHttpsCallable(name);
		if (typeof options?.timeout === 'number') {
			callable.setTimeout(options.timeout, java.util.concurrent.TimeUnit.SECONDS);
		}
		return (data: any) => {
			return new Promise((resolve, reject) => {
				org.nativescript.firebase.functions.FirebaseFunctions.call(
					callable,
					data ? serialize(data, true) : null,
					new org.nativescript.firebase.functions.FirebaseFunctions.Callback<com.google.firebase.functions.HttpsCallableResult>({
						onSuccess(result: com.google.firebase.functions.HttpsCallableResult): void {
							resolve(deserialize(result?.getData?.()));
						},
						onError(error): void {
							reject(toHttpsError(error));
						},
					})
				);
			});
		};
	}

	useEmulator(host: string, port: number) {
		this.native.useEmulator(host === 'localhost' || host === '127.0.0.1' ? '10.0.2.2' : host, port);
	}

	get native() {
		return this._native;
	}

	get ios() {
		return this.native;
	}

	useFunctionsEmulatorOrigin(origin: string) {
		this.native.useFunctionsEmulator(origin);
	}

	get app(): FirebaseApp {
		if (!this._app) {
			// @ts-ignore
			this._app = FirebaseApp.fromNative(this.native.getApp());
		}
		return this._app;
	}
}