package androidx.compose.runtime.snapshots.tooling;

import J4.c;
import J4.e;
import androidx.compose.runtime.ExperimentalComposeRuntimeApi;
import androidx.compose.runtime.collection.ScatterSetWrapperKt;
import androidx.compose.runtime.external.kotlinx.collections.immutable.ExtensionsKt;
import androidx.compose.runtime.external.kotlinx.collections.immutable.PersistentList;
import androidx.compose.runtime.snapshots.ObserverHandle;
import androidx.compose.runtime.snapshots.Snapshot;
import androidx.compose.runtime.snapshots.SnapshotKt;
import androidx.compose.runtime.snapshots.a;
import androidx.compose.runtime.snapshots.b;
import java.util.LinkedHashMap;
import java.util.Map;
import java.util.Set;
import n.Z;
import w4.C3137A;
import w4.k;
import x4.C3224A;

/* JADX INFO: loaded from: classes.dex */
public final class SnapshotObserverKt {
    private static PersistentList<? extends SnapshotObserver> observers;

    @ExperimentalComposeRuntimeApi
    public static final <R extends Snapshot> R creatingSnapshot(Snapshot snapshot, c cVar, c cVar2, boolean z6, e eVar) {
        Map map;
        PersistentList persistentList = observers;
        if (persistentList != null) {
            k kVarMergeObservers = mergeObservers(persistentList, snapshot, z6, cVar, cVar2);
            SnapshotInstanceObservers snapshotInstanceObservers = (SnapshotInstanceObservers) kVarMergeObservers.f25469a;
            c readObserver = snapshotInstanceObservers.getReadObserver();
            cVar2 = snapshotInstanceObservers.getWriteObserver();
            map = (Map) kVarMergeObservers.f25470b;
            cVar = readObserver;
        } else {
            map = null;
        }
        R r5 = (R) eVar.invoke(cVar, cVar2);
        if (persistentList != null) {
            dispatchCreatedObservers(persistentList, snapshot, r5, map);
        }
        return r5;
    }

    @ExperimentalComposeRuntimeApi
    public static final void dispatchCreatedObservers(PersistentList<? extends SnapshotObserver> persistentList, Snapshot snapshot, Snapshot snapshot2, Map<SnapshotObserver, SnapshotInstanceObservers> map) {
        int size = persistentList.size();
        for (int i6 = 0; i6 < size; i6++) {
            SnapshotObserver snapshotObserver = persistentList.get(i6);
            snapshotObserver.onCreated(snapshot2, snapshot, map != null ? map.get(snapshotObserver) : null);
        }
    }

    public static final void dispatchObserverOnApplied(Snapshot snapshot, Z z6) {
        Set<? extends Object> setWrapIntoSet;
        PersistentList<? extends SnapshotObserver> persistentList = observers;
        if (persistentList == null || persistentList.isEmpty()) {
            return;
        }
        if (z6 == null || (setWrapIntoSet = ScatterSetWrapperKt.wrapIntoSet(z6)) == null) {
            setWrapIntoSet = C3224A.f26032a;
        }
        int size = persistentList.size();
        for (int i6 = 0; i6 < size; i6++) {
            persistentList.get(i6).onApplied(snapshot, setWrapIntoSet);
        }
    }

    public static final void dispatchObserverOnPreDispose(Snapshot snapshot) {
        PersistentList<? extends SnapshotObserver> persistentList = observers;
        if (persistentList != null) {
            int size = persistentList.size();
            for (int i6 = 0; i6 < size; i6++) {
                persistentList.get(i6).onPreDispose(snapshot);
            }
        }
    }

    @ExperimentalComposeRuntimeApi
    private static /* synthetic */ void getObservers$annotations() {
    }

    private static final c mergeObservers(c cVar, c cVar2) {
        return (cVar == null || cVar2 == null) ? cVar == null ? cVar2 : cVar : new b(2, cVar, cVar2);
    }

    /* JADX INFO: Access modifiers changed from: private */
    public static final C3137A mergeObservers$lambda$1(c cVar, c cVar2, Object obj) {
        cVar.invoke(obj);
        cVar2.invoke(obj);
        return C3137A.f25453a;
    }

    @ExperimentalComposeRuntimeApi
    public static final ObserverHandle observeSnapshots(Snapshot.Companion companion, SnapshotObserver snapshotObserver) {
        synchronized (SnapshotKt.getLock()) {
            try {
                PersistentList<? extends SnapshotObserver> persistentListPersistentListOf = observers;
                if (persistentListPersistentListOf == null) {
                    persistentListPersistentListOf = ExtensionsKt.persistentListOf();
                }
                observers = persistentListPersistentListOf.add(snapshotObserver);
            } catch (Throwable th) {
                throw th;
            }
        }
        return new a(snapshotObserver, 2);
    }

    /* JADX INFO: Access modifiers changed from: private */
    public static final void observeSnapshots$lambda$1(SnapshotObserver snapshotObserver) {
        synchronized (SnapshotKt.getLock()) {
            try {
                PersistentList<? extends SnapshotObserver> persistentList = observers;
                PersistentList<? extends SnapshotObserver> persistentList2 = null;
                PersistentList<? extends SnapshotObserver> persistentListRemove = persistentList != null ? persistentList.remove(snapshotObserver) : null;
                if (persistentListRemove != null && !persistentListRemove.isEmpty()) {
                    persistentList2 = persistentListRemove;
                }
                observers = persistentList2;
            } catch (Throwable th) {
                throw th;
            }
        }
    }

    @ExperimentalComposeRuntimeApi
    public static final k mergeObservers(PersistentList<? extends SnapshotObserver> persistentList, Snapshot snapshot, boolean z6, c cVar, c cVar2) {
        int size = persistentList.size();
        LinkedHashMap linkedHashMap = null;
        for (int i6 = 0; i6 < size; i6++) {
            SnapshotObserver snapshotObserver = persistentList.get(i6);
            SnapshotInstanceObservers snapshotInstanceObserversOnPreCreate = snapshotObserver.onPreCreate(snapshot, z6);
            if (snapshotInstanceObserversOnPreCreate != null) {
                cVar = mergeObservers(snapshotInstanceObserversOnPreCreate.getReadObserver(), cVar);
                cVar2 = mergeObservers(snapshotInstanceObserversOnPreCreate.getWriteObserver(), cVar2);
                if (linkedHashMap == null) {
                    linkedHashMap = new LinkedHashMap();
                }
                linkedHashMap.put(snapshotObserver, snapshotInstanceObserversOnPreCreate);
            }
        }
        return new k(new SnapshotInstanceObservers(cVar, cVar2), linkedHashMap);
    }
}