chore: web Cloud Functions stream wip

Author: SelaseKay

packages/cloud_functions/cloud_functions_platform_interface/lib/src/platform_interface/platform_interface_firebase_functions.dart

@@ -70,14 +70,14 @@ abstract class FirebaseFunctionsPlatform extends PlatformInterface {
   /// Creates a [HttpsCallablePlatform] instance from a [Uri]
   HttpsCallablePlatform httpsCallableWithUri(
       String? origin, Uri uri, HttpsCallableOptions options) {
-    throw UnimplementedError('httpsCallable() is not implemented');
+    throw UnimplementedError('httpsCallableWithUri() is not implemented');
   }
 
   HttpsCallableStreamsPlatform httpsStreamCallable(
     String? origin,
     String name,
   ) {
-    throw UnimplementedError('httpsCallable() is not implemented');
+    throw UnimplementedError('httpsStreamCallable() is not implemented');
   }
 
   HttpsCallableStreamsPlatform httpsStreamCallableWithUri(

packages/cloud_functions/cloud_functions_web/lib/cloud_functions_web.dart

@@ -4,6 +4,7 @@
 // found in the LICENSE file.
 
 import 'package:cloud_functions_platform_interface/cloud_functions_platform_interface.dart';
+import 'package:cloud_functions_web/https_callable_stream_web.dart';
 import 'package:firebase_core/firebase_core.dart';
 import 'package:firebase_core_web/firebase_core_web.dart';
 import 'package:firebase_core_web/firebase_core_web_interop.dart'
@@ -62,4 +63,9 @@ class FirebaseFunctionsWeb extends FirebaseFunctionsPlatform {
       String? origin, Uri uri, HttpsCallableOptions options) {
     return HttpsCallableWeb(this, _delegate, origin, null, options, uri);
   }
+
+  @override
+  HttpsCallableStreamsPlatform httpsStreamCallable(String? origin, String name) {
+    return HttpsCallableStreamWeb(this, _delegate, origin, name, null);
+  }
 }

packages/cloud_functions/cloud_functions_web/lib/https_callable_stream_web.dart

@@ -0,0 +1,45 @@
+// ignore_for_file: require_trailing_commas
+// Copyright 2020, the Chromium project authors.  Please see the AUTHORS file
+// for details. All rights reserved. Use of this source code is governed by a
+// BSD-style license that can be found in the LICENSE file.
+
+import 'dart:js_interop';
+
+import 'package:cloud_functions_platform_interface/cloud_functions_platform_interface.dart';
+
+import 'interop/functions.dart' as functions_interop;
+
+class HttpsCallableStreamWeb extends HttpsCallableStreamsPlatform {
+  HttpsCallableStreamWeb(
+      super.functions, this._webFunctions, super.origin, super.name, super.uri);
+
+  final functions_interop.Functions _webFunctions;
+
+  @override
+  Future get data => throw UnimplementedError();
+
+  @override
+  Stream<dynamic> stream(Object? parameters) async* {
+    if (origin != null) {
+      final uri = Uri.parse(origin!);
+
+      _webFunctions.useFunctionsEmulator(uri.host, uri.port);
+    }
+
+    late functions_interop.HttpsCallable callable;
+
+    if (name != null) {
+      callable = _webFunctions.httpsCallable(name!);
+    } else if (uri != null) {
+      callable = _webFunctions.httpsCallableUri(uri!);
+    } else {
+      throw ArgumentError('Either name or uri must be provided');
+    }
+
+    final JSAny? parametersJS = parameters?.jsify();
+
+    await for (final value in  callable.stream(parametersJS)){
+      yield value;
+    }
+  }
+}

packages/cloud_functions/cloud_functions_web/lib/interop/functions.dart

@@ -6,7 +6,6 @@
 // ignore_for_file: public_member_api_docs
 
 import 'dart:js_interop';
-
 import 'package:firebase_core_web/firebase_core_web_interop.dart';
 
 import 'functions_interop.dart' as functions_interop;
@@ -84,6 +83,19 @@ class HttpsCallable extends JsObjectWrapper<JSFunction> {
       result! as functions_interop.HttpsCallableResultJsImpl,
     );
   }
