import 'dart:convert';
import 'package:http/http.dart' as http;
import 'package:get/get.dart';
import 'package:marco/helpers/services/storage/local_storage.dart';
import 'package:marco/controller/permission_controller.dart';
import 'package:logger/logger.dart'; 
final Logger logger = Logger();

class AuthService {
  static const String _baseUrl = "https://stageapi.marcoaiot.com/api";
  static const Map<String, String> _headers = {
    'Content-Type': 'application/json',
  };
  static bool isLoggedIn = false;
  static Future<Map<String, String>?> loginUser(
      Map<String, dynamic> data) async {
    try {
      final response = await http.post(
        Uri.parse("$_baseUrl/auth/login"),
        headers: _headers,
        body: jsonEncode(data),
      );

      final responseData = jsonDecode(response.body);
      if (response.statusCode == 200 && responseData['data'] != null) {
        isLoggedIn = true;

        final jwtToken = responseData['data']['token'];
        final refreshToken = responseData['data']['refreshToken'];

        // Log the tokens using the logger
        logger.i("JWT Token: $jwtToken");
        if (refreshToken != null) logger.i("Refresh Token: $refreshToken");

        await LocalStorage.setJwtToken(jwtToken);
        await LocalStorage.setLoggedInUser(true);

        if (refreshToken != null) {
          await LocalStorage.setRefreshToken(refreshToken);
        }

        Get.put(PermissionController());

        return null;
      } else if (response.statusCode == 401) {
        return {"password": "Invalid email or password"};
      } else {
        return {
          "error": responseData['message'] ?? "Unexpected error occurred"
        };
      }
    } catch (e) {
      logger.e("Login error: $e");
      return {"error": "Network error. Please check your connection."};
    }
  }

  /// Refreshes the JWT token using the refresh token.
  static Future<bool> refreshToken() async {
    final accessToken = await LocalStorage.getJwtToken();
    final refreshToken = await LocalStorage.getRefreshToken();

    if (accessToken == null ||
        refreshToken == null ||
        accessToken.isEmpty ||
        refreshToken.isEmpty) {
      logger.w("Missing token or refresh token for refresh.");
      return false;
    }

    final requestBody = {
      "token": accessToken,
      "refreshToken": refreshToken,
    };

    logger.i("Sending refresh token request with body: $requestBody");

    try {
      final response = await http.post(
        Uri.parse("$_baseUrl/auth/refresh-token"),
        headers: {
          'Content-Type': 'application/json',
        },
        body: jsonEncode(requestBody),
      );

      logger.i(
          "Refresh token API response (${response.statusCode}): ${response.body}");

      final data = jsonDecode(response.body);
      if (response.statusCode == 200 && data['success'] == true) {
        final newAccessToken = data['data']['token'];
        final newRefreshToken = data['data']['refreshToken'];

        if (newAccessToken == null || newRefreshToken == null) {
          logger.w("Invalid tokens received during refresh.");
          return false;
        }

        await LocalStorage.setJwtToken(newAccessToken);
        await LocalStorage.setRefreshToken(newRefreshToken);
        await LocalStorage.setLoggedInUser(true);

        logger.i("Token refreshed successfully.");
        return true;
      } else {
        logger.w("Refresh failed: ${data['message']}");
        return false;
      }
    } catch (e) {
      logger.e("Exception during token refresh: $e");
      return false;
    }
  }
}