package com.ifpdos.daemonserver.router;

import android.text.TextUtils;
import android.util.Log;
import java.util.Objects;
import java.util.concurrent.TimeUnit;

/* JADX INFO: compiled from: RouterChecker.java */
/* JADX INFO: loaded from: classes.dex */
public class o {

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    private static volatile o f1546b;

    /* JADX INFO: renamed from: a, reason: collision with root package name */
    private p f1547a = new p();

    public static synchronized o b() {
        if (f1546b == null) {
            f1546b = new o();
        }
        return f1546b;
    }

    static /* synthetic */ Boolean h(String str, String str2) throws Throwable {
        return (!TextUtils.isEmpty(str) || TextUtils.isEmpty(str2)) ? Boolean.valueOf(Objects.equals(str, str2)) : Boolean.TRUE;
    }

    private b.a.a.a.g<String> k() {
        return b.a.a.a.g.w(this.f1547a.b("get", "routerinfo", "info", "version"), this.f1547a.a("cat /etc/router.version | grep version | cut -d '=' -f2"), new b.a.a.d.b() { // from class: com.ifpdos.daemonserver.router.e
            @Override // b.a.a.d.b
            public final Object a(Object obj, Object obj2) {
                return o.h((String) obj, (String) obj2);
            }
        }).f(new b.a.a.d.d() { // from class: com.ifpdos.daemonserver.router.c
            @Override // b.a.a.d.d
            public final Object a(Object obj) {
                return this.f1531a.i((Boolean) obj);
            }
        });
    }

    public void a() {
        Log.d("RouterChecker", "checkAndResetRouter start");
        if (com.ifpdos.daemonserver.j.f.h()) {
            b.a.a.a.g.m(1).c(5L, TimeUnit.SECONDS, b.a.a.h.a.b()).f(new b.a.a.d.d() { // from class: com.ifpdos.daemonserver.router.a
                @Override // b.a.a.d.d
                public final Object a(Object obj) {
                    return this.f1529a.c((Integer) obj);
                }
            }).u(b.a.a.h.a.b()).r(new b.a.a.d.c() { // from class: com.ifpdos.daemonserver.router.b
                @Override // b.a.a.d.c
                public final void a(Object obj) {
                    Log.d("RouterChecker", "checkAndResetRouter: " + ((String) obj));
                }
            }, new b.a.a.d.c() { // from class: com.ifpdos.daemonserver.router.d
                @Override // b.a.a.d.c
                public final void a(Object obj) {
                    Log.e("RouterChecker", "checkAndResetRouter", (Throwable) obj);
                }
            });
        } else {
            Log.d("RouterChecker", "no router");
        }
    }

    public /* synthetic */ b.a.a.a.h c(Integer num) throws Throwable {
        return k();
    }

    public /* synthetic */ b.a.a.a.h i(Boolean bool) throws Throwable {
        if (bool.booleanValue()) {
            return b.a.a.a.g.m("OK");
        }
        com.ifpdos.daemonserver.j.f.q("resetRouter by firstboot");
        return this.f1547a.a("firstboot -y && reboot");
    }

    public void j() {
        Log.d("RouterChecker", "resetRouterConfig");
        this.f1547a.a("firstboot -y && reboot").r(new b.a.a.d.c() { // from class: com.ifpdos.daemonserver.router.f
            @Override // b.a.a.d.c
            public final void a(Object obj) {
                Log.d("RouterChecker", "resetRouterConfig succeed");
            }
        }, new b.a.a.d.c() { // from class: com.ifpdos.daemonserver.router.g
            @Override // b.a.a.d.c
            public final void a(Object obj) {
                Log.e("RouterChecker", "", (Throwable) obj);
            }
        });
    }
}