package com.benq.platform.utils;

import android.util.Log;
import androidx.exifinterface.media.ExifInterface;
import com.google.gson.Gson;
import com.google.gson.reflect.TypeToken;
import com.ifpdos.udi.sdk.IEventHandler;
import com.ifpdos.udi.sdk.UdiSdk;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
import kotlin.jvm.internal.l;
import kotlin.jvm.internal.y;
import n1.e;
import n1.f;
import o1.AbstractC0676l;
import okhttp3.MediaType;
import okhttp3.OkHttpClient;
import okhttp3.Request;
import okhttp3.RequestBody;
import okhttp3.Response;
import okhttp3.ResponseBody;

/* JADX INFO: loaded from: classes.dex */
public final class UDIHelper {
    private static final String TAG = "UDIHelper";
    private static MediaType mediaType;
    public static final UDIHelper INSTANCE = new UDIHelper();
    private static final e udiClient$delegate = f.a(UDIHelper$udiClient$2.INSTANCE);

    static {
        MediaType mediaType2 = MediaType.Companion.parse("application/json;charset=utf-8");
        l.b(mediaType2);
        mediaType = mediaType2;
    }

    private UDIHelper() {
    }

    private final OkHttpClient getUdiClient() {
        return (OkHttpClient) udiClient$delegate.getValue();
    }

    /* JADX INFO: Access modifiers changed from: private */
    public static final void registerCTSStatus$lambda$0(CTSStatusChangeListener listener, String str, String str2) {
        l.e(listener, "$listener");
        boolean enable = ((EnableBody) new Gson().fromJson(str2, EnableBody.class)).getEnable();
        Log.i(TAG, "register CTS status result: " + enable);
        listener.onStatusChange(enable);
    }

    public final boolean exportLog(String fileName) {
        l.e(fileName, "fileName");
        y yVar = y.f5106a;
        String str = String.format("{\"fileName\": \"%s\"}", Arrays.copyOf(new Object[]{fileName}, 1));
        l.d(str, "format(...)");
        try {
            Log.i(TAG, "exportLog: " + fileName);
            Request.Builder builder = new Request.Builder();
            String fullUrl = UdiSdk.getFullUrl("v1/debugmenu/system/log/export");
            l.d(fullUrl, "getFullUrl(...)");
            Request requestBuild = builder.url(fullUrl).post(RequestBody.Companion.create(str, mediaType)).build();
            OkHttpClient udiClient = getUdiClient();
            l.b(udiClient);
            Response responseExecute = udiClient.newCall(requestBuild).execute();
            Log.i(TAG, "exportLog: " + (responseExecute.code() == 200) + " " + responseExecute + " ");
            return responseExecute.code() == 200;
        } catch (Exception e2) {
            Log.i(TAG, "exportLog: ", e2);
            return false;
        }
    }

    public final boolean getCTSStatus() {
        Log.v(TAG, "request udi.");
        if (supportCheckCTS()) {
            try {
                Request.Builder builder = new Request.Builder();
                String fullUrl = UdiSdk.getFullUrl("/v1/system/cts/enable");
                l.d(fullUrl, "getFullUrl(...)");
                ResponseBody responseBodyBody = getUdiClient().newCall(builder.url(fullUrl).build()).execute().body();
                String strString = responseBodyBody != null ? responseBodyBody.string() : null;
                Log.i(TAG, "get CST status: " + strString);
                if (strString == null || strString.length() <= 0) {
                    return false;
                }
                return ((EnableBody) new Gson().fromJson(strString, EnableBody.class)).getEnable();
            } catch (Exception e2) {
                Log.i(TAG, "get CST error: ", e2);
            }
        }
        return false;
    }

    public final ArrayList<CameraDevice> getCameraList() {
        Log.i(TAG, "getCameraList:");
        try {
            Request.Builder builder = new Request.Builder();
            String fullUrl = UdiSdk.getFullUrl("/v1/device/camera/list");
            l.d(fullUrl, "getFullUrl(...)");
            ResponseBody responseBodyBody = getUdiClient().newCall(builder.url(fullUrl).build()).execute().body();
            Object objFromJson = new Gson().fromJson(responseBodyBody != null ? responseBodyBody.string() : null, new TypeToken<CameraDeviceList>() { // from class: com.benq.platform.utils.UDIHelper$getCameraList$finalResult$1
            }.getType());
            l.c(objFromJson, "null cannot be cast to non-null type com.benq.platform.utils.CameraDeviceList");
            return ((CameraDeviceList) objFromJson).getList();
        } catch (Exception e2) {
            e2.printStackTrace();
            return new ArrayList<>();
        }
    }

