package com.xiaomi.push.service;
import android.content.ComponentName;
import android.content.Context;
import android.content.Intent;
import android.content.pm.PackageInfo;
import android.os.Build;
import android.os.Bundle;
import android.os.Message;
import android.os.Messenger;
import android.os.RemoteException;
import android.text.TextUtils;
import com.xiaomi.channel.commonutils.logger.b;
import com.xiaomi.mipush.sdk.Constants;
import com.xiaomi.push.ae;
import com.xiaomi.push.bj;
import com.xiaomi.push.eu;
import com.xiaomi.push.gd;
import com.xiaomi.push.ge;
import com.xiaomi.push.gf;
import com.xiaomi.push.gi;
import com.xiaomi.push.gr;
import com.xiaomi.push.l;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import org.apache.http.NameValuePair;
public class ServiceClient {
private static long a = 0;
/* renamed from: a */
private static ServiceClient f7463a;
/* renamed from: a */
private static String f7464a;
private static String b = (gr.a(5) + Constants.ACCEPT_TIME_SEPARATOR_SERVER);
/* renamed from: a */
private Context f7465a;
/* renamed from: a */
private Messenger f7466a = null;
/* renamed from: a */
private List<Message> f7467a = new ArrayList();
/* renamed from: a */
private boolean f7468a = false;
/* renamed from: b */
private Messenger f7469b;
/* renamed from: b */
private boolean f7470b = false;
private ServiceClient(Context context) {
this.f7465a = context.getApplicationContext();
if (m9621a()) {
b.c("use miui push service");
this.f7468a = true;
}
}
private Intent a() {
if (isMiuiPushServiceEnabled()) {
Intent intent = new Intent();
intent.setPackage("com.xiaomi.xmsf");
intent.setClassName("com.xiaomi.xmsf", m9618a());
intent.putExtra(bh.A, this.f7465a.getPackageName());
m9619a();
return intent;
}
Intent intent2 = new Intent(this.f7465a, XMPushService.class);
intent2.putExtra(bh.A, this.f7465a.getPackageName());
b();
return intent2;
}
private Message a(Intent intent) {
Message obtain = Message.obtain();
obtain.what = 17;
obtain.obj = intent;
return obtain;
}
/* renamed from: a */
private String m9618a() {
try {
return this.f7465a.getPackageManager().getPackageInfo("com.xiaomi.xmsf", 4).versionCode >= 106 ? "com.xiaomi.push.service.XMPushService" : "com.xiaomi.xmsf.push.service.XMPushService";
} catch (Exception unused) {
return "com.xiaomi.xmsf.push.service.XMPushService";
}
}
private String a(Map<String, String> map) {
StringBuilder sb = new StringBuilder();
int i = 1;
for (Map.Entry<String, String> entry : map.entrySet()) {
sb.append(entry.getKey());
sb.append(Constants.COLON_SEPARATOR);
sb.append(entry.getValue());
if (i < map.size()) {
sb.append(Constants.ACCEPT_TIME_SEPARATOR_SP);
}
i++;
}
return sb.toString();
}
private Map<String, String> a(List<NameValuePair> list) {
HashMap hashMap = new HashMap();
if (list != null && list.size() > 0) {
for (NameValuePair nameValuePair : list) {
if (nameValuePair != null) {
hashMap.put(nameValuePair.getName(), nameValuePair.getValue());
}
}
}
return hashMap;
}
/* renamed from: a */
private void m9619a() {
this.f7465a.getPackageManager().setComponentEnabledSetting(new ComponentName(this.f7465a, XMPushService.class), 2, 1);
}
/* renamed from: a */
private synchronized void m9620a(Intent intent) {
if (this.f7470b) {
Message a2 = a(intent);
if (this.f7467a.size() >= 50) {
this.f7467a.remove(0);
}
this.f7467a.add(a2);
} else if (this.f7469b == null) {
this.f7465a.bindService(intent, new br(this), 1);
this.f7470b = true;
this.f7467a.clear();
this.f7467a.add(a(intent));
} else {
try {
this.f7469b.send(a(intent));
} catch (RemoteException unused) {
this.f7469b = null;
this.f7470b = false;
}
}
}
private void a(Intent intent, String str, String str2, String str3, String str4, String str5, boolean z, Map<String, String> map, Map<String, String> map2) {
intent.putExtra(bh.p, str);
intent.putExtra(bh.s, str2);
intent.putExtra(bh.u, str3);
intent.putExtra(bh.w, str5);
intent.putExtra(bh.v, str4);
intent.putExtra(bh.x, z);
intent.putExtra(bh.E, f7464a);
intent.putExtra(bh.I, this.f7466a);
if (map != null && map.size() > 0) {
String a2 = a(map);
if (!TextUtils.isEmpty(a2)) {
intent.putExtra(bh.y, a2);
}
}
if (map2 != null && map2.size() > 0) {
String a3 = a(map2);
if (!TextUtils.isEmpty(a3)) {
intent.putExtra(bh.z, a3);
}
}
}
/* renamed from: a */
private boolean m9621a() {
if (ae.e) {
return false;
}
try {
PackageInfo packageInfo = this.f7465a.getPackageManager().getPackageInfo("com.xiaomi.xmsf", 4);
return packageInfo != null && packageInfo.versionCode >= 104;
} catch (Exception unused) {
return false;
}
}
private void b() {
this.f7465a.getPackageManager().setComponentEnabledSetting(new ComponentName(this.f7465a, XMPushService.class), 1, 1);
}
public static ServiceClient getInstance(Context context) {
if (f7463a == null) {
f7463a = new ServiceClient(context);
}
return f7463a;
}
public static String getSession() {
return f7464a;
}
public static void setSession(String str) {
f7464a = str;
}
public boolean batchSendMessage(gf[] gfVarArr, boolean z) {
if (!bj.b(this.f7465a)) {
return false;
}
Intent a2 = a();
int length = gfVarArr.length;
Bundle[] bundleArr = new Bundle[length];
for (int i = 0; i < gfVarArr.length; i++) {
String a3 = eu.a();
if (!TextUtils.isEmpty(a3)) {
gd gdVar = new gd("pf", null, null, null);
gd gdVar2 = new gd("sent", null, null, null);
gdVar2.m9388a(a3);
gdVar.a(gdVar2);
gfVarArr[i].a(gdVar);
}
b.c("SEND:" + gfVarArr[i].m9391a());
bundleArr[i] = gfVarArr[i].a();
}
if (length <= 0) {
return false;
}
a2.setAction(bh.g);
a2.putExtra(bh.E, f7464a);
a2.putExtra("ext_packets", bundleArr);
a2.putExtra("ext_encrypt", z);
return startServiceSafely(a2);
}
public void checkAlive() {
Intent a2 = a();
a2.setAction("com.xiaomi.push.check_alive");
startServiceSafely(a2);
}
public boolean closeChannel() {
Intent a2 = a();
a2.setAction(bh.i);
return startServiceSafely(a2);
}
public boolean closeChannel(String str) {
Intent a2 = a();
a2.setAction(bh.i);
a2.putExtra(bh.s, str);
return startServiceSafely(a2);
}
public boolean closeChannel(String str, String str2) {
Intent a2 = a();
a2.setAction(bh.i);
a2.putExtra(bh.s, str);
a2.putExtra(bh.p, str2);
return startServiceSafely(a2);
}
public boolean forceReconnection(String str, String str2, String str3, String str4, String str5, boolean z, List<NameValuePair> list, List<NameValuePair> list2) {
return forceReconnection(str, str2, str3, str4, str5, z, a(list), a(list2));
}
public boolean forceReconnection(String str, String str2, String str3, String str4, String str5, boolean z, Map<String, String> map, Map<String, String> map2) {
Intent a2 = a();
a2.setAction(bh.j);
a(a2, str, str2, str3, str4, str5, z, map, map2);
return startServiceSafely(a2);
}
public boolean isMiuiPushServiceEnabled() {
return this.f7468a;
}
public int openChannel(String str, String str2, String str3, String str4, String str5, Map<String, String> map, Map<String, String> map2, boolean z) {
Intent a2 = a();
a2.setAction(bh.d);
a(a2, str, str2, str3, str4, str5, z, map, map2);
startServiceSafely(a2);
return 0;
}
public int openChannel(String str, String str2, String str3, String str4, String str5, boolean z, List<NameValuePair> list, List<NameValuePair> list2) {
return openChannel(str, str2, str3, str4, str5, a(list), a(list2), z);
}
public void resetConnection(String str, String str2, String str3, String str4, String str5, boolean z, List<NameValuePair> list, List<NameValuePair> list2) {
resetConnection(str, str2, str3, str4, str5, z, a(list), a(list2));
}
public void resetConnection(String str, String str2, String str3, String str4, String str5, boolean z, Map<String, String> map, Map<String, String> map2) {
Intent a2 = a();
a2.setAction(bh.k);
a(a2, str, str2, str3, str4, str5, z, map, map2);
startServiceSafely(a2);
}
public boolean sendIQ(ge geVar) {
if (!bj.b(this.f7465a)) {
return false;
}
Intent a2 = a();
Bundle a3 = geVar.a();
if (a3 == null) {
return false;
}
b.c("SEND:" + geVar.m9390a());
a2.setAction(bh.f);
a2.putExtra(bh.E, f7464a);
a2.putExtra("ext_packet", a3);
return startServiceSafely(a2);
}
public boolean sendMessage(gf gfVar, boolean z) {
if (!bj.b(this.f7465a)) {
return false;
}
Intent a2 = a();
String a3 = eu.a();
if (!TextUtils.isEmpty(a3)) {
gd gdVar = new gd("pf", null, null, null);
gd gdVar2 = new gd("sent", null, null, null);
gdVar2.m9388a(a3);
gdVar.a(gdVar2);
gfVar.a(gdVar);
}
Bundle a4 = gfVar.a();
if (a4 == null) {
return false;
}
b.c("SEND:" + gfVar.m9391a());
a2.setAction(bh.e);
a2.putExtra(bh.E, f7464a);
a2.putExtra("ext_packet", a4);
a2.putExtra("ext_encrypt", z);
return startServiceSafely(a2);
}
public boolean sendMessage(byte[] bArr, String str, String str2) {
String str3;
if (!bj.b(this.f7465a) || bArr == null || TextUtils.isEmpty(str) || TextUtils.isEmpty(str2)) {
b.m9051a("Failed to send message: message|userId|chid may be empty, or the network is unavailable.");
return false;
}
Intent a2 = a();
if (bArr == null) {
return false;
}
a2.setAction(bh.e);
a2.putExtra(bh.E, f7464a);
a2.putExtra("ext_raw_packet", bArr);
int indexOf = str.indexOf("@");
String str4 = null;
String substring = indexOf != -1 ? str.substring(0, indexOf) : null;
int lastIndexOf = str.lastIndexOf("/");
if (lastIndexOf != -1) {
str4 = str.substring(indexOf + 1, lastIndexOf);
str3 = str.substring(lastIndexOf + 1);
} else {
str3 = null;
}
a2.putExtra(bh.p, substring);
a2.putExtra(bh.q, str4);
a2.putExtra(bh.r, str3);
StringBuilder sb = new StringBuilder();
sb.append(b);
long j = a;
a = 1 + j;
sb.append(j);
String sb2 = sb.toString();
a2.putExtra("ext_pkt_id", sb2);
a2.putExtra("ext_chid", str2);
b.e("SEND: chid=" + str2 + ", packetId=" + sb2);
return startServiceSafely(a2);
}
public boolean sendPresence(gi giVar) {
if (!bj.b(this.f7465a)) {
return false;
}
Intent a2 = a();
Bundle a3 = giVar.a();
if (a3 == null) {
return false;
}
b.c("SEND:" + giVar.m9396a());
a2.setAction(bh.h);
a2.putExtra(bh.E, f7464a);
a2.putExtra("ext_packet", a3);
return startServiceSafely(a2);
}
public void setMessenger(Messenger messenger) {
this.f7466a = messenger;
}
public boolean startServiceSafely(Intent intent) {
try {
if (l.m9608a() || Build.VERSION.SDK_INT < 26) {
this.f7465a.startService(intent);
return true;
}
m9620a(intent);
return true;
} catch (Exception e) {
b.a(e);
return false;
}
}
public void updateChannelInfo(String str, List<NameValuePair> list, List<NameValuePair> list2) {
updateChannelInfo(str, a(list), a(list2));
}
public void updateChannelInfo(String str, Map<String, String> map, Map<String, String> map2) {
Intent a2 = a();
a2.setAction(bh.l);
if (map != null) {
String a3 = a(map);
if (!TextUtils.isEmpty(a3)) {
a2.putExtra(bh.y, a3);
}
}
if (map2 != null) {
String a4 = a(map2);
if (!TextUtils.isEmpty(a4)) {
a2.putExtra(bh.z, a4);
}
}
a2.putExtra(bh.s, str);
startServiceSafely(a2);
}
}