package d.f.a;

import com.cvte.vman.instance.InvokeCmd;
import com.ifpdos.udi.sdk.service.sdk.UdiGlobal;
import com.ifpdos.udi.sdk.service.sdk.json.IConverter;
import com.ifpdos.udi.sdk.service.sdk.json.MissingFieldException;
import com.ifpdos.udi.sdk.service.sdk.json.TypeToken;
import com.ifpdos.udi.sdk.service.sdk.log.IRequestTracker;
import com.ifpdos.udi.sdk.service.sdk.server.Api;
import com.ifpdos.udi.sdk.service.sdk.server.IRequest;
import com.ifpdos.udi.sdk.service.sdk.server.IUdiServer;
import com.ifpdos.udi.sdk.service.sdk.server.Response;
import d.f.a.a2;
import g.h0.b.l;
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.Reader;
import java.util.Map;
import java.util.Objects;
import java.util.concurrent.TimeUnit;

/* JADX INFO: compiled from: ExportXBugApi.kt */
/* JADX INFO: loaded from: classes.dex */
@g.i
public final class p0 {
    public static final p0 a = null;

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    public static final b f2667b = new b();

    /* JADX INFO: renamed from: c, reason: collision with root package name */
    public final Api f2668c;

    /* JADX INFO: compiled from: ExportXBugApi.kt */
    @g.i
    public /* synthetic */ class a extends g.h0.c.j implements g.h0.b.l<IRequest, Response> {
        public a(Object obj) {
            super(1, obj, a2.class, "exportXBug", "exportXBug(Lcom/ifpdos/udi/sdk/service/sdk/server/IRequest;)Lcom/ifpdos/udi/sdk/service/sdk/server/Response;", 0);
        }

        @Override // g.h0.b.l
        public Response invoke(IRequest iRequest) {
            c cVar;
            IRequest iRequest2 = iRequest;
            g.h0.c.l.f(iRequest2, "p0");
            a2 a2Var = (a2) this.receiver;
            Objects.requireNonNull(a2Var);
            g.h0.c.l.f(iRequest2, "request");
            Reader inputStreamReader = new InputStreamReader(iRequest2.getData(), g.m0.a.f4156b);
            BufferedReader bufferedReader = inputStreamReader instanceof BufferedReader ? (BufferedReader) inputStreamReader : new BufferedReader(inputStreamReader, InvokeCmd.CMD_TOUCH_CTRL_START);
            try {
                String strB = g.g0.f.b(bufferedReader);
                f.a.y.a.B(bufferedReader, null);
                try {
                    a2.a aVar = a2Var.f2557b;
                    g.h0.c.l.f(strB, "json");
                    g.h0.c.l.f(aVar, "token");
                    UdiGlobal udiGlobal = UdiGlobal.INSTANCE;
                    r0 r0Var = (r0) ((IConverter) udiGlobal.get(g.h0.c.b0.a(IConverter.class))).fromJson(strB, aVar);
                    g.h0.c.l.f(iRequest2, "request");
                    g.h0.c.l.f(r0Var, "paramParse");
                    ((IRequestTracker) udiGlobal.get(g.h0.c.b0.a(IRequestTracker.class))).onParseRequestSuccess(iRequest2, null, strB, r0Var);
                    d.f.a.o2.h hVar = a2Var.a;
                    String uri = iRequest2.getUri();
                    Map<String, String> fields = iRequest2.getFields();
                    g.h0.c.l.f(r0Var, "body");
                    g.h0.c.l.f(uri, "uri");
                    g.h0.c.l.f(fields, "fields");
                    Objects.requireNonNull(hVar);
                    d.f.a.r2.n2 n2Var = d.f.a.r2.n2.a;
                    if (d.f.a.r2.n2.f3282b) {
                        cVar = new c(Response.Companion.makeErrorResponse(500, new Response.ErrorBody("Exporting! Don't call it again.")));
                    } else {
                        d.f.a.r2.n2.f3282b = true;
                        f.a.i<q0> iVarB = d.f.a.r2.n2.b(hVar.f2662c, r0Var.a, r0Var.f3140b);
                        f.a.o oVar = f.a.z.a.f4044c;
                        f.a.i<q0> iVarY = iVarB.w(oVar).n(oVar).y(30L, TimeUnit.MINUTES);
                        final d.f.a.o2.f fVar = d.f.a.o2.f.f2659b;
                        f.a.v.c<? super q0> cVar2 = new f.a.v.c() { // from class: d.f.a.o2.c
                            @Override // f.a.v.c
                            public final void accept(Object obj) {
                                l lVar = fVar;
                                g.h0.c.l.f(lVar, "$tmp0");
                                lVar.invoke(obj);
                            }
                        };
                        final d.f.a.o2.g gVar = d.f.a.o2.g.f2660b;
                        iVarY.u(cVar2, new f.a.v.c() { // from class: d.f.a.o2.e
                            @Override // f.a.v.c
                            public final void accept(Object obj) {
                                l lVar = gVar;
                                g.h0.c.l.f(lVar, "$tmp0");
                                lVar.invoke(obj);
                            }
                        }, f.a.w.b.a.f3725b, f.a.w.b.a.f3726c);
                        cVar = new c();
                    }
                    return cVar.a;
                } catch (MissingFieldException e2) {
                    g.h0.c.l.f(iRequest2, "request");
                    g.h0.c.l.f(e2, "throwable");
                    ((IRequestTracker) UdiGlobal.INSTANCE.get(g.h0.c.b0.a(IRequestTracker.class))).onParseRequestFailed(iRequest2, null, strB, e2);
                    Response.Companion companion = Response.Companion;
                    StringBuilder sbE = d.b.a.a.a.E("params ", strB, ", miss field : ");
                    sbE.append(e2.getMissingFields());
                    return companion.makeErrorResponse(400, new Response.ErrorBody(sbE.toString()));
                } catch (Throwable th) {
                    g.h0.c.l.f(iRequest2, "request");
                    g.h0.c.l.f(th, "throwable");
                    ((IRequestTracker) UdiGlobal.INSTANCE.get(g.h0.c.b0.a(IRequestTracker.class))).onParseRequestFailed(iRequest2, null, strB, th);
                    return Response.Companion.makeErrorResponse(400, new Response.ErrorBody(d.b.a.a.a.q("params ", strB, " decode failed")));
                }
            } catch (Throwable th2) {
                try {
                    throw th2;
                } catch (Throwable th3) {
                    f.a.y.a.B(bufferedReader, th2);
                    throw th3;
                }
            }
        }
    }

