package com.xiaomi.mipush.sdk; import android.app.ActivityManager; import android.content.Context; import android.content.Intent; import android.content.SharedPreferences; import android.text.TextUtils; import com.huawei.hms.support.api.entity.auth.AuthCode; import com.meizu.cloud.pushsdk.constants.PushConstants; import com.xiaomi.channel.commonutils.logger.b; import com.xiaomi.mipush.sdk.PushMessageHandler; import com.xiaomi.push.Cif; import com.xiaomi.push.bp; import com.xiaomi.push.bx; import com.xiaomi.push.db; import com.xiaomi.push.eo; import com.xiaomi.push.ep; import com.xiaomi.push.ez; import com.xiaomi.push.hj; import com.xiaomi.push.ho; import com.xiaomi.push.ht; import com.xiaomi.push.hv; import com.xiaomi.push.hw; import com.xiaomi.push.hx; import com.xiaomi.push.hz; import com.xiaomi.push.i; import com.xiaomi.push.ia; import com.xiaomi.push.ie; import com.xiaomi.push.ig; import com.xiaomi.push.ih; import com.xiaomi.push.ii; import com.xiaomi.push.ik; import com.xiaomi.push.im; import com.xiaomi.push.io; import com.xiaomi.push.iq; import com.xiaomi.push.is; import com.xiaomi.push.it; import com.xiaomi.push.iu; import com.xiaomi.push.iz; import com.xiaomi.push.service.aj; import com.xiaomi.push.service.av; import com.xiaomi.push.service.ax; import com.xiaomi.push.service.ay; import com.xiaomi.push.service.bh; import com.xiaomi.push.service.bo; import com.xiaomi.push.t; import com.xiaomi.push.w; import java.util.ArrayList; import java.util.HashMap; import java.util.LinkedList; import java.util.List; import java.util.Map; import java.util.Queue; import java.util.TimeZone; public class am { private static am a; /* renamed from: a reason: collision with other field name */ private static Object f6689a = new Object(); /* renamed from: a reason: collision with other field name */ private static Queue<String> f6690a; /* renamed from: a reason: collision with other field name */ private Context f6691a; private am(Context context) { Context applicationContext = context.getApplicationContext(); this.f6691a = applicationContext; if (applicationContext == null) { this.f6691a = context; } } public static Intent a(Context context, String str, Map<String, String> map, int i) { return aj.b(context, str, map, i); } private PushMessageHandler.a a(Cif ifVar, boolean z, byte[] bArr, String str, int i, Intent intent) { ep a2; String packageName; String a3; String str2; String str3; String str4; MiPushMessage miPushMessage; String str5; int i2; String str6; String str7; ep epVar; ArrayList arrayList = null; try { iu a4 = ai.a(this.f6691a, ifVar); if (a4 == null) { b.d("receiving an un-recognized message. " + ifVar.f7263a); ep.a(this.f6691a).b(this.f6691a.getPackageName(), eo.m9316a(i), str, "18"); s.c(this.f6691a, ifVar, z); return null; } hj a5 = ifVar.a(); b.m9051a("processing a message, action=" + a5); switch (an.a[a5.ordinal()]) { case 1: if (!ifVar.m9509b()) { b.d("receiving an un-encrypt message(SendMessage)."); return null; } else if (!b.m9086a(this.f6691a).m9097e() || z) { im imVar = (im) a4; hv a6 = imVar.a(); if (a6 == null) { b.d("receive an empty message without push content, drop it"); ep.a(this.f6691a).b(this.f6691a.getPackageName(), eo.m9316a(i), str, "22"); s.d(this.f6691a, ifVar, z); return null; } int intExtra = intent.getIntExtra("notification_click_button", 0); if (z) { if (aj.m9665a(ifVar)) { MiPushClient.reportIgnoreRegMessageClicked(this.f6691a, a6.m9449a(), ifVar.m9501a(), ifVar.f7270b, a6.b()); } else { hw hwVar = ifVar.m9501a() != null ? new hw(ifVar.m9501a()) : new hw(); if (hwVar.m9458a() == null) { hwVar.a(new HashMap()); } hwVar.m9458a().put("notification_click_button", String.valueOf(intExtra)); MiPushClient.reportMessageClicked(this.f6691a, a6.m9449a(), hwVar, a6.b()); } } if (!z) { if (!TextUtils.isEmpty(imVar.d()) && MiPushClient.aliasSetTime(this.f6691a, imVar.d()) < 0) { MiPushClient.addAlias(this.f6691a, imVar.d()); } else if (!TextUtils.isEmpty(imVar.c()) && MiPushClient.topicSubscribedTime(this.f6691a, imVar.c()) < 0) { MiPushClient.addTopic(this.f6691a, imVar.c()); } } if (ifVar.f7264a == null || ifVar.f7264a.m9458a() == null) { str4 = null; str3 = null; } else { str4 = ifVar.f7264a.f7175a.get("jobkey"); str3 = str4; } if (TextUtils.isEmpty(str4)) { str4 = a6.m9449a(); } if (z || !m9070a(this.f6691a, str4)) { MiPushMessage generateMessage = PushMessageHelper.generateMessage(imVar, ifVar.m9501a(), z); if (generateMessage.getPassThrough() != 0 || z || !aj.m9666a(generateMessage.getExtra())) { b.m9051a("receive a message, msgid=" + a6.m9449a() + ", jobkey=" + str4 + ", btn=" + intExtra); String a7 = aj.a(generateMessage.getExtra(), intExtra); if (!z || generateMessage.getExtra() == null || TextUtils.isEmpty(a7)) { miPushMessage = generateMessage; } else { Map<String, String> extra = generateMessage.getExtra(); if (!(intExtra == 0 || ifVar.m9501a() == null)) { ao.a(this.f6691a).a(ifVar.m9501a().c(), intExtra); } if (aj.m9665a(ifVar)) { Intent a8 = a(this.f6691a, ifVar.f7270b, extra, intExtra); a8.putExtra("eventMessageType", i); a8.putExtra("messageId", str); a8.putExtra("jobkey", str3); if (a8 == null) { b.m9051a("Getting Intent fail from ignore reg message. "); ep.a(this.f6691a).b(this.f6691a.getPackageName(), eo.m9316a(i), str, "23"); return null; } String c = a6.c(); if (!TextUtils.isEmpty(c)) { a8.putExtra("payload", c); } this.f6691a.startActivity(a8); s.a(this.f6691a, ifVar); ep.a(this.f6691a).a(this.f6691a.getPackageName(), eo.m9316a(i), str, 3006, a7); return null; } Context context = this.f6691a; Intent a9 = a(context, context.getPackageName(), extra, intExtra); if (a9 == null) { return null; } if (!a7.equals(bh.c)) { a9.putExtra(PushMessageHelper.KEY_MESSAGE, generateMessage); a9.putExtra("eventMessageType", i); a9.putExtra("messageId", str); a9.putExtra("jobkey", str3); } this.f6691a.startActivity(a9); s.a(this.f6691a, ifVar); b.m9051a("start activity succ"); ep.a(this.f6691a).a(this.f6691a.getPackageName(), eo.m9316a(i), str, 1006, a7); if (!a7.equals(bh.c)) { return null; } ep.a(this.f6691a).a(this.f6691a.getPackageName(), eo.m9316a(i), str, "13"); return null; } } else { aj.m9662a(this.f6691a, ifVar, bArr); return null; } } else { b.m9051a("drop a duplicate message, key=" + str4); ep a10 = ep.a(this.f6691a); String packageName2 = this.f6691a.getPackageName(); String a11 = eo.m9316a(i); a10.c(packageName2, a11, str, "2:" + str4); miPushMessage = null; } if (ifVar.m9501a() == null && !z) { a(imVar, ifVar); } return miPushMessage; } else { b.m9051a("receive a message in pause state. drop it"); ep.a(this.f6691a).a(this.f6691a.getPackageName(), eo.m9316a(i), str, "12"); return null; } case 2: ik ikVar = (ik) a4; String str8 = b.m9086a(this.f6691a).f6707a; if (TextUtils.isEmpty(str8) || !TextUtils.equals(str8, ikVar.m9530a())) { b.m9051a("bad Registration result:"); ep.a(this.f6691a).b(this.f6691a.getPackageName(), eo.m9316a(i), str, "21"); return null; } b.m9086a(this.f6691a).f6707a = null; int i3 = (ikVar.f7326a > 0 ? 1 : (ikVar.f7326a == 0 ? 0 : -1)); Context context2 = this.f6691a; if (i3 == 0) { b.m9086a(context2).b(ikVar.f7336e, ikVar.f7337f, ikVar.f7343l); epVar = ep.a(this.f6691a); str7 = this.f6691a.getPackageName(); str6 = eo.m9316a(i); i2 = AuthCode.StatusCode.PERMISSION_EXPIRED; str5 = "1"; } else { epVar = ep.a(context2); str7 = this.f6691a.getPackageName(); str6 = eo.m9316a(i); i2 = AuthCode.StatusCode.PERMISSION_EXPIRED; str5 = PushConstants.PUSH_TYPE_UPLOAD_LOG; } epVar.a(str7, str6, str, i2, str5); if (!TextUtils.isEmpty(ikVar.f7336e)) { arrayList = new ArrayList(); arrayList.add(ikVar.f7336e); } MiPushCommandMessage generateCommandMessage = PushMessageHelper.generateCommandMessage(ez.COMMAND_REGISTER.f6970a, arrayList, ikVar.f7326a, ikVar.f7335d, null); ao.a(this.f6691a).m9084d(); return generateCommandMessage; case 3: if (((iq) a4).f7402a == 0) { b.m9086a(this.f6691a).m9088a(); MiPushClient.clearExtras(this.f6691a); } PushMessageHandler.a(); break; case 4: io ioVar = (io) a4; if (ioVar.f7377a == 0) { MiPushClient.addTopic(this.f6691a, ioVar.b()); } if (!TextUtils.isEmpty(ioVar.b())) { arrayList = new ArrayList(); arrayList.add(ioVar.b()); } b.e("resp-cmd:" + ez.COMMAND_SUBSCRIBE_TOPIC + ", " + ioVar.a()); return PushMessageHelper.generateCommandMessage(ez.COMMAND_SUBSCRIBE_TOPIC.f6970a, arrayList, ioVar.f7377a, ioVar.f7383d, ioVar.c()); case 5: is isVar = (is) a4; if (isVar.f7422a == 0) { MiPushClient.removeTopic(this.f6691a, isVar.b()); } if (!TextUtils.isEmpty(isVar.b())) { arrayList = new ArrayList(); arrayList.add(isVar.b()); } b.e("resp-cmd:" + ez.COMMAND_UNSUBSCRIBE_TOPIC + ", " + isVar.a()); return PushMessageHelper.generateCommandMessage(ez.COMMAND_UNSUBSCRIBE_TOPIC.f6970a, arrayList, isVar.f7422a, isVar.f7428d, isVar.c()); case 6: db.a(this.f6691a.getPackageName(), this.f6691a, a4, hj.Command, bArr.length); ie ieVar = (ie) a4; String b = ieVar.b(); List<String> a12 = ieVar.m9495a(); if (ieVar.f7251a == 0) { if (TextUtils.equals(b, ez.COMMAND_SET_ACCEPT_TIME.f6970a) && a12 != null && a12.size() > 1) { MiPushClient.addAcceptTime(this.f6691a, a12.get(0), a12.get(1)); if (!"00:00".equals(a12.get(0)) || !"00:00".equals(a12.get(1))) { b.m9086a(this.f6691a).a(false); } else { b.m9086a(this.f6691a).a(true); } a12 = a(TimeZone.getTimeZone("GMT+08"), TimeZone.getDefault(), a12); } else if (TextUtils.equals(b, ez.COMMAND_SET_ALIAS.f6970a) && a12 != null && a12.size() > 0) { MiPushClient.addAlias(this.f6691a, a12.get(0)); } else if (TextUtils.equals(b, ez.COMMAND_UNSET_ALIAS.f6970a) && a12 != null && a12.size() > 0) { MiPushClient.removeAlias(this.f6691a, a12.get(0)); } else if (TextUtils.equals(b, ez.COMMAND_SET_ACCOUNT.f6970a) && a12 != null && a12.size() > 0) { MiPushClient.addAccount(this.f6691a, a12.get(0)); } else if (TextUtils.equals(b, ez.COMMAND_UNSET_ACCOUNT.f6970a) && a12 != null && a12.size() > 0) { MiPushClient.removeAccount(this.f6691a, a12.get(0)); } else if (TextUtils.equals(b, ez.COMMAND_CHK_VDEVID.f6970a)) { if (a12 != null && a12.size() > 0) { i.a(this.f6691a, a12.get(0)); } return null; } } b.e("resp-cmd:" + b + ", " + ieVar.a()); return PushMessageHelper.generateCommandMessage(b, a12, ieVar.f7251a, ieVar.f7259d, ieVar.c()); case 7: db.a(this.f6691a.getPackageName(), this.f6691a, a4, hj.Notification, bArr.length); if (!(a4 instanceof ia)) { if (a4 instanceof ii) { ii iiVar = (ii) a4; if (!"registration id expired".equalsIgnoreCase(iiVar.f7287d)) { if (ht.ClientInfoUpdateOk.f7140a.equalsIgnoreCase(iiVar.f7287d)) { if (iiVar.m9517a() != null && iiVar.m9517a().containsKey("app_version")) { b.m9086a(this.f6691a).m9089a(iiVar.m9517a().get("app_version")); break; } } else if (ht.AwakeApp.f7140a.equalsIgnoreCase(iiVar.f7287d)) { if (ifVar.m9509b() && iiVar.m9517a() != null && iiVar.m9517a().containsKey("awake_info")) { Context context3 = this.f6691a; o.a(context3, b.m9086a(context3).m9087a(), ax.a(this.f6691a).a(ho.AwakeInfoUploadWaySwitch.a(), 0), iiVar.m9517a().get("awake_info")); break; } } else if (!ht.NormalClientConfigUpdate.f7140a.equalsIgnoreCase(iiVar.f7287d)) { if (!ht.CustomClientConfigUpdate.f7140a.equalsIgnoreCase(iiVar.f7287d)) { if (!ht.SyncInfoResult.f7140a.equalsIgnoreCase(iiVar.f7287d)) { if (!ht.ForceSync.f7140a.equalsIgnoreCase(iiVar.f7287d)) { if (!ht.CancelPushMessage.f7140a.equals(iiVar.f7287d)) { if (!ht.HybridRegisterResult.f7140a.equals(iiVar.f7287d)) { if (!ht.HybridUnregisterResult.f7140a.equals(iiVar.f7287d)) { if (!ht.PushLogUpload.f7140a.equals(iiVar.f7287d)) { if (!ht.DetectAppAlive.f7140a.equals(iiVar.f7287d)) { if (com.xiaomi.push.service.i.a(iiVar)) { b.b("receive notification handle by cpra"); break; } } else { b.b("receive detect msg"); b(iiVar); break; } } } else { iq iqVar = new iq(); it.a(iqVar, iiVar.m9522a()); MiPushClient4Hybrid.onReceiveUnregisterResult(this.f6691a, iqVar); break; } } else { try { ik ikVar2 = new ik(); it.a(ikVar2, iiVar.m9522a()); MiPushClient4Hybrid.onReceiveRegisterResult(this.f6691a, ikVar2); break; } catch (iz e) { b.a(e); break; } } } else { b.e("resp-type:" + iiVar.f7287d + ", " + iiVar.m9516a()); if (iiVar.m9517a() != null) { int i4 = -2; if (iiVar.m9517a().containsKey(bh.L)) { String str9 = iiVar.m9517a().get(bh.L); if (!TextUtils.isEmpty(str9)) { try { i4 = Integer.parseInt(str9); } catch (NumberFormatException e2) { e2.printStackTrace(); } } } if (i4 >= -1) { MiPushClient.clearNotification(this.f6691a, i4); } else { MiPushClient.clearNotification(this.f6691a, iiVar.m9517a().containsKey(bh.J) ? iiVar.m9517a().get(bh.J) : "", iiVar.m9517a().containsKey(bh.K) ? iiVar.m9517a().get(bh.K) : ""); } } a(iiVar); break; } } else { b.m9051a("receive force sync notification"); av.a(this.f6691a, false); break; } } else { av.a(this.f6691a, iiVar); break; } } else { ig igVar = new ig(); it.a(igVar, iiVar.m9522a()); ay.a(ax.a(this.f6691a), igVar); break; } } else { ih ihVar = new ih(); try { it.a(ihVar, iiVar.m9522a()); ay.a(ax.a(this.f6691a), ihVar); break; } catch (iz unused) { break; } } } else { List<String> allAlias = MiPushClient.getAllAlias(this.f6691a); List<String> allTopic = MiPushClient.getAllTopic(this.f6691a); List<String> allUserAccount = MiPushClient.getAllUserAccount(this.f6691a); String acceptTime = MiPushClient.getAcceptTime(this.f6691a); b.e("resp-type:" + iiVar.f7287d + ", " + iiVar.m9516a()); MiPushClient.reInitialize(this.f6691a, hx.RegIdExpired); for (String str10 : allAlias) { MiPushClient.removeAlias(this.f6691a, str10); MiPushClient.setAlias(this.f6691a, str10, null); } for (String str11 : allTopic) { MiPushClient.removeTopic(this.f6691a, str11); MiPushClient.subscribe(this.f6691a, str11, null); } for (String str12 : allUserAccount) { MiPushClient.removeAccount(this.f6691a, str12); MiPushClient.setUserAccount(this.f6691a, str12, null); } String[] split = acceptTime.split(Constants.ACCEPT_TIME_SEPARATOR_SP); if (split.length == 2) { MiPushClient.removeAcceptTime(this.f6691a); MiPushClient.addAcceptTime(this.f6691a, split[0], split[1]); break; } } } } else { ia iaVar = (ia) a4; String a13 = iaVar.a(); b.e("resp-type:" + iaVar.b() + ", code:" + iaVar.f7221a + ", " + a13); if (ht.DisablePushMessage.f7140a.equalsIgnoreCase(iaVar.f7228d)) { if (iaVar.f7221a != 0) { if ("syncing".equals(af.a(this.f6691a).a(au.DISABLE_PUSH))) { synchronized (af.class) { if (af.a(this.f6691a).m9069a(a13)) { if (af.a(this.f6691a).a(a13) < 10) { af.a(this.f6691a).b(a13); ao.a(this.f6691a).a(true, a13); } else { af.a(this.f6691a).c(a13); } } } break; } } else { synchronized (af.class) { if (af.a(this.f6691a).m9069a(a13)) { af.a(this.f6691a).c(a13); if ("syncing".equals(af.a(this.f6691a).a(au.DISABLE_PUSH))) { af.a(this.f6691a).a(au.DISABLE_PUSH, "synced"); MiPushClient.clearNotification(this.f6691a); MiPushClient.clearLocalNotificationType(this.f6691a); PushMessageHandler.a(); ao.a(this.f6691a).m9081b(); } } } break; } } else if (ht.EnablePushMessage.f7140a.equalsIgnoreCase(iaVar.f7228d)) { if (iaVar.f7221a != 0) { if ("syncing".equals(af.a(this.f6691a).a(au.ENABLE_PUSH))) { synchronized (af.class) { if (af.a(this.f6691a).m9069a(a13)) { if (af.a(this.f6691a).a(a13) < 10) { af.a(this.f6691a).b(a13); ao.a(this.f6691a).a(false, a13); } else { af.a(this.f6691a).c(a13); } } } break; } } else { synchronized (af.class) { if (af.a(this.f6691a).m9069a(a13)) { af.a(this.f6691a).c(a13); if ("syncing".equals(af.a(this.f6691a).a(au.ENABLE_PUSH))) { af.a(this.f6691a).a(au.ENABLE_PUSH, "synced"); } } } break; } } else if (!ht.ThirdPartyRegUpdate.f7140a.equalsIgnoreCase(iaVar.f7228d)) { if (ht.UploadTinyData.f7140a.equalsIgnoreCase(iaVar.f7228d)) { a(iaVar); break; } } else { b(iaVar); break; } af.a(this.f6691a).c(a13); break; } break; } return null; } catch (u e3) { b.a(e3); a(ifVar); a2 = ep.a(this.f6691a); packageName = this.f6691a.getPackageName(); a3 = eo.m9316a(i); str2 = "19"; a2.b(packageName, a3, str, str2); s.c(this.f6691a, ifVar, z); return null; } catch (iz e4) { b.a(e4); b.d("receive a message which action string is not valid. is the reg expired?"); a2 = ep.a(this.f6691a); packageName = this.f6691a.getPackageName(); a3 = eo.m9316a(i); str2 = "20"; a2.b(packageName, a3, str, str2); s.c(this.f6691a, ifVar, z); return null; } } private PushMessageHandler.a a(Cif ifVar, byte[] bArr) { String str; String str2 = null; try { iu a2 = ai.a(this.f6691a, ifVar); if (a2 == null) { b.d("message arrived: receiving an un-recognized message. " + ifVar.f7263a); return null; } hj a3 = ifVar.a(); b.m9051a("message arrived: processing an arrived message, action=" + a3); if (an.a[a3.ordinal()] != 1) { return null; } if (!ifVar.m9509b()) { str = "message arrived: receiving an un-encrypt message(SendMessage)."; } else { im imVar = (im) a2; hv a4 = imVar.a(); if (a4 == null) { str = "message arrived: receive an empty message without push content, drop it"; } else { if (!(ifVar.f7264a == null || ifVar.f7264a.m9458a() == null)) { str2 = ifVar.f7264a.f7175a.get("jobkey"); } MiPushMessage generateMessage = PushMessageHelper.generateMessage(imVar, ifVar.m9501a(), false); generateMessage.setArrivedMessage(true); b.m9051a("message arrived: receive a message, msgid=" + a4.m9449a() + ", jobkey=" + str2); return generateMessage; } } b.d(str); return null; } catch (u e) { b.a(e); str = "message arrived: receive a message but decrypt failed. report when click."; } catch (iz e2) { b.a(e2); str = "message arrived: receive a message which action string is not valid. is the reg expired?"; } } public static am a(Context context) { if (a == null) { a = new am(context); } return a; } private void a() { SharedPreferences sharedPreferences = this.f6691a.getSharedPreferences("mipush_extra", 0); long currentTimeMillis = System.currentTimeMillis(); if (Math.abs(currentTimeMillis - sharedPreferences.getLong(Constants.SP_KEY_LAST_REINITIALIZE, 0)) > 1800000) { MiPushClient.reInitialize(this.f6691a, hx.PackageUnregistered); sharedPreferences.edit().putLong(Constants.SP_KEY_LAST_REINITIALIZE, currentTimeMillis).commit(); } } public static void a(Context context, String str) { synchronized (f6689a) { f6690a.remove(str); b.m9086a(context); SharedPreferences a2 = b.a(context); String a3 = bp.a(f6690a, Constants.ACCEPT_TIME_SEPARATOR_SP); SharedPreferences.Editor edit = a2.edit(); edit.putString("pref_msg_ids", a3); t.a(edit); } } private void a(ia iaVar) { String a2 = iaVar.a(); b.b("receive ack " + a2); Map<String, String> a3 = iaVar.m9482a(); if (a3 != null) { String str = a3.get("real_source"); if (!TextUtils.isEmpty(str)) { b.b("receive ack : messageId = " + a2 + " realSource = " + str); bx.a(this.f6691a).a(a2, str, Boolean.valueOf(iaVar.f7221a == 0)); } } } private void a(Cif ifVar) { b.m9051a("receive a message but decrypt failed. report now."); ii iiVar = new ii(ifVar.m9501a().f7173a, false); iiVar.c(ht.DecryptMessageFail.f7140a); iiVar.b(ifVar.m9502a()); iiVar.d(ifVar.f7270b); iiVar.f7282a = new HashMap(); iiVar.f7282a.put("regid", MiPushClient.getRegId(this.f6691a)); ao.a(this.f6691a).a((iu) iiVar, hj.Notification, false, (hw) null); } private void a(ii iiVar) { ia iaVar = new ia(); iaVar.c(ht.CancelPushMessageACK.f7140a); iaVar.a(iiVar.m9516a()); iaVar.a(iiVar.a()); iaVar.b(iiVar.b()); iaVar.e(iiVar.c()); iaVar.a(0); iaVar.d("success clear push message."); ao.a(this.f6691a).a(iaVar, hj.Notification, false, true, null, false, this.f6691a.getPackageName(), b.m9086a(this.f6691a).m9087a(), false); } private void a(im imVar, Cif ifVar) { hw a2 = ifVar.m9501a(); if (a2 != null) { a2 = bo.a(a2.m9456a()); } hz hzVar = new hz(); hzVar.b(imVar.b()); hzVar.a(imVar.m9537a()); hzVar.a(imVar.a().a()); if (!TextUtils.isEmpty(imVar.c())) { hzVar.c(imVar.c()); } if (!TextUtils.isEmpty(imVar.d())) { hzVar.d(imVar.d()); } hzVar.a(it.a(this.f6691a, ifVar)); ao.a(this.f6691a).a(hzVar, hj.AckMessage, a2); } private void a(String str, long j, e eVar) { au a2 = l.a(eVar); if (a2 != null) { if (j == 0) { synchronized (af.class) { if (af.a(this.f6691a).m9069a(str)) { af.a(this.f6691a).c(str); if ("syncing".equals(af.a(this.f6691a).a(a2))) { af.a(this.f6691a).a(a2, "synced"); } } } } else if ("syncing".equals(af.a(this.f6691a).a(a2))) { synchronized (af.class) { if (af.a(this.f6691a).m9069a(str)) { if (af.a(this.f6691a).a(str) < 10) { af.a(this.f6691a).b(str); ao.a(this.f6691a).a(str, a2, eVar); } else { af.a(this.f6691a).c(str); } } } } else { af.a(this.f6691a).c(str); } } } /* renamed from: a reason: collision with other method in class */ private static boolean m9070a(Context context, String str) { synchronized (f6689a) { b.m9086a(context); SharedPreferences a2 = b.a(context); if (f6690a == null) { String[] split = a2.getString("pref_msg_ids", "").split(Constants.ACCEPT_TIME_SEPARATOR_SP); f6690a = new LinkedList(); for (String str2 : split) { f6690a.add(str2); } } if (f6690a.contains(str)) { return true; } f6690a.add(str); if (f6690a.size() > 25) { f6690a.poll(); } String a3 = bp.a(f6690a, Constants.ACCEPT_TIME_SEPARATOR_SP); SharedPreferences.Editor edit = a2.edit(); edit.putString("pref_msg_ids", a3); t.a(edit); return false; } } /* renamed from: a reason: collision with other method in class */ private boolean m9071a(Cif ifVar) { Map<String, String> a2 = ifVar.m9501a() == null ? null : ifVar.m9501a().m9458a(); if (a2 == null) { return false; } String str = a2.get(Constants.EXTRA_KEY_PUSH_SERVER_ACTION); return TextUtils.equals(str, Constants.EXTRA_VALUE_HYBRID_MESSAGE) || TextUtils.equals(str, Constants.EXTRA_VALUE_PLATFORM_MESSAGE); } private void b(ia iaVar) { long j; e eVar; b.c("ASSEMBLE_PUSH : " + iaVar.toString()); String a2 = iaVar.a(); Map<String, String> a3 = iaVar.m9482a(); if (a3 != null) { String str = a3.get(Constants.ASSEMBLE_PUSH_REG_INFO); if (!TextUtils.isEmpty(str)) { if (str.contains("brand:" + ag.FCM.name())) { b.m9051a("ASSEMBLE_PUSH : receive fcm token sync ack"); i.b(this.f6691a, e.ASSEMBLE_PUSH_FCM, str); j = iaVar.f7221a; eVar = e.ASSEMBLE_PUSH_FCM; } else { if (str.contains("brand:" + ag.HUAWEI.name())) { b.m9051a("ASSEMBLE_PUSH : receive hw token sync ack"); i.b(this.f6691a, e.ASSEMBLE_PUSH_HUAWEI, str); j = iaVar.f7221a; eVar = e.ASSEMBLE_PUSH_HUAWEI; } else { if (str.contains("brand:" + ag.OPPO.name())) { b.m9051a("ASSEMBLE_PUSH : receive COS token sync ack"); i.b(this.f6691a, e.ASSEMBLE_PUSH_COS, str); j = iaVar.f7221a; eVar = e.ASSEMBLE_PUSH_COS; } else { if (str.contains("brand:" + ag.VIVO.name())) { b.m9051a("ASSEMBLE_PUSH : receive FTOS token sync ack"); i.b(this.f6691a, e.ASSEMBLE_PUSH_FTOS, str); a(a2, iaVar.f7221a, e.ASSEMBLE_PUSH_FTOS); return; } return; } } } a(a2, j, eVar); } } } private void b(Cif ifVar) { hw a2 = ifVar.m9501a(); if (a2 != null) { a2 = bo.a(a2.m9456a()); } hz hzVar = new hz(); hzVar.b(ifVar.m9502a()); hzVar.a(a2.m9457a()); hzVar.a(a2.m9455a()); if (!TextUtils.isEmpty(a2.m9462b())) { hzVar.c(a2.m9462b()); } hzVar.a(it.a(this.f6691a, ifVar)); ao.a(this.f6691a).a((iu) hzVar, hj.AckMessage, false, a2); } private void b(ii iiVar) { String str; Map<String, String> a2 = iiVar.m9517a(); if (a2 == null) { str = "detect failed because null"; } else { String str2 = (String) av.a(a2, "pkgList", (Object) null); if (TextUtils.isEmpty(str2)) { str = "detect failed because empty"; } else { try { List<ActivityManager.RunningAppProcessInfo> runningAppProcesses = ((ActivityManager) this.f6691a.getSystemService(PushConstants.INTENT_ACTIVITY_NAME)).getRunningAppProcesses(); if (!w.a(runningAppProcesses)) { String[] split = str2.split(Constants.ACCEPT_TIME_SEPARATOR_SP); HashMap hashMap = new HashMap(); for (String str3 : split) { String[] split2 = str3.split(Constants.WAVE_SEPARATOR); if (split2.length >= 2) { hashMap.put(split2[1], split2[0]); } } w.a aVar = new w.a(Constants.WAVE_SEPARATOR, Constants.ACCEPT_TIME_SEPARATOR_SP); for (ActivityManager.RunningAppProcessInfo runningAppProcessInfo : runningAppProcesses) { if (hashMap.containsKey(runningAppProcessInfo.processName)) { aVar.a((String) hashMap.get(runningAppProcessInfo.processName), String.valueOf(runningAppProcessInfo.importance)); hashMap.remove(runningAppProcessInfo.processName); } } if (aVar.toString().length() > 0) { ii iiVar2 = new ii(); iiVar2.a(iiVar.m9516a()); iiVar2.b(iiVar.b()); iiVar2.d(iiVar.c()); iiVar2.c(ht.DetectAppAliveResult.f7140a); iiVar2.f7282a = new HashMap(); iiVar2.f7282a.put("alive", aVar.toString()); if (Boolean.parseBoolean((String) av.a(a2, "reportNotAliveApp", "false")) && hashMap.size() > 0) { w.a aVar2 = new w.a("", Constants.ACCEPT_TIME_SEPARATOR_SP); for (String str4 : hashMap.keySet()) { aVar2.a((String) hashMap.get(str4), ""); } iiVar2.f7282a.put("notAlive", aVar2.toString()); } ao.a(this.f6691a).a((iu) iiVar2, hj.Notification, false, (hw) null); return; } b.b("detect failed because no alive process"); return; } b.m9051a("detect failed because params illegal"); return; } catch (Throwable th) { str = "detect failed " + th; } } } b.m9051a(str); } public PushMessageHandler.a a(Intent intent) { String str; String str2; String str3; ep epVar; Throwable e; ep a2; String packageName; String format; String action = intent.getAction(); b.m9051a("receive an intent from server, action=" + action); String stringExtra = intent.getStringExtra("mrt"); if (stringExtra == null) { stringExtra = Long.toString(System.currentTimeMillis()); } String stringExtra2 = intent.getStringExtra("messageId"); int intExtra = intent.getIntExtra("eventMessageType", -1); if ("com.xiaomi.mipush.RECEIVE_MESSAGE".equals(action)) { byte[] byteArrayExtra = intent.getByteArrayExtra("mipush_payload"); boolean booleanExtra = intent.getBooleanExtra("mipush_notified", false); if (byteArrayExtra == null) { b.d("receiving an empty message, drop"); ep.a(this.f6691a).a(this.f6691a.getPackageName(), intent, "12"); return null; } Cif ifVar = new Cif(); try { it.a(ifVar, byteArrayExtra); b a3 = b.m9086a(this.f6691a); hw a4 = ifVar.m9501a(); if (ifVar.a() == hj.SendMessage && a4 != null && !a3.m9097e() && !booleanExtra) { a4.a("mrt", stringExtra); a4.a("mat", Long.toString(System.currentTimeMillis())); if (!m9071a(ifVar)) { b(ifVar); } else { b.b("this is a mina's message, ack later"); a4.a(Constants.EXTRA_KEY_HYBRID_MESSAGE_TS, String.valueOf(a4.m9455a())); a4.a(Constants.EXTRA_KEY_HYBRID_DEVICE_STATUS, String.valueOf((int) it.a(this.f6691a, ifVar))); } } String str4 = ""; if (ifVar.a() == hj.SendMessage && !ifVar.m9509b()) { if (aj.m9665a(ifVar)) { Object[] objArr = new Object[2]; objArr[0] = ifVar.b(); if (a4 != null) { str4 = a4.m9457a(); } objArr[1] = str4; b.m9051a(String.format("drop an un-encrypted wake-up messages. %1$s, %2$s", objArr)); a2 = ep.a(this.f6691a); packageName = this.f6691a.getPackageName(); format = String.format("13: %1$s", ifVar.b()); } else { Object[] objArr2 = new Object[2]; objArr2[0] = ifVar.b(); if (a4 != null) { str4 = a4.m9457a(); } objArr2[1] = str4; b.m9051a(String.format("drop an un-encrypted messages. %1$s, %2$s", objArr2)); a2 = ep.a(this.f6691a); packageName = this.f6691a.getPackageName(); format = String.format("14: %1$s", ifVar.b()); } a2.a(packageName, intent, format); s.a(this.f6691a, ifVar, booleanExtra); return null; } else if (ifVar.a() == hj.SendMessage && ifVar.m9509b() && aj.m9665a(ifVar) && (!booleanExtra || a4 == null || a4.m9458a() == null || !a4.m9458a().containsKey("notify_effect"))) { Object[] objArr3 = new Object[2]; objArr3[0] = ifVar.b(); if (a4 != null) { str4 = a4.m9457a(); } objArr3[1] = str4; b.m9051a(String.format("drop a wake-up messages which not has 'notify_effect' attr. %1$s, %2$s", objArr3)); ep.a(this.f6691a).a(this.f6691a.getPackageName(), intent, String.format("25: %1$s", ifVar.b())); s.b(this.f6691a, ifVar, booleanExtra); return null; } else if (a3.m9095c() || ifVar.f7263a == hj.Registration) { if (!a3.m9095c() || !a3.m9098f()) { return a(ifVar, booleanExtra, byteArrayExtra, stringExtra2, intExtra, intent); } if (ifVar.f7263a == hj.UnRegistration) { a3.m9088a(); MiPushClient.clearExtras(this.f6691a); PushMessageHandler.a(); } else { s.e(this.f6691a, ifVar, booleanExtra); MiPushClient.unregisterPush(this.f6691a); } } else if (aj.m9665a(ifVar)) { return a(ifVar, booleanExtra, byteArrayExtra, stringExtra2, intExtra, intent); } else { s.e(this.f6691a, ifVar, booleanExtra); boolean d = a3.m9096d(); b.d("receive message without registration. need re-register!registered?" + d); ep.a(this.f6691a).a(this.f6691a.getPackageName(), intent, "15"); if (d) { a(); } } } catch (iz e2) { e = e2; epVar = ep.a(this.f6691a); str3 = this.f6691a.getPackageName(); str2 = "16"; epVar.a(str3, intent, str2); b.a(e); return null; } catch (Exception e3) { e = e3; epVar = ep.a(this.f6691a); str3 = this.f6691a.getPackageName(); str2 = "17"; epVar.a(str3, intent, str2); b.a(e); return null; } } else if ("com.xiaomi.mipush.ERROR".equals(action)) { MiPushCommandMessage miPushCommandMessage = new MiPushCommandMessage(); Cif ifVar2 = new Cif(); try { byte[] byteArrayExtra2 = intent.getByteArrayExtra("mipush_payload"); if (byteArrayExtra2 != null) { it.a(ifVar2, byteArrayExtra2); } } catch (iz unused) { } miPushCommandMessage.setCommand(String.valueOf(ifVar2.a())); miPushCommandMessage.setResultCode((long) intent.getIntExtra("mipush_error_code", 0)); miPushCommandMessage.setReason(intent.getStringExtra("mipush_error_msg")); b.d("receive a error message. code = " + intent.getIntExtra("mipush_error_code", 0) + ", msg= " + intent.getStringExtra("mipush_error_msg")); return miPushCommandMessage; } else if ("com.xiaomi.mipush.MESSAGE_ARRIVED".equals(action)) { byte[] byteArrayExtra3 = intent.getByteArrayExtra("mipush_payload"); if (byteArrayExtra3 == null) { b.d("message arrived: receiving an empty message, drop"); return null; } Cif ifVar3 = new Cif(); try { it.a(ifVar3, byteArrayExtra3); b a5 = b.m9086a(this.f6691a); if (aj.m9665a(ifVar3)) { str = "message arrived: receive ignore reg message, ignore!"; } else if (!a5.m9095c()) { str = "message arrived: receive message without registration. need unregister or re-register!"; } else if (!a5.m9095c() || !a5.m9098f()) { return a(ifVar3, byteArrayExtra3); } else { str = "message arrived: app info is invalidated"; } b.d(str); } catch (Exception e4) { b.d("fail to deal with arrived message. " + e4); } } return null; } public List<String> a(TimeZone timeZone, TimeZone timeZone2, List<String> list) { if (timeZone.equals(timeZone2)) { return list; } long rawOffset = (long) (((timeZone.getRawOffset() - timeZone2.getRawOffset()) / 1000) / 60); long parseLong = Long.parseLong(list.get(0).split(Constants.COLON_SEPARATOR)[0]); long parseLong2 = Long.parseLong(list.get(0).split(Constants.COLON_SEPARATOR)[1]); long j = ((((parseLong * 60) + parseLong2) - rawOffset) + 1440) % 1440; long parseLong3 = ((((Long.parseLong(list.get(1).split(Constants.COLON_SEPARATOR)[0]) * 60) + Long.parseLong(list.get(1).split(Constants.COLON_SEPARATOR)[1])) - rawOffset) + 1440) % 1440; ArrayList arrayList = new ArrayList(); arrayList.add(String.format("%1$02d:%2$02d", Long.valueOf(j / 60), Long.valueOf(j % 60))); arrayList.add(String.format("%1$02d:%2$02d", Long.valueOf(parseLong3 / 60), Long.valueOf(parseLong3 % 60))); return arrayList; } }