    public final Integer getCurrentCamera() {
        Log.i(TAG, "getCurrentCamera:");
        try {
            Request.Builder builder = new Request.Builder();
            String fullUrl = UdiSdk.getFullUrl("/v1/device/camera/select");
            l.d(fullUrl, "getFullUrl(...)");
            ResponseBody responseBodyBody = getUdiClient().newCall(builder.url(fullUrl).build()).execute().body();
            String strString = responseBodyBody != null ? responseBodyBody.string() : null;
            Log.i(TAG, "getCurrentCamera: " + strString);
            return Integer.valueOf(((ValueIntBody) new Gson().fromJson(strString, ValueIntBody.class)).getValue());
        } catch (Exception e2) {
            e2.printStackTrace();
            return null;
        }
    }

    public final boolean getHDMISourceEncryption() {
        try {
            Request.Builder builder = new Request.Builder();
            String fullUrl = UdiSdk.getFullUrl("v1/source/hdmi/encryption");
            l.d(fullUrl, "getFullUrl(...)");
            ResponseBody responseBodyBody = getUdiClient().newCall(builder.url(fullUrl).build()).execute().body();
            String strString = responseBodyBody != null ? responseBodyBody.string() : null;
            Log.i(TAG, "getHDMISourceEncryption: " + strString);
            if (strString != null && strString.length() != 0) {
                return ((ValueBody) new Gson().fromJson(strString, ValueBody.class)).getValue();
            }
            return false;
        } catch (Exception e2) {
            Log.i(TAG, "getHDMISourceEncryption: ", e2);
            return false;
        }
    }

    public final float getSensorData(String obj) {
        l.e(obj, "obj");
        Log.i(TAG, "getSensorData: " + obj);
        try {
            Request.Builder builder = new Request.Builder();
            String fullUrl = UdiSdk.getFullUrl("/v1/device/sensor/" + obj);
            l.d(fullUrl, "getFullUrl(...)");
            Response responseExecute = getUdiClient().newCall(builder.url(fullUrl).build()).execute();
            ResponseBody responseBodyBody = responseExecute.body();
            String strString = responseBodyBody != null ? responseBodyBody.string() : null;
            Log.i(TAG, "setSensorEnable: " + (responseExecute.code() == 200) + " " + strString + " ");
            return ((ValueFloat) new Gson().fromJson(strString, ValueFloat.class)).getValue();
        } catch (Exception e2) {
            e2.printStackTrace();
            return 0.0f;
        }
    }

    public final boolean getSensorEnable(String sensor) {
        l.e(sensor, "sensor");
        try {
            Request.Builder builder = new Request.Builder();
            String fullUrl = UdiSdk.getFullUrl("/v1/device/sensor/" + sensor + "/enable");
            l.d(fullUrl, "getFullUrl(...)");
            ResponseBody responseBodyBody = getUdiClient().newCall(builder.url(fullUrl).build()).execute().body();
            String strString = responseBodyBody != null ? responseBodyBody.string() : null;
            Log.i(TAG, "getSensorEnable: " + strString);
            if (strString != null && strString.length() != 0) {
                return ((EnableBody) new Gson().fromJson(strString, EnableBody.class)).getEnable();
            }
            return false;
        } catch (Exception e2) {
            Log.i(TAG, "getSensorEnable: ", e2);
            return false;
        }
    }

    public final void registerCTSStatus(final CTSStatusChangeListener listener) {
        l.e(listener, "listener");
        try {
            UdiSdk.registerEvents((List<String>) AbstractC0676l.b("/v1/system/cts/enable"), new IEventHandler() { // from class: com.benq.platform.utils.b
                @Override // com.ifpdos.udi.sdk.IEventHandler
                public final void onEvent(String str, String str2) {
                    UDIHelper.registerCTSStatus$lambda$0(listener, str, str2);
                }
            });
        } catch (Exception e2) {
            Log.i(TAG, "register CTS error: ", e2);
        }
    }