    /* JADX INFO: compiled from: ExportXBugApi.kt */
    @g.i
    public static final class b extends TypeToken<q0> {
    }

    public p0(d.f.a.o2.h hVar) {
        g.h0.c.l.f(hVar, "receiver");
        this.f2668c = new Api("v1/debugmenu/system/xbug", true, 0, null, new a(new a2(hVar)), 7, null, 0, true, 200, null);
    }

    public static final void a(q0 q0Var) {
        g.h0.c.l.f(q0Var, "notify");
        b bVar = f2667b;
        g.h0.c.l.f(bVar, "token");
        UdiGlobal udiGlobal = UdiGlobal.INSTANCE;
        IUdiServer.DefaultImpls.sendEvent$default((IUdiServer) udiGlobal.get(g.h0.c.b0.a(IUdiServer.class)), "v1/debugmenu/system/xbug", ((IConverter) udiGlobal.get(g.h0.c.b0.a(IConverter.class))).toJson(q0Var, bVar), null, 4, null);
    }

    /* JADX INFO: compiled from: ExportXBugApi.kt */
    @g.i
    public static final class c {
        public final Response a;

        public c() {
            this.a = Response.Companion.makeOkResponse();
        }

        public c(Response response) {
            g.h0.c.l.f(response, "response");
            this.a = response;
        }
    }
}