Even G2 に直接接続するスマートフォンアプリをFlutterで作った ( 前編 )

// lib/src/ble/g2_scanner.dart
await UniversalBle.startScan(
  scanFilter: ScanFilter(withNamePrefix: ['Even G2']),
);

// lib/src/ble/g2_scanner.dart
// _found は pairKey をキーにした Map。G2Glasses は左右 2 台をまとめて持つ入れ物
final pairKey = name.replaceFirst(RegExp(r'_[LR]_.*$'), '');
final glasses = _found.putIfAbsent(pairKey, () => G2Glasses(pairKey));

// lib/src/ble/g2_scanner.dart
// universal_ble は先頭 2 バイトをリトルエンディアンの companyId として解釈する
static const int _erCompanyId = 0x5245; // 'E' | 'R' << 8

String? _serialNumberFrom(BleDevice device) {
  for (final md in device.manufacturerDataList) {
    if (md.companyId == _erCompanyId && md.payload.length >= 14) {
      // 制御文字と非 ASCII を落とす（一次資料の extractSN と同じ扱い）
      return String.fromCharCodes(
          md.payload.sublist(0, 14).where((b) => b >= 0x20 && b <= 0x7E));
    }
  }
  return null;
}

// lib/src/ble/g2_scanner.dart
// primaryServiceUuid は G2 の write と notify を含むサービス（iOS では指定必須）
if (Platform.isIOS) {
  // 実装では取得失敗を try/catch で握りつぶし、スキャンは継続する（ここでは省略）
  final system = await UniversalBle.getSystemDevices(
    withServices: [primaryServiceUuid],
  );
  
  // スキャンで見つけたときと同じ経路に流し、左右のペアに束ねる
  system.forEach(_onScanResult);
}

// lib/src/ble/g2_side_connection.dart
static String _parentService(List<BleService> services, String charUuid) {
  for (final service in services) {
    for (final c in service.characteristics) {
      if (c.uuid == charUuid) return service.uuid;
    }
  }
  
  throw StateError('キャラクタリスティック $charUuid が見つからない');
}

// lib/src/ble/g2_side_connection.dart
// writeCharUuid などのキャラクタリスティック UUID は一次資料の定数をそのまま使う
final services = await UniversalBle.discoverServices(deviceId);

_writeServiceUuid = _parentService(services, writeCharUuid);
final protocolServiceUuid = _parentService(services, protocolNotifyCharUuid);
final audioServiceUuid = _parentService(services, audioNotifyCharUuid);

await UniversalBle.subscribeNotifications(
    deviceId, protocolServiceUuid, protocolNotifyCharUuid);
await UniversalBle.subscribeNotifications(
    deviceId, audioServiceUuid, audioNotifyCharUuid);

// lib/src/client/even_g2_client.dart（_runAuthSequence の一部）
// _sendTo は指定した側へメッセージを書き込む
// （実装には右アーム専用の別名もあるが、ここでは _sendTo に揃えた。
//   実装では各送信をタイムアウト時に再送するラッパーで包んでいる）

// 認証は左右それぞれに送る
await _sendTo(_left, msg.authentication(
    magicRandom: _nextMagicRandom(), phoneType: phoneType));
await Future<void>.delayed(_authStepGap);  // _authStepGap = 200 ms
await _sendTo(_right, msg.authentication(
    magicRandom: _nextMagicRandom(), phoneType: phoneType));
await Future<void>.delayed(_authStepGap);

// 以降は右だけ
await _sendTo(_right, msg.pipeRoleChange(magicRandom: _nextMagicRandom()));
await Future<void>.delayed(_authStepGap);

final now = DateTime.now();
await _sendTo(_right, msg.timeSync(
  magicRandom: _nextMagicRandom(),
  unixSeconds:
      now.millisecondsSinceEpoch ~/ 1000 + now.timeZoneOffset.inSeconds,
));
await Future<void>.delayed(_authStepGap);

