import 'dart:convert';
import 'dart:io';
import 'package:dio/dio.dart';
import 'package:firebase_analytics/firebase_analytics.dart';
import 'package:flutter_app_intents/flutter_app_intents.dart';
import 'package:go_router/go_router.dart';
import 'package:island/models/auth.dart';
import 'package:island/pods/config.dart';
import 'package:shared_preferences/shared_preferences.dart';
import 'package:island/services/event_bus.dart';
import 'package:island/talker.dart';
import 'package:island/route.dart';

class AppIntentsService {
  static final AppIntentsService _instance = AppIntentsService._internal();
  factory AppIntentsService() => _instance;
  AppIntentsService._internal();

  FlutterAppIntentsClient? _client;
  bool _initialized = false;
  Dio? _dio;

  Future<void> initialize() async {
    if (!Platform.isIOS) {
      talker.warning('[AppIntents] App Intents only supported on iOS');
      return;
    }

    if (_initialized) {
      talker.info('[AppIntents] Already initialized');
      return;
    }

    try {
      talker.info('[AppIntents] Initializing App Intents client...');
      _client = FlutterAppIntentsClient.instance;

      // Initialize Dio for API calls
      final prefs = await SharedPreferences.getInstance();
      final serverUrl =
          prefs.getString(kNetworkServerStoreKey) ?? kNetworkServerDefault;
      final tokenString = prefs.getString(kTokenPairStoreKey);

      final headers = {
        'Accept': 'application/json',
        'Content-Type': 'application/json',
      };

      if (tokenString != null) {
        try {
          final token = AppToken.fromJson(jsonDecode(tokenString));
          headers['Authorization'] = 'AtField ${token.token}';
        } catch (e) {
          talker.warning('[AppIntents] Failed to parse token: $e');
        }
      }

      _dio = Dio(
        BaseOptions(
          baseUrl: serverUrl,
          connectTimeout: const Duration(seconds: 10),
          receiveTimeout: const Duration(seconds: 10),
          headers: headers,
        ),
      );

      await _registerIntents();
      _initialized = true;
      talker.info('[AppIntents] All intents registered successfully');
    } catch (e, stack) {
      talker.error('[AppIntents] Initialization failed', e, stack);
      rethrow;
    }
  }

  Future<void> _registerIntents() async {
    if (_client == null) {
      throw StateError('Client not initialized');
    }

    // Navigation Intents
    await _client!.registerIntent(
      AppIntentBuilder()
          .identifier('open_chat')
          .title('Open Chat')
          .description('Open a specific chat room')
          .parameter(
            const AppIntentParameter(
              name: 'channelId',
              title: 'Channel ID',
              type: AppIntentParameterType.string,
              isOptional: false,
            ),
          )
          .build(),
      _handleOpenChatIntent,
    );

    await _client!.registerIntent(
      AppIntentBuilder()
          .identifier('open_post')
          .title('Open Post')
          .description('Open a specific post')
          .parameter(
            const AppIntentParameter(
              name: 'postId',
              title: 'Post ID',
              type: AppIntentParameterType.string,
              isOptional: false,
            ),
          )
          .build(),
      _handleOpenPostIntent,
    );

    await _client!.registerIntent(
      AppIntentBuilder()
          .identifier('open_compose')
          .title('Open Compose')
          .description('Open compose post screen')
          .build(),
      _handleOpenComposeIntent,
    );

    // Action Intent
    await _client!.registerIntent(
      AppIntentBuilder()
          .identifier('compose_post')
          .title('Compose Post')
          .description('Create a new post')
          .build(),
      _handleComposePostIntent,
    );

    // Query Intents
    await _client!.registerIntent(
      AppIntentBuilder()
          .identifier('search_content')
          .title('Search Content')
          .description('Search for content')
          .parameter(
            const AppIntentParameter(
              name: 'query',
              title: 'Search Query',
              type: AppIntentParameterType.string,
              isOptional: false,
            ),
          )
          .build(),
      _handleSearchContentIntent,
    );

    await _client!.registerIntent(
      AppIntentBuilder()
          .identifier('view_notifications')
          .title('View Notifications')
          .description('View notifications')
          .build(),
      _handleViewNotificationsIntent,
    );

    await _client!.registerIntent(
      AppIntentBuilder()
          .identifier('check_notifications')
          .title('Check Notifications')
          .description('Check notification count')
          .build(),
      _handleCheckNotificationsIntent,
    );

    // Message Intents
    await _client!.registerIntent(
      AppIntentBuilder()
          .identifier('send_message')
          .title('Send Message')
          .description('Send a message to a chat channel')
          .parameter(
            const AppIntentParameter(
              name: 'channelId',
              title: 'Channel ID',
              type: AppIntentParameterType.string,
              isOptional: false,
            ),
          )
          .parameter(
            const AppIntentParameter(
              name: 'content',
              title: 'Message Content',
              type: AppIntentParameterType.string,
              isOptional: false,
            ),
          )
          .build(),
      _handleSendMessageIntent,
    );

    await _client!.registerIntent(
      AppIntentBuilder()
          .identifier('read_messages')
          .title('Read Messages')
          .description('Read recent messages from a chat channel')
          .parameter(
            const AppIntentParameter(
              name: 'channelId',
              title: 'Channel ID',
              type: AppIntentParameterType.string,
              isOptional: false,
            ),
          )
          .parameter(
            const AppIntentParameter(
              name: 'limit',
              title: 'Number of Messages',
              type: AppIntentParameterType.string,
              isOptional: true,
            ),
          )
          .build(),
      _handleReadMessagesIntent,
    );

    await _client!.registerIntent(
      AppIntentBuilder()
          .identifier('check_unread_chats')
          .title('Check Unread Chats')
          .description('Check number of unread chat messages')
          .build(),
      _handleCheckUnreadChatsIntent,
    );

    await _client!.registerIntent(
      AppIntentBuilder()
          .identifier('mark_notifications_read')
          .title('Mark Notifications Read')
          .description('Mark all notifications as read')
          .build(),
      _handleMarkNotificationsReadIntent,
    );
  }

