package com.ifpdos.debugmenu.action;

import android.annotation.SuppressLint;
import android.content.Context;
import com.cvte.vman.impl.FwUpgradeManager;
import com.ifpdos.debugmenu.R;
import com.ifpdos.debugmenu.action.ShowTeaVersionAction;
import com.ifpdos.debugmenu.action.base.ItemInfoAction;
import com.ifpdos.debugmenu.entity.UpgradeInformationBody;
import com.seewo.sdk.util.RLog;
import com.trello.rxlifecycle3.android.ActivityEvent;
import com.trello.rxlifecycle3.components.support.RxAppCompatActivity;
import d.f.a.j2.e.f;
import d.f.a.p2.p0;
import d.f.a.p2.t0;
import d.f.a.r2.k3.b;
import d.f.a.v0;
import f.a.k;
import f.a.w.e.d.c;
import f.a.z.a;
import java.util.Objects;
import java.util.concurrent.TimeUnit;

/* JADX INFO: loaded from: classes.dex */
public class ShowTeaVersionAction extends ItemInfoAction implements v0 {
    private static final String TAG = "ShowTeaVersionAction";
    private int retryCount;
    private String standard_data;
    private p0 upgradeHandler;

    public ShowTeaVersionAction(Context context) {
        super(context);
        this.upgradeHandler = t0.a;
        this.retryCount = 0;
    }

    @SuppressLint({"CheckResult"})
    private void getTeaVersion() {
        new c(new k() { // from class: d.f.a.p1.g6
            @Override // f.a.k
            public final void subscribe(f.a.j jVar) throws InterruptedException {
                ShowTeaVersionAction showTeaVersionAction = this.a;
                Objects.requireNonNull(showTeaVersionAction);
                Thread.sleep(1000L);
                UpgradeInformationBody upgradeInformationBody = (UpgradeInformationBody) d.f.a.r2.j3.e.a.b("/v1/device/tea/mic/ota/information", UpgradeInformationBody.class);
                d.b.a.a.a.U(d.b.a.a.a.B("value："), upgradeInformationBody == null ? showTeaVersionAction.mContext.getString(R.string.fail) : upgradeInformationBody.getVersion(), "ShowTeaVersionAction");
                if (upgradeInformationBody == null) {
                    ((c.a) jVar).c(new RuntimeException(""));
                    return;
                }
                c.a aVar = (c.a) jVar;
                aVar.d(upgradeInformationBody.getVersion());
                aVar.b();
            }
        }).s(new b(40, FwUpgradeManager.TYPE_FW_CVTE_CAMERA)).y(30L, TimeUnit.SECONDS).w(a.f4044c).n(f.a.s.b.a.a()).g(((RxAppCompatActivity) this.mContext).bindUntilEvent(ActivityEvent.DESTROY)).u(new f.a.v.c() { // from class: d.f.a.p1.h6
            @Override // f.a.v.c
            public final void accept(Object obj) {
                this.f2759b.j((String) obj);
            }
        }, new f.a.v.c() { // from class: d.f.a.p1.i6
            @Override // f.a.v.c
            public final void accept(Object obj) {
                this.f2770b.k((Throwable) obj);
            }
        }, f.a.w.b.a.f3725b, f.a.w.b.a.f3726c);
    }

    @Override // com.ifpdos.debugmenu.action.base.ItemInfoAction
    public String getValue(Context context) {
        getTeaVersion();
        return this.mContext.getString(R.string.device_loading);
    }

    /* JADX WARN: Multi-variable type inference failed */
    public void j(String str) {
        if (d.b.a.a.a.b0("Tea Version", str, TAG, str)) {
            return;
        }
        ((f) this.mViewModel).f2613g.i(str);
        setInfoColor(this.standard_data);
    }

    /* JADX WARN: Multi-variable type inference failed */
    public void k(Throwable th) {
        RLog.e(TAG, "Tea Version error: ", th);
        f fVar = (f) this.mViewModel;
        fVar.f2613g.i(this.mContext.getString(R.string.fail));
        setInfoColor(this.standard_data);
    }

    @Override // d.f.a.v0
    public void setStandData(String str) {
        this.standard_data = str;
    }
}