dependencies {
    // TRTC Lite版SDK、TRTCとライブ再生の2つの機能を含み、コンパクトなサイズ
    implementation 'com.tencent.liteav:LiteAVSDK_TRTC:latest.release'
    
    // TRTCフル機能版SDK, 、ライブ配信、ショートビデオ、ビデオオンデマンドなど多機能, を含み、やや大きめのサイズ
    // implementation 'com.tencent.liteav:LiteAVSDK_Professional:latest.release'
}

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.** { *; }

// TRTC SDKのインスタンスを作成する（シングルトンパターン）
TRTCCloud mTRTCCloud = TRTCCloud.sharedInstance(context);
// イベントリスナーを設定する
mTRTCCloud.addListener(trtcSdkListener);

// SDKからの各種イベント通知（例：エラーコード、警告コード、オーディオ・ビデオの状態パラメータなど）
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);
    }
};

// イベントリスナーを削除
mTRTCCloud.removeListener(trtcSdkListener);
// TRTC SDKインスタンスを破棄する（シングルトンパターン）
TRTCCloud.destroySharedInstance();

public void enterRoom(String roomId, String userId) {
    TRTCCloudDef.TRTCParams params = new TRTCCloudDef.TRTCParams();
    // 文字列のルーム番号を例に
    params.strRoomId = roomId;
    params.userId = userId;
    // 業務バックエンドから取得したUserSig
    params.userSig = getUserSig(userId);
    // 自分のSDKAppIDに置き換える
    params.sdkAppId = SDKAppID;
    // すべて視聴者ロールで入室する事がお勧め
    params.role = TRTCCloudDef.TRTCRoleAudience;
    // 入室シナリオはLIVEを選択
    mTRTCCloud.enterRoom(params, TRTCCloudDef.TRTC_APP_SCENE_LIVE);
}

// 入室結果イベントコールバック
@Override
public void onEnterRoom(long result) {
    if (result > 0) {
        // resultは入室にかかった時間（ミリ秒）
        Log.d(TAG, "Enter room succeed");
        // ブラックフレーム挿入の実験的インターフェースを有効にする
        mTRTCCloud.callExperimentalAPI("{\\"api\\":\\"enableBlackStream\\",\\"params\\": {\\"enable\\":true}}");
    } else {
        // result入室失敗のエラーコード
        Log.d(TAG, "Enter room failed");
    }
}

// アンカーロールに切り替え
mTRTCCloud.switchRole(TRTCCloudDef.TRTCRoleAnchor);

// ロール切り替えイベントコールバック
@Override
public void onSwitchRole(int errCode, String errMsg) {
    if (errCode == TXLiteAVCode.ERR_NULL) {
        // メディア音量タイプの設定
        mTRTCCloud.setSystemVolumeType(TRTCCloudDef.TRTCSystemVolumeTypeMedia);
        // ローカルオーディオストリームを配布し、音質を設定する
        mTRTCCloud.startLocalAudio(TRTCCloudDef.TRTC_AUDIO_QUALITY_MUSIC);       
    }
}

// オーディオエフェクト管理クラスを取得
TXAudioEffectManager mTXAudioEffectManager = mTRTCCloud.getAudioEffectManager();

// originMusicId: カスタム原曲識別子。originMusicUrl: 原曲リソースアドレス
TXAudioEffectManager.AudioMusicParam originMusicParam = new TXAudioEffectManager.AudioMusicParam(originMusicId, originMusicUrl);
// 原曲をリモートにパブリッシュ（またはローカルのみで再生）
originMusicParam.publish = true;

// accompMusicId: カスタム伴奏識別子。accompMusicUrl: 伴奏リソースアドレス
TXAudioEffectManager.AudioMusicParam accompMusicParam = new TXAudioEffectManager.AudioMusicParam(accompMusicId, accompMusicUrl);
// 伴奏をリモートにパブリッシュ（またはローカルのみで再生）
accompMusicParam.publish = true;

// 原曲の再生を開始
mTXAudioEffectManager.startPlayMusic(originMusicParam);
// 伴奏の再生を開始
mTXAudioEffectManager.startPlayMusic(accompMusicParam);

// 原曲に切り替える
mTXAudioEffectManager.setMusicPlayoutVolume(originMusicId, 100);
mTXAudioEffectManager.setMusicPlayoutVolume(accompMusicId, 0);
mTXAudioEffectManager.setMusicPublishVolume(originMusicId, 100);
mTXAudioEffectManager.setMusicPublishVolume(accompMusicId, 0);

