package com.ifpdos.daemonserver.h;

import com.ifpdos.daemonserver.App;
import com.ifpdos.daemonserver.g;
import javax.net.ssl.HostnameVerifier;
import javax.net.ssl.SSLSession;
import org.eclipse.paho.client.mqttv3.IMqttDeliveryToken;
import org.eclipse.paho.client.mqttv3.MqttCallback;
import org.eclipse.paho.client.mqttv3.MqttClient;
import org.eclipse.paho.client.mqttv3.MqttConnectOptions;
import org.eclipse.paho.client.mqttv3.MqttMessage;
import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence;

/* JADX INFO: compiled from: MQTTChecker.java */
/* JADX INFO: loaded from: classes.dex */
public class e implements c, MqttCallback {

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

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    private boolean f1513b = true;

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

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

    private boolean d() {
        try {
            if (this.f1512a == null) {
                this.f1512a = new MqttClient(com.ifpdos.daemonserver.f.f1502a, com.ifpdos.daemonserver.f.f1503b, new MemoryPersistence());
            }
            if (!this.f1512a.isConnected()) {
                com.ifpdos.daemonserver.i.c.a("MQTTChecker", "try connect mqtt server");
                MqttConnectOptions mqttConnectOptions = new MqttConnectOptions();
                mqttConnectOptions.setConnectionTimeout(10);
                mqttConnectOptions.setHttpsHostnameVerificationEnabled(false);
                mqttConnectOptions.setSSLHostnameVerifier(new HostnameVerifier() { // from class: com.ifpdos.daemonserver.h.a
                    @Override // javax.net.ssl.HostnameVerifier
                    public final boolean verify(String str, SSLSession sSLSession) {
                        return e.f(str, sSLSession);
                    }
                });
                mqttConnectOptions.setSocketFactory(g.a(App.f1492b.getAssets().open("ca.crt"), App.f1492b.getAssets().open("client.p12"), "monitor"));
                this.f1512a.setCallback(this);
                this.f1512a.connect(mqttConnectOptions);
                this.f1512a.subscribe(com.ifpdos.daemonserver.f.f1505d);
                com.ifpdos.daemonserver.i.c.a("MQTTChecker", "connect succeed!");
            }
        } catch (Exception e2) {
            com.ifpdos.daemonserver.i.c.b("MQTTChecker", e2.getMessage(), e2);
        }
        MqttClient mqttClient = this.f1512a;
        return mqttClient != null && mqttClient.isConnected();
    }

    private void e() {
        try {
            com.ifpdos.daemonserver.i.c.c("MQTTChecker", "echo");
            this.f1513b = false;
            this.f1512a.publish(com.ifpdos.daemonserver.f.f1504c, "echo".getBytes(), 0, false);
        } catch (Exception e2) {
            com.ifpdos.daemonserver.i.c.a("MQTTChecker", e2.getMessage());
        }
    }

    static /* synthetic */ boolean f(String str, SSLSession sSLSession) {
        return true;
    }

    private void g() {
        com.ifpdos.daemonserver.i.c.b("MQTTChecker", "onMqttClientLost", null);
        com.ifpdos.daemonserver.j.f.s();
    }

    private void h() throws Throwable {
        com.ifpdos.daemonserver.i.c.b("MQTTChecker", "onMqttServerLost", null);
        if (com.ifpdos.daemonserver.j.f.l()) {
            return;
        }
        int i = this.f1515d;
        this.f1515d = i + 1;
        if (i > 2) {
            this.f1515d = 0;
            com.ifpdos.daemonserver.i.c.b("MQTTChecker", "clearBroker", null);
            com.ifpdos.daemonserver.j.f.b();
            com.ifpdos.daemonserver.j.f.w(App.f1492b);
        }
        com.ifpdos.daemonserver.j.f.y(true);
    }

    @Override // com.ifpdos.daemonserver.h.c
    public boolean a() throws Throwable {
        if (!d()) {
            h();
        } else if (com.ifpdos.daemonserver.j.f.i(App.f1492b, "com.ifpdos.monitor")) {
            if (this.f1513b) {
                e();
            } else {
                this.f1514c++;
                com.ifpdos.daemonserver.i.c.b("MQTTChecker", "check mClientLostCount=" + this.f1514c, null);
                if (this.f1514c >= 3) {
                    this.f1514c = 0;
                    g();
                } else {
                    e();
                }
                this.f1513b = true;
            }
        }
        return true;
    }

    @Override // com.ifpdos.daemonserver.h.c
    public int b() {
        return 120;
    }

    @Override // com.ifpdos.daemonserver.h.c
    public int c() {
        return 10;
    }

    @Override // org.eclipse.paho.client.mqttv3.MqttCallback
    public void connectionLost(Throwable th) {
        com.ifpdos.daemonserver.i.c.b("MQTTChecker", "connectionLost", th);
    }

    @Override // org.eclipse.paho.client.mqttv3.MqttCallback
    public void deliveryComplete(IMqttDeliveryToken iMqttDeliveryToken) {
    }

    @Override // org.eclipse.paho.client.mqttv3.MqttCallback
    public void messageArrived(String str, MqttMessage mqttMessage) throws Exception {
        com.ifpdos.daemonserver.i.c.c("MQTTChecker", "echo response");
        this.f1513b = true;
    }
}