インモビインモビ

import 'package:flutter_riverpod/flutter_riverpod.dart';
import 'package:speech_to_text/speech_to_text.dart';
import 'package:speech_to_text/speech_recognition_error.dart';
import 'package:flutter/material.dart';

/// 状態クラス
class SpeechState {
  final bool isListening;
  final bool isInitialized;
  final String recognizedWords;

  SpeechState({
    required this.isListening,
    this.isInitialized = false,
    this.recognizedWords = '',
  });

  SpeechState copyWith({
    bool? isListening,
    bool? isInitialized,
    String? recognizedWords,
  }) =>
      SpeechState(
        isListening: isListening ?? this.isListening,
        isInitialized: isInitialized ?? this.isInitialized,
        recognizedWords: recognizedWords ?? this.recognizedWords,
      );
}

class SpeechStateNotifier extends StateNotifierSpeechState> {
  final SpeechToText _speech;
  final CommandHandler commandHandler;

  // 自動再起動ロジック用
  bool _shouldRestart = true;
  final Duration _listenFor = const Duration(seconds: 30);
  final Duration _pauseFor = const Duration(seconds: 4);
  final Duration _restartDelay = const Duration(milliseconds: 100);
  final int _maxErrorRetry = 5;
  int _errorCount = 0;

  SpeechStateNotifier(this._speech)
      : commandHandler = CommandHandler(),
        super(SpeechState(isListening: false));

  /// 初回のみ initialize
  Futurevoid> initializeSpeech() async {
    if (!state.isInitialized) {
      final available = await _speech.initialize(
        onError: _errorListener,
        onStatus: _statusListener,
      );
      state = state.copyWith(isInitialized: available);
    }
  }

  Futurevoid> startListening() async {
    // 前回結果をクリア
    state = state.copyWith(recognizedWords: '');
    try {
      _shouldRestart = true;
      await _speech.listen(
        onResult: (r) {
          state = state.copyWith(recognizedWords: r.recognizedWords);
          commandHandler.handleCommand(r.recognizedWords);
        },
        localeId: 'ja_JP',
        listenFor: _listenFor,
        pauseFor: _pauseFor,
        partialResults: true,
        onDevice: true,
      );
      state = state.copyWith(isListening: true);
      _errorCount = 0;
    } catch (_) {
      _errorCount++;
      state = state.copyWith(isListening: false);
    }
  }

  Futurevoid> stopListening() async {
    _shouldRestart = false;
    try {
      if (state.isListening) {
        await _speech.stop();
      }
    } finally {
      state = state.copyWith(isListening: false, recognizedWords: '');
      // 再開を許可するなら enableRestart() を呼ぶ
    }
  }

  Futurevoid> cancelListening() async {
    _shouldRestart = false;
    try {
      if (state.isListening) {
        await _speech.cancel();
      }
    } finally {
      state = state.copyWith(isListening: false);
      _shouldRestart = true;
    }
  }

  /// プラグインの状態変化を監視、自動再起動
  void _statusListener(String status) {
    final listening = status == SpeechToText.listeningStatus;
    state = state.copyWith(isListening: listening);
    if (!_shouldRestart) return;

    if (status == SpeechToText.doneStatus ||
        status == SpeechToText.notListeningStatus) {
      Future.delayed(_restartDelay, () {
        if (_shouldRestart) startListening();
      });
    }
  }

  /// エラーリスナーでリトライ
  void _errorListener(SpeechRecognitionError err) {
    state = state.copyWith(isListening: false);
    if (_errorCount  _maxErrorRetry) {
      _errorCount++;
      startListening();
    }
  }
}

/// コマンド登録用ハンドラ
class CommandHandler {
  final ListMapString, VoidCallback>> _scopes = [{}];

  void addCommands(MapString, VoidCallback> cmds, {int priority = 0}) {
    while (_scopes.length = priority) _scopes.add({});
    _scopes[priority].addAll(cmds);
  }

  void removeCommands(MapString, VoidCallback> cmds, {int priority = 0}) {
    if (priority  _scopes.length) {
      cmds.keys.forEach(_scopes[priority].remove);
    }
  }

  void handleCommand(String words) {
    for (final scope in _scopes.reversed) {
      for (final entry in scope.entries) {
        if (words.contains(entry.key)) {
          entry.value();
          return;
        }
      }
    }
  }
}

/// Provider 定義
final speechToTextProvider = Provider((_) => SpeechToText());
final speechStateProvider =
    StateNotifierProviderSpeechStateNotifier, SpeechState>(
  (ref) => SpeechStateNotifier(ref.read(speechToTextProvider)),
);

import 'package:flutter/material.dart';
import 'package:flutter_riverpod/flutter_riverpod.dart';
import 'package:flutterapptest/speech_state.dart';

class HomePage extends ConsumerStatefulWidget {
  const HomePage({Key? key}) : super(key: key);

  @override
  ConsumerStateHomePage> createState() => _HomePageState();
}

class _HomePageState extends ConsumerStateHomePage> {
  @override
  void initState() {
    super.initState();
    _startSpeech();
    _addCommands();
  }

  @override
  void dispose() {
    _stopSpeech();
    _removeCommands();
    super.dispose();
  }

  /// 音声認識を開始する。
  Futurevoid> _startSpeech() async {
    if (!mounted) return;
    final SpeechStateNotifier speechStateNotifier =
        ref.read(speechStateProvider.notifier);
    await speechStateNotifier.initializeSpeech();
    if (!mounted) return;
    await speechStateNotifier.startListening();
  }

  /// 音声認識を停止する。
  Futurevoid> _stopSpeech() async {
    if (!mounted) return;
    final SpeechStateNotifier speechStateNotifier =
        ref.read(speechStateProvider.notifier);
    await speechStateNotifier.cancelListening();
    if (!mounted) return;
    await speechStateNotifier.stopListening();
  }

  /// コマンドを登録する。
  void _addCommands() {
    final SpeechStateNotifier speechStateNotifier =
        ref.read(speechStateProvider.notifier);
    speechStateNotifier.commandHandler.addCommands({
      "こんにちは": () {
        debugPrint("音声コマンド: こんにちは");
      },
    });
  }

  /// コマンドを登録解除する。
  void _removeCommands() {
    final SpeechStateNotifier speechStateNotifier =
        ref.read(speechStateProvider.notifier);
    speechStateNotifier.commandHandler.removeCommands({
      "こんにちは": () {},
    });
  }

  @override
  Widget build(BuildContext context) {
    final s = ref.watch(speechStateProvider);

    return Column(
      children: [
        if (s.isListening || s.recognizedWords.isNotEmpty) ...[
          Container(
            color: Colors.black54,
            padding: EdgeInsets.all(4),
            child: Text(
              s.isListening ? '🔊 音声認識中…' : '🔈 停止中…',
              style: const TextStyle(
                  color: Colors.white, fontWeight: FontWeight.bold),
            ),
          ),
          if (s.recognizedWords.isNotEmpty)
            Container(
              color: Colors.black26,
              padding: EdgeInsets.all(4),
              child: Text('認識結果: ${s.recognizedWords}',
                  style: const TextStyle(color: Colors.white)),
            ),
        ],
        ElevatedButton(
          onPressed: () async {
            final ctrl = ref.read(speechStateProvider.notifier);
            await ctrl.initializeSpeech();
            await ctrl.startListening();
          },
          child: const Text('開始'),
        ),
        ElevatedButton(
          onPressed: () =>
              ref.read(speechStateProvider.notifier).stopListening(),
          child: const Text('停止'),
        ),
      ],
    );
  }
}