package com.ifpdos.update.device.camera.imp;

import android.content.BroadcastReceiver;
import android.content.Context;
import android.content.Intent;
import android.text.TextUtils;
import android.util.Log;
import d.f.a.r2.h3;
import d.f.f.c.g.c;
import java.io.File;
import java.lang.ref.WeakReference;
import java.util.Objects;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.TimeUnit;
import java.util.regex.Pattern;
import l.b0;
import l.c0;
import l.d;
import l.i0.b.k;
import l.j0.f;
import l.j0.l;
import l.j0.o;
import l.j0.q;
import okhttp3.MediaType;
import okhttp3.MultipartBody;
import okhttp3.OkHttpClient;
import okhttp3.RequestBody;

/* JADX INFO: loaded from: classes.dex */
public class NetworkCamera implements d.f.f.c.b.b {
    public b a;

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    public CountDownLatch f2029b;

    /* JADX INFO: renamed from: c, reason: collision with root package name */
    public d.f.f.d.a f2030c;

    public interface UpgradeNetworkCameraApi {
        @f("cgi-bin/param.cgi?get_ota_key")
        l.b<String> getOtaKey();

        @o("cgi-bin/param.cgi?post_image_file")
        @l
        l.b<String> uploadFile(@q MultipartBody.Part part);
    }

    public class a implements d<String> {
        public a() {
        }

        @Override // l.d
        public void a(l.b<String> bVar, Throwable th) {
            NetworkCamera networkCamera = NetworkCamera.this;
            StringBuilder sbB = d.b.a.a.a.B("[uploadUpgradeFileRequest] onFailure ");
            sbB.append(th.getMessage());
            String string = sbB.toString();
            Objects.requireNonNull(networkCamera);
            Log.e("NetworkCamera", string);
            networkCamera.f2030c = d.f.f.d.a.UNKNOWN_ERROR;
            CountDownLatch countDownLatch = networkCamera.f2029b;
            if (countDownLatch != null) {
                countDownLatch.countDown();
            }
        }

        @Override // l.d
        public void b(l.b<String> bVar, b0<String> b0Var) {
            String str = b0Var.f4997b;
            Log.i("NetworkCamera", str);
            if (!TextUtils.isEmpty(str)) {
                Objects.requireNonNull(NetworkCamera.this);
                if (str.contains("File upload to complete")) {
                    h3.t("persist.sys.camera.upgrade", "1");
                    return;
                }
            }
            NetworkCamera networkCamera = NetworkCamera.this;
            Objects.requireNonNull(networkCamera);
            Log.e("NetworkCamera", "[uploadUpgradeFileRequest] upload upgrade file fail! ");
            networkCamera.f2030c = d.f.f.d.a.UNKNOWN_ERROR;
            CountDownLatch countDownLatch = networkCamera.f2029b;
            if (countDownLatch != null) {
                countDownLatch.countDown();
            }
        }
    }

    public static class b extends BroadcastReceiver {
        public WeakReference<NetworkCamera> a;

        public b(NetworkCamera networkCamera) {
            this.a = new WeakReference<>(networkCamera);
        }

        @Override // android.content.BroadcastReceiver
        public void onReceive(Context context, Intent intent) {
            WeakReference<NetworkCamera> weakReference;
            String action = intent.getAction();
            if (d.b.a.a.a.b0("[onReceive]Broadcast Action: ", action, "NetworkCamera", action) || (weakReference = this.a) == null) {
                Log.e("NetworkCamera", "[onReceive]actionStr or reference is null!");
                return;
            }
            NetworkCamera networkCamera = weakReference.get();
            if (networkCamera == null) {
                Log.e("NetworkCamera", "[onReceive]WeakReference networkCamera is null");
                return;
            }
            if (action.equals("com.android.intent.action.CAMERA_UPGRADE_SUCCESS")) {
                networkCamera.f2030c = d.f.f.d.a.SUCCESS;
            } else if (!action.equals("com.android.intent.action.CAMERA_NOT_WORKING")) {
                networkCamera.f2030c = d.f.f.d.a.UNKNOWN_ERROR;
            } else if (h3.m("persist.sys.camera.upgrade", "0").equals("1")) {
                return;
            }
            CountDownLatch countDownLatch = networkCamera.f2029b;
            if (countDownLatch != null) {
                countDownLatch.countDown();
            }
        }
    }

    @Override // d.f.f.c.b.b
    public d.f.f.d.a a(String str) {
        File file = new File(str);
        if (!file.exists()) {
            return d.f.f.d.a.FILE_NOT_FOUND;
        }
        this.f2029b = new CountDownLatch(1);
        String strM = h3.m("persist.sys.camera.ip", "NO-LINK");
        Log.i("NetworkCamera", "network camera ip: " + strM + "  upgrade file path: " + str);
        if (!Pattern.compile("^((2[0-4]\\d|25[0-5]|[01]?\\d\\d?)\\.){3}(2[0-4]\\d|25[0-5]|[01]?\\d\\d?)$").matcher(strM).matches()) {
            return d.f.f.d.a.DEVICE_NOT_FOUND;
        }
        if (strM.contains("UPGRADING")) {
            return d.f.f.d.a.UPGRADING;
        }
        try {
            b(strM, file);
            return this.f2030c;
        } catch (InterruptedException unused) {
            Log.e("NetworkCamera", "no response！");
            return d.f.f.d.a.NETWORK_CAMERA_TIME_OUT;
        }
    }

    public final void b(String str, File file) throws InterruptedException {
        d.f.f.c.g.d dVar = new d.f.f.c.g.d();
        OkHttpClient.Builder builder = new OkHttpClient.Builder();
        TimeUnit timeUnit = TimeUnit.SECONDS;
        builder.connectTimeout(60L, timeUnit);
        builder.readTimeout(60L, timeUnit);
        builder.writeTimeout(60L, timeUnit);
        builder.hostnameVerifier(new c(dVar)).sslSocketFactory(dVar.a.getSocketFactory());
        c0.b bVar = new c0.b();
        bVar.a("http://" + str + "/");
        OkHttpClient okHttpClientBuild = builder.build();
        Objects.requireNonNull(okHttpClientBuild, "client == null");
        bVar.f5007b = okHttpClientBuild;
        bVar.f5009d.add(new k());
        ((UpgradeNetworkCameraApi) bVar.b().b(UpgradeNetworkCameraApi.class)).uploadFile(MultipartBody.Part.createFormData("filename", file.getName(), RequestBody.create(MediaType.parse("multipart/form-data"), file))).f(new a());
        CountDownLatch countDownLatch = this.f2029b;
        if (countDownLatch != null) {
            countDownLatch.await(480000L, TimeUnit.MILLISECONDS);
        }
    }

    @Override // d.f.f.c.b.b
    public String getVersion() {
        return h3.m("persist.sys.camera.version", "");
    }
}