mohemm-flutter-app/lib/api/chat/chat_api_client.dart

import 'dart:convert';
import 'dart:io';
import 'dart:typed_data';

import 'package:flutter/foundation.dart';
import 'package:http/http.dart';
import 'package:mohem_flutter_app/api/api_client.dart';
import 'package:mohem_flutter_app/app_state/app_state.dart';
import 'package:mohem_flutter_app/classes/consts.dart';
import 'package:mohem_flutter_app/exceptions/api_exception.dart';
import 'package:mohem_flutter_app/main.dart';
import 'package:mohem_flutter_app/models/chat/chat_user_image_model.dart';
import 'package:mohem_flutter_app/models/chat/get_search_user_chat_model.dart';
import 'package:mohem_flutter_app/models/chat/get_user_login_token_model.dart' as user;
import 'package:mohem_flutter_app/models/chat/make_user_favotire_unfavorite_chat_model.dart' as fav;

class ChatApiClient {
  static final ChatApiClient _instance = ChatApiClient._internal();

  ChatApiClient._internal();

  factory ChatApiClient() => _instance;

  Future<user.UserAutoLoginModel> getUserLoginToken() async {
    Response response = await ApiClient().postJsonForResponse(
      "${ApiConsts.chatLoginTokenUrl}externaluserlogin",
      {
        "employeeNumber": AppState().memberInformationList!.eMPLOYEENUMBER.toString(),
        "password": "FxIu26rWIKoF8n6mpbOmAjDLphzFGmpG",
      },
    );
    if (!kReleaseMode) {
      logger.i("res: " + response.body);
    }
    user.UserAutoLoginModel userLoginResponse = user.userAutoLoginModelFromJson(response.body);
    return userLoginResponse;
  }

  Future<List<ChatUser>?> getChatMemberFromSearch(String sName, int cUserId) async {
    Response response = await ApiClient().getJsonForResponse(
      "${ApiConsts.chatLoginTokenUrl}getUserWithStatusAndFavAsync/$sName/$cUserId",
      token: AppState().chatDetails!.response!.token,
    );
    if (!kReleaseMode) {
      logger.i("res: " + response.body);
    }
    return List<ChatUser>.from(json.decode(response.body).map((x) => ChatUser.fromJson(x)));
  }

  Future<ChatUserModel> getRecentChats() async {
    try {
      Response response = await ApiClient().getJsonForResponse(
        "${ApiConsts.chatRecentUrl}getchathistorybyuserid",
        token: AppState().chatDetails!.response!.token,
      );
      if (!kReleaseMode) {
        logger.i("res: " + response.body);
      }
      return ChatUserModel.fromJson(
        json.decode(response.body),
      );
    } catch (e) {
      // if (e.message == "api_common_unauthorized") {
      //   user.UserAutoLoginModel userLoginResponse = await ChatApiClient().getUserLoginToken();
      //   if (userLoginResponse.response != null) {
      //     AppState().setchatUserDetails = userLoginResponse;
      //     getRecentChats();
      //   } else {
      //     Utils.showToast(
      //       userLoginResponse.errorResponses!.first.fieldName.toString() + " Erorr",
      //     );
      //   }
      // }
      throw e;
    }
  }

  Future<ChatUserModel> getFavUsers() async {
    Response favRes = await ApiClient().getJsonForResponse(
      "${ApiConsts.chatFavUser}getFavUserById/${AppState().chatDetails!.response!.id}",
      token: AppState().chatDetails!.response!.token,
    );
    if (!kReleaseMode) {
      logger.i("res: " + favRes.body);
    }
    return ChatUserModel.fromJson(json.decode(favRes.body));
  }

