小红书.apk(点击下载) / e.java

package ub2;

import android.app.AlarmManager;
import android.app.PendingIntent;
import android.content.Intent;
import android.os.Build;
import com.meizu.cloud.pushsdk.notification.model.AdvanceSetting;
import com.tencent.wcdb.database.SQLiteDatabase;
import com.uber.autodispose.a0;
import com.uber.autodispose.d;
import com.uber.autodispose.y;
import com.xingin.roombase.live.heartbeat.LiveRoomAlarmReceiver;
import com.xingin.roombase.longlink.RoomAck;
import com.xingin.utils.XYUtilsCenter;
import cx2.a;
import dw2.r;
import hw2.b;
import hw2.c;
import java.util.Objects;
import java.util.concurrent.TimeUnit;
import kotlin.Metadata;
import kotlin.jvm.internal.Intrinsics;
import sb2.z;
import y7.f;
import z60.h;

@Metadata(bv = {}, d1 = {"\u00004\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0002\u0010\u0002\n\u0000\n\u0002\u0010\u000e\n\u0002\b\u0002\n\u0002\u0010\u000b\n\u0002\b\u0002\n\u0002\u0010\t\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0004\bÆ\u0002\u0018\u00002\u00020\u0001B\t\b\u0002¢\u0006\u0004\b\u0011\u0010\u0012J\u0006\u0010\u0003\u001a\u00020\u0002J\u000e\u0010\u0006\u001a\u00020\u00022\u0006\u0010\u0005\u001a\u00020\u0004J\u000e\u0010\t\u001a\u00020\u00022\u0006\u0010\b\u001a\u00020\u0007J\u0018\u0010\u000e\u001a\u00020\u00022\u0006\u0010\u000b\u001a\u00020\n2\u0006\u0010\r\u001a\u00020\fH\u0002J\b\u0010\u0010\u001a\u00020\u000fH\u0002¨\u0006\u0013"}, d2 = {"Lub2/e;", "", "", f.f156778k, "", "roomId", "e", "", "screenOff", h.f160753a, "", "timeGap", "Landroid/app/PendingIntent;", "pIntent", "g", "Landroid/content/Intent;", "d", "<init>", "()V", "room_base_release"}, k = 1, mv = {1, 6, 0})
/* compiled from: LiveRoomHeartBeater.kt */
public final class e {

    /* renamed from: a  reason: collision with root package name */
    public static final e f136682a = new e();

    /* renamed from: b  reason: collision with root package name */
    public static final AlarmManager f136683b;

    /* renamed from: c  reason: collision with root package name */
    public static String f136684c = "";

    /* renamed from: d  reason: collision with root package name */
    public static int f136685d = 15;

    /* renamed from: e  reason: collision with root package name */
    public static boolean f136686e;

    /* renamed from: f  reason: collision with root package name */
    public static final b f136687f = new b();

    static {
        Object systemService = XYUtilsCenter.e().getApplicationContext().getSystemService("alarm");
        Objects.requireNonNull(systemService, "null cannot be cast to non-null type android.app.AlarmManager");
        f136683b = (AlarmManager) systemService;
    }

    public static final c i(Long l14) {
        Intrinsics.checkNotNullParameter(l14, AdvanceSetting.NETWORK_TYPE);
        r<RoomAck> z14 = z.f129181a.z(f136684c);
        a0 a0Var = a0.D;
        Intrinsics.checkNotNullExpressionValue(a0Var, "UNBOUND");
        Object n14 = z14.n(d.b(a0Var));
        Intrinsics.checkExpressionValueIsNotNull(n14, "this.`as`(AutoDispose.autoDisposable(provider))");
        return ((y) n14).a(b.f136679a, new rb2.f(pb2.b.f117597a));
    }

    public static final void j(RoomAck roomAck) {
    }

    public static final void k(c cVar) {
        pb2.b.a("live room:" + f136684c + " heartbeat...  screen off...");
    }

    public final Intent d() {
        Intent intent = new Intent(XYUtilsCenter.e().getApplicationContext(), LiveRoomAlarmReceiver.class);
        intent.setAction("com.xingin.roombase.live.heartbeat.LiveRoomHeartBeater.HEART_BEAT");
        intent.putExtra("room_id", f136684c);
        return intent;
    }

    public final void e(String str) {
        Intrinsics.checkNotNullParameter(str, "roomId");
        if (Intrinsics.areEqual(str, f136684c)) {
            PendingIntent broadcast = PendingIntent.getBroadcast(XYUtilsCenter.e().getApplicationContext(), 0, d(), Build.VERSION.SDK_INT >= 23 ? 335544320 : SQLiteDatabase.CREATE_IF_NECESSARY);
            Intrinsics.checkNotNullExpressionValue(broadcast, "getBroadcast(XYUtilsCent…, 0, buildIntent(), flag)");
            f136683b.cancel(broadcast);
            pb2.b.a("live room:" + f136684c + " heartbeat canceled");
            f136684c = "";
        }
    }

    public final void f() {
        PendingIntent broadcast = PendingIntent.getBroadcast(XYUtilsCenter.e().getApplicationContext(), 0, d(), Build.VERSION.SDK_INT >= 23 ? 201326592 : 134217728);
        Intrinsics.checkNotNullExpressionValue(broadcast, "getBroadcast(XYUtilsCent…, 0, buildIntent(), flag)");
        g(((long) f136685d) * 1000, broadcast);
    }

    public final void g(long j14, PendingIntent pendingIntent) {
        if (!f136686e) {
            f136683b.setExact(0, System.currentTimeMillis() + j14, pendingIntent);
        } else if (Build.VERSION.SDK_INT >= 23) {
            f136683b.setExactAndAllowWhileIdle(0, System.currentTimeMillis() + j14, pendingIntent);
        } else {
            f136683b.setExact(0, System.currentTimeMillis() + j14, pendingIntent);
        }
    }

    public final void h(boolean z14) {
        if (!(f136684c.length() == 0)) {
            f136686e = z14;
            if (z14) {
                c t14 = r.I0(0, ((long) f136685d) * 1000, TimeUnit.MILLISECONDS, a.a()).M0(d.f136681a).t1(c.f136680a, new rb2.f(pb2.b.f117597a));
                Intrinsics.checkNotNullExpressionValue(t14, "interval(0, mGapSecond *…}, RoomBaseLog::logError)");
                bx2.a.a(t14, f136687f);
                return;
            }
            f136687f.d();
        }
    }
}