  void dispose() {
    _client = null;
    _initialized = false;
  }

  Future<AppIntentResult> _handleOpenChatIntent(
    Map<String, dynamic> parameters,
  ) async {
    try {
      final channelId = parameters['channelId'] as String?;
      if (channelId == null) {
        throw ArgumentError('channelId is required');
      }

      talker.info('[AppIntents] Opening chat: $channelId');

      if (rootNavigatorKey.currentContext == null) {
        return AppIntentResult.failed(error: 'App context not available');
      }

      rootNavigatorKey.currentContext!.push('/chat/$channelId');

      return AppIntentResult.successful(
        value: 'Opening chat $channelId',
        needsToContinueInApp: true,
      );
    } catch (e, stack) {
      talker.error('[AppIntents] Failed to open chat', e, stack);
      return AppIntentResult.failed(error: 'Failed to open chat: $e');
    }
  }

  Future<AppIntentResult> _handleOpenPostIntent(
    Map<String, dynamic> parameters,
  ) async {
    try {
      final postId = parameters['postId'] as String?;
      if (postId == null) {
        throw ArgumentError('postId is required');
      }

      talker.info('[AppIntents] Opening post: $postId');

      if (rootNavigatorKey.currentContext == null) {
        return AppIntentResult.failed(error: 'App context not available');
      }

      rootNavigatorKey.currentContext!.push('/posts/$postId');

      return AppIntentResult.successful(
        value: 'Opening post $postId',
        needsToContinueInApp: true,
      );
    } catch (e, stack) {
      talker.error('[AppIntents] Failed to open post', e, stack);
      return AppIntentResult.failed(error: 'Failed to open post: $e');
    }
  }

  Future<AppIntentResult> _handleOpenComposeIntent(
    Map<String, dynamic> parameters,
  ) async {
    try {
      talker.info('[AppIntents] Opening compose screen');

      eventBus.fire(ShowComposeSheetEvent());

      return AppIntentResult.successful(
        value: 'Opening compose screen',
        needsToContinueInApp: true,
      );
    } catch (e, stack) {
      talker.error('[AppIntents] Failed to open compose', e, stack);
      return AppIntentResult.failed(error: 'Failed to open compose: $e');
    }
  }

  Future<AppIntentResult> _handleComposePostIntent(
    Map<String, dynamic> parameters,
  ) async {
    try {
      talker.info('[AppIntents] Composing new post');

      eventBus.fire(ShowComposeSheetEvent());

      return AppIntentResult.successful(
        value: 'Opening compose screen',
        needsToContinueInApp: true,
      );
    } catch (e, stack) {
      talker.error('[AppIntents] Failed to compose post', e, stack);
      return AppIntentResult.failed(error: 'Failed to compose post: $e');
    }
  }

