TikTok.apk(点击下载) / MusNotificationApiManager.java
package com.ss.android.ugc.aweme.notification.api;
import X.AbstractC09150Ym;
import X.AbstractC13250fy;
import X.AbstractC21740tf;
import X.AbstractC21780tj;
import X.AbstractC22510uu;
import X.AbstractC22730vG;
import X.AbstractC22750vI;
import X.AbstractC22760vJ;
import X.AbstractC22850vS;
import X.AbstractC22900vX;
import X.AbstractC29991Gq;
import X.AbstractC30021Gt;
import X.AbstractC30181Hj;
import X.AbstractFutureC10390bM;
import X.AnonymousClass0ED;
import X.AnonymousClass0WE;
import X.AnonymousClass75A;
import X.C08550We;
import X.C12720f7;
import X.C16640lR;
import X.C20590ro;
import X.C22330uc;
import X.C22430um;
import X.C264412z;
import X.C29021Cx;
import X.C39191gi;
import X.C45739Hxg;
import X.C45742Hxj;
import X.C46038I5z;
import X.C788638p;
import X.EPA;
import X.GFN;
import com.bytedance.covode.number.Covode;
import com.ss.android.ugc.aweme.base.api.BaseResponse;
import com.ss.android.ugc.aweme.live.LiveOuterService;
import com.ss.android.ugc.aweme.notice.repo.list.bean.NoticeCombineDatas;
import com.ss.android.ugc.aweme.notice.repo.list.bean.NoticeCombineResponse;
import com.ss.android.ugc.aweme.notice.repo.list.bean.NoticeItems;
import com.ss.android.ugc.aweme.notice.repo.list.bean.NoticeListsResponse;
import com.ss.android.ugc.aweme.notification.bean.LiveNoticeMessageResponse;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import java.util.concurrent.ExecutionException;
public final class MusNotificationApiManager {
public static NoticeApi LIZ;
public static NoticeWebcastApi LIZIZ = ((NoticeWebcastApi) C08550We.LIZ(C16640lR.LIZJ() ? "https://webcast.tiktokv.com" : "https://webcast-va.tiktokv.com", NoticeWebcastApi.class));
public static final String LIZJ;
public interface NoticeApi {
static {
Covode.recordClassIndex(84632);
}
@AbstractC22850vS(LIZ = "/aweme/v1/notice/del/")
AnonymousClass0ED<BaseResponse> deleteNotice(@AbstractC22900vX(LIZ = "notice_id") String str);
@AbstractC22760vJ(LIZ = "/aweme/janus/v1/notice/multi/")
AbstractFutureC10390bM<NoticeCombineResponse> fetchCombineNotice(@AbstractC22900vX(LIZ = "live_entrance") int i2, @AbstractC22900vX(LIZ = "req_from") String str, @AbstractC22900vX(LIZ = "is_draw") long j, @AbstractC22900vX(LIZ = "content_type") int i3, @AbstractC22900vX(LIZ = "channel_id") int i4, @AbstractC22900vX(LIZ = "count") int i5, @AbstractC09150Ym Map<String, String> map, @AbstractC22900vX(LIZ = "scenario") int i6);
@AbstractC22760vJ(LIZ = "/aweme/v1/notice/multi/")
AbstractFutureC10390bM<NoticeListsResponse> fetchGroupNotice(@AbstractC22900vX(LIZ = "group_list") String str, @AbstractC22900vX(LIZ = "scenario") int i2);
@AbstractC22760vJ(LIZ = "/aweme/janus/v1/notice/multi/feed/")
AnonymousClass0ED<LiveNoticeMessageResponse> fetchLiveNotice(@AbstractC22900vX(LIZ = "req_from") String str, @AbstractC22900vX(LIZ = "is_draw") long j, @AbstractC22900vX(LIZ = "content_type") int i2, @AbstractC22900vX(LIZ = "channel_id") int i3);
@AbstractC22760vJ(LIZ = "aweme/v1/report/inbox/notice/")
AbstractFutureC10390bM<NoticeListsResponse> fetchReportInboxNotice();
@AbstractC22760vJ(LIZ = "https://oec-api.tiktokv.com/chat/api/client/getLatestMessage")
AbstractFutureC10390bM<NoticeListsResponse> fetchShopInboxNotice();
@AbstractC22850vS(LIZ = "/tiktok/v1/sharer/link/notice/ignore/")
AbstractC30021Gt ignoreLinkNotice(@AbstractC22900vX(LIZ = "link_id") String str);
@AbstractC22850vS(LIZ = "/tiktok/notice/report/v1/")
@AbstractC22750vI
AbstractC30181Hj<BaseResponse> reportNoticeAction(@AbstractC22730vG(LIZ = "nid") long j, @AbstractC22730vG(LIZ = "user_action") int i2, @AbstractC22730vG(LIZ = "action_meta") String str);
@AbstractC22760vJ(LIZ = "/tiktok/user/relation/recommended_notice/update/v1")
AbstractC30181Hj<BaseResponse> reportNoticeBoot();
}
public interface NoticeWebcastApi {
static {
Covode.recordClassIndex(84633);
}
@AbstractC22760vJ(LIZ = "/webcast/tab/")
AnonymousClass0ED<Object> fetchRecommendAvatars(@AbstractC22900vX(LIZ = "live_entrance") int i2, @AbstractC09150Ym Map<String, String> map);
}
static {
Covode.recordClassIndex(84629);
String str = AnonymousClass75A.LJ;
LIZJ = str;
LIZ = (NoticeApi) C08550We.LIZ(str + "/", NoticeApi.class);
}
public static AnonymousClass0ED<BaseResponse> LIZ(String str) {
return LIZ.deleteNotice(str);
}
public static AbstractFutureC10390bM<NoticeCombineResponse> LIZ(boolean z, int i2) {
return LIZ.fetchCombineNotice(5, "tiktok_message", 0, 3, 81, !z ? 1 : 0, LiveOuterService.LJJIFFI().LJ().LIZ(AnonymousClass0WE.LJJI.LIZ()), i2);
}
public static NoticeListsResponse LIZ(List<GFN> list, int i2) {
try {
return LIZ.fetchGroupNotice(C20590ro.LIZ().toJson(list), i2).get();
} catch (ExecutionException e) {
throw AbstractC13250fy.getCompatibleException(e);
}
}
public static NoticeListsResponse LIZ(List<GFN> list, int i2, int i3) {
NoticeListsResponse noticeListsResponse;
AbstractFutureC10390bM<NoticeListsResponse> r0;
try {
AbstractFutureC10390bM<NoticeListsResponse> fetchGroupNotice = LIZ.fetchGroupNotice(C20590ro.LIZ().toJson(list), i3);
List<NoticeItems> list2 = null;
if (i2 == 37) {
try {
r0 = LIZ.fetchReportInboxNotice();
} catch (Exception unused) {
if (i2 == 37) {
LIZ(1);
}
}
} else {
if (i2 == 599) {
r0 = LIZ.fetchShopInboxNotice();
}
noticeListsResponse = fetchGroupNotice.get();
if (!C39191gi.LIZ(list2) && noticeListsResponse != null) {
noticeListsResponse.setCollapseNotices(list2);
}
return noticeListsResponse;
}
if (r0 != null) {
NoticeListsResponse noticeListsResponse2 = r0.get();
if (i2 == 37) {
if (noticeListsResponse2.status_code == 0) {
LIZ(0);
} else {
C29021Cx.LIZ("tns_api_status", "", new C12720f7().LIZ("type", "/aweme/v1/report/inbox/notice/").LIZ("status", (Integer) 1).LIZ("error_message", String.valueOf(noticeListsResponse2.status_code)).LIZ("tns_logId", noticeListsResponse2.getLobPb().getImprId()).LIZ());
}
}
list2 = noticeListsResponse2.getNotices();
}
noticeListsResponse = fetchGroupNotice.get();
noticeListsResponse.setCollapseNotices(list2);
return noticeListsResponse;
} catch (ExecutionException e) {
throw AbstractC13250fy.getCompatibleException(e);
}
}
public static NoticeListsResponse LIZ(List<GFN> list, C264412z<NoticeCombineDatas> r5, int i2) {
try {
AbstractFutureC10390bM<NoticeListsResponse> fetchGroupNotice = LIZ.fetchGroupNotice(C20590ro.LIZ().toJson(list), i2);
ArrayList arrayList = new ArrayList();
try {
NoticeCombineResponse noticeCombineResponse = LIZ(true, i2).get();
if (noticeCombineResponse != null) {
if (C46038I5z.LIZJ.LJIIIZ() && noticeCombineResponse.getData() != null) {
noticeCombineResponse.getData().setLiveNotices(null);
}
if (noticeCombineResponse.getData() != null) {
C45739Hxg.LIZ(noticeCombineResponse.getData());
}
if (C788638p.LIZ && noticeCombineResponse.getData() != null) {
noticeCombineResponse.getData().setShopNotice(null);
}
r5.postValue(noticeCombineResponse.getData());
if (noticeCombineResponse.getData() != null) {
if (noticeCombineResponse.getData().getShopNotice() != null) {
arrayList.addAll(noticeCombineResponse.getData().getShopNotice());
}
if (C45742Hxj.LIZ() && noticeCombineResponse.getData().getReportNotice() != null) {
arrayList.addAll(noticeCombineResponse.getData().getReportNotice());
}
}
}
} catch (Exception unused) {
}
NoticeListsResponse noticeListsResponse = fetchGroupNotice.get();
if (!C39191gi.LIZ(arrayList) && noticeListsResponse != null) {
noticeListsResponse.setCollapseNotices(arrayList);
}
return noticeListsResponse;
} catch (ExecutionException e) {
throw AbstractC13250fy.getCompatibleException(e);
}
}
public static void LIZ() {
AbstractC29991Gq.LIZ((AbstractC22510uu) LIZ.reportNoticeBoot()).LIZIZ(C22330uc.LIZIZ(C22430um.LIZJ)).a_(new AbstractC21740tf<BaseResponse>() {
/* class com.ss.android.ugc.aweme.notification.api.MusNotificationApiManager.AnonymousClass2 */
static {
Covode.recordClassIndex(84631);
}
@Override // X.AbstractC21740tf
public final void onError(Throwable th) {
}
@Override // X.AbstractC21740tf
public final void onSubscribe(AbstractC21780tj r1) {
}
/* JADX DEBUG: Method arguments types fixed to match base method, original types: [java.lang.Object] */
@Override // X.AbstractC21740tf
public final /* bridge */ /* synthetic */ void onSuccess(BaseResponse baseResponse) {
}
});
}
public static void LIZ(int i2) {
C29021Cx.LIZ("tns_api_status", "", new C12720f7().LIZ("type", "/aweme/v1/report/inbox/notice/").LIZ("status", Integer.valueOf(i2)).LIZ());
}
public static void LIZ(long j, EPA epa, String str) {
AbstractC29991Gq.LIZ((AbstractC22510uu) LIZ.reportNoticeAction(j, epa.getValue(), str)).LIZIZ(C22330uc.LIZIZ(C22430um.LIZJ)).a_(new AbstractC21740tf<BaseResponse>() {
/* class com.ss.android.ugc.aweme.notification.api.MusNotificationApiManager.AnonymousClass1 */
static {
Covode.recordClassIndex(84630);
}
@Override // X.AbstractC21740tf
public final void onError(Throwable th) {
}
@Override // X.AbstractC21740tf
public final void onSubscribe(AbstractC21780tj r1) {
}
/* JADX DEBUG: Method arguments types fixed to match base method, original types: [java.lang.Object] */
@Override // X.AbstractC21740tf
public final /* bridge */ /* synthetic */ void onSuccess(BaseResponse baseResponse) {
}
});
}
}