import 'package:PiliPlus/grpc/app/main/community/reply/v1/reply.pb.dart';
import 'package:PiliPlus/http/loading_state.dart';
import 'package:PiliPlus/http/reply.dart';
import 'package:PiliPlus/models/common/reply_type.dart';
import 'package:PiliPlus/models/video/reply/data.dart';
import 'package:PiliPlus/pages/common/common_controller.dart';
import 'package:PiliPlus/pages/video/detail/reply_new/reply_page.dart';
import 'package:PiliPlus/utils/extension.dart';
import 'package:PiliPlus/utils/global_data.dart';
import 'package:PiliPlus/utils/utils.dart';
import 'package:easy_debounce/easy_throttle.dart';
import 'package:flutter/material.dart';
import 'package:flutter_smart_dialog/flutter_smart_dialog.dart';
import 'package:get/get.dart';
import 'package:PiliPlus/models/common/reply_sort_type.dart';
import 'package:PiliPlus/models/video/reply/item.dart';
import 'package:PiliPlus/utils/feed_back.dart';
import 'package:PiliPlus/utils/storage.dart';
import 'package:get/get_navigation/src/dialog/dialog_route.dart';

abstract class ReplyController extends CommonController {
  String nextOffset = '';
  RxInt count = (-1).obs;

  Rx<ReplySortType> sortType = ReplySortType.time.obs;

  late final savedReplies = {};

  late final bool isLogin = GStorage.userInfo.get('userInfoCache') != null;

  CursorReply? cursor;
  late Rx<Mode> mode = Mode.MAIN_LIST_HOT.obs;
  late bool hasUpTop = false;

  late final banWordForReply = GStorage.banWordForReply;
  late final enableCommAntifraud = GStorage.enableCommAntifraud;

  @override
  void onInit() {
    super.onInit();
    int defaultReplySortIndex = GStorage.setting
        .get(SettingBoxKey.replySortType, defaultValue: 1) as int;
    if (defaultReplySortIndex == 2) {
      GStorage.setting.put(SettingBoxKey.replySortType, 0);
      defaultReplySortIndex = 0;
    }
    sortType.value = ReplySortType.values[defaultReplySortIndex];
    if (sortType.value == ReplySortType.time) {
      mode.value = Mode.MAIN_LIST_TIME;
    }
  }

  @override
  Future onRefresh() {
    cursor = null;
    nextOffset = '';
    return super.onRefresh();
  }

  @override
  bool customHandleResponse(Success response) {
    if (GlobalData().grpcReply) {
      MainListReply replies = response.response;
      if (cursor == null) {
        count.value = replies.subjectControl.count.toInt();
        hasUpTop = replies.hasUpTop();
        if (replies.hasUpTop()) {
          replies.replies.insert(0, replies.upTop);
        }
      }
      cursor = replies.cursor;
      if (currentPage != 1 && loadingState.value is Success) {
        replies.replies
            .insertAll(0, (loadingState.value as Success).response.replies);
      }
      isEnd = replies.replies.isEmpty ||
          replies.cursor.isEnd ||
          replies.replies.length >= count.value;
      loadingState.value = LoadingState.success(replies);
    } else {
      List<ReplyItemModel> replies = response.response.replies;
      if (isLogin.not) {
        nextOffset = response.response.cursor.paginationReply.nextOffset ?? '';
      }
      count.value = isLogin.not
          ? response.response.cursor.allCount
          : response.response.page.count ?? 0;
      if (replies.isEmpty) {
        isEnd = true;
      }
      if (currentPage == 1) {
        if (response.response.upper.top != null) {
          final bool flag = response.response.topReplies.any(
              (ReplyItemModel reply) =>
                  reply.rpid != response.response.upper.top.rpid) as bool;
          if (flag) {
            replies.insert(0, response.response.upper.top);
            hasUpTop = true;
          }
        }
        if ((response.response.topReplies as List?)?.isNotEmpty == true) {
          replies.insertAll(0, response.response.topReplies);
          hasUpTop = true;
        }
      } else if (loadingState.value is Success) {
        replies.insertAll(0, (loadingState.value as Success).response.replies);
      }
      if (replies.length >= count.value) {
        isEnd = true;
      }
      loadingState.value = LoadingState.success(response.response);
    }
    return true;
  }

  // 排序搜索评论
  queryBySort() {
    EasyThrottle.throttle('queryBySort', const Duration(seconds: 1), () {
      feedBack();
      switch (sortType.value) {
        case ReplySortType.time:
          sortType.value = ReplySortType.like;
          mode.value = Mode.MAIN_LIST_HOT;
          break;
        case ReplySortType.like:
          sortType.value = ReplySortType.time;
          mode.value = Mode.MAIN_LIST_TIME;
          break;
      }
      nextOffset = '';
      loadingState.value = LoadingState.loading();
      onRefresh();
    });
  }