  Future<AppIntentResult> _handleSearchContentIntent(
    Map<String, dynamic> parameters,
  ) async {
    try {
      final query = parameters['query'] as String?;
      if (query == null) {
        throw ArgumentError('query is required');
      }

      talker.info('[AppIntents] Searching for: $query');

      if (rootNavigatorKey.currentContext == null) {
        return AppIntentResult.failed(error: 'App context not available');
      }

      rootNavigatorKey.currentContext!.push('/search?q=$query');

      return AppIntentResult.successful(
        value: 'Searching for "$query"',
        needsToContinueInApp: true,
      );
    } catch (e, stack) {
      talker.error('[AppIntents] Failed to search', e, stack);
      return AppIntentResult.failed(error: 'Failed to search: $e');
    }
  }

  Future<AppIntentResult> _handleViewNotificationsIntent(
    Map<String, dynamic> parameters,
  ) async {
    try {
      talker.info('[AppIntents] Opening notifications');

      if (rootNavigatorKey.currentContext == null) {
        return AppIntentResult.failed(error: 'App context not available');
      }

      // Note: You may need to adjust the route based on your actual notifications route
      // This is a common pattern - check your route.dart for exact path
      // If you don't have a dedicated notifications route, you might need to add one
      return AppIntentResult.failed(
        error: 'Notifications route not implemented',
      );
    } catch (e, stack) {
      talker.error('[AppIntents] Failed to view notifications', e, stack);
      return AppIntentResult.failed(error: 'Failed to view notifications: $e');
    }
  }

  Future<AppIntentResult> _handleCheckNotificationsIntent(
    Map<String, dynamic> parameters,
  ) async {
    try {
      talker.info('[AppIntents] Checking notifications count');

      if (_dio == null) {
        return AppIntentResult.failed(error: 'API client not initialized');
      }

      try {
        final response = await _dio!.get('/ring/notifications/count');
        final count = (response.data as num).toInt();
        final countValue = count;

        String message;
        if (countValue == 0) {
          message = 'You have no new notifications';
        } else if (countValue == 1) {
          message = 'You have 1 new notification';
        } else {
          message = 'You have $countValue new notifications';
        }

        return AppIntentResult.successful(
          value: message,
          needsToContinueInApp: false,
        );
      } on DioException catch (e) {
        talker.error('[AppIntents] API error checking notifications', e);
        return AppIntentResult.failed(
          error:
              'Failed to fetch notifications: ${e.message ?? 'Network error'}',
        );
      }
    } catch (e, stack) {
      talker.error('[AppIntents] Failed to check notifications', e, stack);
      return AppIntentResult.failed(error: 'Failed to check notifications: $e');
    }
  }

  Future<AppIntentResult> _handleSendMessageIntent(
    Map<String, dynamic> parameters,
  ) async {
    try {
      final channelId = parameters['channelId'] as String?;
      final content = parameters['content'] as String?;

      if (channelId == null) {
        throw ArgumentError('channelId is required');
      }
      if (content == null || content.isEmpty) {
        throw ArgumentError('content is required');
      }

      talker.info('[AppIntents] Sending message to $channelId: $content');

      if (_dio == null) {
        return AppIntentResult.failed(error: 'API client not initialized');
      }

      try {
        final nonce = _generateNonce();

        await _dio!.post(
          '/messager/chat/$channelId/messages',
          data: {'content': content, 'nonce': nonce},
        );

        talker.info('[AppIntents] Message sent successfully');
        return AppIntentResult.successful(
          value: 'Message sent to channel $channelId',
          needsToContinueInApp: false,
        );
      } on DioException catch (e) {
        talker.error('[AppIntents] API error sending message', e);
        return AppIntentResult.failed(
          error: 'Failed to send message: ${e.message ?? 'Network error'}',
        );
      }
    } catch (e, stack) {
      talker.error('[AppIntents] Failed to send message', e, stack);
      return AppIntentResult.failed(error: 'Failed to send message: $e');
    }
  }