    public final /* synthetic */ <T> IEventHandler registerUrlStatus(final String url, final y1.l onStatusChange) {
        l.e(url, "url");
        l.e(onStatusChange, "onStatusChange");
        l.h();
        IEventHandler iEventHandler = new IEventHandler() { // from class: com.benq.platform.utils.UDIHelper$registerUrlStatus$handler$1
            @Override // com.ifpdos.udi.sdk.IEventHandler
            public final void onEvent(String str, String str2) {
                Gson gson = new Gson();
                l.i(4, ExifInterface.GPS_DIRECTION_TRUE);
                Object objFromJson = gson.fromJson(str2, (Class<Object>) Object.class);
                Log.i("registerUrlStatus", "register " + url + " status result: " + objFromJson);
                onStatusChange.invoke(objFromJson);
            }
        };
        UdiSdk.registerEvents((List<String>) AbstractC0676l.b(url), iEventHandler);
        return iEventHandler;
    }

    public final /* synthetic */ <T> IEventHandler registerUrlStatusSafely(final String url, final y1.l onStatusChange) {
        l.e(url, "url");
        l.e(onStatusChange, "onStatusChange");
        try {
            l.h();
            IEventHandler iEventHandler = new IEventHandler() { // from class: com.benq.platform.utils.UDIHelper$registerUrlStatusSafely$$inlined$registerUrlStatus$1
                @Override // com.ifpdos.udi.sdk.IEventHandler
                public final void onEvent(String str, String str2) {
                    Gson gson = new Gson();
                    l.i(4, ExifInterface.GPS_DIRECTION_TRUE);
                    Object objFromJson = gson.fromJson(str2, (Class<Object>) Object.class);
                    Log.i("registerUrlStatus", "register " + url + " status result: " + objFromJson);
                    onStatusChange.invoke(objFromJson);
                }
            };
            UdiSdk.registerEvents((List<String>) AbstractC0676l.b(url), iEventHandler);
            return iEventHandler;
        } catch (Exception e2) {
            Log.i("registerUrlStatus", "register " + url + " error: ", e2);
            return null;
        }
    }

    public final boolean setHdcpCaptureEnable(boolean z2) {
        Log.d(TAG, "setHdcpCaptureEnable " + z2);
        y yVar = y.f5106a;
        String str = String.format("{\"enable\": %s}", Arrays.copyOf(new Object[]{Boolean.valueOf(z2)}, 1));
        l.d(str, "format(...)");
        try {
            Request.Builder builder = new Request.Builder();
            String fullUrl = UdiSdk.getFullUrl("/v1/source/hdcp/capture/enable");
            l.d(fullUrl, "getFullUrl(...)");
            Request requestBuild = builder.url(fullUrl).post(RequestBody.Companion.create(str, mediaType)).build();
            OkHttpClient udiClient = getUdiClient();
            l.b(udiClient);
            Response responseExecute = udiClient.newCall(requestBuild).execute();
            ResponseBody responseBodyBody = responseExecute.body();
            String strString = responseBodyBody != null ? responseBodyBody.string() : null;
            Log.i(TAG, "setHdcpCaptureEnable: " + (responseExecute.code() == 200) + " " + strString + " ");
            if (z2) {
                try {
                    Thread.sleep(100L);
                } catch (InterruptedException unused) {
                }
            }
            return responseExecute.code() == 200;
        } catch (Exception e2) {
            Log.i(TAG, "setHdcpCaptureEnable error: ", e2);
            return false;
        }
    }

    public final void setSensorEnable(String sensor, boolean z2) {
        l.e(sensor, "sensor");
        y yVar = y.f5106a;
        boolean z3 = true;
        String str = String.format("{\"enable\": %s}", Arrays.copyOf(new Object[]{Boolean.valueOf(z2)}, 1));
        l.d(str, "format(...)");
        try {
            Request.Builder builder = new Request.Builder();
            String fullUrl = UdiSdk.getFullUrl("/v1/device/sensor/" + sensor + "/enable");
            l.d(fullUrl, "getFullUrl(...)");
            Response responseExecute = getUdiClient().newCall(builder.url(fullUrl).post(RequestBody.Companion.create(str, mediaType)).build()).execute();
            ResponseBody responseBodyBody = responseExecute.body();
            String strString = responseBodyBody != null ? responseBodyBody.string() : null;
            if (responseExecute.code() != 200) {
                z3 = false;
            }
            Log.i(TAG, "setSensorEnable: " + z3 + " " + strString + " ");
        } catch (Exception e2) {
            Log.i(TAG, "setSensorEnable: ", e2);
        }
    }

    public final boolean supportCheckCTS() {
        return true;
    }

    public final void unRegisterUrlStatus(IEventHandler handler) {
        l.e(handler, "handler");
        UdiSdk.unregisterEvents(handler);
    }
}