// 伴奏に切り替える
mTXAudioEffectManager.setMusicPlayoutVolume(originMusicId, 0);
mTXAudioEffectManager.setMusicPlayoutVolume(accompMusicId, 100);
mTXAudioEffectManager.setMusicPublishVolume(originMusicId, 0);
mTXAudioEffectManager.setMusicPublishVolume(accompMusicId, 100);

mTXAudioEffectManager.setMusicObserver(musicId, new TXAudioEffectManager.TXMusicPlayObserver() {
    @Override
    public void onStart(int id, int errCode) {
        // 音楽再生を開始
    }
    
    @Override
    public void onPlayProgress(int id, long curPtsMs, long durationMs) {
        // 最新の進行状況とローカルの歌詞の進行状況の誤差に基づいて、seekが必要かどうかを判断する
        // SEIメッセージを送信して曲の進行状況を伝える
        try {
            JSONObject jsonObject = new JSONObject();
            jsonObject.put("musicId", id);
            jsonObject.put("progress", curPtsMs);
            jsonObject.put("duration", durationMs);
            mTRTCCloud.sendSEIMsg(jsonObject.toString().getBytes(), 1);
        } catch (JSONException e) {
            e.printStackTrace();
        }
    }
    
    @Override
    public void onComplete(int id, int errCode) {
        // 音楽再生完了
    }
});

// 視聴者ロールに切り替える
mTRTCCloud.switchRole(TRTCCloudDef.TRTCRoleAudience);

// ロール切り替えイベントコールバック
@Override
public void onSwitchRole(int errCode, String errMsg) {
    if (errCode == TXLiteAVCode.ERR_NULL) {
        // 伴奏の再生を停止
        mTRTCCloud.getAudioEffectManager().stopPlayMusic(musicId);
        // ローカルオーディオのキャプチャーとパブリッシュを停止する
        mTRTCCloud.stopLocalAudio();
    }
}

// ルームから退出
mTRTCCloud.exitRoom();

// 退室イベントコールバック
@Override
public void onExitRoom(int reason) {
    if (reason == 0) {
        Log.d(TAG, "exitRoomアクティブコールでルーム退出します");
    } else if (reason == 1) {
        Log.d(TAG, "現在のルームからサーバーによってキックされました");
    } else if (reason == 2) {
        Log.d(TAG, "現在のルームは解散されました");
    }
}

public void enterRoom(String roomId, String userId) {
    TRTCCloudDef.TRTCParams params = new TRTCCloudDef.TRTCParams();
    // 文字列のルーム番号を例に
    params.strRoomId = roomId;
    params.userId = userId;
    // 業務バックエンドから取得したUserSig
    params.userSig = getUserSig(userId);
    // 自分のSDKAppIDに置き換える
    params.sdkAppId = SDKAppID;
    // すべて視聴者ロールで入室する事がお勧め
    params.role = TRTCCloudDef.TRTCRoleAudience;
    // 入室シナリオはLIVEを選択
    mTRTCCloud.enterRoom(params, TRTCCloudDef.TRTC_APP_SCENE_LIVE);
}

// 入室結果イベントコールバック
@Override
public void onEnterRoom(long result) {
    if (result > 0) {
        // resultは入室にかかった時間（ミリ秒）
        Log.d(TAG, "Enter room succeed");
    } else {
        // result入室失敗のエラーコード
        Log.d(TAG, "Enter room failed");
    }
}

@Override
public void onUserVideoAvailable(String userId, boolean available) {
    if (available) {
        mTRTCCloud.startRemoteView(userId, null);
    } else {
        mTRTCCloud.stopRemoteView(userId);
    }
}

@Override
public void onRecvSEIMsg(String userId, byte[] data) {
    String result = new String(data);
    try {
        JSONObject jsonObject = new JSONObject(result);
        int musicId = jsonObject.getInt("musicId");
        long progress = jsonObject.getLong("progress");
        long duration = jsonObject.getLong("duration");
    } catch (JSONException e) {
        e.printStackTrace();
    }
    ...
    // TODO歌詞コントロールロジックの更新：
    // 受信した最新の進行状況とローカルの歌詞進行の誤差に基づいて、歌詞コントロールがseekする必要があるかどうかを判断します。
    ...
}

// ルームから退出
mTRTCCloud.exitRoom();