+
+  Stream<HttpsCallableResult> stream(JSAny? data) async* {
+    final streamCallable =
+        await (jsObject as functions_interop.HttpsCallable).stream().toDart;
+    final streamResult =
+        streamCallable! as functions_interop.HttpsCallableStreamResultJsImpl;
+
+    await for (final value in streamResult.stream.asStream()) {
+      yield HttpsCallableResult.getInstance(
+        value as functions_interop.HttpsCallableResultJsImpl,
+      );
+    }
+  }
 }
 
 /// Returns Dart representation from JS Object.
@@ -137,3 +149,25 @@ class HttpsCallableResult
     return _data;
   }
 }
+
+class HttpsCallableStreamResult
+    extends JsObjectWrapper<functions_interop.HttpsCallableStreamResultJsImpl> {
+  HttpsCallableStreamResult._fromJsObject(
+      functions_interop.HttpsCallableStreamResultJsImpl jsObject)
+      : _data = _dartify(jsObject.data),
+        super.fromJsObject(jsObject);
+
+  static final _expando = Expando<HttpsCallableStreamResult>();
+  final dynamic _data;
+
+  /// Creates a new HttpsCallableResult from a [jsObject].
+  static HttpsCallableStreamResult getInstance(
+      functions_interop.HttpsCallableStreamResultJsImpl jsObject) {
+    return _expando[jsObject] ??=
+        HttpsCallableStreamResult._fromJsObject(jsObject);
+  }
+
+  dynamic get data {
+    return _data;
+  }
+}

packages/cloud_functions/cloud_functions_web/lib/interop/functions_interop.dart

@@ -76,3 +76,67 @@ abstract class HttpsCallableResultJsImpl {}
 extension HttpsCallableResultJsImplExtension on HttpsCallableResultJsImpl {
   external JSAny? get data;
 }
+
+@JS('HttpsCallable')
+@staticInterop
+class HttpsCallable {}
+
+extension HttpsCallableExtension on HttpsCallable {
+  external JSPromise stream(
+      [JSAny? data, HttpsCallableStreamOptions? options]);
+}
+
+
+@JS('HttpsCallableStreamResult')
+@staticInterop
+class HttpsCallableStreamResultJsImpl {}
+
+extension HttpsCallableStreamResultJsImplExtension
+    on HttpsCallableStreamResultJsImpl {
+  external JSPromise data;
+  external JsAsyncIterator<JSAny> stream;
+}
+
+
+@JS('HttpsCallableStreamOptions')
+@staticInterop
+@anonymous
+abstract class HttpsCallableStreamOptions {
+  external factory HttpsCallableStreamOptions(
+      {JSBoolean? limitedUseAppCheckTokens});
+}
+
+extension HttpsCallableStreamOptionsExtension on HttpsCallableStreamOptions {
+  external JSBoolean? get limitedUseAppCheckTokens;
+  external set limitedUseAppCheckTokens(JSBoolean? t);
+}
+
+extension type JsAsyncIterator<T extends JSAny>._(JSObject _)
+    implements JSObject {
+  external JSPromise<JsAsyncIteratorState<T>> next();
+
+  Stream<T> asStream() async* {
+    this as SymbolJsImpl;
+    while (true) {
+      final result = await next().toDart;
+      if (result.done) break;
+      yield result.value;
+    }
+  }
+}
+
+extension type JsAsyncIteratorState<T extends JSAny>._(JSObject _)
+    implements JSObject {
+  external bool get done;
+
+  external T get value;
+}
+
+
+@JS('Symbol')
+@staticInterop
+extension type SymbolJsImpl(JSObject _) implements JSObject {
+  
+  @JS('asyncIterator')
+  external static JSSymbol asyncIterator;
+}