基于Flutter实现短信验证码监控与转发

/// Query a list of SMS
Future<List<SmsMessage>> querySms({
    int? start,
    int? count,
    String? address,
    int? threadId,
    List<SmsQueryKind> kinds = const [SmsQueryKind.Inbox],
    bool sort = true}) async {
    List<SmsMessage> result = [];
    for (var kind in kinds) {
        result.addAll(await _querySmsWrapper(
        start: start,
        count: count,
        address: address,
        threadId: threadId,
        kind: kind,
    ));
}
if (sort == true) {
    result.sort((a, b) => a.compareTo(b));
}
return (result);
}

if (messages.isNotEmpty) {
    // 获取第一条短信
    SmsMessage firstMessage = messages.first;
    String? messageBody = firstMessage.body;

    // 使用正则表达式匹配验证码，假设验证码是 6 位数字
    RegExp regex = RegExp(r'\d{6}');
    Match? match = regex.firstMatch(messageBody!);

    if (match != null) {
        String smsCode = match.group(0)!;
        // 发送验证码到 API
        result = await _sendCodeToAPI(smsCode);
    } else {
        result = '未在短信中找到验证码';
    }
} else {
    result = '未找到短信';
}

SmsQuery query = SmsQuery();
List<SmsMessage>? messages = await query.querySms(
    address: _phoneNumber,
    kinds: [SmsQueryKind.Inbox],
); // 获取收件箱中的短信
if (messages.isEmpty) {
    List<SmsMessage>? messages = await query.querySms(
    kinds: [SmsQueryKind.Inbox],
    ); // 根据条件二进行查询
    for (SmsMessage message in messages) {
        if (message.body?.contains(_targetApp) ?? false) {
            final code = _extractCode(message.body);
            if (code != null) {
                return await _sendCodeToAPI(code);
            }
        }
    }
}

Future<String?> _sendCodeToAPI(String code) async {
    try {
        final response = await http.post(
            Uri.parse(_apiEndpoint),
            headers: {'Content-Type': 'application/json'},
            body: jsonEncode({'code': code}),
        );
        if (response.statusCode != 200) {
            return ('Failed to send code: ${response.statusCode}');
        } else {
            return 'Successfully Code sent ';
        }
    } catch (e) {
        return ('Error sending code: $e');
    }
}

// 在主isolate的接收端口监听中添加状态更新
void _initReceivePort() {
_receivePort = ReceivePort();
_receivePort.listen((message) {
    if (message is String) {
    if (message == 'isolate_stopped') {
        // 处理isolate退出通知
        if (mounted) {
        setState(() {
            _isolate = null;
            isMonitoring = false;
            buttonText = '开始监控';
        });
        }
    } else {
        setState(() => response = message);
        if(message == 'Successfully Code sent') {
        _stopIsolate();
        }
    }
    } else if (message is SendPort) {
    _isolateSendPort = message;
    }
});
}

static void _monitorSmsInBackground(List<dynamic> args) async {
    final rootIsolateToken = args[4] as RootIsolateToken;
    BackgroundIsolateBinaryMessenger.ensureInitialized(rootIsolateToken);

    final apiEndpoint = args[0] as String;
    final targetApp = args[1] as String;
    final phoneNumber = args[2] as String;
    final mainSendPort = args[3] as SendPort;
    final smsHandler = SMSHandler(apiEndpoint, targetApp, phoneNumber);
    final controlPort = ReceivePort();
    mainSendPort.send(controlPort.sendPort);

    final stopCompleter = Completer<void>();
    controlPort.listen((message) {
      if (message == 'stop') {
        stopCompleter.complete();
      }
    });

    try {
      while (!stopCompleter.isCompleted) {
        final value = await smsHandler.initSMSListener().timeout(
          const Duration(seconds: 1),
          onTimeout: () => null,
        );
        print(value);
        mainSendPort.send(value);

        if (stopCompleter.isCompleted) break;
      }
    } finally {
      controlPort.close();
      mainSendPort.send('isolate_stopped'); // 添加退出通知
    }
}

// 修改 _stopIsolate 方法，仅发送停止信号，不强制终止Isolate
void _stopIsolate() {
    if (_isolate != null) {
        _isolateSendPort?.send('stop');
    }
}