package com.ifpdos.debugmenu.action;

import android.content.Context;
import c.n.a;
import com.ifpdos.debugmenu.R;
import com.ifpdos.debugmenu.action.BaseVersionUpsAction;
import com.ifpdos.debugmenu.action.base.ItemInfoAction;
import com.ifpdos.debugmenu.upgrades.entrties.DeviceInfo;
import com.ifpdos.debugmenu.upgrades.listener.IRequestCallback;
import d.f.a.j2.e.f;
import d.f.a.q2.d.d;
import d.f.a.r2.s2;
import d.f.a.v0;
import f.a.j;
import f.a.k;
import f.a.w.e.d.c;
import g.a0;
import g.c0.g;
import g.h0.b.l;
import g.h0.c.m;
import g.i;
import java.io.IOException;
import java.util.ArrayList;
import java.util.Iterator;
import java.util.List;
import java.util.concurrent.TimeUnit;

/* JADX INFO: compiled from: BaseVersionUpsAction.kt */
/* JADX INFO: loaded from: classes.dex */
@i
public abstract class BaseVersionUpsAction extends ItemInfoAction implements v0 {

    /* JADX INFO: renamed from: com.ifpdos.debugmenu.action.BaseVersionUpsAction$getUpsFirmwareVersion$2, reason: invalid class name */
    /* JADX INFO: compiled from: BaseVersionUpsAction.kt */
    @i
    public static final class AnonymousClass2 extends m implements l<s2<String>, a0> {

        /* JADX INFO: renamed from: com.ifpdos.debugmenu.action.BaseVersionUpsAction$getUpsFirmwareVersion$2$1, reason: invalid class name */
        /* JADX INFO: compiled from: BaseVersionUpsAction.kt */
        @i
        public static final class AnonymousClass1 extends m implements l<String, a0> {
            public final /* synthetic */ BaseVersionUpsAction this$0;

            /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
            public AnonymousClass1(BaseVersionUpsAction baseVersionUpsAction) {
                super(1);
                this.this$0 = baseVersionUpsAction;
            }

            @Override // g.h0.b.l
            public /* bridge */ /* synthetic */ a0 invoke(String str) {
                invoke2(str);
                return a0.a;
            }

            /* JADX INFO: renamed from: invoke, reason: avoid collision after fix types in other method */
            public final void invoke2(String str) {
                ((f) this.this$0.mViewModel).f2613g.i(str);
                BaseVersionUpsAction baseVersionUpsAction = this.this$0;
                baseVersionUpsAction.setInfoColor(baseVersionUpsAction.standard_data);
            }
        }

        /* JADX INFO: renamed from: com.ifpdos.debugmenu.action.BaseVersionUpsAction$getUpsFirmwareVersion$2$2, reason: invalid class name and collision with other inner class name */
        /* JADX INFO: compiled from: BaseVersionUpsAction.kt */
        @i
        public static final class C00252 extends m implements l<Throwable, a0> {
            public final /* synthetic */ BaseVersionUpsAction this$0;

            /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
            public C00252(BaseVersionUpsAction baseVersionUpsAction) {
                super(1);
                this.this$0 = baseVersionUpsAction;
            }

            @Override // g.h0.b.l
            public /* bridge */ /* synthetic */ a0 invoke(Throwable th) {
                invoke2(th);
                return a0.a;
            }

            /* JADX INFO: renamed from: invoke, reason: avoid collision after fix types in other method */
            public final void invoke2(Throwable th) {
                g.h0.c.l.f(th, "it");
                f fVar = (f) this.this$0.mViewModel;
                fVar.f2613g.i(this.this$0.mContext.getString(R.string.fail));
                BaseVersionUpsAction baseVersionUpsAction = this.this$0;
                baseVersionUpsAction.setInfoColor(baseVersionUpsAction.standard_data);
            }
        }

        public AnonymousClass2() {
            super(1);
        }

        @Override // g.h0.b.l
        public /* bridge */ /* synthetic */ a0 invoke(s2<String> s2Var) {
            invoke2(s2Var);
            return a0.a;
        }

        /* JADX INFO: renamed from: invoke, reason: avoid collision after fix types in other method */
        public final void invoke2(s2<String> s2Var) {
            g.h0.c.l.f(s2Var, "$this$customSubscribe");
            s2Var.b(new AnonymousClass1(BaseVersionUpsAction.this));
            s2Var.a(new C00252(BaseVersionUpsAction.this));
        }
    }

    /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
    public BaseVersionUpsAction(Context context) {
        super(context);
        g.h0.c.l.f(context, "context");
    }

    private final void getUpsFirmwareVersion() {
        f.a.i<T> iVarY = new c(new k() { // from class: d.f.a.p1.l
            @Override // f.a.k
            public final void subscribe(f.a.j jVar) {
                BaseVersionUpsAction.getUpsFirmwareVersion$lambda$0(this.a, jVar);
            }
        }).y(30L, TimeUnit.SECONDS);
        g.h0.c.l.e(iVarY, "create { emitter: Observ…out(30, TimeUnit.SECONDS)");
        Context context = this.mContext;
        g.h0.c.l.e(context, "mContext");
        a.l(a.c0(iVarY, context, null, 2), new AnonymousClass2());
    }

    /* JADX INFO: Access modifiers changed from: private */
    public static final void getUpsFirmwareVersion$lambda$0(BaseVersionUpsAction baseVersionUpsAction, final j jVar) {
        g.h0.c.l.f(baseVersionUpsAction, "this$0");
        g.h0.c.l.f(jVar, "emitter");
        baseVersionUpsAction.getRepository().b(new IRequestCallback<DeviceInfo>() { // from class: com.ifpdos.debugmenu.action.BaseVersionUpsAction$getUpsFirmwareVersion$1$1
            @Override // com.ifpdos.debugmenu.upgrades.listener.IRequestCallback
            public void onError(String str) {
                g.h0.c.l.f(str, "msg");
                ((c.a) jVar).c(new RuntimeException(d.b.a.a.a.p("getUpsFirmwareVersion error: ", str)));
            }

            @Override // com.ifpdos.debugmenu.upgrades.listener.IRequestCallback
            public void onResult(List<? extends DeviceInfo> list) throws IOException {
                g.h0.c.l.f(list, "list");
                if (list.isEmpty()) {
                    ((c.a) jVar).c(new RuntimeException());
                    return;
                }
                ArrayList arrayList = new ArrayList(f.a.y.a.C(list, 10));
                Iterator<T> it = list.iterator();
                while (it.hasNext()) {
                    arrayList.add(((DeviceInfo) it.next()).getVersion());
                }
                String strR = g.r(arrayList, ";", null, null, 0, null, null, 62);
                if (!g.m0.f.o(strR)) {
                    ((c.a) jVar).d(strR);
                    ((c.a) jVar).b();
                } else {
                    ((c.a) jVar).c(new RuntimeException());
                }
            }
        });
    }

    public abstract d<?> getRepository();

    @Override // com.ifpdos.debugmenu.action.base.ItemInfoAction
    public String getValue(Context context) {
        getUpsFirmwareVersion();
        String string = this.mContext.getString(R.string.device_loading);
        g.h0.c.l.e(string, "mContext.getString(R.string.device_loading)");
        return string;
    }

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