  Future<AppIntentResult> _handleReadMessagesIntent(
    Map<String, dynamic> parameters,
  ) async {
    try {
      final channelId = parameters['channelId'] as String?;
      final limitParam = parameters['limit'] as String?;
      final limit = limitParam != null ? int.tryParse(limitParam) ?? 5 : 5;

      if (channelId == null) {
        throw ArgumentError('channelId is required');
      }
      if (limit < 1 || limit > 20) {
        return AppIntentResult.failed(error: 'limit must be between 1 and 20');
      }

      talker.info('[AppIntents] Reading $limit messages from $channelId');

      if (_dio == null) {
        return AppIntentResult.failed(error: 'API client not initialized');
      }

      try {
        final response = await _dio!.get(
          '/messager/chat/$channelId/messages',
          queryParameters: {'offset': 0, 'take': limit},
        );

        final messages = response.data as List;
        if (messages.isEmpty) {
          return AppIntentResult.successful(
            value: 'No messages found in channel $channelId',
            needsToContinueInApp: false,
          );
        }

        final formattedMessages = messages
            .map((msg) {
              final senderName =
                  msg['sender']?['account']?['name'] ?? 'Unknown';
              final messageContent = msg['content'] ?? '';
              return '$senderName: $messageContent';
            })
            .join('\n');

        talker.info('[AppIntents] Retrieved ${messages.length} messages');
        return AppIntentResult.successful(
          value: formattedMessages,
          needsToContinueInApp: false,
        );
      } on DioException catch (e) {
        talker.error('[AppIntents] API error reading messages', e);
        return AppIntentResult.failed(
          error: 'Failed to read messages: ${e.message ?? 'Network error'}',
        );
      }
    } catch (e, stack) {
      talker.error('[AppIntents] Failed to read messages', e, stack);
      return AppIntentResult.failed(error: 'Failed to read messages: $e');
    }
  }

  String _generateNonce() {
    return '${DateTime.now().millisecondsSinceEpoch}-${DateTime.now().microsecondsSinceEpoch}';
  }

  void _logDonation(String eventName, Map<String, Object> parameters) {
    try {
      FirebaseAnalytics.instance.logEvent(
        name: eventName,
        parameters: parameters.isEmpty ? null : parameters,
      );
    } catch (e) {
      talker.warning('[AppIntents] Failed to log analytics: $e');
    }
  }

  Future<AppIntentResult> _handleCheckUnreadChatsIntent(
    Map<String, dynamic> parameters,
  ) async {
    try {
      talker.info('[AppIntents] Checking unread chats count');

      if (_dio == null) {
        return AppIntentResult.failed(error: 'API client not initialized');
      }

      try {
        final response = await _dio!.get('/messager/chat/unread');
        final count = response.data as int? ?? 0;

        String message;
        if (count == 0) {
          message = 'You have no unread messages';
        } else if (count == 1) {
          message = 'You have 1 unread message';
        } else {
          message = 'You have $count unread messages';
        }

        return AppIntentResult.successful(
          value: message,
          needsToContinueInApp: false,
        );
      } on DioException catch (e) {
        talker.error('[AppIntents] API error checking unread chats', e);
        return AppIntentResult.failed(
          error:
              'Failed to fetch unread chats: ${e.message ?? 'Network error'}',
        );
      }
    } catch (e, stack) {
      talker.error('[AppIntents] Failed to check unread chats', e, stack);
      return AppIntentResult.failed(error: 'Failed to check unread chats: $e');
    }
  }

  Future<AppIntentResult> _handleMarkNotificationsReadIntent(
    Map<String, dynamic> parameters,
  ) async {
    try {
      talker.info('[AppIntents] Marking all notifications as read');

      if (_dio == null) {
        return AppIntentResult.failed(error: 'API client not initialized');
      }

      try {
        await _dio!.post('/ring/notifications/all/read');

        talker.info('[AppIntents] Notifications marked as read');
        return AppIntentResult.successful(
          value: 'All notifications marked as read',
          needsToContinueInApp: false,
        );
      } on DioException catch (e) {
        talker.error('[AppIntents] API error marking notifications read', e);
        return AppIntentResult.failed(
          error:
              'Failed to mark notifications: ${e.message ?? 'Network error'}',
        );
      }
    } catch (e, stack) {
      talker.error('[AppIntents] Failed to mark notifications read', e, stack);
      return AppIntentResult.failed(
        error: 'Failed to mark notifications read: $e',
      );
    }
  }

  // Donation Methods - to be called manually from your app code

  Future<void> donateOpenChat(String channelId) async {
    if (!_initialized) return;
    try {
      await FlutterAppIntentsService.donateIntentWithMetadata(
        'open_chat',
        {'channelId': channelId},
        relevanceScore: 0.8,
        context: {'feature': 'chat', 'userAction': true},
      );
      _logDonation('open_chat', {'channel_id': channelId});
      talker.info('[AppIntents] Donated open_chat intent');
    } catch (e, stack) {
      talker.error('[AppIntents] Failed to donate open_chat', e, stack);
    }
  }

