package com.xiaomi.push; import io.dcloud.common.DHInterface.IApp; import java.io.ByteArrayInputStream; import java.io.InputStreamReader; import org.xmlpull.v1.XmlPullParser; import org.xmlpull.v1.XmlPullParserException; import org.xmlpull.v1.XmlPullParserFactory; public class fp { /* renamed from: a reason: collision with root package name */ private XmlPullParser f8142a; fp() { try { XmlPullParser newPullParser = XmlPullParserFactory.newInstance().newPullParser(); this.f8142a = newPullParser; newPullParser.setFeature("http://xmlpull.org/v1/doc/features.html#process-namespaces", true); } catch (XmlPullParserException unused) { } } /* access modifiers changed from: package-private */ public gm a(byte[] bArr, fv fvVar) { this.f8142a.setInput(new InputStreamReader(new ByteArrayInputStream(bArr))); this.f8142a.next(); int eventType = this.f8142a.getEventType(); String name = this.f8142a.getName(); if (eventType != 2) { return null; } if (name.equals("message")) { return gu.a(this.f8142a); } if (name.equals("iq")) { return gu.a(this.f8142a, fvVar); } if (name.equals("presence")) { return gu.m372a(this.f8142a); } if (this.f8142a.getName().equals(IApp.ConfigProperty.CONFIG_STREAM)) { return null; } if (this.f8142a.getName().equals("error")) { throw new gg(gu.m373a(this.f8142a)); } else if (this.f8142a.getName().equals("warning")) { this.f8142a.next(); this.f8142a.getName().equals("multi-login"); return null; } else { this.f8142a.getName().equals("bind"); return null; } } }