// 退室イベントコールバック
@Override
public void onExitRoom(int reason) {
    if (reason == 0) {
        Log.d(TAG, "exitRoomアクティブコールでルーム退出します");
    } else if (reason == 1) {
        Log.d(TAG, "現在のルームからサーバーによってキックされました");
    } else if (reason == 2) {
        Log.d(TAG, "現在のルームは解散されました");
    }
}

// TRTCCloudマスターインスタンス（ボーカルインスタンス）を作成
TRTCCloud mTRTCCloud = TRTCCloud.sharedInstance(context);
// TRTCCloudサブインスタンス（インストゥルメンタルインスタンス）を作成
TRTCCloud subCloud = mTRTCCloud.createSubCloud();

// マスターインスタンス（ボーカルインスタンス）が入室
TRTCCloudDef.TRTCParams params = new TRTCCloudDef.TRTCParams();
params.sdkAppId = SDKAppId;
params.userId = UserId;
params.userSig = UserSig;
params.role = TRTCCloudDef.TRTCRoleAnchor;
params.strRoomId = RoomId;
mTRTCCloud.enterRoom(params, TRTCCloudDef.TRTC_APP_SCENE_LIVE);

// サブインスタンスが手動購読モードを開始し、デフォルトではリモートストリームを購読しない
subCloud.setDefaultStreamRecvMode(false, false);

// サブインスタンス（インストゥルメンタルインスタンス）が入室
TRTCCloudDef.TRTCParams bgmParams = new TRTCCloudDef.TRTCParams();
bgmParams.sdkAppId = SDKAppId;
// サブインスタンスのユーザー名は、ルーム内の他のユーザーと重複してはいけません。
bgmParams.userId = UserId + "_bgm";
bgmParams.userSig = UserSig;
bgmParams.role = TRTCCloudDef.TRTCRoleAnchor;
bgmParams.strRoomId = RoomId;
subCloud.enterRoom(bgmParams, TRTCCloudDef.TRTC_APP_SCENE_LIVE);

// マスターインスタンスの入室結果イベントコールバック
@Override
public void onEnterRoom(long result) {
    if (result > 0) {
        // マスターインスタンスがサブインスタンスがパブリッシュした音楽ストリームの購読をキャンセル
        mTRTCCloud.muteRemoteAudio(UserId + "_bgm", true);
        // マスターインスタンスがブラックフレーム挿入の実験的インターフェースを開始
        mTRTCCloud.callExperimentalAPI(
        "{\\"api\\":\\"enableBlackStream\\",\\"params\\": {\\"enable\\":true}}");
        // マスターインスタンスが合唱モードの実験的インターフェースを開始
        mTRTCCloud.callExperimentalAPI(
        "{\\"api\\":\\"enableChorus\\",\\"params\\":{\\"enable\\":true,\\"audioSource\\":0}}");
        // マスターインスタンスが低遅延モードの実験的インターフェースを開始
        mTRTCCloud.callExperimentalAPI(
        "{\\"api\\":\\"setLowLatencyModeEnabled\\",\\"params\\":{\\"enable\\":true}}");
        // マスターインスタンスが音量コールバックを有効にする
        mTRTCCloud.enableAudioVolumeEvaluation(300, false);
        // マスターインスタンス全過程のメディア音量タイプを設定
        mTRTCCloud.setSystemVolumeType(TRTCCloudDef.TRTCSystemVolumeTypeMedia);
        // マスターインスタンスがローカルオーディオをキャプチャー・パブリッシュし、同時に音質を設定
        mTRTCCloud.startLocalAudio(TRTCCloudDef.TRTC_AUDIO_QUALITY_MUSIC);
    } else {
        // result入室失敗のエラーコード
        Log.d(TAG, "Enter room failed");
    }
}

// サブインスタンスの入室結果イベントコールバック
@Override
public void onEnterRoom(long result) {
    if (result > 0) {
        // サブインスタンスで合唱モードの実験的インターフェースを有効にする
        subCloud.callExperimentalAPI(
        "{\\"api\\":\\"enableChorus\\",\\"params\\":{\\"enable\\":true,\\"audioSource\\":1}}");
        // サブインスタンスが低遅延モードの実験的インターフェースを開始
        subCloud.callExperimentalAPI(
        "{\\"api\\":\\"setLowLatencyModeEnabled\\",\\"params\\":{\\"enable\\":true}}");
        // サブインスタンスの全過程のメディア音量タイプを設定
        subCloud.setSystemVolumeType(TRTCCloudDef.TRTCSystemVolumeTypeMedia);
        // サブインスタンスの音質設定
        subCloud.setAudioQuality(TRTCCloudDef.TRTC_AUDIO_QUALITY_MUSIC);
    } else {
        // result入室失敗のエラーコード
        Log.d(TAG, "Enter room failed");
    }
}

