refactor: abstract web scanner

@@ -33,10 +33,6 @@ class MobileScannerWebPlugin {
   // Controller to send events back to the framework
   // Controller to send events back to the framework
   StreamController controller = StreamController.broadcast();
   StreamController controller = StreamController.broadcast();
 
 
-  // The video stream. Will be initialized later to see which camera needs to be used.
-  html.MediaStream? _localStream;
-  html.VideoElement video = html.VideoElement();
-
   // ID of the video feed
   // ID of the video feed
   String viewID = 'WebScanner-${DateTime.now().millisecondsSinceEpoch}';
   String viewID = 'WebScanner-${DateTime.now().millisecondsSinceEpoch}';
 
 
@@ -46,8 +42,6 @@ class MobileScannerWebPlugin {
   final WebBarcodeReaderBase _barCodeReader = JsQrCodeReader();
   final WebBarcodeReaderBase _barCodeReader = JsQrCodeReader();
   StreamSubscription? _barCodeStreamSubscription;
   StreamSubscription? _barCodeStreamSubscription;
 
 
-  html.DivElement vidDiv = html.DivElement();
-
   /// Handle incomming messages
   /// Handle incomming messages
   Future<dynamic> handleMethodCall(MethodCall call) async {
   Future<dynamic> handleMethodCall(MethodCall call) async {
     switch (call.method) {
     switch (call.method) {
@@ -68,87 +62,48 @@ class MobileScannerWebPlugin {
 
 
   /// Can enable or disable the flash if available
   /// Can enable or disable the flash if available
   Future<void> _torch(arguments) async {
   Future<void> _torch(arguments) async {
-    if (hasFlash) {
-      final track = _localStream?.getVideoTracks();
-      await track!.first.applyConstraints({
-        'advanced': {'torch': arguments == 1}
-      });
-    } else {
+    // if (hasFlash) {
+    //   final track = _localStream?.getVideoTracks();
+    //   await track!.first.applyConstraints({
+    //     'advanced': {'torch': arguments == 1}
+    //   });
+    // } else {
+    //   controller.addError('Device has no flash');
+    // }
     controller.addError('Device has no flash');
     controller.addError('Device has no flash');
   }
   }
-  }
 
 
   /// Starts the video stream and the scanner
   /// Starts the video stream and the scanner
   Future<Map> _start(Map arguments) async {
   Future<Map> _start(Map arguments) async {
-    vidDiv.children = [video];
-
     var cameraFacing = CameraFacing.front;
     var cameraFacing = CameraFacing.front;
     if (arguments.containsKey('facing')) {
     if (arguments.containsKey('facing')) {
       cameraFacing = CameraFacing.values[arguments['facing'] as int];
       cameraFacing = CameraFacing.values[arguments['facing'] as int];
     }
     }
 
 
-    // See https://github.com/flutter/flutter/issues/41563
-    // ignore: UNDEFINED_PREFIXED_NAME, avoid_dynamic_calls
-    ui.platformViewRegistry.registerViewFactory(
-      viewID,
-      (int id) => vidDiv
-        ..style.width = '100%'
-        ..style.height = '100%',
-    );
-
     // Check if stream is running
     // Check if stream is running
-    if (_localStream != null) {
+    if (_barCodeReader.isStarted) {
       return {
       return {
         'ViewID': viewID,
         'ViewID': viewID,
-        'videoWidth': video.videoWidth,
-        'videoHeight': video.videoHeight
+        'videoWidth': _barCodeReader.videoWidth,
+        'videoHeight': _barCodeReader.videoHeight
       };
       };
     }
     }
-
     try {
     try {
-      // Check if browser supports multiple camera's and set if supported
-      final Map? capabilities =
-          html.window.navigator.mediaDevices?.getSupportedConstraints();
-      if (capabilities != null && capabilities['facingMode'] as bool) {
-        final constraints = {
-          'video': VideoOptions(
-            facingMode:
-                cameraFacing == CameraFacing.front ? 'user' : 'environment',
-          )
-        };
-
-        _localStream =
-            await html.window.navigator.mediaDevices?.getUserMedia(constraints);
-      } else {
-        _localStream = await html.window.navigator.mediaDevices
-            ?.getUserMedia({'video': true});
-      }
-
-      video.srcObject = _localStream;
-
-      // TODO: fix flash light. See https://github.com/dart-lang/sdk/issues/48533
-      // final track = _localStream?.getVideoTracks();
-      // if (track != null) {
-      //   final imageCapture = html.ImageCapture(track.first);
-      //   final photoCapabilities = await imageCapture.getPhotoCapabilities();
-      // }
-
-      // required to tell iOS safari we don't want fullscreen
-      video.setAttribute('playsinline', 'true');
+      await _barCodeReader.start(
+        viewID: viewID,
+        cameraFacing: cameraFacing,
+      );
 
 
-      _barCodeStreamSubscription =
-          _barCodeReader.detectBarcodeContinuously(video).listen((code) {
-        if (_localStream == null) return;
+      _barCodeStreamSubscription = _barCodeReader.detectBarcodeContinuously().listen((code) {
         if (code != null) {
         if (code != null) {
           controller.add({'name': 'barcodeWeb', 'data': code});
           controller.add({'name': 'barcodeWeb', 'data': code});
         }
         }
       });
       });
-      await video.play();
 
 
       return {
       return {
         'ViewID': viewID,
         'ViewID': viewID,
-        'videoWidth': video.videoWidth,
-        'videoHeight': video.videoHeight,
+        'videoWidth': _barCodeReader.videoWidth,
+        'videoHeight': _barCodeReader.videoHeight,
         'torchable': hasFlash
         'torchable': hasFlash
       };
       };
     } catch (e) {
     } catch (e) {
@@ -172,19 +127,7 @@ class MobileScannerWebPlugin {
 
 
   /// Stops the video feed and analyzer
   /// Stops the video feed and analyzer
   Future<void> cancel() async {
   Future<void> cancel() async {
-    try {
-      // Stop the camera stream
-      _localStream?.getTracks().forEach((track) {
-        if (track.readyState == 'live') {
-          track.stop();
-        }
-      });
-    } catch (e) {
-      debugPrint('Failed to stop stream: $e');
-    }
-
-    video.srcObject = null;
-    _localStream = null;
+    _barCodeReader.stop();
     await _barCodeStreamSubscription?.cancel();
     await _barCodeStreamSubscription?.cancel();
     _barCodeStreamSubscription = null;
     _barCodeStreamSubscription = null;
   }
   }

-import 'dart:html';
+import 'package:mobile_scanner/src/enums/camera_facing.dart';
 
 
 abstract class WebBarcodeReaderBase {
 abstract class WebBarcodeReaderBase {
-  Stream<String?> detectBarcodeContinuously(VideoElement video);
+  /// Timer used to capture frames to be analyzed
+  final frameInterval = const Duration(milliseconds: 200);
+
+  bool get isStarted;
+
+  int get videoWidth;
+  int get videoHeight;
+
+  /// Starts streaming video
+  Future<void> start({
+    required String viewID,
+    required CameraFacing cameraFacing,
+  });
+
+  /// Starts scanning QR codes or barcodes
+  Stream<String?> detectBarcodeContinuously();
+
+  /// Stops streaming video
+  Future<void> stop();
 }
 }

@@ -4,10 +4,15 @@ library jsqr;
 import 'dart:async';
 import 'dart:async';
 import 'dart:html';
 import 'dart:html';
 import 'dart:typed_data';
 import 'dart:typed_data';
+import 'dart:ui' as ui;
 
 
+import 'package:flutter/widgets.dart';
 import 'package:js/js.dart';
 import 'package:js/js.dart';
+import 'package:mobile_scanner/src/enums/camera_facing.dart';
 import 'package:mobile_scanner/src/web/base.dart';
 import 'package:mobile_scanner/src/web/base.dart';
 
 
+import 'media.dart';
+
 @JS('jsQR')
 @JS('jsQR')
 external Code? jsQR(dynamic data, int? width, int? height);
 external Code? jsQR(dynamic data, int? width, int? height);
 
 
@@ -20,18 +25,77 @@ class Code {
 
 
 
 
 class JsQrCodeReader extends WebBarcodeReaderBase {
 class JsQrCodeReader extends WebBarcodeReaderBase {
-  // Timer used to capture frames to be analyzed
-  final frameInterval = const Duration(milliseconds: 200);
+  // The video stream. Will be initialized later to see which camera needs to be used.
+  MediaStream? _localStream;
+
+  VideoElement video = VideoElement();
+
+  DivElement vidDiv = DivElement();
+
+  @override
+  bool get isStarted => _localStream != null;
+
+  @override
+  int get videoWidth => video.width;
+  @override
+  int get videoHeight => video.height;
+
+  @override
+  Future<void> start({
+    required String viewID,
+    required CameraFacing cameraFacing,
+  }) async {
+    vidDiv.children = [video];
+    // See https://github.com/flutter/flutter/issues/41563
+    // ignore: UNDEFINED_PREFIXED_NAME, avoid_dynamic_calls
+    ui.platformViewRegistry.registerViewFactory(
+      viewID,
+      (int id) => vidDiv
+        ..style.width = '100%'
+        ..style.height = '100%',
+    );
+    // Check if browser supports multiple camera's and set if supported
+    final Map? capabilities =
+        window.navigator.mediaDevices?.getSupportedConstraints();
+    if (capabilities != null && capabilities['facingMode'] as bool) {
+      final constraints = {
+        'video': VideoOptions(
+          facingMode:
+              cameraFacing == CameraFacing.front ? 'user' : 'environment',
+        )
+      };
+
+      _localStream =
+          await window.navigator.mediaDevices?.getUserMedia(constraints);
+    } else {
+      _localStream = await window.navigator.mediaDevices
+          ?.getUserMedia({'video': true});
+    }
+
+    video.srcObject = _localStream;
+
+    // TODO: fix flash light. See https://github.com/dart-lang/sdk/issues/48533
+    // final track = _localStream?.getVideoTracks();
+    // if (track != null) {
+    //   final imageCapture = html.ImageCapture(track.first);
+    //   final photoCapabilities = await imageCapture.getPhotoCapabilities();
+    // }
+
+    // required to tell iOS safari we don't want fullscreen
+    video.setAttribute('playsinline', 'true');
+    await video.play();
+  }
 
 
   @override
   @override
-  Stream<String?> detectBarcodeContinuously(VideoElement video) async* {
+  Stream<String?> detectBarcodeContinuously() async* {
     yield* Stream.periodic(frameInterval, (_) {
     yield* Stream.periodic(frameInterval, (_) {
       return _captureFrame(video);
       return _captureFrame(video);
-    }).asyncMap((event) async => (await event)?.data);
+    }).asyncMap((e) => e).map((event) => event?.data);
   }
   }
 
 
   /// Captures a frame and analyzes it for QR codes
   /// Captures a frame and analyzes it for QR codes
   Future<Code?> _captureFrame(VideoElement video) async {
   Future<Code?> _captureFrame(VideoElement video) async {
+    if (_localStream == null) return null;
     final canvas = CanvasElement(width: video.videoWidth, height: video.videoHeight);
     final canvas = CanvasElement(width: video.videoWidth, height: video.videoHeight);
     final ctx = canvas.context2D;
     final ctx = canvas.context2D;
 
 
@@ -41,4 +105,21 @@ class JsQrCodeReader extends WebBarcodeReaderBase {
     final code = jsQR(imgData.data, canvas.width, canvas.height);
     final code = jsQR(imgData.data, canvas.width, canvas.height);
     return code;
     return code;
   }
   }
+
+  @override
+  Future<void> stop() async {
+    try {
+      // Stop the camera stream
+      _localStream?.getTracks().forEach((track) {
+        if (track.readyState == 'live') {
+          track.stop();
+        }
+      });
+    } catch (e) {
+      debugPrint('Failed to stop stream: $e');
+    }
+
+    video.srcObject = null;
+    _localStream = null;
+  }
 }
 }