package G0;

import H0.s;
import android.content.ComponentName;
import android.content.Context;
import android.content.Intent;
import android.content.pm.PackageManager;
import android.os.Binder;
import android.os.Handler;
import android.os.IBinder;
import android.os.Looper;
import android.os.Message;
import android.os.RemoteException;
import android.util.Log;
import com.seewo.sdk.internal.model.ISDKService;
import com.seewo.sdk.internal.model.IWatchDogService;
import com.seewo.sdk.internal.model.LibMcuCallback;
import com.seewo.sdk.internal.model.ResponseCallback;
import com.seewo.sdk.internal.model.SDKEventType;
import com.seewo.sdk.internal.model.SDKParsable;
import com.seewo.sdk.internal.model.SDKRequest;
import com.seewo.sdk.internal.model.SDKResponse;
import com.seewo.sdk.internal.response.common.RespVoidResult;
import java.util.HashMap;
import java.util.Iterator;
import java.util.LinkedList;
import java.util.List;
import java.util.Map;
import java.util.concurrent.ConcurrentLinkedQueue;
import java.util.concurrent.CopyOnWriteArrayList;

/* JADX INFO: loaded from: classes.dex */
public class d {

    /* JADX INFO: renamed from: a, reason: collision with root package name */
    private String f759a;

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    private LinkedList f760b;

    /* JADX INFO: renamed from: c, reason: collision with root package name */
    private Map f761c;

    /* JADX INFO: renamed from: d, reason: collision with root package name */
    private Context f762d;

    /* JADX INFO: renamed from: e, reason: collision with root package name */
    private ConcurrentLinkedQueue f763e;

    /* JADX INFO: renamed from: f, reason: collision with root package name */
    private ISDKService f764f;

    /* JADX INFO: renamed from: g, reason: collision with root package name */
    private boolean f765g;

    /* JADX INFO: renamed from: h, reason: collision with root package name */
    private int f766h;

    /* JADX INFO: renamed from: i, reason: collision with root package name */
    private List f767i;

    /* JADX INFO: renamed from: j, reason: collision with root package name */
    private Handler f768j;

    /* JADX INFO: renamed from: k, reason: collision with root package name */
    private IBinder.DeathRecipient f769k;

    /* JADX INFO: renamed from: l, reason: collision with root package name */
    private IWatchDogService f770l;

    class a extends Handler {
        a(Looper looper) {
            super(looper);
        }

        @Override // android.os.Handler
        public void handleMessage(Message message) {
            int i2 = message.what;
            if (i2 == 1001) {
                Q0.e.g("OpenSDK", "SDKService reconnecting...");
                if (d.this.q()) {
                    return;
                }
                Q0.e.b("OpenSDK", "SDKService connecting fail!");
                d.this.A();
                d.this.f768j.sendEmptyMessageDelayed(1001, 1000L);
                return;
            }
            if (i2 != 1002) {
                return;
            }
            d.this.f768j.removeMessages(1001);
            Q0.e.f("OpenSDK", "SDKService connected!");
            if (d.this.f765g) {
                d.this.y();
                d.this.f765g = false;
            }
            android.support.v4.media.a.a(d.this.f763e.poll());
        }
    }

    class b implements IBinder.DeathRecipient {
        b() {
        }

        @Override // android.os.IBinder.DeathRecipient
        public void binderDied() {
            Q0.e.b("OpenSDK", "SDKService connection interrupt!");
            d.this.v();
            d.this.f765g = true;
            d.this.f768j.sendEmptyMessage(1001);
        }
    }

    class c extends LibMcuCallback.Stub {

        /* JADX INFO: renamed from: e, reason: collision with root package name */
        final /* synthetic */ ResponseCallback f773e;

        c(ResponseCallback responseCallback) {
            this.f773e = responseCallback;
        }

        @Override // com.seewo.sdk.internal.model.LibMcuCallback
        public void onCall(String str) {
            ResponseCallback responseCallback = this.f773e;
            if (responseCallback != null) {
                responseCallback.onCall((SDKResponse) Q0.c.f(str, SDKResponse.class));
            }
        }
    }

    /* JADX INFO: renamed from: G0.d$d, reason: collision with other inner class name */
    private static class C0006d {

        /* JADX INFO: renamed from: a, reason: collision with root package name */
        private static final d f775a = new d(null);
    }

    public class e extends RuntimeException {
        e() {
            super("Make sure OpenSDKService has been connected!!!");
        }
    }

    /* synthetic */ d(a aVar) {
        this();
    }

    /* JADX INFO: Access modifiers changed from: private */
    public void A() {
        if (J0.c.g().j()) {
            Intent intent = new Intent();
            intent.setComponent(new ComponentName("com.seewo.mcuservice", "com.seewo.mcuservice.McuService"));
            this.f762d.startService(intent);
        }
    }

