正在查看： 050 IP Phone v2.3.0 应用的 c.java JAVA 源代码文件
本页面展示 JAVA 反编译生成的源代码文件，支持语法高亮显示。 仅供安全研究与技术分析使用，严禁用于任何非法用途。请遵守相关法律法规。
页面标题
页面副标题
050 IP Phone v2.3.0 - c.java 源代码
package a2;
import a2.d;
import a2.f;
import android.content.Context;
import android.content.pm.PackageManager;
import android.net.TrafficStats;
import android.text.TextUtils;
import android.util.JsonReader;
import android.util.Log;
import androidx.annotation.NonNull;
import androidx.annotation.Nullable;
import androidx.annotation.VisibleForTesting;
import com.google.android.gms.common.internal.Preconditions;
import com.google.android.gms.common.util.AndroidUtilsLight;
import com.google.android.gms.common.util.Hex;
import com.google.android.gms.tasks.Tasks;
import com.google.firebase.installations.d;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.HttpURLConnection;
import java.net.MalformedURLException;
import java.net.URL;
import java.net.URLConnection;
import java.nio.charset.Charset;
import java.util.concurrent.ExecutionException;
import java.util.regex.Pattern;
import java.util.zip.GZIPOutputStream;
import org.json.JSONException;
import org.json.JSONObject;
import u1.i;
public class c {
private static final Pattern d = Pattern.compile("[0-9]+s");
private static final Charset e = Charset.forName("UTF-8");
private final Context a;
private final w1.b<i> b;
private final e c = new e();
public c(@NonNull Context context, @NonNull w1.b<i> bVar) {
this.a = context;
this.b = bVar;
}
private static String a(@Nullable String str, @NonNull String str2, @NonNull String str3) {
String str4;
if (TextUtils.isEmpty(str)) {
str4 = "";
} else {
str4 = ", " + str;
}
return String.format("Firebase options used while communicating with Firebase server APIs: %s, %s%s", str2, str3, str4);
}
private static JSONObject b(@Nullable String str, @NonNull String str2) {
try {
JSONObject jSONObject = new JSONObject();
jSONObject.put("fid", str);
jSONObject.put("appId", str2);
jSONObject.put("authVersion", "FIS_v2");
jSONObject.put("sdkVersion", "a:18.0.0");
return jSONObject;
} catch (JSONException e8) {
throw new IllegalStateException(e8);
}
}
private static JSONObject c() {
try {
JSONObject jSONObject = new JSONObject();
jSONObject.put("sdkVersion", "a:18.0.0");
JSONObject jSONObject2 = new JSONObject();
jSONObject2.put("installation", jSONObject);
return jSONObject2;
} catch (JSONException e8) {
throw new IllegalStateException(e8);
}
}
private String f() {
try {
Context context = this.a;
byte[] packageCertificateHashBytes = AndroidUtilsLight.getPackageCertificateHashBytes(context, context.getPackageName());
if (packageCertificateHashBytes != null) {
return Hex.bytesToStringUppercase(packageCertificateHashBytes, false);
}
Log.e("ContentValues", "Could not get fingerprint hash for package: " + this.a.getPackageName());
return null;
} catch (PackageManager.NameNotFoundException e8) {
Log.e("ContentValues", "No such package: " + this.a.getPackageName(), e8);
return null;
}
}
private URL g(String str) {
try {
return new URL(String.format("https://%s/%s/%s", "firebaseinstallations.googleapis.com", "v1", str));
} catch (MalformedURLException e8) {
throw new com.google.firebase.installations.d(e8.getMessage(), d.a.UNAVAILABLE);
}
}
private static byte[] h(JSONObject jSONObject) {
return jSONObject.toString().getBytes("UTF-8");
}
private static boolean i(int i) {
return i >= 200 && i < 300;
}
private static void j() {
Log.e("Firebase-Installations", "Firebase Installations can not communicate with Firebase server APIs due to invalid configuration. Please update your Firebase initialization process and set valid Firebase options (API key, Project ID, Application ID) when initializing Firebase.");
}
private static void k(HttpURLConnection httpURLConnection, @Nullable String str, @NonNull String str2, @NonNull String str3) {
String o = o(httpURLConnection);
if (TextUtils.isEmpty(o)) {
return;
}
Log.w("Firebase-Installations", o);
Log.w("Firebase-Installations", a(str, str2, str3));
}
private HttpURLConnection l(URL url, String str) {
try {
HttpURLConnection httpURLConnection = (HttpURLConnection) url.openConnection();
httpURLConnection.setConnectTimeout(10000);
httpURLConnection.setUseCaches(false);
httpURLConnection.setReadTimeout(10000);
httpURLConnection.addRequestProperty("Content-Type", "application/json");
httpURLConnection.addRequestProperty("Accept", "application/json");
httpURLConnection.addRequestProperty("Content-Encoding", "gzip");
httpURLConnection.addRequestProperty("Cache-Control", "no-cache");
httpURLConnection.addRequestProperty("X-Android-Package", this.a.getPackageName());
i iVar = this.b.get();
if (iVar != null) {
try {
httpURLConnection.addRequestProperty("x-firebase-client", (String) Tasks.await(iVar.a()));
} catch (InterruptedException e8) {
Thread.currentThread().interrupt();
Log.w("ContentValues", "Failed to get heartbeats header", e8);
} catch (ExecutionException e9) {
Log.w("ContentValues", "Failed to get heartbeats header", e9);
}
}
httpURLConnection.addRequestProperty("X-Android-Cert", f());
httpURLConnection.addRequestProperty("x-goog-api-key", str);
return httpURLConnection;
} catch (IOException unused) {
throw new com.google.firebase.installations.d("Firebase Installations Service is unavailable. Please try again later.", d.a.UNAVAILABLE);
}
}
@VisibleForTesting
static long m(String str) {
Preconditions.checkArgument(d.matcher(str).matches(), "Invalid Expiration Timestamp.");
if (str == null || str.length() == 0) {
return 0L;
}
return Long.parseLong(str.substring(0, str.length() - 1));
}
private d n(HttpURLConnection httpURLConnection) {
InputStream inputStream = httpURLConnection.getInputStream();
JsonReader jsonReader = new JsonReader(new InputStreamReader(inputStream, e));
f.a a = f.a();
d.a a8 = d.a();
jsonReader.beginObject();
while (jsonReader.hasNext()) {
String nextName = jsonReader.nextName();
if (nextName.equals("name")) {
a8.f(jsonReader.nextString());
} else if (nextName.equals("fid")) {
a8.c(jsonReader.nextString());
} else if (nextName.equals("refreshToken")) {
a8.d(jsonReader.nextString());
} else if (nextName.equals("authToken")) {
jsonReader.beginObject();
while (jsonReader.hasNext()) {
String nextName2 = jsonReader.nextName();
if (nextName2.equals("token")) {
a.c(jsonReader.nextString());
} else if (nextName2.equals("expiresIn")) {
a.d(m(jsonReader.nextString()));
} else {
jsonReader.skipValue();
}
}
a8.b(a.a());
jsonReader.endObject();
} else {
jsonReader.skipValue();
}
}
jsonReader.endObject();
jsonReader.close();
inputStream.close();
return a8.e(d.b.OK).a();
}
@Nullable
private static String o(HttpURLConnection httpURLConnection) {
InputStream errorStream = httpURLConnection.getErrorStream();
if (errorStream == null) {
return null;
}
BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(errorStream, e));
try {
try {
StringBuilder sb = new StringBuilder();
while (true) {
String readLine = bufferedReader.readLine();
if (readLine == null) {
break;
}
sb.append(readLine);
sb.append('\n');
}
String format = String.format("Error when communicating with the Firebase Installations server API. HTTP response: [%d %s: %s]", Integer.valueOf(httpURLConnection.getResponseCode()), httpURLConnection.getResponseMessage(), sb);
try {
bufferedReader.close();
} catch (IOException unused) {
}
return format;
} catch (IOException unused2) {
return null;
}
} catch (IOException unused3) {
bufferedReader.close();
return null;
} catch (Throwable th) {
try {
bufferedReader.close();
} catch (IOException unused4) {
}
throw th;
}
}
private f p(HttpURLConnection httpURLConnection) {
InputStream inputStream = httpURLConnection.getInputStream();
JsonReader jsonReader = new JsonReader(new InputStreamReader(inputStream, e));
f.a a = f.a();
jsonReader.beginObject();
while (jsonReader.hasNext()) {
String nextName = jsonReader.nextName();
if (nextName.equals("token")) {
a.c(jsonReader.nextString());
} else if (nextName.equals("expiresIn")) {
a.d(m(jsonReader.nextString()));
} else {
jsonReader.skipValue();
}
}
jsonReader.endObject();
jsonReader.close();
inputStream.close();
return a.b(f.b.OK).a();
}
private void q(HttpURLConnection httpURLConnection, @Nullable String str, @NonNull String str2) {
s(httpURLConnection, h(b(str, str2)));
}
private void r(HttpURLConnection httpURLConnection) {
s(httpURLConnection, h(c()));
}
private static void s(URLConnection uRLConnection, byte[] bArr) {
OutputStream outputStream = uRLConnection.getOutputStream();
if (outputStream == null) {
throw new IOException("Cannot send request to FIS servers. No OutputStream available.");
}
GZIPOutputStream gZIPOutputStream = new GZIPOutputStream(outputStream);
try {
gZIPOutputStream.write(bArr);
} finally {
try {
gZIPOutputStream.close();
outputStream.close();
} catch (IOException unused) {
}
}
}
@NonNull
public d d(@NonNull String str, @Nullable String str2, @NonNull String str3, @NonNull String str4, @Nullable String str5) {
int responseCode;
d n;
if (!this.c.b()) {
throw new com.google.firebase.installations.d("Firebase Installations Service is unavailable. Please try again later.", d.a.UNAVAILABLE);
}
URL g = g(String.format("projects/%s/installations", str3));
for (int i = 0; i <= 1; i++) {
TrafficStats.setThreadStatsTag(32769);
HttpURLConnection l = l(g, str);
try {
try {
l.setRequestMethod("POST");
l.setDoOutput(true);
if (str5 != null) {
l.addRequestProperty("x-goog-fis-android-iid-migration-auth", str5);
}
q(l, str2, str4);
responseCode = l.getResponseCode();
this.c.f(responseCode);
} catch (IOException | AssertionError unused) {
}
if (i(responseCode)) {
n = n(l);
} else {
k(l, str4, str, str3);
if (responseCode == 429) {
throw new com.google.firebase.installations.d("Firebase servers have received too many requests from this client in a short period of time. Please try again later.", d.a.TOO_MANY_REQUESTS);
}
if (responseCode < 500 || responseCode >= 600) {
j();
n = d.a().e(d.b.BAD_CONFIG).a();
}
l.disconnect();
TrafficStats.clearThreadStatsTag();
}
l.disconnect();
TrafficStats.clearThreadStatsTag();
return n;
} catch (Throwable th) {
l.disconnect();
TrafficStats.clearThreadStatsTag();
throw th;
}
}
throw new com.google.firebase.installations.d("Firebase Installations Service is unavailable. Please try again later.", d.a.UNAVAILABLE);
}
@NonNull
public f e(@NonNull String str, @NonNull String str2, @NonNull String str3, @NonNull String str4) {
int responseCode;
f p;
if (!this.c.b()) {
throw new com.google.firebase.installations.d("Firebase Installations Service is unavailable. Please try again later.", d.a.UNAVAILABLE);
}
URL g = g(String.format("projects/%s/installations/%s/authTokens:generate", str3, str2));
for (int i = 0; i <= 1; i++) {
TrafficStats.setThreadStatsTag(32771);
HttpURLConnection l = l(g, str);
try {
try {
l.setRequestMethod("POST");
l.addRequestProperty("Authorization", "FIS_v2 " + str4);
l.setDoOutput(true);
r(l);
responseCode = l.getResponseCode();
this.c.f(responseCode);
} finally {
l.disconnect();
TrafficStats.clearThreadStatsTag();
}
} catch (IOException | AssertionError unused) {
}
if (i(responseCode)) {
p = p(l);
} else {
k(l, null, str, str3);
if (responseCode == 401 || responseCode == 404) {
p = f.a().b(f.b.AUTH_ERROR).a();
} else {
if (responseCode == 429) {
throw new com.google.firebase.installations.d("Firebase servers have received too many requests from this client in a short period of time. Please try again later.", d.a.TOO_MANY_REQUESTS);
}
if (responseCode < 500 || responseCode >= 600) {
j();
p = f.a().b(f.b.BAD_CONFIG).a();
}
}
}
return p;
}
throw new com.google.firebase.installations.d("Firebase Installations Service is unavailable. Please try again later.", d.a.UNAVAILABLE);
}
}