import 'dart:async';
import 'package:gemini_app/config.dart';
import 'package:http/http.dart' as http;

import 'package:flutter_bloc/flutter_bloc.dart';

class EegState {
  final double mind_wandering;
  final double focus;

  EegState({
    required this.mind_wandering,
    required this.focus,
  });

  String getJsonString() {
    return '{"mind_wandering": $mind_wandering, "focus": $focus}';
  }
}

class EegCubit extends Cubit<EegState> {
  EegCubit() : super(EegState(mind_wandering: 0.9, focus: 0.1)) {
    // Start the timer when the cubit is created
    if (!isDebug) {
      startPolling();
    }
  }

  Timer? _timer;

  void startPolling() {
    // Poll every 1 second (adjust the duration as needed)
    _timer = Timer.periodic(Duration(seconds: 1), (timer) {
      // Simulate getting new EEG data
      // In a real application, you would fetch this data from your EEG device or API
      // double newMindWandering = (DateTime.now().millisecondsSinceEpoch % 100) / 100;
      // double newFocus = 1 - newMindWandering;

      fetchEegData().then((data) {
        double newMindWandering = data[0];
        double newFocus = data[1];
        // Update the state with the new EEG data
        updateEegData(newMindWandering, newFocus);
      });

      // updateEegData(newMindWandering, newFocus);
    });
  }

  Future<List<double>> fetchEegData() async {
    if (isDebug) {
      return [0.9, 0.1]; // Placeholder ret
    }

    final url = Uri.parse('http://192.168.83.153:1234');

    try {
      final response = await http.get(url);

      if (response.statusCode == 200) {
        // Split the response body by newline and parse as floats
        List<String> values = response.body.trim().split('\n');
        if (values.length == 2) {
          return [
            double.parse(values[0]),
            double.parse(values[1]),
          ];
        } else {
          throw Exception('Unexpected response format');
        }
      } else {
        throw Exception('Failed to load EEG data: ${response.statusCode}');
      }
    } catch (e) {
      throw Exception('Error fetching EEG data: $e');
    }
  }

  void stopPolling() {
    _timer?.cancel();
    _timer = null;
  }

  void updateEegData(double mindWandering, double focus) {
    emit(EegState(mind_wandering: mindWandering, focus: focus));
    print('Mind Wandering: $mindWandering, Focus: $focus');
  }

  @override
  Future<void> close() {
    stopPolling();
    return super.close();
  }

  void toggleState() {
    // Toggle the state between mind_wandering and focus
    if (state.mind_wandering > state.focus) {
      updateEegData(state.focus, state.mind_wandering);
    } else {
      updateEegData(state.mind_wandering, state.focus);
    }
  }
}