Tasker v6.5.11 - ServiceMatterCommissioning.java 源代码

package com.joaomgcd.oldtaskercompat.matter;

import android.app.Service;
import android.content.Intent;
import android.os.IBinder;
import android.util.Log;
import chip.devicecontroller.AttestationInfo;
import chip.devicecontroller.ChipDeviceController;
import chip.devicecontroller.DeviceAttestationDelegate;
import com.google.android.gms.home.matter.commissioning.CommissioningRequestMetadata;
import com.joaomgcd.oldtaskercompat.matter.ServiceMatterCommissioning;
import da.m;
import id.i;
import java.util.concurrent.CancellationException;
import jk.a0;
import jk.a2;
import jk.d1;
import jk.e2;
import jk.n0;
import jk.o0;
import jk.p0;
import k9.b;
import lj.e0;
import lj.j;
import lj.k;
import lj.s;
import oj.g;
import qj.f;
import qj.l;
import yj.p;
import yj.q;

public final class ServiceMatterCommissioning extends Service implements b.InterfaceC0278b {
    private final j i = k.b(new a());
    private final j q = k.b(new b());
    private final a0 r;
    private final n0 s;

    static final class a extends q implements xj.a<k9.b> {
        a() {
            super(0);
        }

        public final k9.b invoke() {
            k9.b a = new b.a(ServiceMatterCommissioning.this).b(ServiceMatterCommissioning.this).a();
            p.h(a, "build(...)");
            return a;
        }
    }

    static final class b extends q implements xj.a<ChipDeviceController> {
        b() {
            super(0);
        }

        public final ChipDeviceController invoke() {
            ChipDeviceController q = i.q(ServiceMatterCommissioning.this);
            ServiceMatterCommissioning.this.h(q);
            return q;
        }
    }

    @f(c = "com.joaomgcd.oldtaskercompat.matter.ServiceMatterCommissioning$onCommissioningRequested$1", f = "ServiceMatterCommissioning.kt", l = {m.f154wc, m.Ac, 74, 76, 81}, m = "invokeSuspend")
    static final class c extends l implements xj.p<n0, oj.d<? super e0>, Object> {
        Object t;
        int u;
        final String v;
        final ServiceMatterCommissioning w;
        final long x;
        final int y;
        final long z;

        @f(c = "com.joaomgcd.oldtaskercompat.matter.ServiceMatterCommissioning$onCommissioningRequested$1$1", f = "ServiceMatterCommissioning.kt", l = {m.f154wc}, m = "invokeSuspend")
        static final class a extends l implements xj.l<oj.d<? super e0>, Object> {
            int t;
            final ServiceMatterCommissioning u;

            a(ServiceMatterCommissioning serviceMatterCommissioning, oj.d<? super a> dVar) {
                super(1, dVar);
                this.u = serviceMatterCommissioning;
            }

            public final Object r(Object obj) {
                Object c = pj.b.c();
                int i = this.t;
                if (i == 0) {
                    s.b(obj);
                    k9.b f = this.u.f();
                    this.t = 1;
                    if (i.k(f, 1001, this) == c) {
                        return c;
                    }
                } else {
                    if (i != 1) {
                        throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                    }
                    s.b(obj);
                }
                return e0.a;
            }

            public final oj.d<e0> u(oj.d<?> dVar) {
                return new a(this.u, dVar);
            }

            public final Object invoke(oj.d<? super e0> dVar) {
                return u(dVar).r(e0.a);
            }
        }

        @f(c = "com.joaomgcd.oldtaskercompat.matter.ServiceMatterCommissioning$onCommissioningRequested$1$2", f = "ServiceMatterCommissioning.kt", l = {76}, m = "invokeSuspend")
        static final class b extends l implements xj.l<oj.d<? super e0>, Object> {
            int t;
            final ServiceMatterCommissioning u;

            b(ServiceMatterCommissioning serviceMatterCommissioning, oj.d<? super b> dVar) {
                super(1, dVar);
                this.u = serviceMatterCommissioning;
            }

            public final Object r(Object obj) {
                Object c = pj.b.c();
                int i = this.t;
                if (i == 0) {
                    s.b(obj);
                    k9.b f = this.u.f();
                    this.t = 1;
                    if (i.k(f, 1000, this) == c) {
                        return c;
                    }
                } else {
                    if (i != 1) {
                        throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                    }
                    s.b(obj);
                }
                return e0.a;
            }

            public final oj.d<e0> u(oj.d<?> dVar) {
                return new b(this.u, dVar);
            }

            public final Object invoke(oj.d<? super e0> dVar) {
                return u(dVar).r(e0.a);
            }
        }

        c(String str, ServiceMatterCommissioning serviceMatterCommissioning, long j, int i, long j2, oj.d<? super c> dVar) {
            super(2, dVar);
            this.v = str;
            this.w = serviceMatterCommissioning;
            this.x = j;
            this.y = i;
            this.z = j2;
        }

        public final oj.d<e0> k(Object obj, oj.d<?> dVar) {
            return new c(this.v, this.w, this.x, this.y, this.z, dVar);
        }

        public final java.lang.Object r(java.lang.Object r17) {
            throw new UnsupportedOperationException("Method not decompiled: com.joaomgcd.oldtaskercompat.matter.ServiceMatterCommissioning.c.r(java.lang.Object):java.lang.Object");
        }

