package com.ifpdos.sdk.udi.opensdk;

import android.os.Handler;
import android.os.Looper;
import android.os.Message;
import android.os.RemoteException;
import android.util.Log;
import com.ifpdos.sdk.httpd.binder.aidl.IEventListener;
import com.ifpdos.sdk.httpd.binder.aidl.Request;
import com.seewo.sdk.internal.model.LibMcuCallback;
import com.seewo.sdk.internal.model.SDKResponse;
import e.c.d.y.c;
import java.util.Iterator;
import java.util.List;
import java.util.concurrent.CopyOnWriteArrayList;

/* JADX INFO: loaded from: classes.dex */
class EventHandler {
    private static final long RETRY_DELAY = 1000;
    private static final int RETRY_LIMIT = 180;
    private static final String TAG = "EventHandler";
    private final String mEventClass;
    private final String mUrl;
    private final List<LibMcuCallback> mCallbacks = new CopyOnWriteArrayList();
    private final RetryHandler mHandler = new RetryHandler();
    private final IEventListener mListener = new IEventListener.Stub() { // from class: com.ifpdos.sdk.udi.opensdk.EventHandler.1
        @Override // com.ifpdos.sdk.httpd.binder.aidl.IEventListener
        public void onEvent(String str, String str2) {
            String strH = c.h(new SDKResponse(EventHandler.this.mEventClass, str2));
            Iterator it = EventHandler.this.mCallbacks.iterator();
            while (it.hasNext()) {
                try {
                    ((LibMcuCallback) it.next()).onCall(strH);
                } catch (Exception e2) {
                    Log.e(EventHandler.TAG, "call back " + str + " failed", e2);
                    StringBuilder sb = new StringBuilder();
                    sb.append("data :");
                    sb.append(str2);
                    Log.e(EventHandler.TAG, sb.toString());
                    Log.e(EventHandler.TAG, "response :" + strH);
                }
            }
        }
    };

    private class RetryHandler extends Handler {
        static final int MSG_RETRY_CONNECT = 1;
        private int mConnectRetryTime;

        RetryHandler() {
            super(Looper.getMainLooper());
            this.mConnectRetryTime = 0;
        }

        @Override // android.os.Handler
        public void handleMessage(Message message) {
            super.handleMessage(message);
            if (message.what == 1) {
                EventHandler.this.registerListener();
            }
        }

        public boolean retryConnect() {
            int i2 = this.mConnectRetryTime;
            if (i2 >= EventHandler.RETRY_LIMIT) {
                return false;
            }
            this.mConnectRetryTime = i2 + 1;
            removeMessages(1);
            sendEmptyMessageDelayed(1, 1000L);
            return true;
        }
    }

    EventHandler(String str, String str2) {
        this.mEventClass = str;
        this.mUrl = str2;
        registerListener();
    }

    /* JADX INFO: Access modifiers changed from: private */
    public void registerListener() {
        try {
            if (SdkEnvironment.getUdiServer().addEventListener(new Request.Builder().addHeader("token", SdkEnvironment.getToken()).addHeader("invoker", SdkEnvironment.getPackageName()).post("/v1/udi/events/add", String.format("{\"events\":[\"%s\"]}", this.mUrl)).build(), this.mListener).getCode() == 503) {
                this.mHandler.retryConnect();
            }
        } catch (RemoteException unused) {
            this.mHandler.retryConnect();
        }
    }

    void addCallback(LibMcuCallback libMcuCallback) {
        this.mCallbacks.add(libMcuCallback);
    }

    void removeCallback(LibMcuCallback libMcuCallback) {
        this.mCallbacks.remove(libMcuCallback);
    }
}