  void onReply(
    BuildContext context, {
    dynamic oid,
    dynamic replyItem,
    int index = 0,
    ReplyType? replyType,
  }) {
    dynamic key = oid ??
        replyItem.oid +
            (GlobalData().grpcReply ? replyItem.id : replyItem.rpid);
    Navigator.of(context)
        .push(
      GetDialogRoute(
        pageBuilder: (buildContext, animation, secondaryAnimation) {
          return GlobalData().grpcReply
              ? ReplyPage(
                  oid: oid ?? replyItem.oid.toInt(),
                  root: oid != null ? 0 : replyItem.id.toInt(),
                  parent: oid != null ? 0 : replyItem.id.toInt(),
                  replyType: replyItem != null
                      ? ReplyType.values[replyItem.type.toInt()]
                      : replyType,
                  replyItem: replyItem,
                  initialValue: savedReplies[key],
                  onSave: (reply) {
                    savedReplies[key] = reply;
                  },
                )
              : ReplyPage(
                  oid: oid ?? replyItem.oid,
                  root: oid != null ? 0 : replyItem.rpid,
                  parent: oid != null ? 0 : replyItem.rpid,
                  replyType: replyItem != null
                      ? ReplyType.values[replyItem.type.toInt()]
                      : replyType,
                  replyItem: replyItem,
                  initialValue: savedReplies[key],
                  onSave: (reply) {
                    savedReplies[key] = reply;
                  },
                );
        },
        transitionDuration: const Duration(milliseconds: 500),
        transitionBuilder: (context, animation, secondaryAnimation, child) {
          const begin = Offset(0.0, 1.0);
          const end = Offset.zero;
          const curve = Curves.linear;

          var tween =
              Tween(begin: begin, end: end).chain(CurveTween(curve: curve));

          return SlideTransition(
            position: animation.drive(tween),
            child: child,
          );
        },
      ),
    )
        .then(
      (res) {
        if (res != null) {
          savedReplies[key] = null;
          if (GlobalData().grpcReply) {
            ReplyInfo replyInfo = Utils.replyCast(res);
            MainListReply response = loadingState.value is Success
                ? (loadingState.value as Success).response
                : MainListReply();
            if (oid != null) {
              response.replies.insert(hasUpTop ? 1 : 0, replyInfo);
            } else {
              response.replies[index].replies.add(replyInfo);
            }
            count.value += 1;
            loadingState.value = LoadingState.success(response);
            if (enableCommAntifraud && context.mounted) {
              checkReply(
                context,
                oid ?? replyItem.oid.toInt(),
                replyItem?.id.toInt(),
                replyItem?.type.toInt() ??
                    replyType?.index ??
                    ReplyType.video.index,
                replyInfo.id.toInt(),
                replyInfo.content.message,
              );
            }
          } else {
            ReplyData response = loadingState.value is Success
                ? (loadingState.value as Success).response
                : ReplyData();
            response.replies ??= <ReplyItemModel>[];
            ReplyItemModel replyInfo = ReplyItemModel.fromJson(res, '');
            if (oid != null) {
              response.replies?.insert(hasUpTop ? 1 : 0, replyInfo);
            } else {
              response.replies?[index].replies ??= <ReplyItemModel>[];
              response.replies?[index].replies?.add(replyInfo);
            }
            count.value += 1;
            loadingState.value = LoadingState.success(response);
            if (enableCommAntifraud && context.mounted) {
              checkReply(
                context,
                oid ?? replyItem.oid,
                replyItem?.rpid,
                replyItem?.type.toInt() ??
                    replyType?.index ??
                    ReplyType.video.index,
                replyInfo.rpid ?? 0,
                replyInfo.content?.message ?? '',
              );
            }
          }
        }
      },
    );
  }

  onMDelete(rpid, frpid) {
    if (GlobalData().grpcReply) {
      MainListReply response = (loadingState.value as Success).response;
      if (frpid == null) {
        response.replies.removeWhere((item) {
          return item.id.toInt() == rpid;
        });
      } else {
        response.replies.map((item) {
          if (item.id == frpid) {
            return item
              ..replies.removeWhere((reply) => reply.id.toInt() == rpid);
          } else {
            return item;
          }
        }).toList();
      }
      count.value -= 1;
      loadingState.value = LoadingState.success(response);
    } else {
      ReplyData response = (loadingState.value as Success).response;
      response.replies = frpid == null
          ? response.replies?.where((item) => item.rpid != rpid).toList()
          : response.replies?.map((item) {
              if (item.rpid == frpid) {
                return item
                  ..replies = item.replies
                      ?.where((reply) => reply.rpid != rpid)
                      .toList();
              } else {
                return item;
              }
            }).toList();
      count.value -= 1;
      loadingState.value = LoadingState.success(response);
    }
  }

