package coil.decode;

import androidx.navigation.C1134i;
import coil.decode.ImageSource;
import coil.util.Utils;
import java.io.File;
import kotlin.jvm.internal.o;
import n2.AbstractC2613d;
import p5.AbstractC2732b;
import p5.AbstractC2749t;
import p5.G;
import p5.I;
import p5.InterfaceC2742l;
import p5.J;

/* JADX INFO: loaded from: classes.dex */
public final class SourceImageSource extends ImageSource {
    private J4.a cacheDirectoryFactory;
    private G file;
    private boolean isClosed;
    private final ImageSource.Metadata metadata;
    private InterfaceC2742l source;

    public SourceImageSource(InterfaceC2742l interfaceC2742l, J4.a aVar, ImageSource.Metadata metadata) {
        super(null);
        this.metadata = metadata;
        this.source = interfaceC2742l;
        this.cacheDirectoryFactory = aVar;
    }

    private final void assertNotClosed() {
        if (this.isClosed) {
            throw new IllegalStateException("closed");
        }
    }

    private final G createTempFile() {
        J4.a aVar = this.cacheDirectoryFactory;
        o.e(aVar);
        File file = (File) aVar.invoke();
        if (!file.isDirectory()) {
            throw new IllegalStateException("cacheDirectory must be a directory.");
        }
        String str = G.f23047b;
        return C1134i.p(File.createTempFile("tmp", null, file));
    }

    @Override // java.io.Closeable, java.lang.AutoCloseable
    public synchronized void close() {
        try {
            this.isClosed = true;
            InterfaceC2742l interfaceC2742l = this.source;
            if (interfaceC2742l != null) {
                Utils.closeQuietly(interfaceC2742l);
            }
            G g6 = this.file;
            if (g6 != null) {
                getFileSystem().delete(g6);
            }
        } catch (Throwable th) {
            throw th;
        }
    }

    @Override // coil.decode.ImageSource
    public synchronized G file() {
        Throwable th;
        assertNotClosed();
        G g6 = this.file;
        if (g6 != null) {
            return g6;
        }
        G gCreateTempFile = createTempFile();
        I iB = AbstractC2732b.b(getFileSystem().sink(gCreateTempFile, false));
        try {
            InterfaceC2742l interfaceC2742l = this.source;
            o.e(interfaceC2742l);
            iB.q(interfaceC2742l);
            try {
                iB.close();
                th = null;
            } catch (Throwable th2) {
                th = th2;
            }
        } catch (Throwable th3) {
            try {
                iB.close();
            } catch (Throwable th4) {
                AbstractC2613d.b(th3, th4);
            }
            th = th3;
        }
        if (th != null) {
            throw th;
        }
        this.source = null;
        this.file = gCreateTempFile;
        this.cacheDirectoryFactory = null;
        return gCreateTempFile;
    }

    @Override // coil.decode.ImageSource
    public synchronized G fileOrNull() {
        assertNotClosed();
        return this.file;
    }

    @Override // coil.decode.ImageSource
    public AbstractC2749t getFileSystem() {
        return AbstractC2749t.SYSTEM;
    }

    @Override // coil.decode.ImageSource
    public ImageSource.Metadata getMetadata() {
        return this.metadata;
    }

    @Override // coil.decode.ImageSource
    public synchronized InterfaceC2742l source() {
        assertNotClosed();
        InterfaceC2742l interfaceC2742l = this.source;
        if (interfaceC2742l != null) {
            return interfaceC2742l;
        }
        AbstractC2749t fileSystem = getFileSystem();
        G g6 = this.file;
        o.e(g6);
        J jC = AbstractC2732b.c(fileSystem.source(g6));
        this.source = jC;
        return jC;
    }

    @Override // coil.decode.ImageSource
    public InterfaceC2742l sourceOrNull() {
        return source();
    }
}