package z02;
import android.app.Application;
import android.content.ComponentName;
import android.content.Intent;
import android.content.ServiceConnection;
import android.os.Bundle;
import android.os.Handler;
import android.os.IBinder;
import android.os.Looper;
import android.os.Message;
import android.os.Messenger;
import android.util.Log;
import com.google.android.gms.common.GoogleApiAvailabilityLight;
import com.xingin.entities.HashTagListBean;
import com.xingin.process.messaging.service.AppMessengerService;
import com.xingin.utils.XYUtilsCenter;
import java.text.SimpleDateFormat;
import java.util.ArrayDeque;
import java.util.Date;
import java.util.Iterator;
import java.util.List;
import java.util.Locale;
import java.util.concurrent.TimeUnit;
import ko2.e;
import kotlin.Metadata;
import kotlin.Unit;
import kotlin.jvm.internal.Intrinsics;
import y7.f;
import z60.h;
@Metadata(bv = {}, d1 = {"\u0000R\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u000b\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0010\b\n\u0002\b\u0003\n\u0002\u0010\u000e\n\u0002\b\u0004\n\u0002\u0018\u0002\n\u0002\b\b\bÆ\u0002\u0018\u00002\u00020\u0001:\u0003!\"#B\t\b\u0002¢\u0006\u0004\b\u001f\u0010 J\b\u0010\u0003\u001a\u0004\u0018\u00010\u0002J\u0006\u0010\u0005\u001a\u00020\u0004J\u0006\u0010\u0007\u001a\u00020\u0006J\u0006\u0010\t\u001a\u00020\bJ\u0006\u0010\n\u001a\u00020\u0004J,\u0010\u0012\u001a\u00020\u00042\b\u0010\f\u001a\u0004\u0018\u00010\u000b2\u000e\u0010\u000f\u001a\n\u0012\u0006\b\u0001\u0012\u00020\u000e0\r2\n\b\u0002\u0010\u0011\u001a\u0004\u0018\u00010\u0010J\u0018\u0010\u0016\u001a\u00020\u00042\u0006\u0010\u0014\u001a\u00020\u00132\b\u0010\u0015\u001a\u0004\u0018\u00010\u000bJ\u0010\u0010\u0019\u001a\u00020\u00042\u0006\u0010\u0018\u001a\u00020\u0017H\u0002J\b\u0010\u001a\u001a\u00020\bH\u0002J\b\u0010\u001b\u001a\u00020\u0004H\u0002J\u0010\u0010\u001d\u001a\u00020\u00042\u0006\u0010\u0018\u001a\u00020\u001cH\u0002J\b\u0010\u001e\u001a\u00020\u000bH\u0002¨\u0006$"}, d2 = {"Lz02/a;", "", "Landroid/os/Messenger;", "i", "", "o", "Lz02/a$a;", h.f160753a, "", f.f156778k, "l", "Landroid/os/Bundle;", "params", "Ljava/lang/Class;", "Lp02/a;", "delegation", "Ls02/b;", "observer", "m", "", "msgType", "result", GoogleApiAvailabilityLight.TRACKING_SOURCE_NOTIFICATION, "", "msg", "k", "e", com.igexin.push.core.d.c.f25536c, "Landroid/os/Message;", "j", "g", "<init>", "()V", "a", "b", "c", "xyprocess_library_release"}, k = 1, mv = {1, 4, 0})
/* compiled from: AppMessengerClient.kt */
public final class a {
/* renamed from: a reason: collision with root package name */
public static final long f160215a = TimeUnit.MINUTES.toMillis(5);
/* renamed from: b reason: collision with root package name */
public static final Object f160216b = new Object();
/* renamed from: c reason: collision with root package name */
public static HandlerC2597a f160217c = new HandlerC2597a();
/* renamed from: d reason: collision with root package name */
public static Messenger f160218d;
/* renamed from: e reason: collision with root package name */
public static c f160219e;
/* renamed from: f reason: collision with root package name */
public static ServiceConnection f160220f;
/* renamed from: g reason: collision with root package name */
public static ArrayDeque<Long> f160221g = new ArrayDeque<>();
/* renamed from: h reason: collision with root package name */
public static List<Runnable> f160222h;
/* renamed from: i reason: collision with root package name */
public static final a f160223i = new a();
@Metadata(bv = {}, d1 = {"\u0000\u0016\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u0002\n\u0002\b\u0004\u0018\u00002\u00020\u0001B\u0007¢\u0006\u0004\b\u0006\u0010\u0007J\u0010\u0010\u0005\u001a\u00020\u00042\u0006\u0010\u0003\u001a\u00020\u0002H\u0016¨\u0006\b"}, d2 = {"Lz02/a$a;", "Landroid/os/Handler;", "Landroid/os/Message;", "msg", "", "handleMessage", "<init>", "()V", "xyprocess_library_release"}, k = 1, mv = {1, 4, 0})
/* renamed from: z02.a$a reason: collision with other inner class name */
/* compiled from: AppMessengerClient.kt */
public static final class HandlerC2597a extends Handler {
public HandlerC2597a() {
super(Looper.getMainLooper());
}
public void handleMessage(Message message) {
Intrinsics.checkParameterIsNotNull(message, "msg");
super.handleMessage(message);
switch (message.what) {
case 102:
y02.a.f156427a.b(message);
return;
case 103:
y02.a.f156427a.d(message);
return;
case 104:
a.f160223i.j(message);
return;
case 105:
boolean z14 = message.obj instanceof Bundle;
return;
default:
return;
}
}
}
@Metadata(bv = {}, d1 = {"\u0000\u001c\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0005\u0018\u00002\u00020\u0001B\u0007¢\u0006\u0004\b\t\u0010\nJ\u0012\u0010\u0005\u001a\u00020\u00042\b\u0010\u0003\u001a\u0004\u0018\u00010\u0002H\u0016J\u001c\u0010\b\u001a\u00020\u00042\b\u0010\u0003\u001a\u0004\u0018\u00010\u00022\b\u0010\u0007\u001a\u0004\u0018\u00010\u0006H\u0016¨\u0006\u000b"}, d2 = {"Lz02/a$b;", "Landroid/content/ServiceConnection;", "Landroid/content/ComponentName;", "name", "", "onServiceDisconnected", "Landroid/os/IBinder;", "service", "onServiceConnected", "<init>", "()V", "xyprocess_library_release"}, k = 1, mv = {1, 4, 0})
/* compiled from: AppMessengerClient.kt */
public static final class b implements ServiceConnection {
public void onServiceConnected(ComponentName componentName, IBinder iBinder) {
e.l("AppMessengerClient", "onServiceConnected: name(" + componentName + "), service(" + iBinder + ')');
a aVar = a.f160223i;
if (!aVar.f()) {
a.f160218d = new Messenger(iBinder);
aVar.n(AppMessengerService.b.f61389b.a(), aVar.g());
c cVar = a.f160219e;
if (cVar != null) {
cVar.a();
}
x02.a.f152124b.b();
}
}
public void onServiceDisconnected(ComponentName componentName) {
e.l("AppMessengerClient", "onServiceDisconnected");
a.f160223i.l();
}
}
@Metadata(bv = {}, d1 = {"\u0000\u0010\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0002\u0010\u0002\n\u0002\b\u0003\bf\u0018\u00002\u00020\u0001J\b\u0010\u0003\u001a\u00020\u0002H&J\b\u0010\u0004\u001a\u00020\u0002H&¨\u0006\u0005"}, d2 = {"Lz02/a$c;", "", "", "a", "b", "xyprocess_library_release"}, k = 1, mv = {1, 4, 0})
/* compiled from: AppMessengerClient.kt */
public interface c {
void a();
void b();
}
public final boolean e() {
synchronized (f160221g) {
a aVar = f160223i;
aVar.k("checkRebindable ===>");
boolean z14 = true;
if (f160221g.size() < 3) {
aVar.k("allowRebind by size(" + f160221g.size() + ") < max(3)");
return true;
}
int size = f160221g.size() - 3;
aVar.k("after offer purgeCount=" + size);
if (size > 0) {
for (int i10 = 0; i10 < size; i10++) {
a aVar2 = f160223i;
aVar2.k("purge: " + f160221g.poll());
}
}
a aVar3 = f160223i;
aVar3.k("after purge");
Long peek = f160221g.peek();
if (peek == null) {
aVar3.k("allowRebind by null oldestRecord is should not happen");
return true;
}
long currentTimeMillis = System.currentTimeMillis() - peek.longValue();
if (currentTimeMillis <= f160215a) {
z14 = false;
}
aVar3.k("allowRebind: " + z14 + " oldestRecordDuration: " + currentTimeMillis);
return z14;
}
}
public final boolean f() {
return f160218d != null;
}
public final Bundle g() {
return new Bundle();
}
public final HandlerC2597a h() {
return f160217c;
}
public final Messenger i() {
return f160218d;
}
public final void j(Message message) {
}
public final void k(String str) {
e.l("AppMessengerClient", "Rebind:: status => " + str);
SimpleDateFormat simpleDateFormat = new SimpleDateFormat("HH:mm:ss.SSS", Locale.getDefault());
Iterator<Long> it3 = f160221g.iterator();
while (it3.hasNext()) {
Long next = it3.next();
StringBuilder sb3 = new StringBuilder();
sb3.append("SwanRebind:: >>> record @ ");
Intrinsics.checkExpressionValueIsNotNull(next, HashTagListBean.HashTag.TYPE_RECORD);
sb3.append(simpleDateFormat.format(new Date(next.longValue())));
Log.i("AppMessengerClient", sb3.toString());
}
}
public final synchronized void l() {
f160220f = null;
f160218d = null;
c cVar = f160219e;
if (cVar != null) {
cVar.b();
}
p();
if (f160222h != null) {
synchronized (f160216b) {
List<Runnable> list = f160222h;
if (list != null) {
Iterator<T> it3 = list.iterator();
while (it3.hasNext()) {
it3.next().run();
}
}
List<Runnable> list2 = f160222h;
if (list2 != null) {
list2.clear();
Unit unit = Unit.INSTANCE;
}
}
}
}
public final void m(Bundle bundle, Class<? extends p02.a> cls, s02.b bVar) {
Intrinsics.checkParameterIsNotNull(cls, "delegation");
Message obtain = Message.obtain((Handler) null, 6);
Bundle bundle2 = new Bundle();
bundle2.putString("key_delegation_name", cls.getName());
if (bVar != null) {
bundle2.putString("key_observer_id", bVar.a());
r02.a.f124339d.b(bVar);
}
if (bundle != null) {
bundle2.putBundle("key_data", bundle);
}
obtain.obj = bundle2;
x02.a aVar = x02.a.f152124b;
Intrinsics.checkExpressionValueIsNotNull(obtain, "msg");
aVar.d(new x02.b(obtain));
}
public final void n(int i10, Bundle bundle) {
x02.a.f152124b.d(new x02.b(i10, bundle));
}
public final synchronized void o() {
if (f160220f == null && a12.a.f1368f.d()) {
f160220f = new b();
Application e14 = XYUtilsCenter.e();
if (e14 != null) {
try {
Intent intent = new Intent(e14, AppMessengerService.class);
ServiceConnection serviceConnection = f160220f;
if (serviceConnection == null) {
Intrinsics.throwNpe();
}
e14.bindService(intent, serviceConnection, 1);
} catch (Exception e15) {
e.f("AppMessengerClient", "tryBindRemoteMsgService", e15);
Unit unit = Unit.INSTANCE;
}
}
}
}
public final void p() {
synchronized (f160221g) {
a aVar = f160223i;
if (aVar.e()) {
f160221g.offer(Long.valueOf(System.currentTimeMillis()));
aVar.o();
}
Unit unit = Unit.INSTANCE;
}
}
}