tencent cloud

dependencies {
    // TRTC SDK lite version, includes two features: TRTC and live streaming playback
    implementation 'com.tencent.liteav:LiteAVSDK_TRTC:latest.release'
    
    // Add IM SDK. It is recommended to use the latest version number
    implementation 'com.tencent.imsdk:imsdk-plus:Version number'

    // If you need to add Quic plugin, uncomment the next line (Note: Version number of the plugin needs to be the same as that of the IM SDK)
    // implementation 'com.tencent.imsdk:timquic-plugin:Version number'
}

defaultConfig {
     ndk {
             abiFilters "armeabi-v7a", "arm64-v8a"
     }
}

<uses-permission android:name="android.permission.INTERNET" />
<uses-permission android:name="android.permission.ACCESS_NETWORK_STATE" />
<uses-permission android:name="android.permission.ACCESS_WIFI_STATE" />
<uses-permission android:name="android.permission.RECORD_AUDIO" />
<uses-permission android:name="android.permission.MODIFY_AUDIO_SETTINGS" />
<uses-permission android:name="android.permission.BLUETOOTH" />
<uses-permission android:name="android.permission.CAMERA" />
<uses-feature android:name="android.hardware.camera.autofocus" />

-keep class com.tencent.** { *; }

// Add event listener
V2TIMManager.getInstance().addIMSDKListener(imSdkListener);
// Initialize the IM SDK. After calling this API, you can immediately call the log-in API
V2TIMManager.getInstance().initSDK(context, sdkAppID, null);

// After the SDK is initialized, it will trigger various events, such as connection status and expiration of log-in credentials
private V2TIMSDKListener imSdkListener = new V2TIMSDKListener() {
    @Override
    public void onConnecting() {
        Log.d(TAG, "IM SDK is connecting to the Cloud Virtual Machine");
    }

    @Override
    public void onConnectSuccess() {
        Log.d(TAG, "IM SDK has successfully connected to the Cloud Virtual Machine");
    }
};

// Remove event listener
V2TIMManager.getInstance().removeIMSDKListener(imSdkListener);
// Deinitialize the IM SDK
V2TIMManager.getInstance().unInitSDK();

// Create TRTC SDK instance (single instance pattern)
TRTCCloud mTRTCCloud = TRTCCloud.sharedInstance(context);
// Add TRTC event listener
mTRTCCloud.addListener(trtcSdkListener);

// Notifications from various SDK events (e.g., error codes, warning codes, audio and video status parameters, etc.)
private TRTCCloudListener trtcSdkListener = new TRTCCloudListener() {
    @Override
    public void onError(int errCode, String errMsg, Bundle extraInfo) {
        Log.d(TAG, errCode + errMsg);
    }
    
    @Override
    public void onWarning(int warningCode, String warningMsg, Bundle extraInfo) {
        Log.d(TAG, warningCode + warningMsg);
    }
};

// Remove TRTC event listener
mTRTCCloud.removeListener(trtcSdkListener);
// Destroy TRTC SDK instance (single instance pattern)
TRTCCloud.destroySharedInstance();

// Log in: userID can be defined by the user and userSig can be generated as per step 1
V2TIMManager.getInstance().login(userID, userSig, new V2TIMCallback() {
    @Override
    public void onSuccess() {
        Log.i("imsdk", "success");
    }
    
    @Override
    public void onError(int code, String desc) {
        // The following error codes indicate an expired userSig, and you need to generate a new one for log-in again.
        // 1. ERR_USER_SIG_EXPIRED(6206).
        // 2. ERR_SVR_ACCOUNT_USERSIG_EXPIRED(70001).
        // Note: Do not call the log-in API in case of other error codes. Otherwise, the IM SDK may enter an infinite loop of log-in.
        Log.i("imsdk", "failure, code:" + code + ", desc:" + desc);
    }
});

// Log out
V2TIMManager.getInstance().logout(new V2TIMCallback() {
    @Override
    public void onSuccess() {
        Log.i("imsdk", "success");
    }
    
    @Override
    public void onError(int code, String desc) {
        Log.i("imsdk", "failure, code:" + code + ", desc:" + desc);
    }
});

// Set video encoding parameters to determine the picture quality seen by remote users
TRTCCloudDef.TRTCVideoEncParam encParam = new TRTCCloudDef.TRTCVideoEncParam();
encParam.videoResolution = TRTCCloudDef.TRTC_VIDEO_RESOLUTION_960_540;
encParam.videoFps = 15;
encParam.videoBitrate = 850;
encParam.videoResolutionMode = TRTCCloudDef.TRTC_VIDEO_RESOLUTION_MODE_PORTRAIT;
mTRTCCloud.setVideoEncoderParam(encParam);

// Enable local camera preview (you can specify to use the front/rear camera for video capture)
mTRTCCloud.startLocalPreview(isFrontCamera, previewView);