    private void j(IBinder iBinder, int i2) throws RemoteException {
        iBinder.linkToDeath(this.f769k, 0);
        this.f764f = ISDKService.Stub.asInterface(iBinder);
        String packageName = this.f762d.getPackageName();
        if (i2 != com.seewo.hiddenapi.g.f3345e) {
            packageName = packageName + ":" + i2;
        }
        this.f759a = this.f764f.getToken(packageName, null);
        Log.i("OpenSDK", "SDK connected. Token: " + this.f759a + " Package name: " + packageName);
        this.f768j.sendEmptyMessage(1002);
    }

    private void k(IBinder iBinder) throws RemoteException {
        IWatchDogService iWatchDogServiceAsInterface = IWatchDogService.Stub.asInterface(iBinder);
        this.f770l = iWatchDogServiceAsInterface;
        if (iWatchDogServiceAsInterface != null) {
            iWatchDogServiceAsInterface.bindWatchDog(new Binder(), this.f762d.getPackageName());
        }
    }

    public static d o() {
        return C0006d.f775a;
    }

    /* JADX INFO: Access modifiers changed from: private */
    public boolean q() {
        J0.c.g().n();
        P0.f.b().e();
        j.f().k();
        O0.d.a().c();
        N0.b.a().c();
        K0.d.a().c();
        IBinder iBinderF = J0.c.g().f("opensdk");
        IBinder iBinderF2 = J0.c.g().f("opensdk_watchdog");
        if (iBinderF == null) {
            return false;
        }
        try {
            j(iBinderF, this.f766h);
            k(iBinderF2);
            return true;
        } catch (RemoteException e2) {
            Log.e("OpenSDK", "REMOTE_EXCEPTION", e2);
            return false;
        }
    }

    private boolean s() {
        try {
            this.f762d.getPackageManager().getApplicationInfo("com.seewo.mcuservice", 8192);
            return false;
        } catch (PackageManager.NameNotFoundException unused) {
            return true;
        }
    }

    private synchronized SDKRequest t() {
        try {
        } catch (Throwable th) {
            throw th;
        }
        return !this.f760b.isEmpty() ? (SDKRequest) this.f760b.removeFirst() : new SDKRequest();
    }

    /* JADX INFO: Access modifiers changed from: private */
    public void v() {
        ISDKService iSDKService = this.f764f;
        if (iSDKService != null) {
            iSDKService.asBinder().unlinkToDeath(this.f769k, 0);
            this.f764f = null;
            this.f766h = com.seewo.hiddenapi.g.f3345e;
        }
        IWatchDogService iWatchDogService = this.f770l;
        if (iWatchDogService != null) {
            try {
                iWatchDogService.unbindWatchDog(this.f762d.getPackageName());
            } catch (RemoteException e2) {
                Q0.e.d("OpenSDK", e2);
            }
        }
    }

    private synchronized void w(SDKRequest sDKRequest) {
        this.f760b.addLast(sDKRequest);
    }

    /* JADX INFO: Access modifiers changed from: private */
    public void y() {
        for (Class cls : this.f761c.keySet()) {
            x(cls, (LibMcuCallback) this.f761c.get(cls));
        }
    }

    void B(Class cls, LibMcuCallback libMcuCallback) {
        Iterator it = this.f767i.iterator();
        if (it.hasNext()) {
            android.support.v4.media.a.a(it.next());
            throw null;
        }
        if (s() || libMcuCallback == null) {
            return;
        }
        this.f761c.remove(cls);
        if (this.f764f != null) {
            try {
                SDKEventType sDKEventType = new SDKEventType();
                sDKEventType.setEventType(cls.getName());
                this.f764f.unregisterCallback(this.f759a, Q0.c.h(sDKEventType), libMcuCallback);
                return;
            } catch (RemoteException e2) {
                Log.e("OpenSDK", e2.getMessage(), e2);
                return;
            }
        }
        Log.e("OpenSDK", "SDKService not found! \n[" + this.f762d.getPackageName() + "]");
        StringBuilder sb = new StringBuilder();
        sb.append("[unregister] ");
        sb.append(cls.getSimpleName());
        Log.e("OpenSDK", sb.toString());
    }

    public void i(s sVar) {
        if (sVar == null) {
            return;
        }
        if (s() || r()) {
            sVar.onSdkConnected();
        } else {
            if (this.f763e.contains(sVar)) {
                return;
            }
            this.f763e.add(sVar);
        }
    }

    public void l(Context context) {
        m(context, null);
    }

    public void m(Context context, s sVar) {
        this.f762d = context.getApplicationContext();
        if (s()) {
            if (sVar != null) {
                sVar.onSdkConnected();
            }
        } else {
            J0.c.g().h(this.f762d);
            i(sVar);
            if (q()) {
                return;
            }
            this.f768j.sendEmptyMessage(1001);
        }
    }

