forwardMessage method

void forwardMessage(NIMMessage message, String conversationId, { String? postScript, })

Implementation

void forwardMessage(
  NIMMessage message,
  String conversationId, {
  String? postScript,
}) async {
  if (await haveConnectivity()) {
    NIMMessageAIConfigParams? aiConfigParams;

    if ((await ConversationIdUtil().conversationType(conversationId)).data ==
        NIMConversationType.p2p) {
      NIMAIUser? aiAgent = AIUserManager.instance.getAIUserById(
        ChatKitUtils.getConversationTargetId(conversationId),
      );
      if (aiAgent != null) {
        final aiStreamMode = await IMKitClient.enableAIStream;
        // AI 参数处理
        aiConfigParams = NIMMessageAIConfigParams(
          accountId: aiAgent.accountId,
          aiStream: aiStreamMode,
        );
        if (ChatMessageHelper.getAIContentMsg(message)?.isNotEmpty == true) {
          NIMAIModelCallContent content = NIMAIModelCallContent(
            type: 0,
            msg: ChatMessageHelper.getAIContentMsg(message),
          );
          aiConfigParams.content = content;
        }
      }
    }

    final params = await ChatMessageHelper.getSenderParams(
      message,
      conversationId,
    );
    params.aiConfig = aiConfigParams;
    ChatMessageRepo.forwardMessage(
      message,
      conversationId,
      params: params,
    ).then((value) async {
      if (value.code == ChatMessageRepo.errorInBlackList) {
        ChatMessageRepo.saveTipsMessage(
          conversationId,
          S.of().chatMessageSendFailedByBlackList,
        );
      }
      if (postScript?.isNotEmpty == true) {
        //处理AI Config
        NIMMessageAIConfigParams? aiConfigParams;

        if ((await ConversationIdUtil().conversationType(
              conversationId,
            ))
                .data ==
            NIMConversationType.p2p) {
          NIMAIUser? aiAgent = AIUserManager.instance.getAIUserById(
            ChatKitUtils.getConversationTargetId(conversationId),
          );
          if (aiAgent != null) {
            final aiStreamMode = await IMKitClient.enableAIStream;
            // AI 参数处理
            aiConfigParams = NIMMessageAIConfigParams(
              accountId: aiAgent.accountId,
              aiStream: aiStreamMode,
            );
            NIMAIModelCallContent content = NIMAIModelCallContent(
              type: 0,
              msg: postScript,
            );
            aiConfigParams.content = content;
          }
        }
        ChatMessageRepo.sendTextMessageWithMessageAck(
          conversationId: conversationId,
          text: postScript!,
          aiConfigParams: aiConfigParams,
        ).then((msgSend) {
          if (msgSend.code == ChatMessageRepo.errorInBlackList) {
            ChatMessageRepo.saveTipsMessage(
              conversationId,
              S.of().chatMessageSendFailedByBlackList,
            );
          }
        });
      }
      notifyListeners();
    });
  }
}