package com.xiaomi.push;
import android.text.TextUtils;
import com.huawei.hms.push.constant.RemoteMessageConst;
import com.huawei.hms.support.api.entity.common.CommonConstant;
import com.tencent.matrix.iocanary.config.SharePluginInfo;
import com.xiaomi.channel.commonutils.logger.b;
import com.xiaomi.push.gj;
import com.xiaomi.push.gn;
import com.xiaomi.push.gp;
import com.xiaomi.push.service.am;
import com.xiaomi.push.service.av;
import com.xiaomi.push.service.e;
import com.xingin.android.mixim.msg.MsgType;
import com.xingin.xhs.v2.album.entities.AlbumBean;
import java.io.ByteArrayInputStream;
import java.io.InputStreamReader;
import java.io.PrintStream;
import java.util.ArrayList;
import java.util.HashMap;
import org.xmlpull.v1.XmlPullParser;
import org.xmlpull.v1.XmlPullParserException;
import org.xmlpull.v1.XmlPullParserFactory;
public class gt {
/* renamed from: a reason: collision with root package name */
private static XmlPullParser f36724a;
public static gi a(String str, String str2, XmlPullParser xmlPullParser) {
Object a14 = gs.a().m470a("all", "xm:chat");
if (a14 == null || !(a14 instanceof e)) {
return null;
}
return ((e) a14).b(xmlPullParser);
}
public static gj a(XmlPullParser xmlPullParser, fu fuVar) {
String attributeValue = xmlPullParser.getAttributeValue("", "id");
String attributeValue2 = xmlPullParser.getAttributeValue("", RemoteMessageConst.TO);
String attributeValue3 = xmlPullParser.getAttributeValue("", "from");
String attributeValue4 = xmlPullParser.getAttributeValue("", "chid");
gj.a a14 = gj.a.a(xmlPullParser.getAttributeValue("", "type"));
HashMap hashMap = new HashMap();
boolean z14 = false;
for (int i10 = 0; i10 < xmlPullParser.getAttributeCount(); i10++) {
String attributeName = xmlPullParser.getAttributeName(i10);
hashMap.put(attributeName, xmlPullParser.getAttributeValue("", attributeName));
}
gj gjVar = null;
gp gpVar = null;
while (!z14) {
int next = xmlPullParser.next();
if (next == 2) {
String name = xmlPullParser.getName();
String namespace = xmlPullParser.getNamespace();
if (name.equals("error")) {
gpVar = m474a(xmlPullParser);
} else {
gjVar = new gj();
gjVar.a(a(name, namespace, xmlPullParser));
}
} else if (next == 3 && xmlPullParser.getName().equals("iq")) {
z14 = true;
}
}
if (gjVar == null) {
if (gj.a.f36652a == a14 || gj.a.f36653b == a14) {
gu guVar = new gu();
guVar.k(attributeValue);
guVar.m(attributeValue3);
guVar.n(attributeValue2);
guVar.a(gj.a.f36655d);
guVar.l(attributeValue4);
guVar.a(new gp(gp.a.f36702e));
fuVar.a(guVar);
b.d("iq usage error. send packet in packet parser.");
return null;
}
gjVar = new gv();
}
gjVar.k(attributeValue);
gjVar.m(attributeValue2);
gjVar.l(attributeValue4);
gjVar.n(attributeValue3);
gjVar.a(a14);
gjVar.a(gpVar);
gjVar.a(hashMap);
return gjVar;
}
public static gl a(XmlPullParser xmlPullParser) {
String str;
boolean z14 = false;
String str2 = null;
if ("1".equals(xmlPullParser.getAttributeValue("", "s"))) {
String attributeValue = xmlPullParser.getAttributeValue("", "chid");
String attributeValue2 = xmlPullParser.getAttributeValue("", "id");
String attributeValue3 = xmlPullParser.getAttributeValue("", "from");
String attributeValue4 = xmlPullParser.getAttributeValue("", RemoteMessageConst.TO);
String attributeValue5 = xmlPullParser.getAttributeValue("", "type");
am.b a14 = am.a().a(attributeValue, attributeValue4);
if (a14 == null) {
a14 = am.a().a(attributeValue, attributeValue3);
}
if (a14 != null) {
gl glVar = null;
while (!z14) {
int next = xmlPullParser.next();
if (next == 2) {
if (!"s".equals(xmlPullParser.getName())) {
throw new gf("error while receiving a encrypted message with wrong format");
} else if (xmlPullParser.next() == 4) {
String text = xmlPullParser.getText();
if ("5".equals(attributeValue) || "6".equals(attributeValue)) {
gk gkVar = new gk();
gkVar.l(attributeValue);
gkVar.b(true);
gkVar.n(attributeValue3);
gkVar.m(attributeValue4);
gkVar.k(attributeValue2);
gkVar.f(attributeValue5);
gi giVar = new gi("s", null, null, null);
giVar.m458a(text);
gkVar.a(giVar);
return gkVar;
}
a(av.a(av.a(a14.f37271h, attributeValue2), text));
f36724a.next();
glVar = a(f36724a);
} else {
throw new gf("error while receiving a encrypted message with wrong format");
}
} else if (next == 3 && xmlPullParser.getName().equals("message")) {
z14 = true;
}
}
if (glVar != null) {
return glVar;
}
throw new gf("error while receiving a encrypted message with wrong format");
}
throw new gf("the channel id is wrong while receiving a encrypted message");
}
gk gkVar2 = new gk();
String attributeValue6 = xmlPullParser.getAttributeValue("", "id");
if (attributeValue6 == null) {
attributeValue6 = "ID_NOT_AVAILABLE";
}
gkVar2.k(attributeValue6);
gkVar2.m(xmlPullParser.getAttributeValue("", RemoteMessageConst.TO));
gkVar2.n(xmlPullParser.getAttributeValue("", "from"));
gkVar2.l(xmlPullParser.getAttributeValue("", "chid"));
gkVar2.a(xmlPullParser.getAttributeValue("", "appid"));
try {
str = xmlPullParser.getAttributeValue("", "transient");
} catch (Exception unused) {
str = null;
}
try {
String attributeValue7 = xmlPullParser.getAttributeValue("", "seq");
if (!TextUtils.isEmpty(attributeValue7)) {
gkVar2.b(attributeValue7);
}
} catch (Exception unused2) {
}
try {
String attributeValue8 = xmlPullParser.getAttributeValue("", "mseq");
if (!TextUtils.isEmpty(attributeValue8)) {
gkVar2.c(attributeValue8);
}
} catch (Exception unused3) {
}
try {
String attributeValue9 = xmlPullParser.getAttributeValue("", "fseq");
if (!TextUtils.isEmpty(attributeValue9)) {
gkVar2.d(attributeValue9);
}
} catch (Exception unused4) {
}
try {
String attributeValue10 = xmlPullParser.getAttributeValue("", "status");
if (!TextUtils.isEmpty(attributeValue10)) {
gkVar2.e(attributeValue10);
}
} catch (Exception unused5) {
}
gkVar2.a(!TextUtils.isEmpty(str) && str.equalsIgnoreCase("true"));
gkVar2.f(xmlPullParser.getAttributeValue("", "type"));
String b14 = b(xmlPullParser);
if (b14 == null || "".equals(b14.trim())) {
gl.q();
} else {
gkVar2.j(b14);
}
while (!z14) {
int next2 = xmlPullParser.next();
if (next2 == 2) {
String name = xmlPullParser.getName();
String namespace = xmlPullParser.getNamespace();
if (TextUtils.isEmpty(namespace)) {
namespace = "xm";
}
if (name.equals("subject")) {
b(xmlPullParser);
gkVar2.g(m475a(xmlPullParser));
} else if (name.equals("body")) {
String attributeValue11 = xmlPullParser.getAttributeValue("", "encode");
String a15 = m475a(xmlPullParser);
if (!TextUtils.isEmpty(attributeValue11)) {
gkVar2.a(a15, attributeValue11);
} else {
gkVar2.h(a15);
}
} else if (name.equals(SharePluginInfo.ISSUE_FILE_THREAD)) {
if (str2 == null) {
str2 = xmlPullParser.nextText();
}
} else if (name.equals("error")) {
gkVar2.a(m474a(xmlPullParser));
} else {
gkVar2.a(a(name, namespace, xmlPullParser));
}
} else if (next2 == 3 && xmlPullParser.getName().equals("message")) {
z14 = true;
}
}
gkVar2.i(str2);
return gkVar2;
}
/* renamed from: a reason: collision with other method in class */
public static gn m472a(XmlPullParser xmlPullParser) {
gn.b bVar = gn.b.f36685a;
String attributeValue = xmlPullParser.getAttributeValue("", "type");
if (attributeValue != null && !attributeValue.equals("")) {
try {
bVar = gn.b.valueOf(attributeValue);
} catch (IllegalArgumentException unused) {
PrintStream printStream = System.err;
printStream.println("Found invalid presence type " + attributeValue);
}
}
gn gnVar = new gn(bVar);
gnVar.m(xmlPullParser.getAttributeValue("", RemoteMessageConst.TO));
gnVar.n(xmlPullParser.getAttributeValue("", "from"));
gnVar.l(xmlPullParser.getAttributeValue("", "chid"));
String attributeValue2 = xmlPullParser.getAttributeValue("", "id");
if (attributeValue2 == null) {
attributeValue2 = "ID_NOT_AVAILABLE";
}
gnVar.k(attributeValue2);
boolean z14 = false;
while (!z14) {
int next = xmlPullParser.next();
if (next == 2) {
String name = xmlPullParser.getName();
String namespace = xmlPullParser.getNamespace();
if (name.equals("status")) {
gnVar.a(xmlPullParser.nextText());
} else if (name.equals(RemoteMessageConst.Notification.PRIORITY)) {
try {
gnVar.a(Integer.parseInt(xmlPullParser.nextText()));
} catch (NumberFormatException unused2) {
} catch (IllegalArgumentException unused3) {
gnVar.a(0);
}
} else if (name.equals("show")) {
String nextText = xmlPullParser.nextText();
try {
gnVar.a(gn.a.valueOf(nextText));
} catch (IllegalArgumentException unused4) {
PrintStream printStream2 = System.err;
printStream2.println("Found invalid presence mode " + nextText);
}
} else if (name.equals("error")) {
gnVar.a(m474a(xmlPullParser));
} else {
gnVar.a(a(name, namespace, xmlPullParser));
}
} else if (next == 3 && xmlPullParser.getName().equals("presence")) {
z14 = true;
}
}
return gnVar;
}
/* renamed from: a reason: collision with other method in class */
public static go m473a(XmlPullParser xmlPullParser) {
go goVar = null;
boolean z14 = false;
while (!z14) {
int next = xmlPullParser.next();
if (next == 2) {
goVar = new go(xmlPullParser.getName());
} else if (next == 3 && xmlPullParser.getName().equals("error")) {
z14 = true;
}
}
return goVar;
}
/* renamed from: a reason: collision with other method in class */
public static gp m474a(XmlPullParser xmlPullParser) {
ArrayList arrayList = new ArrayList();
boolean z14 = false;
String str = AlbumBean.ID_ALBUM_ALL;
String str2 = null;
String str3 = null;
for (int i10 = 0; i10 < xmlPullParser.getAttributeCount(); i10++) {
if (xmlPullParser.getAttributeName(i10).equals("code")) {
str = xmlPullParser.getAttributeValue("", "code");
}
if (xmlPullParser.getAttributeName(i10).equals("type")) {
str3 = xmlPullParser.getAttributeValue("", "type");
}
if (xmlPullParser.getAttributeName(i10).equals("reason")) {
str2 = xmlPullParser.getAttributeValue("", "reason");
}
}
String str4 = null;
String str5 = null;
while (!z14) {
int next = xmlPullParser.next();
if (next == 2) {
if (xmlPullParser.getName().equals(MsgType.TYPE_TEXT)) {
str5 = xmlPullParser.nextText();
} else {
String name = xmlPullParser.getName();
String namespace = xmlPullParser.getNamespace();
if ("urn:ietf:params:xml:ns:xmpp-stanzas".equals(namespace)) {
str4 = name;
} else {
arrayList.add(a(name, namespace, xmlPullParser));
}
}
} else if (next == 3) {
if (xmlPullParser.getName().equals("error")) {
z14 = true;
}
} else if (next == 4) {
str5 = xmlPullParser.getText();
}
}
return new gp(Integer.parseInt(str), str3 == null ? "cancel" : str3, str2, str4, str5, arrayList);
}
/* renamed from: a reason: collision with other method in class */
private static String m475a(XmlPullParser xmlPullParser) {
int depth = xmlPullParser.getDepth();
String str = "";
while (true) {
if (xmlPullParser.next() == 3 && xmlPullParser.getDepth() == depth) {
return str;
}
str = str + xmlPullParser.getText();
}
}
private static void a(byte[] bArr) {
if (f36724a == null) {
try {
XmlPullParser newPullParser = XmlPullParserFactory.newInstance().newPullParser();
f36724a = newPullParser;
newPullParser.setFeature("http://xmlpull.org/v1/doc/features.html#process-namespaces", true);
} catch (XmlPullParserException e14) {
e14.printStackTrace();
}
}
f36724a.setInput(new InputStreamReader(new ByteArrayInputStream(bArr)));
}
private static String b(XmlPullParser xmlPullParser) {
for (int i10 = 0; i10 < xmlPullParser.getAttributeCount(); i10++) {
String attributeName = xmlPullParser.getAttributeName(i10);
if ("xml:lang".equals(attributeName) || (CommonConstant.ReqAccessTokenParam.LANGUAGE_LABEL.equals(attributeName) && "xml".equals(xmlPullParser.getAttributePrefix(i10)))) {
return xmlPullParser.getAttributeValue(i10);
}
}
return null;
}
}