tencent cloud

dependencies {
    // TRTC Lite Edition SDK, including 2 features, TRTC and live streaming playback.
    implementation 'com.tencent.liteav:LiteAVSDK_TRTC:latest.release'
    
    // Add the Chat SDK. It's recommended to enter the latest version number.
    implementation 'com.tencent.imsdk:imsdk-plus:Version number'

    // If you need to add the Quic plugin, uncomment the next line (Note: the plugin version number should be identical to the Chat SDK version number).
    // 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" />

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

// Add event listener.
V2TIMManager.getInstance().addIMSDKListener(imSdkListener);
// Initialize the Chat SDK. After calling this API, you can immediately call the login 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,"Chat SDK is connecting to Tencent Cloud Virtual Machine (CVM)");
    }

    @Override
    public void onConnectSuccess() {
        Log.d(TAG, "Chat SDK has successfully connected to Tencent CVM");
    }
};

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

// Create an RTC Engine SDK instance (singleton mode)
TRTCCloud mTRTCCloud = TRTCCloud.sharedInstance(context);
// Set event listeners.
mTRTCCloud.setListener(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 event listener.
mTRTCCloud.setListener(null);
// Terminate the RTC Engine SDK instance (singleton mode)
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) {
        // If the following error codes are returned, it means that an expired UserSig is in use. You need to generate a new one for login again.
        // 1. ERR_USER_SIG_EXPIRED (6206)
        // 2. ERR_SVR_ACCOUNT_USERSIG_EXPIRED (70001)
        // Note: For other error codes, do not call the login API here to avoid the Chat SDK entering an infinite loop.
        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);
    }
});

V2TIMManager.getInstance().createGroup(V2TIMManager.GROUP_TYPE_AVCHATROOM, groupID, groupName, new V2TIMValueCallback<String>() {
  @Override
  public void onSuccess(String s) {
      // Group created successfully.
  }

  @Override
  public void onError(int code, String desc) {
      // Group creation failed.
  }
});

// Listen for group creation notifications.
V2TIMManager.getInstance().addGroupListener(new V2TIMGroupListener() {
  @Override
  public void onGroupCreated(String groupID) {
      // Group creation callback. GroupID is the ID of the newly created group.
  }
});

V2TIMManager.getInstance().joinGroup(groupID, message, new V2TIMCallback() {
  @Override
  public void onSuccess() {
      // Successfully joined the group.
  }

  @Override
  public void onError(int code, String desc) {
      // Failed to join the group.
  }
});

// Listen for the event of joining a group.
V2TIMManager.getInstance().addGroupListener(new V2TIMGroupListener() {
  @Override
  public void onMemberEnter(String groupID, List<V2TIMGroupMemberInfo> memberList) {
      // Someone joined the group.
  }
});

private void enterRoom(String roomId, String userId) {
    TRTCCloudDef.TRTCParams params = new TRTCCloudDef.TRTCParams();
    // Using a string-type room ID for example, it is recommended to keep it consistent with the Chat group ID.
    params.strRoomId = roomId;
    params.userId = userId;
    // UserSig obtained from the business backend.
    params.userSig = getUserSig(userId);
    // Replace with your SDKAppID.
    params.sdkAppId = SDKAppID;
    // For room entry in voice chat interaction scenarios, specify the user's role.
    params.role = TRTCCloudDef.TRTCRoleAudience;
    // Use room entry in voice chat interaction scenarios as an example.
    mTRTCCloud.enterRoom(params, TRTCCloudDef.TRTC_APP_SCENE_VOICE_CHATROOM);
}

// Event callback for the result of entering the room.
@Override
public void onEnterRoom(long result) {
    if (result > 0) {
        // Result indicates the time taken (in milliseconds) to join the room.
        Log.d(TAG, "Enter room succeed");
    } else {
        // Result indicates the error code in the case of room entry failure.
        Log.d(TAG, "Enter room failed");
    }
}

V2TIMManager.getInstance().quitGroup(groupID, new V2TIMCallback() {
  @Override
  public void onSuccess() {
      // Successfully exited the group.
  }

  @Override
  public void onError(int code, String desc) {
      // Failed to exit the group.
  }
});

V2TIMManager.getInstance().addGroupListener(new V2TIMGroupListener() {
  @Override
  public void onMemberLeave(String groupID, V2TIMGroupMemberInfo member) {
        // Group member leaving callback.
  }
});

private void exitRoom() {
    mTRTCCloud.stopLocalAudio();
    mTRTCCloud.exitRoom();
}

// Event callback for exiting the room.
@Override
public void onExitRoom(int reason) {
    if (reason == 0) {
        Log.d(TAG, "Actively call exitRoom to exit the room.");
    } else if (reason == 1) {
        Log.d(TAG, "Removed from the current room by the server.");
    } else if (reason == 2) {
        Log.d(TAG, "The current room has been dissolved.");
    }
}

V2TIMManager.getInstance().dismissGroup(groupID, new V2TIMCallback() {
  @Override
  public void onSuccess() {
      // Group dissolved successfully.
  }

  @Override
  public void onError(int code, String desc) {
      // Failed to dissolve the group.
  }
});

V2TIMManager.getInstance().addGroupListener(new V2TIMGroupListener() {
  @Override
  public void onGroupDismissed(String groupID, V2TIMGroupMemberInfo opUser) {
      // Group dissolving callback.
  }
});

// Audience sends a request to speak. userId is the Anchor ID, and data can pass in a JSON identifying the signaling.
private String sendInvitation(String userId, String data) {
    return V2TIMManager.getSignalingManager().invite(userId, data, true, null, 0, new V2TIMCallback() {
        @Override
        public void onError(int i, String s) {
            Log.e(TAG, "sendInvitation error " + i);
        }

        @Override
        public void onSuccess() {
            Log.i(TAG, "sendInvitation success ");
        }
    });
}