  Future<void> donateOpenPost(String postId) async {
    if (!_initialized) return;
    try {
      await FlutterAppIntentsService.donateIntentWithMetadata(
        'open_post',
        {'postId': postId},
        relevanceScore: 0.8,
        context: {'feature': 'posts', 'userAction': true},
      );
      _logDonation('open_post', {'post_id': postId});
      talker.info('[AppIntents] Donated open_post intent');
    } catch (e, stack) {
      talker.error('[AppIntents] Failed to donate open_post', e, stack);
    }
  }

  Future<void> donateCompose() async {
    if (!_initialized) return;
    try {
      await FlutterAppIntentsService.donateIntentWithMetadata(
        'open_compose',
        {},
        relevanceScore: 0.9,
        context: {'feature': 'compose', 'userAction': true},
      );
      _logDonation('open_compose', {});
      talker.info('[AppIntents] Donated compose intent');
    } catch (e, stack) {
      talker.error('[AppIntents] Failed to donate compose', e, stack);
    }
  }

  Future<void> donateSearch(String query) async {
    if (!_initialized) return;
    try {
      await FlutterAppIntentsService.donateIntentWithMetadata(
        'search_content',
        {'query': query},
        relevanceScore: 0.7,
        context: {'feature': 'search', 'userAction': true},
      );
      _logDonation('search_content', {'query': query});
      talker.info('[AppIntents] Donated search intent');
    } catch (e, stack) {
      talker.error('[AppIntents] Failed to donate search', e, stack);
    }
  }

  Future<void> donateCheckNotifications() async {
    if (!_initialized) return;
    try {
      await FlutterAppIntentsService.donateIntentWithMetadata(
        'check_notifications',
        {},
        relevanceScore: 0.6,
        context: {'feature': 'notifications', 'userAction': true},
      );
      _logDonation('check_notifications', {});
      talker.info('[AppIntents] Donated check_notifications intent');
    } catch (e, stack) {
      talker.error(
        '[AppIntents] Failed to donate check_notifications',
        e,
        stack,
      );
    }
  }

  Future<void> donateSendMessage(String channelId, String content) async {
    if (!_initialized) return;
    try {
      await FlutterAppIntentsService.donateIntentWithMetadata(
        'send_message',
        {'channelId': channelId, 'content': content},
        relevanceScore: 0.8,
        context: {'feature': 'chat', 'userAction': true},
      );
      _logDonation('send_message', {'channel_id': channelId});
      talker.info('[AppIntents] Donated send_message intent');
    } catch (e, stack) {
      talker.error('[AppIntents] Failed to donate send_message', e, stack);
    }
  }

  Future<void> donateReadMessages(String channelId) async {
    if (!_initialized) return;
    try {
      await FlutterAppIntentsService.donateIntentWithMetadata(
        'read_messages',
        {'channelId': channelId},
        relevanceScore: 0.7,
        context: {'feature': 'chat', 'userAction': true},
      );
      _logDonation('read_messages', {'channel_id': channelId});
      talker.info('[AppIntents] Donated read_messages intent');
    } catch (e, stack) {
      talker.error('[AppIntents] Failed to donate read_messages', e, stack);
    }
  }

  Future<void> donateCheckUnreadChats() async {
    if (!_initialized) return;
    try {
      await FlutterAppIntentsService.donateIntentWithMetadata(
        'check_unread_chats',
        {},
        relevanceScore: 0.7,
        context: {'feature': 'chat', 'userAction': true},
      );
      _logDonation('check_unread_chats', {});
      talker.info('[AppIntents] Donated check_unread_chats intent');
    } catch (e, stack) {
      talker.error(
        '[AppIntents] Failed to donate check_unread_chats',
        e,
        stack,
      );
    }
  }

  Future<void> donateMarkNotificationsRead() async {
    if (!_initialized) return;
    try {
      await FlutterAppIntentsService.donateIntentWithMetadata(
        'mark_notifications_read',
        {},
        relevanceScore: 0.6,
        context: {'feature': 'notifications', 'userAction': true},
      );
      _logDonation('mark_notifications_read', {});
      talker.info('[AppIntents] Donated mark_notifications_read intent');
    } catch (e, stack) {
      talker.error(
        '[AppIntents] Failed to donate mark_notifications_read',
        e,
        stack,
      );
    }
  }
}