add ios implementation for functions

Author: nbransby

firebase-auth/src/iosMain/kotlin/dev/teamhub/firebase/auth/auth.kt

@@ -6,7 +6,10 @@ import dev.teamhub.firebase.FirebaseApp
 import dev.teamhub.firebase.FirebaseException
 import kotlinx.cinterop.*
 import kotlinx.coroutines.channels.awaitClose
+import kotlinx.coroutines.flow.*
 import platform.Foundation.*
+import kotlinx.coroutines.CompletableDeferred
+
 
 actual val Firebase.auth
     get() = FirebaseAuth(FIRAuth.auth())
@@ -93,7 +96,6 @@ private suspend fun <T> T.await(function: T.(callback: (NSError?) -> Unit) -> Un
     job.await()
 }
 
-
 private fun NSError.toException() = when(domain) {
     FIRAuthErrorDomain -> when(code) {
         FIRAuthErrorCodeInvalidActionCode,

firebase-firestore/src/iosMain/kotlin/dev/teamhub/firebase/firestore/firestore.kt

@@ -8,7 +8,7 @@ import kotlinx.serialization.ImplicitReflectionSerializer
 import kotlinx.serialization.SerializationStrategy
 import kotlinx.serialization.DeserializationStrategy
 
-actual open class FirebaseFirestoreException : FirebaseException()
+actual open class FirebaseFirestoreException(message: String) : FirebaseException(message)
 
 actual val FirebaseFirestoreException.code: FirestoreExceptionCode get() = TODO("not implemented")
 

firebase-functions/src/iosMain/kotlin/dev/teamhub/firebase/functions/FirebaseFunctions.kt

@@ -0,0 +1,75 @@
+package dev.teamhub.firebase.functions
+
+import cocoapods.FirebaseFunctions.*
+import dev.teamhub.firebase.Firebase
+import dev.teamhub.firebase.FirebaseApp
+import dev.teamhub.firebase.FirebaseException
+import kotlinx.serialization.DeserializationStrategy
+import kotlinx.serialization.SerializationStrategy
+import kotlinx.serialization.ImplicitReflectionSerializer
+import dev.teamhub.firebase.decode
+import dev.teamhub.firebase.encode
+import platform.Foundation.*
+import kotlinx.coroutines.CompletableDeferred
+
+actual val Firebase.functions
+    get() = FirebaseFunctions(FIRFunctions.functions())
+
+actual fun Firebase.functions(region: String) =
+    FirebaseFunctions(FIRFunctions.functionsForRegion(region))
+
+actual fun Firebase.functions(app: FirebaseApp) =
+    FirebaseFunctions(FIRFunctions.functionsForApp(app.ios))
+
+actual fun Firebase.functions(app: FirebaseApp, region: String) =
+    FirebaseFunctions(FIRFunctions.functionsForApp(app.ios, region))
+
+actual class FirebaseFunctions internal constructor(val ios: FIRFunctions) {
+    actual fun httpsCallable(name: String, timeout: Long?) =
+        HttpsCallableReference(ios.HTTPSCallableWithName(name).apply { timeout?.let { setTimeoutInterval(it/1000.0) } })
+}
+
+actual class HttpsCallableReference internal constructor(val ios: FIRHTTPSCallable) {
+    actual suspend fun call() = HttpsCallableResult(ios.awaitResult { callWithCompletion(it) })
+
+    actual suspend inline fun <reified T> call(data: T) =
+        HttpsCallableResult(ios.awaitResult { callWithObject(encode(data), it) })
+
+    actual suspend inline fun <reified T> call(strategy: SerializationStrategy<T>, data: T) =
+        HttpsCallableResult(ios.awaitResult { callWithObject(encode(strategy, data), it) })
+}
+
+actual class HttpsCallableResult constructor(val ios: FIRHTTPSCallableResult) {
+
+    actual inline fun <reified T> data() =
+        decode<T>(value = ios.data)
+
+    actual inline fun <reified T> data(strategy: DeserializationStrategy<T>) =
+        decode(strategy, ios.data)
+}
+
+actual class FirebaseFunctionsException(message: String): FirebaseException(message)
+
+private suspend fun <T> T.await(function: T.(callback: (NSError?) -> Unit) -> Unit) {
+    val job = CompletableDeferred<Unit>()
+    function { error ->
+        if(error == null) {
+            job.complete(Unit)
+        } else {
+            job.completeExceptionally(FirebaseFunctionsException(error.toString()))
+        }
+    }
+    job.await()
+}
+
+suspend fun <T, R> T.awaitResult(function: T.(callback: (R?, NSError?) -> Unit) -> Unit): R {
+    val job = CompletableDeferred<R>()
+    function { result, error ->
+        if(result != null) {
+            job.complete(result)
+        } else if(error != null) {
+            job.completeExceptionally(FirebaseFunctionsException(error.toString()))
+        }
+    }
+    return job.await()
+}