// Anchor receives the request to speak. inviteID is the request ID, and inviter is the requester ID.
V2TIMManager.getSignalingManager().addSignalingListener(new V2TIMSignalingListener() {
    @Override
    public void onReceiveNewInvitation(String inviteID, String inviter,
                                       String groupId, List<String> inviteeList, String data) {
        Log.i(TAG, "received invitation: " + inviteID + " from " + inviter);
    }
});

// Agree to the request to speak.
private void acceptInvitation(String inviteID, String data) {
    V2TIMManager.getSignalingManager().accept(inviteID, data, new V2TIMCallback() {
        @Override
        public void onError(int i, String s) {
            Log.e(TAG, "acceptInvitation error " + i);
        }

        @Override
        public void onSuccess() {
            Log.i(TAG, "acceptInvitation success ");
        }
    });
}

// Reject the request to speak.
private void rejectInvitation(String inviteID, String data) {
    V2TIMManager.getSignalingManager().reject(inviteID, data, new V2TIMCallback() {
        @Override
        public void onError(int i, String s) {
            Log.e(TAG, "rejectInvitation error " + i);
        }

        @Override
        public void onSuccess() {
            Log.i(TAG, "rejectInvitation success ");
        }
    });
}

// Locally saved full list of seats.
private List<SeatInfo> mSeatInfoList;

// Callback for agreeing to the request to speak.
V2TIMManager.getSignalingManager().addSignalingListener(new V2TIMSignalingListener() {
    @Override
    public void onInviteeAccepted(String inviteID, String invitee, String data) {
        Log.i(TAG, "received accept invitation: " + inviteID + " from " + invitee);
        takeSeat(seatIndex);
    }
});

// Audience begins to speak.
private void takeSeat(int seatIndex) {
    // Create a seat information instance. Store the modified seat information.
    SeatInfo localInfo = mSeatInfoList.get(seatIndex);
    SeatInfo seatInfo = new SeatInfo();
    seatInfo.status = SeatInfo.STATUS_USED;
    seatInfo.mute = localInfo.mute;
    seatInfo.userId = mUserId;
    
    // Serialize the seat information object into JSON format.
    Gson gson = new Gson();
    String json = gson.toJson(seatInfo, SeatInfo.class);
    HashMap<String, String> map = new HashMap<>();
    map.put("seat" + seatIndex, json);
    
    // Set group attributes. If the group attribute already exists, its value is updated. Otherwise, the group attribute is added.
    V2TIMManager.getGroupManager().setGroupAttributes(groupId, map, new V2TIMCallback() {
        @Override
        public void onError(int code, String message) {
            // Failed to modify group attributes. Failed to become a speaker.
        }

        @Override
        public void onSuccess() {
            // Group attributes modified successfully. Switch the TRTC role and start streaming.
            mTRTCCloud.switchRole(TRTCCloudDef.TRTCRoleAnchor);
            mTRTCCloud.startLocalAudio(TRTCCloudDef.TRTC_AUDIO_QUALITY_DEFAULT);
        }
    });
}

// Locally saved full list of seats.
private List<SeatInfo> mSeatInfoList;

// Anchor calls this API to modify the seat information saved in group attributes.
private void pickSeat(String userId, int seatIndex) {
    // Create a seat information instance. Store the modified seat information.
    SeatInfo localInfo = mSeatInfoList.get(seatIndex);
    SeatInfo seatInfo = new SeatInfo();
    seatInfo.status = SeatInfo.STATUS_USED;
    seatInfo.mute = localInfo.mute;
    seatInfo.userId = userId;
    
    // Serialize the seat information object into JSON format.
    Gson gson = new Gson();
    String json = gson.toJson(seatInfo, SeatInfo.class);
    HashMap<String, String> map = new HashMap<>();
    map.put("seat" + seatIndex, json);
    
    // Set group attributes. If the group attribute already exists, its value is updated. Otherwise, the group attribute is added.
    V2TIMManager.getGroupManager().setGroupAttributes(groupId, map, new V2TIMCallback() {
        @Override
        public void onError(int code, String message) {
            // Failed to modify group attributes. Failed to invite a listener to speak.
        }

        @Override
        public void onSuccess() {
            // Group attributes modified successfully. Trigger onGroupAttributeChanged callback.
        }
    });
}

// Audience receives group attribute change callback. Audience starts streaming after successfully matching own information.
V2TIMManager.getInstance().addGroupListener(new V2TIMGroupListener() {
    @Override
    public void onGroupAttributeChanged(String groupID, Map<String, String> groupAttributeMap) {
        // Last locally saved full seat information list.
        final List<SeatInfo> oldSeatInfoList = mSeatInfoList;
        // The most recent full seat information list parsed in groupAttributeMap.
        final List<SeatInfo> newSeatInfoList = getSeatListFromAttr(groupAttributeMap, seatSize);
        // Iterate through the full seat information list. Compare old and new seat information.
        for (int i = 0; i < seatSize; i++) {
            SeatInfo oldInfo = oldSeatInfoList.get(i);
            SeatInfo newInfo = newSeatInfoList.get(i);
            if (oldInfo.status != newInfo.status && newInfo.status == SeatInfo.STATUS_USED) {
                if (newInfo.userId.equals(mUserId)) {
                    // Personal user information matched successfully. Switch the TRTC role and start streaming.
                    mTRTCCloud.switchRole(TRTCCloudDef.TRTCRoleAnchor);
                    mTRTCCloud.startLocalAudio(TRTCCloudDef.TRTC_AUDIO_QUALITY_DEFAULT);
                } else {
                    // Update the local seat list. Render local seat view.
                }
            }
        }
    }
});