await _sendTo(_right, msg.onboardingFinish(magicRandom: _nextMagicRandom()));
await _sendTo(_right, msg.gestureCtrlInit(magicRandom: _nextMagicRandom()));

// lib/src/client/even_g2_client.dart
Future<void> displayText(String text) async {
  if (!_pageCreated) {
    // _textPageContainers はテキスト 1 個ぶんのコンテナ定義を組み立てて返す
    final page = msg.createStartupPage(
      _textPageContainers(text),
      magicRandom: _nextMagicRandom(),
    );
    await _sendTo(_right, page);
    _pageCreated = true;
    return;
  }
  
  // 2 回目以降はページを作り直さず、コンテナの中身だけ差し替える。
  // ACK が返らないことがあるので、一次資料と同様に同じ内容を 2 回送る
  await _sendTo(_right, msg.updateText(
    containerId: _textContainerId,
    content: text,
    magicRandom: _nextMagicRandom(),
  ));
  await _sendTo(_right, msg.updateText(
    containerId: _textContainerId,
    content: text,
    magicRandom: _nextMagicRandom(),
  ));
}

// lib/src/client/even_g2_client.dart（_startHeartbeat）
// _heartbeatInterval = 5 秒。書き込み失敗は未処理例外にしない
_heartbeatTimer = Timer.periodic(_heartbeatInterval, (_) {
  unawaited(_sendToBoth(
      msg.baseConnHeartbeat(magicRandom: _nextMagicRandom())).catchError((_) {}));
  unawaited(_sendToBoth(
      msg.evenHubHeartbeat(magicRandom: _nextMagicRandom())).catchError((_) {}));
});

// 開発アプリ側から見た全体の流れ
import 'package:even_g2_ble/even_g2_ble.dart';
import 'package:universal_ble/universal_ble.dart';

Future<void> main() async {
  // 0. BLE 権限（Android は実行時許可が要る）
  if (!await UniversalBle.hasPermissions()) {
    await UniversalBle.requestPermissions();
  }

  // 1. スキャンして左右が揃ったペアを待つ。
  //    購読は start() より先に張る。iOS でシステム接続済みのアームは
  //    start() の中で一度だけ流れ、後から購読すると受け取れない
  final scanner = G2Scanner();
  final glassesFuture = scanner.results
      .expand((pairs) => pairs)
      .firstWhere((g) => g.isComplete);
  await scanner.start();
  final glasses = await glassesFuture;
  await scanner.stop();

  // 2. 接続、認証、ハートビート開始まで
  final client = EvenG2Client(glasses);
  await client.connect();

  // 3. 表示
  await client.displayText('こんにちは');

  // 4. 後片付け
  await client.dispose();
}

// lib/src/client/even_g2_client.dart
Future<void> connect() async {
  _setState(G2ConnectionState.connecting);

  // 左右それぞれ: BLE 接続 → MTU 確保 → 親サービス解決 → notify 購読
  await Future.wait([_left.connect(), _right.connect()]);

  _setState(G2ConnectionState.authenticating);
  await _runAuthSequence();  // 左右へ authentication、以降は右アームだけ
  await _waitForAuth();      // 左右から secAuth が返るまで待つ

  _startHeartbeat();         // 5 秒周期、左右両方へ 2 種
  _setState(G2ConnectionState.connected);
}

// lib/src/ble/g2_side_connection.dart
Future<void> connect() async {
  await UniversalBle.connect(deviceId);
  if (Platform.isAndroid) {
    // 最大パケット 246B と ATT ヘッダを収める（Android 14 以降は自動で 517 になる）
    await UniversalBle.requestMtu(deviceId, 512);
    // ... 接続優先度の引き上げ
  }
  final services = await UniversalBle.discoverServices(deviceId);
  _writeServiceUuid = _parentService(services, writeCharUuid);
  // ... プロトコル notify と音声 notify を購読
}