        public final Object l(n0 n0Var, oj.d<? super e0> dVar) {
            return k(n0Var, dVar).r(e0.a);
        }
    }

    @f(c = "com.joaomgcd.oldtaskercompat.matter.ServiceMatterCommissioning$setDeviceAttestationDelegate$1$1", f = "ServiceMatterCommissioning.kt", l = {}, m = "invokeSuspend")
    static final class d extends l implements xj.p<n0, oj.d<? super e0>, Object> {
        int t;
        final ChipDeviceController u;
        final long v;

        d(ChipDeviceController chipDeviceController, long j, oj.d<? super d> dVar) {
            super(2, dVar);
            this.u = chipDeviceController;
            this.v = j;
        }

        public final oj.d<e0> k(Object obj, oj.d<?> dVar) {
            return new d(this.u, this.v, dVar);
        }

        public final Object r(Object obj) {
            pj.b.c();
            if (this.t != 0) {
                throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
            }
            s.b(obj);
            this.u.continueCommissioning(this.v, true);
            return e0.a;
        }

        public final Object l(n0 n0Var, oj.d<? super e0> dVar) {
            return k(n0Var, dVar).r(e0.a);
        }
    }

    @f(c = "com.joaomgcd.oldtaskercompat.matter.ServiceMatterCommissioning$setDeviceAttestationDelegate$1$2", f = "ServiceMatterCommissioning.kt", l = {}, m = "invokeSuspend")
    static final class e extends l implements xj.p<n0, oj.d<? super e0>, Object> {
        int t;
        final ChipDeviceController u;
        final long v;

        e(ChipDeviceController chipDeviceController, long j, oj.d<? super e> dVar) {
            super(2, dVar);
            this.u = chipDeviceController;
            this.v = j;
        }

        public final oj.d<e0> k(Object obj, oj.d<?> dVar) {
            return new e(this.u, this.v, dVar);
        }

        public final Object r(Object obj) {
            pj.b.c();
            if (this.t != 0) {
                throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
            }
            s.b(obj);
            this.u.continueCommissioning(this.v, true);
            return e0.a;
        }

        public final Object l(n0 n0Var, oj.d<? super e0> dVar) {
            return k(n0Var, dVar).r(e0.a);
        }
    }

    public ServiceMatterCommissioning() {
        a0 b2 = e2.b((a2) null, 1, (Object) null);
        this.r = b2;
        this.s = o0.a(d1.c().V(b2));
    }

    public final k9.b f() {
        return (k9.b) this.i.getValue();
    }

    public final ChipDeviceController g() {
        return (ChipDeviceController) this.q.getValue();
    }

    public final void h(final ChipDeviceController chipDeviceController) {
        chipDeviceController.setDeviceAttestationDelegate(60, new DeviceAttestationDelegate() {
            @Override
            public final void onDeviceAttestationCompleted(long j, AttestationInfo attestationInfo, int i) {
                ServiceMatterCommissioning.i(ServiceMatterCommissioning.this, chipDeviceController, j, attestationInfo, i);
            }
        });
    }

    public static final void i(ServiceMatterCommissioning serviceMatterCommissioning, ChipDeviceController chipDeviceController, long j, AttestationInfo attestationInfo, int i) {
        p.i(serviceMatterCommissioning, "this$0");
        p.i(chipDeviceController, "$this_setDeviceAttestationDelegate");
        com.joaomgcd.oldtaskercompat.matter.b.d("Device attestation errorCode: " + i + ", Look at 'src/credentials/attestation_verifier/DeviceAttestationVerifier.h' AttestationVerificationResult enum to understand the errors", null, 2, null);
        if (i == 0) {
            com.joaomgcd.oldtaskercompat.matter.b.d("DeviceAttestationDelegate: Success on device attestation.", null, 2, null);
            jk.i.d(serviceMatterCommissioning.s, (g) null, (p0) null, new d(chipDeviceController, j, null), 3, (Object) null);
            return;
        }
        com.joaomgcd.oldtaskercompat.matter.b.d("DeviceAttestationDelegate: Error on device attestation [" + i + "].", null, 2, null);
        Log.i("MatterHA", "Ignoring attestation failure.");
        jk.i.d(serviceMatterCommissioning.s, (g) null, (p0) null, new e(chipDeviceController, j, null), 3, (Object) null);
    }

    @Override
    public void a(CommissioningRequestMetadata commissioningRequestMetadata) {
        p.i(commissioningRequestMetadata, "metadata");
        com.joaomgcd.oldtaskercompat.matter.b.d("Commission Request: " + commissioningRequestMetadata, null, 2, null);
        jk.i.d(this.s, (g) null, (p0) null, new c(commissioningRequestMetadata.e().e().getHostAddress(), this, com.joaomgcd.oldtaskercompat.matter.b.b(), commissioningRequestMetadata.e().f(), commissioningRequestMetadata.f(), null), 3, (Object) null);
    }

    @Override
    public IBinder onBind(Intent intent) {
        p.i(intent, "intent");
        IBinder asBinder = f().asBinder();
        p.h(asBinder, "asBinder(...)");
        return asBinder;
    }

    @Override
    public void onDestroy() {
        super.onDestroy();
        a2.a.a(this.r, (CancellationException) null, 1, (Object) null);
    }
}