import 'dart:convert';

import 'package:flutter/services.dart';
import 'package:flutter_openim_sdk/flutter_openim_sdk.dart';

///
///
class ConversationManager {
  MethodChannel _channel;
  late ConversationListener conversationListener;
  var count = 0;

  ConversationManager(this._channel);

  /// Observe conversation changes
  Future setConversationListener(ConversationListener listener) {
    this.conversationListener = listener;
    return _channel.invokeMethod('setConversationListener', _buildParam({}));
  }

  /// Get all conversations
  Future<List<ConversationInfo>> getAllConversationList() => _channel
      .invokeMethod('getAllConversationList', _buildParam({}))
      .then((value) => _toList(value));

  /// Paging to get conversation
  Future<List<ConversationInfo>> getConversationListSplit({
    int offset = 0,
    int count = 20,
  }) =>
      _channel
          .invokeMethod(
              'getConversationListSplit',
              _buildParam({
                'offset': offset,
                'count': count,
              }))
          .then((value) => _toList(value));

  /// Get a single conversation info
  /// [sourceID]  if it is a single chat, Its value is userID. if it is a group chat, Its value is groupID
  /// [sessionType]  if it is a single chat, it value is 1. if it is a group chat, it value is 2
  Future<ConversationInfo> getSingleConversation({
    required String sourceID,
    required int sessionType,
  }) =>
      _channel
          .invokeMethod(
              'getOneConversation',
              _buildParam({
                "sourceID": sourceID,
                "sessionType": sessionType,
              }))
          .then((value) => _toObj(value));

  /// Get conversation list by id list
  Future<List<ConversationInfo>> getMultipleConversation({
    required List<String> conversationIDList,
  }) =>
      _channel
          .invokeMethod(
              'getMultipleConversation',
              _buildParam({
                "conversationIDList": conversationIDList,
              }))
          .then((value) => _toList(value));

  /// Delete conversation by id
  Future deleteConversation({
    required String conversationID,
  }) =>
      _channel
          .invokeMethod(
              'deleteConversation',
              _buildParam({
                "conversationID": conversationID,
              }))
          .then((value) => _printValue(value));

  /// Set draft
  Future setConversationDraft({
    required String conversationID,
    required String draftText,
  }) =>
      _channel
          .invokeMethod(
              'setConversationDraft',
              _buildParam({
                "conversationID": conversationID,
                "draftText": draftText,
              }))
          .then((value) => _printValue(value));

  /// Pinned conversation
  Future pinConversation({
    required String conversationID,
    required bool isPinned,
  }) =>
      _channel
          .invokeMethod(
              'pinConversation',
              _buildParam({
                "conversationID": conversationID,
                "isPinned": isPinned,
              }))
          .then((value) => _printValue(value));

  /// Mark single chat messages as read
  Future<dynamic> markSingleMessageHasRead({required String userID}) =>
      _channel.invokeMethod(
          'markSingleMessageHasRead', _buildParam({'userID': userID}));

  /// Mark group chat messages as read
  Future<dynamic> markGroupMessageHasRead({required String groupID}) =>
      _channel.invokeMethod(
          'markGroupMessageHasRead', _buildParam({'groupID': groupID}));

  /// Get the total number of unread messages
  Future<dynamic> getTotalUnreadMsgCount() =>
      _channel.invokeMethod('getTotalUnreadMsgCount', _buildParam({}));

  /// Query conversation id
  /// [sourceID] : if it is a single chat, Its value is userID. if it is a group chat, Its value is groupID
  /// [sessionType] : if it is a single chat, it value is 1. if it is a group chat, it value is 2
  Future<dynamic> getConversationID({
    required String sourceID,
    required int sessionType,
  }) =>
      _channel.invokeMethod(
          'getConversationIDBySessionType',
          _buildParam({
            "sourceID": sourceID,
            "sessionType": sessionType,
          }));

  /// Message Do Not Disturb
  /// [ status ] 1: Do not receive messages, 2: Do not notify when messages are received; 0: Normal
  Future<dynamic> setConversationRecvMessageOpt({
    required List<String> conversationIDList,
    required int status,
  }) =>
      _channel.invokeMethod(
          'setConversationRecvMessageOpt',
          _buildParam({
            "conversationIDList": conversationIDList,
            "status": status,
          }));

  /// Message Do Not Disturb
  /// [{"conversationId":"single_13922222222","result":0}]
  Future<List<dynamic>> getConversationRecvMessageOpt({
    required List<String> conversationIDList,
  }) =>
      _channel
          .invokeMethod(
              'getConversationRecvMessageOpt',
              _buildParam({
                "conversationIDList": conversationIDList,
              }))
          .then((value) => _formatJson(value));

  /// Custom sort for conversation list
  List<ConversationInfo> simpleSort(List<ConversationInfo> list) => list
    ..sort((a, b) {
      if ((a.isPinned == 1 && b.isPinned == 1) ||
          (a.isPinned != 1 && b.isPinned != 1)) {
        int aCompare = a.draftTimestamp! > a.latestMsgSendTime!
            ? a.draftTimestamp!
            : a.latestMsgSendTime!;
        int bCompare = b.draftTimestamp! > b.latestMsgSendTime!
            ? b.draftTimestamp!
            : b.latestMsgSendTime!;
        if (aCompare > bCompare) {
          return -1;
        } else if (aCompare < bCompare) {
          return 1;
        } else {
          return 0;
        }
      } else if (a.isPinned == 1 && b.isPinned != 1) {
        return -1;
      } else {
        return 1;
      }
    });

  static Map _buildParam(Map param) {
    param["ManagerName"] = "conversationManager";
    return param;
  }

  static List<ConversationInfo> _toList(String? value) {
    var list = _formatJson(value);
    if (null == list) return <ConversationInfo>[];
    return (list as List).map((e) => ConversationInfo.fromJson(e)).toList();
  }

  static ConversationInfo _toObj(String value) =>
      ConversationInfo.fromJson(_formatJson(value));

  static dynamic _formatJson(value) => jsonDecode(_printValue(value));

  static String _printValue(value) {
    return value;
  }
}