lib/control/flutter_blue_plus_scanner_controller.dart


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73

import 'dart:async';
import 'package:uvok_epaper_badge/control/scanner_controller_impl.dart';
import 'package:uvok_epaper_badge/model/device/flutter_blue_plus_device.dart';
import 'package:uvok_epaper_badge/model/device/device.dart';
import 'package:uvok_epaper_badge/control/scanner_controller.dart';
import 'package:flutter_blue_plus/flutter_blue_plus.dart';
import 'package:logger/logger.dart';

var logger = Logger();

class FlutterBluePlusScannerController extends ScannerControllerImpl {
  @override
  Future<void> startScan({
    Duration timeout = const Duration(seconds: 5),
  }) async {
    stopScan();

    var system = await FlutterBluePlus.systemDevices([]);
    for (var d in system) {
      logger.i('${d.platformName} already connected to! ${d.remoteId}');
    }

    super.setStatus(ScanStatus.scanning);

    var subscription = FlutterBluePlus.scanResults.listen(
      (results) {
        List<Device> devices = results
            .map((d) => FlutterBluePlusDevice.fromScan(d))
            .toList();
        super.setDevices(devices);
      },
      onError: (err) {
        logger.e(err);
        super.setStatus(ScanStatus.error);
      },
    );
    // either this, or the cancel in the finally block, should do the same?
    FlutterBluePlus.cancelWhenScanComplete(subscription);
    // withKeywords: ["NimBLE"], on Android
    await FlutterBluePlus.startScan(timeout: Duration(seconds: 5));
    await FlutterBluePlus.isScanning.where((val) => val == false).first;

    super.setStatus(ScanStatus.finished);
  }

  @override
  Future<void> stopScan() async {
    await FlutterBluePlus.stopScan();
  }

  @override
  void dispose() {
    stopScan().ignore();
    super.dispose();
  }

  final List<ScanResult> _scanResults = [];
  bool _deviceInResults(ScanResult incomingDev) => _scanResults.any(
    (existingDev) => existingDev.device.remoteId == incomingDev.device.remoteId,
  );
  void _onScanResult(List<ScanResult> results) {
    if (results.isNotEmpty) {
      for (var r in results.where(
        (d) => d.rssi > -90 && !_deviceInResults(d),
      )) {
        logger.i(
          '${r.device.remoteId}: "${r.device.platformName}" / "${r.device.advName}" / "${r.advertisementData.advName}" found!',
        );
        _scanResults.add(r);
      }
    }
  }
}