  // ref https://github.com/freedom-introvert/biliSendCommAntifraud
  void checkReply(
    BuildContext context,
    dynamic oid,
    dynamic rpid,
    int replyType,
    int replyId,
    String message,
  ) async {
    void showReplyCheckResult(String message) {
      showDialog(
        context: context,
        builder: (context) => AlertDialog(
          title: Text('评论检查结果'),
          content: SelectableText(message),
        ),
      );
    }

    await Future.delayed(const Duration(seconds: 5));
    if (context.mounted.not) return;
    // root reply
    if (rpid == null) {
      // no cookie check
      dynamic res = await ReplyHttp.replyList(
        isLogin: false,
        oid: oid,
        nextOffset: '',
        type: replyType,
        sort: ReplySortType.time.index,
        page: 1,
        banWordForReply: '',
      );
      if (context.mounted.not) return;
      if (res is Error) {
        SmartDialog.showToast('获取评论主列表时发生错误：${res.errMsg}');
        return;
      } else if (res is Success) {
        ReplyData replies = res.response;
        int index =
            replies.replies?.indexWhere((item) => item.rpid == replyId) ?? -1;
        if (index != -1) {
          // found
          if (context.mounted) {
            showReplyCheckResult(
              '无账号状态下找到了你的评论，评论正常！\n\n你的评论：$message',
            );
          }
        } else {
          // not found
          if (context.mounted.not) return;
          // cookie check
          dynamic res1 = await ReplyHttp.replyReplyList(
            isLogin: isLogin,
            oid: oid,
            root: rpid ?? replyId,
            pageNum: 1,
            type: replyType,
            banWordForReply: '',
          );
          if (context.mounted.not) return;
          if (res1 is Error) {
            // not found
            if (context.mounted) {
              showReplyCheckResult(
                '无法找到你的评论。\n\n你的评论：$message',
              );
            }
          } else if (res1 is Success) {
            // found
            if (context.mounted.not) return;
            // no cookie check
            dynamic res2 = await ReplyHttp.replyReplyList(
              isLogin: false,
              oid: oid,
              root: rpid ?? replyId,
              pageNum: 1,
              type: replyType,
              banWordForReply: '',
              isCheck: true,
            );
            if (context.mounted.not) return;
            if (res2 is Error) {
              // not found
              if (context.mounted) {
                showReplyCheckResult(
                  res2.errMsg.startsWith('12022')
                      ? '你的评论被shadow ban（仅自己可见）！\n\n你的评论: $message'
                      : '评论不可见(${res2.errMsg}): $message',
                );
              }
            } else if (res2 is Success) {
              // found
              if (context.mounted) {
                showReplyCheckResult('''
你评论状态有点可疑，虽然无账号翻找评论区获取不到你的评论，但是无账号可通过
https://api.bilibili.com/x/v2/reply/reply?oid=$oid&pn=1&ps=20&root=$rpid&type=$replyType
获取你的评论，疑似评论区被戒严或者这是你的视频。

你的评论：$message''');
              }
            }
          }
        }
      }
    } else {
      for (int i = 1; true; i++) {
        if (context.mounted.not) return;
        dynamic res3 = await ReplyHttp.replyReplyList(
          isLogin: false,
          oid: oid,
          root: rpid ?? replyId,
          pageNum: i,
          type: replyType,
          banWordForReply: '',
          isCheck: true,
        );
        if (res3 is Error) {
          break;
        } else if (res3 is Success) {
          ReplyReplyData data = res3.response;
          if (data.replies.isNullOrEmpty) {
            break;
          }
          int index =
              data.replies?.indexWhere((item) => item.rpid == replyId) ?? -1;
          if (index == -1) {
            // not found
          } else {
            // found
            if (context.mounted) {
              showReplyCheckResult(
                '无账号状态下找到了你的评论，评论正常！\n\n你的评论：$message',
              );
            }
            return;
          }
        }
      }

      for (int i = 1; true; i++) {
        if (context.mounted.not) return;
        dynamic res4 = await ReplyHttp.replyReplyList(
          isLogin: true,
          oid: oid,
          root: rpid ?? replyId,
          pageNum: i,
          type: replyType,
          banWordForReply: '',
          isCheck: true,
        );
        if (res4 is Error) {
          break;
        } else if (res4 is Success) {
          ReplyReplyData data = res4.response;
          if (data.replies.isNullOrEmpty) {
            break;
          }
          int index =
              data.replies?.indexWhere((item) => item.rpid == replyId) ?? -1;
          if (index == -1) {
            // not found
          } else {
            // found
            if (context.mounted) {
              showReplyCheckResult(
                '你的评论被shadow ban（仅自己可见）！\n\n你的评论: $message',
              );
            }
            return;
          }
        }
      }

      if (context.mounted) {
        showReplyCheckResult(
          '评论不可见: $message',
        );
      }
    }
  }
}