tencent cloud

dependencies {
    // TRTC SDK Simplified Edition. It has two features of the TRTC and live streaming playback.
    implementation 'com.tencent.liteav:LiteAVSDK_TRTC:latest.release'
    
    // Add IM SDK. Entering the latest Version No. is recommended.
    implementation 'com.tencent.imsdk:imsdk-plus:Version number'

    // If you need to add the Quic plugin, uncomment the next line (Note: Version No. 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" />

-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 Tencent cloud service");
    }

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

// 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);
// 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 TRTC SDK instance (Singleton 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 mean 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);
    }
});

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

  @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 as the room ID for example, it is recommended to keep it consistent with the IM 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 entering a room 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 when you fail to enter the room.
        Log.d(TAG, "Enter room failed");
    }
}

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

  @Override
  public void onError(int code, String desc) {
      // Exiting the group failed.
  }
});

V2TIMManager.getInstance().addGroupListener(new V2TIMGroupListener() {
  @Override
  public void onMemberLeave(String groupID, V2TIMGroupMemberInfo member) {
        // Group member leave 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() {
      // Dissolving group successful.
  }

  @Override
  public void onError(int code, String desc) {
      // Dissolving the group failed.
  }
});

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

public class SeatInfo implements Serializable {
    public static final transient int STATUS_UNUSED = 0;
    public static final transient int STATUS_USED = 1;
    public static final transient int STATUS_LOCKED = 2;

    // The status of seats. There are three corresponding statuses.
    public int status;
    // Whether the seat is muted.
    public boolean mute;
    // When the seat is occupied, the user information is stored.
    public String userId;

    @Override
    public String toString() {
        return "TXSeatInfo{"
                + "status=" + status
                + ", mute=" + mute
                + ", user='" + userId + '\\''
                + '}';
    }
}

// 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 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() {
            // Successfully modified group attributes. Switch 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 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 be invited to the microphone.
        }

        @Override
        public void onSuccess() {
            // Successfully modified group attributes and it triggers 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 list of seats.
        final List<SeatInfo> oldSeatInfoList = mSeatInfoList;
        // The most recent full list of seats parsed from groupAttributeMap.
        final List<SeatInfo> newSeatInfoList = getSeatListFromAttr(groupAttributeMap, seatSize);
        // Iterate through the full list of seats. 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)) {
                    // Match own information successfully. Switch TRTC role and start streaming.
                    mTRTCCloud.switchRole(TRTCCloudDef.TRTCRoleAnchor);
                    mTRTCCloud.startLocalAudio(TRTCCloudDef.TRTC_AUDIO_QUALITY_DEFAULT);
                } else {
                    // Update local seat list. Render local seat view.
                }
            }
        }
    }
});