// Construct custom data
JSONObject jsonObject = new JSONObject();
try {
    jsonObject.put("cmd", "av_call");
    JSONObject msgJsonObject = new JSONObject();
    msgJsonObject.put("callType", "videoCall"); // Specify the call type (video call, audio call)
    msgJsonObject.put("roomId", generateRoomId());  // Specify the TRTC room ID (caller can generate it randomly)
    jsonObject.put("msg", msgJsonObject);
} catch (JSONException e) {
    e.printStackTrace();
}
String data = jsonObject.toString();

// Send call invitation signaling
V2TIMManager.getSignalingManager().invite(receiver, data, false, v2TIMOfflinePushInfo, timeout, new V2TIMCallback() {
    @Override
    public void onError(int code, String desc) {
        // Failed to send call invitation signaling
        // Prompt call failure, you can try to retry
    }

    @Override
    public void onSuccess() {
        // Successfully send call invitation signaling
        // Render call page, play call ringtone
    }
});

// Callee receives the call request. The inviteID is the request ID, and inviter is the caller ID
V2TIMManager.getSignalingManager().addSignalingListener(new V2TIMSignalingListener() {
    @Override
    public void onReceiveNewInvitation(String inviteID, String inviter,
                                       String groupId, List<String> inviteeList, String data) {
        if (!data.isEmpty()) {
            try {
                JSONObject jsonObject = new JSONObject(data);
                String command = jsonObject.getString("cmd");
                JSONObject messageJsonObject = jsonObject.getJSONObject("msg");
                if (command.equals("av_call")) {
                    String callType = messageJsonObject.getString("callType");
                    String roomId = messageJsonObject.getString("roomId");
                    
                    // Render call page, play call ringtone
                }
            } catch (JSONException e) {
                e.printStackTrace();
            }
        }
    }
});

if (callType.equals("videoCall")) {
    // Set video encoding parameters to determine the picture quality seen by remote users
    TRTCCloudDef.TRTCVideoEncParam encParam = new TRTCCloudDef.TRTCVideoEncParam();
    encParam.videoResolution = TRTCCloudDef.TRTC_VIDEO_RESOLUTION_960_540;
    encParam.videoFps = 15;
    encParam.videoBitrate = 850;
    encParam.videoResolutionMode = TRTCCloudDef.TRTC_VIDEO_RESOLUTION_MODE_PORTRAIT;
    mTRTCCloud.setVideoEncoderParam(encParam);

    // Enable local camera preview (you can specify to use the front/rear camera for video capture)
    mTRTCCloud.startLocalPreview(isFrontCamera, previewView);
}

