package e8;
public abstract class o {
    public final String a;
    public final qbsg.top.ble.data.BleSessionFacade b;
    public final kotlinx.coroutines.flow.SharedFlow c;
    public final String d;
    public final kotlinx.coroutines.CoroutineScope e;
    public kotlinx.coroutines.Job f;
    public final kotlinx.coroutines.sync.Mutex g;
    public final kotlinx.coroutines.flow.MutableStateFlow h;
    public final kotlinx.coroutines.flow.StateFlow i;
    public final kotlinx.coroutines.flow.MutableStateFlow j;
    public final kotlinx.coroutines.flow.StateFlow k;
    public final kotlinx.coroutines.flow.MutableSharedFlow l;
    public final kotlinx.coroutines.flow.SharedFlow m;
    public final kotlinx.coroutines.flow.StateFlow n;
    public final kotlinx.coroutines.flow.MutableStateFlow o;
    public final kotlinx.coroutines.flow.StateFlow p;

    public o(String p7, qbsg.top.ble.data.BleSessionFacade p8, kotlinx.coroutines.flow.SharedFlow p9)
    {
        kotlin.jvm.internal.s.f(p7, "macAddress");
        kotlin.jvm.internal.s.f(p8, "session");
        this.a = p7;
        this.b = p8;
        this.c = p9;
        this.d = w7.w.i();
        kotlinx.coroutines.CoroutineScope v0_2 = kotlinx.coroutines.CoroutineScopeKt.CoroutineScope(kotlinx.coroutines.SupervisorKt.SupervisorJob$default(0, 1, 0).plus(w7.b.a));
        this.e = v0_2;
        this.g = kotlinx.coroutines.sync.MutexKt.Mutex$default(0, 1, 0);
        int v8_4 = kotlinx.coroutines.flow.StateFlowKt.MutableStateFlow(Boolean.FALSE);
        this.h = v8_4;
        this.i = kotlinx.coroutines.flow.FlowKt.asStateFlow(v8_4);
        int v8_7 = kotlinx.coroutines.flow.StateFlowKt.MutableStateFlow(Integer.valueOf(0));
        this.j = v8_7;
        this.k = kotlinx.coroutines.flow.FlowKt.asStateFlow(v8_7);
        int v8_10 = kotlinx.coroutines.flow.SharedFlowKt.MutableSharedFlow$default(0, 64, 0, 5, 0);
        this.l = v8_10;
        this.m = kotlinx.coroutines.flow.FlowKt.asSharedFlow(v8_10);
        this.n = v8_10.getSubscriptionCount();
        int v8_12 = kotlinx.coroutines.flow.StateFlowKt.MutableStateFlow(0);
        this.o = v8_12;
        this.p = kotlinx.coroutines.flow.FlowKt.asStateFlow(v8_12);
        kotlinx.coroutines.BuildersKt.launch$default(v0_2, 0, 0, new e8.i(this, 0, 0), 3, 0);
        kotlinx.coroutines.BuildersKt.launch$default(v0_2, 0, 0, new e8.i(this, 0, 1), 3, 0);
        return;
    }

    public static String k(int p1, long p2)
    {
        c7.a.l(16);
        String v2_1 = Long.toString(p2, 16);
        kotlin.jvm.internal.s.e(v2_1, "toString(...)");
        return i7.i.B0((p1 * 2), v2_1);
    }

    public static String m()
    {
        String v0_0 = System.currentTimeMillis();
        long v6_0 = ((((long) java.util.TimeZone.getDefault().getOffset(v0_0)) / 1000) + (v0_0 / 1000));
        String v0_1 = a.b.s(v0_0);
        String v1_1 = v0_1[0];
        long v3_0 = v0_1[1];
        int v5 = v0_1[2];
        String v0_2 = v0_1[3];
        StringBuilder v8_2 = new StringBuilder();
        v8_2.append(e8.o.k(4, v6_0));
        v8_2.append(e8.o.k(2, ((long) v1_1)));
        v8_2.append(e8.o.k(1, ((long) v3_0)));
        v8_2.append(e8.o.k(1, ((long) v5)));
        v8_2.append(e8.o.k(1, ((long) v0_2)));
        return p.p1.j("dd", v8_2.toString());
    }

    public final void h()
    {
        Integer v0_0 = this.f;
        if (v0_0 != null) {
            kotlinx.coroutines.Job$DefaultImpls.cancel$default(v0_0, 0, 1, 0);
        }
        this.h.setValue(Boolean.FALSE);
        this.j.setValue(Integer.valueOf(0));
        return;
    }

    public final void i(java.util.List p7, a7.a p8)
    {
        this.f = kotlinx.coroutines.BuildersKt.launch$default(this.e, 0, 0, new e8.j(this, p7, p8, 0), 3, 0);
        return;
    }

    public abstract String j();

    public final void l(String p2)
    {
        kotlin.jvm.internal.s.f(p2, "data");
        this.l.tryEmit(new e8.b(p2));
        return;
    }

    public abstract void n(Object p0, g8.d p1, a7.a p2);
}