    public void n() {
        if (s()) {
            return;
        }
        this.f768j.removeCallbacksAndMessages(null);
        v();
    }

    public String p() {
        return this.f759a;
    }

    public boolean r() {
        return this.f764f != null;
    }

    boolean u(SDKParsable sDKParsable, ResponseCallback responseCallback) {
        boolean z2 = true;
        if (!s()) {
            if (this.f764f != null) {
                try {
                    SDKRequest sDKRequestT = t();
                    sDKRequestT.setRequestName(Q0.c.i(sDKParsable));
                    sDKRequestT.setParamsJson(Q0.c.h(sDKParsable));
                    this.f764f.postMessage(this.f759a, Q0.c.h(sDKRequestT), new c(responseCallback));
                    w(sDKRequestT);
                } catch (RemoteException e2) {
                    Log.e("OpenSDK", e2.getMessage(), e2);
                    z2 = false;
                }
            } else {
                Log.e("OpenSDK", "SDKService not found! \n[" + this.f762d.getPackageName() + "]");
                StringBuilder sb = new StringBuilder();
                sb.append("[postCommand] ");
                sb.append(sDKParsable.getClass().getSimpleName());
                Log.e("OpenSDK", sb.toString());
                if (responseCallback != null) {
                    responseCallback.onCall(new SDKResponse(SDKResponse.Status.SERVICE_NOT_FOUND));
                }
            }
            z2 = false;
        } else if (responseCallback != null) {
            responseCallback.onCall(new SDKResponse(new RespVoidResult()));
        }
        if (sDKParsable instanceof R0.b) {
            ((R0.b) sDKParsable).recycle();
        }
        return z2;
    }

    void x(Class cls, LibMcuCallback libMcuCallback) {
        Iterator it = this.f767i.iterator();
        if (it.hasNext()) {
            android.support.v4.media.a.a(it.next());
            throw null;
        }
        if (s() || libMcuCallback == null) {
            return;
        }
        this.f761c.put(cls, libMcuCallback);
        if (this.f764f != null) {
            try {
                SDKEventType sDKEventType = new SDKEventType();
                sDKEventType.setEventType(cls.getName());
                this.f764f.registerCallback(this.f759a, Q0.c.h(sDKEventType), libMcuCallback);
                return;
            } catch (RemoteException e2) {
                Log.e("OpenSDK", e2.getMessage(), e2);
                return;
            }
        }
        this.f765g = true;
        Log.e("OpenSDK", "SDKService not found! \n[" + this.f762d.getPackageName() + "]");
        StringBuilder sb = new StringBuilder();
        sb.append("[register] ");
        sb.append(cls.getSimpleName());
        Log.e("OpenSDK", sb.toString());
    }

    SDKResponse z(SDKParsable sDKParsable) {
        SDKResponse sDKResponse = null;
        if (this.f762d == null) {
            Log.e("OpenSDK", Log.getStackTraceString(new e()));
        } else if (!s()) {
            if (this.f764f != null) {
                try {
                    SDKRequest sDKRequestT = t();
                    sDKRequestT.setRequestName(Q0.c.i(sDKParsable));
                    sDKRequestT.setParamsJson(Q0.c.h(sDKParsable));
                    String strH = Q0.c.h(sDKRequestT);
                    w(sDKRequestT);
                    sDKResponse = (SDKResponse) Q0.c.f(this.f764f.sendMessage(this.f759a, strH), SDKResponse.class);
                } catch (RemoteException e2) {
                    Log.e("OpenSDK", e2.getMessage(), e2);
                }
            } else {
                Log.e("OpenSDK", "SDKService not found! \n[" + this.f762d.getPackageName() + "]");
                StringBuilder sb = new StringBuilder();
                sb.append("[sendCommand] ");
                sb.append(sDKParsable.getClass().getSimpleName());
                Log.e("OpenSDK", sb.toString());
                sDKResponse = new SDKResponse(SDKResponse.Status.SERVICE_NOT_FOUND);
            }
        }
        if (sDKParsable instanceof R0.b) {
            ((R0.b) sDKParsable).recycle();
        }
        return sDKResponse == null ? new SDKResponse(SDKResponse.Status.SDK_NOT_CONNECTED) : sDKResponse;
    }

    private d() {
        this.f760b = new LinkedList();
        this.f761c = new HashMap();
        this.f763e = new ConcurrentLinkedQueue();
        this.f765g = false;
        this.f766h = com.seewo.hiddenapi.g.f3345e;
        this.f767i = new CopyOnWriteArrayList();
        this.f768j = new a(Looper.getMainLooper());
        this.f769k = new b();
    }
}