tencent cloud

// Call addSimpleMsgListener to set up an event listener.
V2TIMManager.getInstance().addSimpleMsgListener(sdkListener);

/**
 * Receive one-on-one custom messages.
 * @param msgID message ID
 * @param sender sender information
 * @param customData the content to be sent
 */
public void onRecvC2CCustomMessage(String msgID, V2TIMUserInfo sender, byte[] customData) {
    Log.i("onRecvC2CCustomMessage", "msgID:" + msgID + ", from:" + sender.getNickName() + ", content:" + new String(customData));
    try {
        String jsonString = new String(customData, "UTF-8");
        JSONObject jsonObject = new JSONObject(jsonString);
        System.out.println("onRecvGroupCustomMessage: " + jsonObject);
        handleMessage(jsonObject);
     } catch (UnsupportedEncodingException e) {
        System.out.println("The data is not a dictionary.");
     } catch (JSONException e) {
        System.out.println("Error parsing JSON: " + e);
     }
}

const onMessageReceived = (event) => {
  const messageList = event.data;
  messageList?.forEach((msg) => {
    if (msg.type === TencentCloudChat.TYPES.MSG_CUSTOM) {
      console.log('received custom message', event);
      const { data } = msg.payload;
      try {
        const jsonData = JSON.parse(data);
        console.log(`receive custom msg from ${msg.from} data: ${data}`);
        if (jsonData.type === 10000) {
          console.log('subtitle message', jsonData);
          return;
        }
        if (jsonData.type === 10001) {
          console.log('chatbot status', jsonData);
          return;
        }
        if (jsonData.type === 10010) {
          console.log('downstream large model message passthrough', jsonData);
          return;
        }
      } catch (error) {
        console.error('receive custom msg', data, error);
      }
    }
  });
}

// Listen to messages.
chat.on(TencentCloudChat.EVENT.MESSAGE_RECEIVED, onMessageReceived);

public void interruptAi() {
    long timestamp = System.currentTimeMillis();
    Map<String, Object> payload = new HashMap<>();
    payload.put("id", userId + "_" + roomId + "_" + timestamp); // Message ID, can use UUID; used for troubleshooting.
    payload.put("timestamp", timestamp); // Timestamp, used for troubleshooting.
    payload.put("taskid", aiTaskId);

    Map<String, Object> content = new HashMap<>();
    content.put("type", 20001);
    content.put("sender", userId);
    content.put("receiver", Collections.singletonList(botId));
    content.put("payload", payload);

    String contentString = new JSONObject(content).toString();

    Map<String, Object> dataDict = new HashMap<>();
    dataDict.put("service_command", "trtc_ai_service.SendCustomCmdMsg");
    dataDict.put("request_content", contentString);

    try {
        byte[] jsonData = new JSONObject(dataDict).toString().getBytes("UTF-8");
        V2TIMManager.getInstance().callExperimentalAPI("sendTRTCCustomData", jsonData, new V2TIMValueCallback() {
            @Override
            public void onSuccess(Object o) {
                System.out.println("sendTRTCCustomData success");
            }
            @Override
            public void onError(int code, String desc) {
                System.out.println("sendTRTCCustomData error, " + code + ", " + (desc != null ? desc : "null"));
            }
        });
    } catch (UnsupportedEncodingException e) {
        System.out.println("Error serializing dictionary to JSON: " + e);
    }
}

// Send interruption signaling.
chat.callExperimentalAPI('sendTRTCCustomData', {
serviceCommand: 'trtc_ai_service.SendCustomCmdMsg',
data: {
  type: 20001,
  sender: "user_a", // The user ID of the sender. The server will check if this user ID is valid.
  receiver: ["user_bot"], // List of receiver user IDs. Only the chatbot user ID needs to be specified.
  payload: {
    id: "uuid", // Message ID, can use UUID; used for troubleshooting.
    timestamp: 123, // Timestamp, used for troubleshooting.
    taskid: "Task's taskID",
  }
}
});