car_common_app/lib/view_models/chat_view_model.dart

import 'package:flutter/cupertino.dart';
import 'package:mc_common_app/classes/app_state.dart';
import 'package:mc_common_app/extensions/string_extensions.dart';
import 'package:mc_common_app/main.dart';
import 'package:mc_common_app/models/chat_models/cat_message_model.dart';
import 'package:mc_common_app/repositories/chat_repo.dart';
import 'package:mc_common_app/utils/enums.dart';
import 'package:mc_common_app/utils/utils.dart';
import 'package:signalr_core/signalr_core.dart';

class ChatVM extends ChangeNotifier {
  final ChatRepo chatRepo;

  ChatVM({required this.chatRepo});

  late HubConnection hubConnection;

  List<ChatMessageModel> chatMessages = [];

  String chatMessageText = "";

  updateChatMessageText(String value) {
    chatMessageText = value;
  }

  clearChatMessageText() {
    chatMessageText = "";
    notifyListeners();
  }

  Future<void> onNewMessageReceived({required List<ChatMessageModel> messages}) async {
    chatMessages.addAll(messages);
    notifyListeners();
  }

  Future<void> buildHubConnection() async {
    // if (hubConnection.state != HubConnectionState.Connected) {
    try {
      hubConnection = await chatRepo.getHubConnection();
      await hubConnection.start();
      hubConnection.on("ReceiveMessageRequestOffer", (List<Object?>? arguments) {
        if (arguments == null || arguments.isEmpty) return;
        List<ChatMessageModel> chat = [];
        for (var message in arguments) {
          final chatMessage = ChatMessageModel.fromJson(message as Map<String, dynamic>);
          chat.add(chatMessage);
        }
        onNewMessageReceived(messages: chat);
        logger.i("I received ping : ${arguments.toString()}");
      });
    } catch (e) {
      logger.i("Error: ${e.toString()}");
    }

    notifyListeners();
    // }
  }

  Future<bool> onSendMessageForRequestOffer({
    required String receiverId,
    required ChatMessageTypeEnum chatMessageType,
    required String message,
    required int requestId,
    required String offerPrice,
  }) async {
    if (hubConnection.state != HubConnectionState.connected) {
      await buildHubConnection();
    }
    if (hubConnection.state == HubConnectionState.connected) {
      final providerId = AppState().getUser.data!.userInfo!.providerId;
      hubConnection.invoke(
        "SendMessageRequestOffer",
        args: <Object>[
          <String, dynamic>{
            "ReceiverUserID": receiverId,
            "MessageType": chatMessageType.getIdFromChatMessageTypeEnum(),
            "Message": message,
            "RequestID": requestId,
            "RequestOfferID": 0,
            "RequestOffer": <String, dynamic>{
              "RequestID": requestId,
              "Price": double.parse(offerPrice),
              "ServiceProviderID": providerId,
              "OfferStatus": RequestOfferStatusEnum.offer.getIdFromRequestOfferStatusEnum(),
              "Comment": message,
            },
          }
        ],
      ).catchError((e) {
        logger.i("error in invoking SendMessageRequestOffer: ${e.toString()}");
        Utils.showToast(e.toString());
        return false;
      });
    }
    return true;
  }

  Future<bool> onTextMessageSend({
    required String receiverId,
    required ChatMessageTypeEnum chatMessageType,
    required String message,
    required int requestId,
    required String offerPrice,
  }) async {
    if (message.isEmpty) return false;

    if (hubConnection.state != HubConnectionState.connected) {
      await buildHubConnection();
    }
    if (hubConnection.state == HubConnectionState.connected) {
      final userId = AppState().getUser.data!.userInfo!.userId.toString();
      final name = AppState().getUser.data!.userInfo!.firstName.toString();
      hubConnection.invoke(
        "SendMessageRequestOffer",
        args: <Object>[
          <String, dynamic>{
            "ReceiverUserID": receiverId,
            "MessageType": chatMessageType.getIdFromChatMessageTypeEnum(),
            "Message": message,
            "RequestID": requestId,
          }
        ],
      ).catchError((e) {
        logger.i("error in invoking SendMessageRequestOffer: ${e.toString()}");
        Utils.showToast(e.toString());
        return false;
      });
      ChatMessageModel chatMessageModel = ChatMessageModel(
        messageType: chatMessageType.getIdFromChatMessageTypeEnum(),
        message: message,
        isMyMessage: true,
        requestID: requestId,
        senderName: name,
        senderUserID: userId,
      );

      onNewMessageReceived(messages: [chatMessageModel]);
    }
    return true;
  }
}