package d8; import android.app.PendingIntent; import android.content.Context; import android.content.Intent; import android.os.Bundle; import android.os.Looper; import android.os.Message; import android.os.Messenger; import android.os.Parcelable; import android.os.RemoteException; import android.util.Log; import androidx.annotation.Nullable; import androidx.collection.s; import e.s0; import java.util.Objects; import java.util.concurrent.ScheduledThreadPoolExecutor; import java.util.concurrent.TimeUnit; import java.util.regex.Matcher; import java.util.regex.Pattern; import tv.danmaku.ijk.media.player.IjkMediaPlayer; import w8.t; /* JADX INFO: loaded from: classes2.dex */ public final class b { /* JADX INFO: renamed from: h, reason: collision with root package name */ public static int f25006h; /* JADX INFO: renamed from: i, reason: collision with root package name */ public static PendingIntent f25007i; /* JADX INFO: renamed from: j, reason: collision with root package name */ public static final Pattern f25008j = Pattern.compile("\\|ID\\|([^|]+)\\|:?+(.*)"); /* JADX INFO: renamed from: b, reason: collision with root package name */ public final Context f25010b; /* JADX INFO: renamed from: c, reason: collision with root package name */ public final l2.h f25011c; /* JADX INFO: renamed from: d, reason: collision with root package name */ public final ScheduledThreadPoolExecutor f25012d; /* JADX INFO: renamed from: f, reason: collision with root package name */ public Messenger f25014f; /* JADX INFO: renamed from: g, reason: collision with root package name */ public g f25015g; /* JADX INFO: renamed from: a, reason: collision with root package name */ public final s f25009a = new s(0); /* JADX INFO: renamed from: e, reason: collision with root package name */ public final Messenger f25013e = new Messenger(new e(this, Looper.getMainLooper())); public b(Context context) { this.f25010b = context; this.f25011c = new l2.h(context); ScheduledThreadPoolExecutor scheduledThreadPoolExecutor = new ScheduledThreadPoolExecutor(1); scheduledThreadPoolExecutor.setKeepAliveTime(60L, TimeUnit.SECONDS); scheduledThreadPoolExecutor.allowCoreThreadTimeOut(true); this.f25012d = scheduledThreadPoolExecutor; } public static void a(b bVar, Message message) { if (message != null) { Object obj = message.obj; if (obj instanceof Intent) { Intent intent = (Intent) obj; intent.setExtrasClassLoader(new f()); if (intent.hasExtra("google.messenger")) { Parcelable parcelableExtra = intent.getParcelableExtra("google.messenger"); if (parcelableExtra instanceof g) { bVar.f25015g = (g) parcelableExtra; } if (parcelableExtra instanceof Messenger) { bVar.f25014f = (Messenger) parcelableExtra; } } Intent intent2 = (Intent) message.obj; String action = intent2.getAction(); if (!Objects.equals(action, "com.google.android.c2dm.intent.REGISTRATION")) { if (Log.isLoggable("Rpc", 3)) { "Unexpected response action: ".concat(String.valueOf(action)); return; } return; } String stringExtra = intent2.getStringExtra("registration_id"); if (stringExtra == null) { stringExtra = intent2.getStringExtra("unregistered"); } if (stringExtra != null) { Matcher matcher = f25008j.matcher(stringExtra); if (!matcher.matches()) { if (Log.isLoggable("Rpc", 3)) { "Unexpected response string: ".concat(stringExtra); return; } return; } String strGroup = matcher.group(1); String strGroup2 = matcher.group(2); if (strGroup != null) { Bundle extras = intent2.getExtras(); extras.putString("registration_id", strGroup2); bVar.zzh(strGroup, extras); return; } return; } String stringExtra2 = intent2.getStringExtra(IjkMediaPlayer.OnNativeInvokeListener.ARG_ERROR); if (stringExtra2 == null) { "Unexpected response, no error or registration id ".concat(String.valueOf(intent2.getExtras())); return; } if (Log.isLoggable("Rpc", 3)) { "Received InstanceID error ".concat(stringExtra2); } if (!stringExtra2.startsWith("|")) { synchronized (bVar.f25009a) { int i10 = 0; while (true) { try { s sVar = bVar.f25009a; if (i10 < sVar.f968c) { bVar.zzh((String) sVar.i(i10), intent2.getExtras()); i10++; } } catch (Throwable th) { throw th; } } } return; } String[] strArrSplit = stringExtra2.split("\\|"); if (strArrSplit.length <= 2 || !Objects.equals(strArrSplit[1], "ID")) { "Unexpected structured response ".concat(stringExtra2); return; } String str = strArrSplit[2]; String strSubstring = strArrSplit[3]; if (strSubstring.startsWith(":")) { strSubstring = strSubstring.substring(1); } bVar.zzh(str, intent2.putExtra(IjkMediaPlayer.OnNativeInvokeListener.ARG_ERROR, strSubstring).getExtras()); } } } private final void zzh(String str, @Nullable Bundle bundle) { synchronized (this.f25009a) { try { w8.i iVar = (w8.i) this.f25009a.remove(str); if (iVar == null) { return; } iVar.setResult(bundle); } catch (Throwable th) { throw th; } } } /* JADX WARN: Removed duplicated region for block: B:38:0x00c3 */ /* JADX WARN: Removed duplicated region for block: B:39:0x00c9 */ /* Code decompiled incorrectly, please refer to instructions dump. */ public final t b(Bundle bundle) { String string; synchronized (b.class) { int i10 = f25006h; f25006h = i10 + 1; string = Integer.toString(i10); } w8.i iVar = new w8.i(); synchronized (this.f25009a) { this.f25009a.put(string, iVar); } Intent intent = new Intent(); intent.setPackage("com.google.android.gms"); if (this.f25011c.h() == 2) { intent.setAction("com.google.iid.TOKEN_REQUEST"); } else { intent.setAction("com.google.android.c2dm.intent.REGISTER"); } intent.putExtras(bundle); Context context = this.f25010b; synchronized (b.class) { try { if (f25007i == null) { Intent intent2 = new Intent(); intent2.setPackage("com.google.example.invalidpackage"); f25007i = PendingIntent.getBroadcast(context, 0, intent2, p8.a.f31781a); } intent.putExtra("app", f25007i); } catch (Throwable th) { throw th; } } intent.putExtra("kid", "|ID|" + string + "|"); if (Log.isLoggable("Rpc", 3)) { "Sending ".concat(String.valueOf(intent.getExtras())); } intent.putExtra("google.messenger", this.f25013e); if (this.f25014f != null || this.f25015g != null) { Message messageObtain = Message.obtain(); messageObtain.obj = intent; try { Messenger messenger = this.f25014f; if (messenger != null) { messenger.send(messageObtain); } else { Messenger messenger2 = this.f25015g.f25020a; messenger2.getClass(); messenger2.send(messageObtain); } } catch (RemoteException unused) { if (this.f25011c.h() != 2) { } } } else if (this.f25011c.h() != 2) { this.f25010b.sendBroadcast(intent); } else { this.f25010b.startService(intent); } iVar.f34224a.a(p.f25045a, new xyz.stream.utils.t(this, string, this.f25012d.schedule(new s0(iVar, 27), 30L, TimeUnit.SECONDS), 13)); return iVar.f34224a; } }