package com.seewo.ota.receiver;

import android.content.BroadcastReceiver;
import android.content.Context;
import android.content.Intent;
import android.util.Log;
import com.seewo.ota.OTARefreshService;
import e.a.h;
import java.util.concurrent.TimeUnit;

/* JADX INFO: compiled from: USBDeviceReceiver.java */
/* JADX INFO: loaded from: classes.dex */
public class d extends BroadcastReceiver {
    private e.a.r.b a;

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    private int f2248b = -1;

    /* JADX INFO: renamed from: c, reason: collision with root package name */
    private int f2249c = -1;

    static /* synthetic */ void a(Context context, Intent intent, Boolean bool) throws Exception {
        Intent intent2 = new Intent(context, (Class<?>) OTARefreshService.class);
        int intExtra = intent.getIntExtra("pid", -1);
        int intExtra2 = intent.getIntExtra("vid", -1);
        intent2.putExtra("com.seewo.ota.START_UPDATE_DEVICE", true);
        intent2.putExtra("pid", intExtra);
        intent2.putExtra("vid", intExtra2);
        context.startService(intent2);
    }

    private void b(final Context context, final Intent intent) {
        e.a.r.b bVar = this.a;
        if (bVar != null && !bVar.isDisposed()) {
            this.a.dispose();
        }
        this.a = h.E(Boolean.TRUE).T(e.a.x.a.b()).i(3000L, TimeUnit.MILLISECONDS).G(e.a.q.b.a.a()).O(new e.a.t.c() { // from class: com.seewo.ota.receiver.b
            @Override // e.a.t.c
            public final void accept(Object obj) throws Exception {
                d.a(context, intent, (Boolean) obj);
            }
        });
    }

    @Override // android.content.BroadcastReceiver
    public void onReceive(Context context, Intent intent) {
        e.a.r.b bVar;
        String action = intent.getAction();
        int intExtra = intent.getIntExtra("pid", -1);
        int intExtra2 = intent.getIntExtra("vid", -1);
        Log.i("@USBDeviceReceiver", "onReceive: action = " + action + ", pid = " + intExtra + ", vid = " + intExtra2);
        if ("com.seewo.HID.ADDDEVICES".equals(action)) {
            this.f2248b = intExtra;
            this.f2249c = intExtra2;
            b(context, intent);
        } else if ("com.seewo.HID.REMOVEDEVICES".equals(action) && (bVar = this.a) != null && !bVar.isDisposed() && intExtra == this.f2248b && intExtra2 == this.f2249c) {
            this.a.dispose();
        }
    }
}