private void startPublishMediaToRoom(String roomId, String userId) {
    // TRTCPublishTargetオブジェクトを作成
    TRTCCloudDef.TRTCPublishTarget target = new TRTCCloudDef.TRTCPublishTarget();
    // ミキシング後にルームにプッシュバック
    target.mode = TRTCCloudDef.TRTC_PublishMixStream_ToRoom;
    target.mixStreamIdentity.strRoomId = roomId;
    // ミキシングロボットのユーザー名は、ルーム内の他のユーザーと重複してはいけません。
    target.mixStreamIdentity.userId = userId + "_robot";

    // トランスコード後のオーディオストリームのエンコードパラメータを設定する（カスタマイズ可能）
    TRTCCloudDef.TRTCStreamEncoderParam trtcStreamEncoderParam = new TRTCCloudDef.TRTCStreamEncoderParam();
    trtcStreamEncoderParam.audioEncodedChannelNum = 2;
    trtcStreamEncoderParam.audioEncodedKbps = 64;
    trtcStreamEncoderParam.audioEncodedCodecType = 2;
    trtcStreamEncoderParam.audioEncodedSampleRate = 48000;

    // トランスコード後のビデオストリームのエンコードパラメータを設定する（ブラックフレームの挿入が必要）
    trtcStreamEncoderParam.videoEncodedFPS = 15;
    trtcStreamEncoderParam.videoEncodedGOP = 3;
    trtcStreamEncoderParam.videoEncodedKbps = 30;
    trtcStreamEncoderParam.videoEncodedWidth = 64;
    trtcStreamEncoderParam.videoEncodedHeight = 64;

    // オーディオストリームミックスのパラメータを設定
    TRTCCloudDef.TRTCStreamMixingConfig trtcStreamMixingConfig = new TRTCCloudDef.TRTCStreamMixingConfig();
    // デフォルトでは空欄のままで大丈夫です。これは、ルーム内のすべてのオーディオがミキシングされることを意味します。
    trtcStreamMixingConfig.audioMixUserList = null;

    // ビデオストリームミックステンプレートの配置（ブラックフレームを挿入する場合は必須）
    TRTCCloudDef.TRTCVideoLayout videoLayout = new TRTCCloudDef.TRTCVideoLayout();
    trtcStreamMixingConfig.videoLayoutList.add(videoLayout);

    // オーディオ・ビデオストリームプッシュバックを開始
    mTRTCCloud.startPublishMediaStream(target, trtcStreamEncoderParam, trtcStreamMixingConfig);
}

TXLiveBase.setListener(new TXLiveBaseListener() {
    @Override
    public void onUpdateNetworkTime(int errCode, String errMsg) {
        super.onUpdateNetworkTime(errCode, errMsg);
        // errCode 0: 時刻同期成功、偏差は30ms以内。1: 時刻同期成功、しかし偏差は30ms以上の可能性あります。-1: 時刻同期失敗
        if (errCode == 0) {
            // 時刻同期成功、NTPタイムスタンプを取得
            long ntpTime = TXLiveBase.getNetworkTimestamp();
        } else {
            // 時刻同期に失敗しました。時刻同期を再試行してください。
            TXLiveBase.updateNetworkTime();
        }
    }
});

TXLiveBase.updateNetworkTime();

Timer mTimer = new Timer();
mTimer.schedule(new TimerTask() {
    @Override
    public void run() {
        try {
            JSONObject jsonObject = new JSONObject();
            jsonObject.put("cmd", "startChorus");
            // 合唱開始時間を設定: 現在のNTP時間＋遅延再生時間（例：3秒）
            jsonObject.put("startPlayMusicTS", TXLiveBase.getNetworkTimestamp() + 3000);
            jsonObject.put("musicId", musicId);
            jsonObject.put("musicDuration", subCloud.getAudioEffectManager().getMusicDurationInMS(originMusicUri));
            mTRTCCloud.sendCustomCmdMsg(1, jsonObject.toString().getBytes(), false, false);
        } catch (JSONException e) {
            e.printStackTrace();
        }
    }
}, 0, 1000);