  Future<Response> getSingleUserChatHistory({required int senderUID, required int receiverUID, required bool loadMore, bool isNewChat = false, required int paginationVal}) async {
    try {
      Response response = await ApiClient().getJsonForResponse(
        "${ApiConsts.chatSingleUserHistoryUrl}GetUserChatHistory/$senderUID/$receiverUID/$paginationVal",
        token: AppState().chatDetails!.response!.token,
      );
      if (!kReleaseMode) {
        logger.i("res: " + response.body);
      }
      return response;
    } catch (e) {
      // e as APIException;
      // if (e.message == "api_common_unauthorized") {
      //   user.UserAutoLoginModel userLoginResponse = await ChatApiClient().getUserLoginToken();
      //   if (userLoginResponse.response != null) {
      //     AppState().setchatUserDetails = userLoginResponse;
      //     getSingleUserChatHistory(senderUID: senderUID, receiverUID: receiverUID, loadMore: loadMore, paginationVal: paginationVal);
      //   } else {
      //     Utils.showToast(userLoginResponse.errorResponses!.first.fieldName.toString() + " Erorr");
      //   }
      // }
      throw e;
    }
  }

  Future<fav.FavoriteChatUser> favUser({required int userID, required int targetUserID}) async {
    Response response = await ApiClient().postJsonForResponse("${ApiConsts.chatFavUser}addFavUser", {"targetUserId": targetUserID, "userId": userID}, token: AppState().chatDetails!.response!.token);
    if (!kReleaseMode) {
      logger.i("res: " + response.body);
    }
    fav.FavoriteChatUser favoriteChatUser = fav.FavoriteChatUser.fromRawJson(response.body);
    return favoriteChatUser;
  }

  Future<fav.FavoriteChatUser> unFavUser({required int userID, required int targetUserID}) async {
    try {
      Response response = await ApiClient().postJsonForResponse(
        "${ApiConsts.chatFavUser}deleteFavUser",
        {"targetUserId": targetUserID, "userId": userID},
        token: AppState().chatDetails!.response!.token,
      );
      if (!kReleaseMode) {
        logger.i("res: " + response.body);
      }

      fav.FavoriteChatUser favoriteChatUser = fav.FavoriteChatUser.fromRawJson(response.body);
      return favoriteChatUser;
    } catch (e) {
      e as APIException;
      // if (e.message == "api_common_unauthorized") {
      //   user.UserAutoLoginModel userLoginResponse = await ChatApiClient().getUserLoginToken();
      //   if (userLoginResponse.response != null) {
      //     AppState().setchatUserDetails = userLoginResponse;
      //     unFavUser(userID: userID, targetUserID: targetUserID);
      //   } else {
      //     Utils.showToast(userLoginResponse.errorResponses!.first.fieldName.toString() + " Erorr");
      //   }
      // }
      throw e;
    }
  }

  Future<StreamedResponse> uploadMedia(String userId, File file) async {
    dynamic request = MultipartRequest('POST', Uri.parse('${ApiConsts.chatMediaImageUploadUrl}upload'));
    request.fields.addAll({'userId': userId, 'fileSource': '1'});
    request.files.add(await MultipartFile.fromPath('files', file.path));
    request.headers.addAll({'Authorization': 'Bearer ${AppState().chatDetails!.response!.token}'});
    StreamedResponse response = await request.send();
    if (!kReleaseMode) {}
    return response;
  }

  // Download File For Chat

  Future<Uint8List> downloadURL({required String fileName, required String fileTypeDescription}) async {
    Response response = await ApiClient().postJsonForResponse(
      "${ApiConsts.chatMediaImageUploadUrl}download",
      {"fileType": fileTypeDescription, "fileName": fileName, "fileSource": 1},
      token: AppState().chatDetails!.response!.token,
    );
    Uint8List data = Uint8List.fromList(response.bodyBytes);
    return data;
  }

  Future<List<ChatUserImageModel>> getUsersImages({required List<String> encryptedEmails}) async {
    Response response = await ApiClient().postJsonForResponse(
      "${ApiConsts.chatUserImages}images",
      {"encryptedEmails": encryptedEmails, "fromClient": false},
      token: AppState().chatDetails!.response!.token,
    );
    if (!kReleaseMode) {
      logger.i("res: " + response.body);
    }
    return chatUserImageModelFromJson(response.body);
  }
}