V2TIMManager.getSignalingManager().cancel(inviteId, data, new V2TIMCallback() {    @Override    public void onError(int code, String desc) {// Failed to cancel the call request
        // Prompt cancel failed, you can try to retry    }    @Override    public void onSuccess() {// Successfully cancel the call request
        // Terminate the call page, and stop the call ringtone    }});

@Override
public void onInvitationCancelled(String inviteID, String inviter, String data) {
    // Terminate the call page, and stop the call ringtone}

@Override
public void onInvitationTimeout(String inviteID, List<String> inviteeList) {
	// Prompt call timeout. Terminate the call page, and stop the call ringtone
}

V2TIMManager.getSignalingManager().accept(inviteId, data, new V2TIMCallback() {    @Override    public void onError(int code, String desc) {// Answer failed, prompt for exception or retry    }    @Override    public void onSuccess() {// Answer successfully, render the call page, and stop the call ringtone
        if (callType.equals("videoCall")) {
            // Start video call
            startVideoCall();
        } else {
            // Start audio call
            startAudioCall();
        }
    }
});

@Override
public void onInviteeAccepted(String inviteID, String invitee, String data) {
    if (callType.equals("videoCall")) {
        // Start video call
        startVideoCall();
    } else {
        // Start audio call
        startAudioCall();
    }
}

private void startAudioCall() {
    TRTCCloudDef.TRTCParams params = new 
TRTCCloudDef.TRTCParams();    
params.sdkAppId = SDKAPPID;// TRTC application ID, obtained from the console    
params.userSig = USERSIG;// TRTC authentication credential, generated on the server
    params.strRoomId = roomId; // Room ID, take the room ID string as an example    
params.userId = userId;// Username, it is recommended to stay sync with IM
    
    mTRTCCloud.startLocalAudio(TRTCCloudDef.TRTC_AUDIO_QUALITY_SPEECH);
    mTRTCCloud.enterRoom(params, TRTCCloudDef.TRTC_APP_SCENE_AUDIOCALL);
}

// Mark whether the call is in progress
boolean isOnCalling = false;

// Event callback for the result of entering the room
@Override
public void onEnterRoom(long result) {
    if (result > 0) {
        // Room entry successful, indicates that the call is in progress
        isOnCalling = true;
    } else {
        // Failed to enter the room, prompt for call exception
        isOnCalling = false;
    }
}

private void startVideoCall() {
    TRTCCloudDef.TRTCParams params = new TRTCCloudDef.TRTCParams();
    params.sdkAppId = SDKAPPID;// TRTC application ID, obtained from the console
    params.userSig = USERSIG;  // TRTC authentication credential, generated on the server
    params.strRoomId = roomId; // Room ID, take the room ID string as an example
    params.userId = userId;// Username, it is recommended to stay sync with IM
    
    mTRTCCloud.startLocalAudio(TRTCCloudDef.TRTC_AUDIO_QUALITY_SPEECH);
    mTRTCCloud.enterRoom(params, TRTCCloudDef.TRTC_APP_SCENE_VIDEOCALL);
}

// Mark whether the call is in progress
boolean isOnCalling = false;

// Event callback for the result of entering the room
@Override
public void onEnterRoom(long result) {
    if (result > 0) {
        // Room entry successful, indicates that the call is in progress
        isOnCalling = true;
    } else {
        // Failed to enter the room, prompt for call exception
        isOnCalling = false;
    }
}

// Pull remote video stream
@Override
public void onUserVideoAvailable(String userId, boolean available) {
    // The remote user publishes/unpublishes the primary video
    if (available) {
        // Subscribe to the remote user's video stream and bind the video rendering control
        mTRTCCloud.startRemoteView(userId, TRTCCloudDef.TRTC_VIDEO_STREAM_TYPE_BIG, view);
    } else {
        // Unsubscribe to the remote user's video stream and release the rendering control
        mTRTCCloud.stopRemoteView(userId, TRTCCloudDef.TRTC_VIDEO_STREAM_TYPE_BIG);
    }
}

private void rejectInvite(String inviteId, String data, final V2TIMCallback callback) {
    V2TIMManager.getSignalingManager().reject(inviteId, data, new V2TIMCallback() {
        @Override
        public void onError(int code, String desc) {
            if (callback != null) {
                callback.onError(code, desc);
            }
        }

        @Override
        public void onSuccess() {
            if (callback != null) {
                callback.onSuccess();
            }
        }
    });
}

JSONObject jsonObject = new JSONObject();
try {
    jsonObject.put("cmd", "av_call");
    JSONObject msgJsonObject = new JSONObject();
    msgJsonObject.put("callType", "videoCall"); // Specify the call type (video call, audio call)
    msgJsonObject.put("reason", "active"); // Specify rejection type (Proactive Rejection, Busy Line Rejection)
    jsonObject.put("msg", msgJsonObject);
} catch (JSONException e) {
    e.printStackTrace();
}

rejectInvite(inviteId, jsonObject.toString(), new V2TIMCallback() {    @Override    public void onError(int code, String desc) {// Rejection failed, prompt for exception or retry    }    @Override    public void onSuccess() {// Rejection successful. Terminate the call page, and stop the call ringtone    }});

@Override
public void onInviteeRejected(String inviteID, String invitee, String data) {
    if (!data.isEmpty()) {
        try {
            JSONObject jsonObject = new JSONObject(data);
            String command = jsonObject.getString("cmd");
            JSONObject messageJsonObject = jsonObject.getJSONObject("msg");
            if (command.equals("av_call")) {
                String reason = messageJsonObject.getString("reason");
                if (reason.equals("active")) {
                    // Prompt that the other party rejects call
                } else if (reason.equals("busy")) {
                    // Prompt that the other party is busy
                }
                
                // Terminate the call page, and stop the call ringtone
            }
        } catch (JSONException e) {
            e.printStackTrace();
        }
    }
}

@Override
public void onReceiveNewInvitation(String inviteID, String inviter,
                                   String groupId, List<String> inviteeList, String data) {
    if (!data.isEmpty()) {
        try {
            JSONObject jsonObject = new JSONObject(data);
            String command = jsonObject.getString("cmd");
            JSONObject messageJsonObject = jsonObject.getJSONObject("msg");
            if (command.equals("av_call") && isOnCalling) {
                JSONObject jsonObject = new JSONObject();
                try {
                    jsonObject.put("cmd", "av_call");
                    JSONObject msgJsonObject = new JSONObject();
                    msgJsonObject.put("callType", "videoCall"); // Specify the call type (video call, audio call)
                    msgJsonObject.put("reason", "busy");   // Specify rejection type (Proactive Rejection, Busy Line Rejection)
                    jsonObject.put("msg", msgJsonObject);
                } catch (JSONException e) {
                    e.printStackTrace();
                }
                // Local call is in progress, and sends busy line rejection signal
                rejectInvite(inviteId, jsonObject.toString(), new V2TIMCallback() {
                    @Override
                    public void onError(int code, String desc) {
                        // Busy line rejection failed
                    }
                
                    @Override
                    public void onSuccess() {
                        // Busy line rejection successful
                    }
                });
            }
        } catch (JSONException e) {
            e.printStackTrace();
        }
    }
}