正在查看： Dostt v1.0.89 应用的 m.java JAVA 源代码文件
本页面展示 JAVA 反编译生成的源代码文件，支持语法高亮显示。 仅供安全研究与技术分析使用，严禁用于任何非法用途。请遵守相关法律法规。
页面标题
页面副标题
Dostt v1.0.89 - m.java 源代码
package Xf;
import Cj.b0;
import Lg.C0712a;
import Lg.C0714c;
import Sh.t;
import Sh.x;
import android.annotation.SuppressLint;
import android.app.Activity;
import android.content.Context;
import android.content.Intent;
import android.net.Uri;
import android.os.Build;
import android.os.Bundle;
import android.os.Environment;
import android.os.StatFs;
import android.util.Base64;
import android.util.Log;
import com.google.firebase.perf.network.FirebasePerfOkHttpClient;
import expo.modules.filesystem.DeletingOptions;
import expo.modules.filesystem.DownloadOptions;
import expo.modules.filesystem.EncodingType;
import expo.modules.filesystem.FileSystemUploadOptions;
import expo.modules.filesystem.FileSystemUploadType;
import expo.modules.filesystem.InfoOptions;
import expo.modules.filesystem.MakeDirectoryOptions;
import expo.modules.filesystem.ReadingOptions;
import expo.modules.filesystem.RelocatingOptions;
import expo.modules.filesystem.WritingOptions;
import java.io.BufferedInputStream;
import java.io.ByteArrayOutputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.math.BigInteger;
import java.net.URLConnection;
import java.util.ArrayList;
import java.util.EnumSet;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import java.util.concurrent.TimeUnit;
import kotlin.Metadata;
import kotlin.Pair;
import kotlin.jvm.internal.AbstractC1735t;
import kotlin.jvm.internal.DefaultConstructorMarker;
import okhttp3.Call;
import okhttp3.Callback;
import okhttp3.Headers;
import okhttp3.Interceptor;
import okhttp3.MediaType;
import okhttp3.MultipartBody;
import okhttp3.OkHttpClient;
import okhttp3.Request;
import okhttp3.RequestBody;
import okhttp3.Response;
import okhttp3.ResponseBody;
import rg.EnumC1880c;
import rg.InterfaceC1879b;
@Metadata(d1 = {"\u0000Î\u0001\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0010\u000e\n\u0000\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\f\n\u0002\u0018\u0002\n\u0002\b\u0005\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0010\u000b\n\u0002\b\b\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u0001\n\u0002\b\u0005\n\u0002\u0010\t\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\b\n\n\u0002\u0010\u0012\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0010%\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\b\r\b\u0016\u0018\u00002\u00020\u0001:\u0005vwx\\`B\u0007¢\u0006\u0004\b\u0002\u0010\u0003J\u0013\u0010\u0006\u001a\u00020\u0005*\u00020\u0004H\u0002¢\u0006\u0004\b\u0006\u0010\u0007J\u0013\u0010\b\u001a\u00020\u0005*\u00020\u0004H\u0002¢\u0006\u0004\b\b\u0010\u0007J\u0017\u0010\u000b\u001a\u00020\u00052\u0006\u0010\n\u001a\u00020\tH\u0002¢\u0006\u0004\b\u000b\u0010\fJ!\u0010\u0011\u001a\n\u0012\u0004\u0012\u00020\u0010\u0018\u00010\u000f2\b\u0010\u000e\u001a\u0004\u0018\u00010\rH\u0002¢\u0006\u0004\b\u0011\u0010\u0012J\u001f\u0010\u0014\u001a\n\u0012\u0004\u0012\u00020\u0010\u0018\u00010\u000f2\u0006\u0010\u0013\u001a\u00020\u0004H\u0002¢\u0006\u0004\b\u0014\u0010\u0015J\u001d\u0010\u0016\u001a\b\u0012\u0004\u0012\u00020\u00100\u000f2\u0006\u0010\u0013\u001a\u00020\u0004H\u0002¢\u0006\u0004\b\u0016\u0010\u0015J'\u0010\u0019\u001a\u00020\u00052\u0006\u0010\u0013\u001a\u00020\u00042\u0006\u0010\u0017\u001a\u00020\u00102\u0006\u0010\u0018\u001a\u00020\rH\u0002¢\u0006\u0004\b\u0019\u0010\u001aJ\u001f\u0010\u001b\u001a\u00020\u00052\u0006\u0010\u0013\u001a\u00020\u00042\u0006\u0010\u0017\u001a\u00020\u0010H\u0002¢\u0006\u0004\b\u001b\u0010\u001cJ\u0017\u0010\u001e\u001a\u00020\u001d2\u0006\u0010\u0013\u001a\u00020\u0004H\u0002¢\u0006\u0004\b\u001e\u0010\u001fJ\u0019\u0010!\u001a\u00020\u001d2\b\u0010 \u001a\u0004\u0018\u00010\rH\u0003¢\u0006\u0004\b!\u0010\"J'\u0010(\u001a\u00020\u00052\u0006\u0010$\u001a\u00020#2\u0006\u0010%\u001a\u00020\t2\u0006\u0010'\u001a\u00020&H\u0002¢\u0006\u0004\b(\u0010)J\u0017\u0010+\u001a\u00020\u00042\u0006\u0010*\u001a\u00020\tH\u0002¢\u0006\u0004\b+\u0010,J/\u00104\u001a\u0002032\u0006\u0010-\u001a\u00020\r2\u0006\u0010.\u001a\u00020\r2\u0006\u00100\u001a\u00020/2\u0006\u00102\u001a\u000201H\u0002¢\u0006\u0004\b4\u00105J'\u00107\u001a\u0002062\u0006\u00100\u001a\u00020/2\u0006\u00102\u001a\u0002012\u0006\u0010*\u001a\u00020\tH\u0002¢\u0006\u0004\b7\u00108J\u001a\u0010<\u001a\u0004\u0018\u00010;2\u0006\u0010:\u001a\u000209H\u0082@¢\u0006\u0004\b<\u0010=J\u0017\u0010>\u001a\u00020\r2\u0006\u0010*\u001a\u00020\tH\u0002¢\u0006\u0004\b>\u0010?J\u0017\u0010@\u001a\u00020\u00052\u0006\u0010*\u001a\u00020\tH\u0002¢\u0006\u0004\b@\u0010\fJ\u0017\u0010B\u001a\u00020A2\u0006\u0010*\u001a\u00020\tH\u0002¢\u0006\u0004\bB\u0010CJ\u0017\u0010D\u001a\u00020\u001d2\u0006\u0010\u0013\u001a\u00020\u0004H\u0002¢\u0006\u0004\bD\u0010\u001fJ\u0017\u0010F\u001a\u00020E2\u0006\u0010\u0013\u001a\u00020\u0004H\u0002¢\u0006\u0004\bF\u0010GJ\u0019\u0010H\u001a\u0004\u0018\u00010#2\u0006\u0010\u0013\u001a\u00020\u0004H\u0002¢\u0006\u0004\bH\u0010IJ\u0013\u0010J\u001a\u00020\t*\u00020\u0004H\u0002¢\u0006\u0004\bJ\u0010KJ\u0017\u0010M\u001a\u00020\r2\u0006\u0010L\u001a\u00020\rH\u0002¢\u0006\u0004\bM\u0010NJ\u0017\u0010Q\u001a\u00020P2\u0006\u0010O\u001a\u00020\u001dH\u0002¢\u0006\u0004\bQ\u0010RJ\u0017\u0010V\u001a\u00020U2\u0006\u0010T\u001a\u00020SH\u0002¢\u0006\u0004\bV\u0010WJ\u000f\u0010Y\u001a\u00020XH\u0017¢\u0006\u0004\bY\u0010ZR\u0018\u0010^\u001a\u0004\u0018\u00010[8\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\b\\\u0010]R\u0018\u0010b\u001a\u0004\u0018\u00010_8\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\b`\u0010aR \u0010g\u001a\u000e\u0012\u0004\u0012\u00020\r\u0012\u0004\u0012\u00020d0c8\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\be\u0010fR\u0014\u0010k\u001a\u00020h8\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\bi\u0010jR\u0014\u0010o\u001a\u00020l8BX\u0082\u0004¢\u0006\u0006\u001a\u0004\bm\u0010nR\u0016\u0010r\u001a\u0004\u0018\u00010[8BX\u0082\u0004¢\u0006\u0006\u001a\u0004\bp\u0010qR\u0018\u0010u\u001a\u00020&*\u00020\u00048BX\u0082\u0004¢\u0006\u0006\u001a\u0004\bs\u0010t¨\u0006y"}, d2 = {"LXf/m;", "LFg/a;", "<init>", "()V", "Landroid/net/Uri;", "LSh/J;", "Q", "(Landroid/net/Uri;)V", "P", "Ljava/io/File;", "dir", "V", "(Ljava/io/File;)V", "", "path", "Ljava/util/EnumSet;", "Lrg/c;", "l0", "(Ljava/lang/String;)Ljava/util/EnumSet;", "uri", "n0", "(Landroid/net/Uri;)Ljava/util/EnumSet;", "m0", "permission", "errorMsg", "X", "(Landroid/net/Uri;Lrg/c;Ljava/lang/String;)V", "W", "(Landroid/net/Uri;Lrg/c;)V", "Ljava/io/InputStream;", "i0", "(Landroid/net/Uri;)Ljava/io/InputStream;", "resourceName", "j0", "(Ljava/lang/String;)Ljava/io/InputStream;", "LQ0/a;", "documentFile", "outputDir", "", "copy", "p0", "(LQ0/a;Ljava/io/File;Z)V", "file", "R", "(Ljava/io/File;)Landroid/net/Uri;", "url", "fileUriString", "Lexpo/modules/filesystem/FileSystemUploadOptions;", "options", "LXf/s;", "decorator", "Lokhttp3/Request;", "T", "(Ljava/lang/String;Ljava/lang/String;Lexpo/modules/filesystem/FileSystemUploadOptions;LXf/s;)Lokhttp3/Request;", "Lokhttp3/RequestBody;", "S", "(Lexpo/modules/filesystem/FileSystemUploadOptions;LXf/s;Ljava/io/File;)Lokhttp3/RequestBody;", "LXf/m$a;", "params", "", "U", "(LXf/m$a;LXh/d;)Ljava/lang/Object;", "h0", "(Ljava/io/File;)Ljava/lang/String;", "Y", "", "a0", "(Ljava/io/File;)J", "b0", "Ljava/io/OutputStream;", "f0", "(Landroid/net/Uri;)Ljava/io/OutputStream;", "d0", "(Landroid/net/Uri;)LQ0/a;", "o0", "(Landroid/net/Uri;)Ljava/io/File;", "uriStr", "k0", "(Ljava/lang/String;)Ljava/lang/String;", "inputStream", "", "c0", "(Ljava/io/InputStream;)[B", "Lokhttp3/Headers;", "headers", "Landroid/os/Bundle;", "q0", "(Lokhttp3/Headers;)Landroid/os/Bundle;", "LFg/c;", "g", "()LFg/c;", "Lokhttp3/OkHttpClient;", "d", "Lokhttp3/OkHttpClient;", "client", "Lwg/n;", "e", "Lwg/n;", "dirPermissionsRequest", "", "LXf/m$e;", "f", "Ljava/util/Map;", "taskHandlers", "LCj/M;", "o", "LCj/M;", "moduleCoroutineScope", "Landroid/content/Context;", "Z", "()Landroid/content/Context;", "context", "e0", "()Lokhttp3/OkHttpClient;", "okHttpClient", "g0", "(Landroid/net/Uri;)Z", "isSAFUri", "a", "b", "c", "expo-file-system_release"}, k = 1, mv = {1, 9, 0}, xi = 48)
public class m extends Fg.a {
private OkHttpClient client;
private wg.n dirPermissionsRequest;
private final Map taskHandlers = new HashMap();
private final Cj.M moduleCoroutineScope = Cj.N.a(b0.a());
public static final class A extends AbstractC1735t implements gi.a {
public static final A a = new A();
public A() {
super(0);
}
@Override
public final ni.p invoke() {
return kotlin.jvm.internal.M.p(MakeDirectoryOptions.class);
}
}
public static final class A0 extends AbstractC1735t implements gi.a {
public static final A0 a = new A0();
public A0() {
super(0);
}
@Override
public final ni.p invoke() {
return kotlin.jvm.internal.M.p(String.class);
}
}
public static final class B extends AbstractC1735t implements gi.l {
public B() {
super(1);
}
@Override
public final Object invoke(Object[] objArr) {
String c;
kotlin.jvm.internal.r.f(objArr, "<name for destructuring parameter 0>");
Object obj = objArr[0];
MakeDirectoryOptions makeDirectoryOptions = (MakeDirectoryOptions) objArr[1];
c = n.c((String) obj);
Uri parse = Uri.parse(c);
m mVar = m.this;
kotlin.jvm.internal.r.c(parse);
mVar.W(parse, EnumC1880c.WRITE);
if (!kotlin.jvm.internal.r.b(parse.getScheme(), "file")) {
throw new IOException("Unsupported scheme for location '" + parse + "'.");
}
File o0 = m.this.o0(parse);
boolean isDirectory = o0.isDirectory();
boolean intermediates = makeDirectoryOptions.getIntermediates();
if ((intermediates ? o0.mkdirs() : o0.mkdir()) || (intermediates && isDirectory)) {
return Sh.J.a;
}
throw new f(parse);
}
}
public static final class B0 extends AbstractC1735t implements gi.a {
public static final B0 a = new B0();
public B0() {
super(0);
}
@Override
public final ni.p invoke() {
return kotlin.jvm.internal.M.p(String.class);
}
}
public static final class C extends AbstractC1735t implements gi.p {
public C() {
super(2);
}
public final void a(Object[] objArr, wg.n promise) {
String c;
kotlin.jvm.internal.r.f(objArr, "<anonymous parameter 0>");
kotlin.jvm.internal.r.f(promise, "promise");
c = n.c((String) promise);
Uri parse = Uri.parse(c);
m mVar = m.this;
kotlin.jvm.internal.r.c(parse);
mVar.W(parse, EnumC1880c.READ);
if (!kotlin.jvm.internal.r.b(parse.getScheme(), "file")) {
if (m.this.g0(parse)) {
throw new r();
}
throw new IOException("Unsupported scheme for location '" + parse + "'.");
}
File[] listFiles = m.this.o0(parse).listFiles();
if (listFiles == null) {
throw new j(parse);
}
ArrayList arrayList = new ArrayList(listFiles.length);
int length = listFiles.length;
for (int i = 0; i < length; i++) {
File file = listFiles[i];
arrayList.add(file != null ? file.getName() : null);
}
}
@Override
public Object invoke(Object obj, Object obj2) {
a((Object[]) obj, (wg.n) obj2);
return Sh.J.a;
}
}
public static final class C0 extends AbstractC1735t implements gi.a {
public static final C0 a = new C0();
public C0() {
super(0);
}
@Override
public final ni.p invoke() {
return kotlin.jvm.internal.M.p(String.class);
}
}
public static final class D extends AbstractC1735t implements gi.a {
public static final D a = new D();
public D() {
super(0);
}
@Override
public final ni.p invoke() {
return kotlin.jvm.internal.M.g(String.class);
}
}
public static final class D0 extends AbstractC1735t implements gi.p {
public D0() {
super(2);
}
public final void a(Activity sender, Cg.j payload) {
kotlin.jvm.internal.r.f(sender, "sender");
kotlin.jvm.internal.r.f(payload, "payload");
int a = payload.a();
int b = payload.b();
Intent c = payload.c();
if (a != 5394 || m.this.dirPermissionsRequest == null) {
return;
}
Bundle bundle = new Bundle();
if (b != -1 || c == null) {
bundle.putBoolean("granted", false);
} else {
Uri data = c.getData();
int flags = c.getFlags() & 3;
if (data != null) {
m.this.f().z().getContentResolver().takePersistableUriPermission(data, flags);
}
bundle.putBoolean("granted", true);
bundle.putString("directoryUri", String.valueOf(data));
}
wg.n nVar = m.this.dirPermissionsRequest;
if (nVar != null) {
nVar.resolve(bundle);
}
m.this.dirPermissionsRequest = null;
}
@Override
public Object invoke(Object obj, Object obj2) {
a((Activity) obj, (Cg.j) obj2);
return Sh.J.a;
}
}
public static final class E extends AbstractC1735t implements gi.l {
public E() {
super(1);
}
@Override
public final Object invoke(Object[] objArr) {
String c;
kotlin.jvm.internal.r.f(objArr, "<name for destructuring parameter 0>");
c = n.c((String) objArr[0]);
Uri parse = Uri.parse(c);
m mVar = m.this;
kotlin.jvm.internal.r.c(parse);
mVar.W(parse, EnumC1880c.READ);
if (!kotlin.jvm.internal.r.b(parse.getScheme(), "file")) {
if (m.this.g0(parse)) {
throw new r();
}
throw new IOException("Unsupported scheme for location '" + parse + "'.");
}
File[] listFiles = m.this.o0(parse).listFiles();
if (listFiles == null) {
throw new j(parse);
}
ArrayList arrayList = new ArrayList(listFiles.length);
int length = listFiles.length;
for (int i = 0; i < length; i++) {
File file = listFiles[i];
arrayList.add(file != null ? file.getName() : null);
}
return arrayList;
}
}
public static final class E0 extends AbstractC1735t implements gi.a {
public E0() {
super(0);
}
public final void a() {
try {
m mVar = m.this;
File filesDir = mVar.Z().getFilesDir();
kotlin.jvm.internal.r.e(filesDir, "getFilesDir(...)");
mVar.V(filesDir);
m mVar2 = m.this;
File cacheDir = mVar2.Z().getCacheDir();
kotlin.jvm.internal.r.e(cacheDir, "getCacheDir(...)");
mVar2.V(cacheDir);
} catch (Exception e) {
e.printStackTrace();
}
}
@Override
public Object invoke() {
a();
return Sh.J.a;
}
}
public static final class F extends AbstractC1735t implements gi.l {
public F() {
super(1);
}
@Override
public final Object invoke(Object[] it) {
kotlin.jvm.internal.r.f(it, "it");
StatFs statFs = new StatFs(Environment.getDataDirectory().getAbsolutePath());
return Double.valueOf(mi.k.e(BigInteger.valueOf(statFs.getBlockCountLong()).multiply(BigInteger.valueOf(statFs.getBlockSizeLong())).doubleValue(), Math.pow(2.0d, 53.0d) - 1));
}
}
public static final class F0 extends AbstractC1735t implements gi.a {
public F0() {
super(0);
}
public final void a() {
String str;
try {
Cj.N.c(m.this.moduleCoroutineScope, new Nf.f(null, 1, null));
} catch (IllegalStateException unused) {
str = n.a;
Log.e(str, "The scope does not have a job in it");
}
}
@Override
public Object invoke() {
a();
return Sh.J.a;
}
}
public static final class G extends AbstractC1735t implements gi.l {
public G() {
super(1);
}
@Override
public final Object invoke(Object[] it) {
kotlin.jvm.internal.r.f(it, "it");
StatFs statFs = new StatFs(Environment.getDataDirectory().getAbsolutePath());
return Double.valueOf(mi.k.e(BigInteger.valueOf(statFs.getAvailableBlocksLong()).multiply(BigInteger.valueOf(statFs.getBlockSizeLong())).doubleValue(), Math.pow(2.0d, 53.0d) - 1));
}
}
public static final class G0 implements Interceptor {
final InterfaceC0870c a;
public G0(InterfaceC0870c interfaceC0870c) {
this.a = interfaceC0870c;
}
public final Response a(Interceptor.Chain chain) {
kotlin.jvm.internal.r.f(chain, "chain");
Response a = chain.a(chain.m());
return a.H().b(new C0872d(a.a(), this.a)).c();
}
}
public static final class H extends AbstractC1735t implements gi.p {
public H() {
super(2);
}
public final void a(Object[] objArr, wg.n promise) {
String c;
kotlin.jvm.internal.r.f(objArr, "<anonymous parameter 0>");
kotlin.jvm.internal.r.f(promise, "promise");
String str = (String) promise;
c = n.c(str);
Uri parse = Uri.parse(c);
m mVar = m.this;
kotlin.jvm.internal.r.c(parse);
mVar.W(parse, EnumC1880c.WRITE);
m.this.W(parse, EnumC1880c.READ);
m.this.P(parse);
if (!kotlin.jvm.internal.r.b(parse.getScheme(), "file")) {
throw new q(str);
}
m.this.R(m.this.o0(parse)).toString();
}
@Override
public Object invoke(Object obj, Object obj2) {
a((Object[]) obj, (wg.n) obj2);
return Sh.J.a;
}
}
static final class H0 extends kotlin.coroutines.jvm.internal.l implements gi.p {
int a;
final C0866a b;
final m c;
H0(C0866a c0866a, m mVar, Xh.d dVar) {
super(2, dVar);
this.b = c0866a;
this.c = mVar;
}
@Override
public final Object invoke(Cj.M m, Xh.d dVar) {
return ((H0) create(m, dVar)).invokeSuspend(Sh.J.a);
}
@Override
public final Xh.d create(Object obj, Xh.d dVar) {
return new H0(this.b, this.c, dVar);
}
@Override
public final Object invokeSuspend(Object obj) {
String str;
String str2;
Yh.b.e();
if (this.a != 0) {
throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
}
t.b(obj);
C0866a c0866a = this.b;
DownloadOptions a = c0866a.a();
Call b = c0866a.b();
File c = c0866a.c();
boolean d = c0866a.d();
wg.n e = c0866a.e();
try {
Response execute = FirebasePerfOkHttpClient.execute(b);
ResponseBody a2 = execute.a();
kotlin.jvm.internal.r.c(a2);
BufferedInputStream bufferedInputStream = new BufferedInputStream(a2.a());
FileOutputStream fileOutputStream = new FileOutputStream(c, d);
byte[] bArr = new byte[1024];
kotlin.jvm.internal.J j = new kotlin.jvm.internal.J();
while (true) {
int read = bufferedInputStream.read(bArr);
j.a = read;
if (read == -1) {
break;
}
fileOutputStream.write(bArr, 0, read);
}
Bundle bundle = new Bundle();
m mVar = this.c;
bundle.putString("uri", Uri.fromFile(c).toString());
bundle.putInt("status", execute.j());
bundle.putBundle("headers", mVar.q0(execute.t()));
Boolean a3 = kotlin.coroutines.jvm.internal.b.a(a.getMd5());
if (!a3.booleanValue()) {
a3 = null;
}
if (a3 != null) {
bundle.putString("md5", mVar.h0(c));
}
execute.close();
e.resolve(bundle);
} catch (Exception e2) {
if (b.H()) {
e.resolve(null);
return null;
}
String message = e2.getMessage();
if (message != null) {
str2 = n.a;
kotlin.coroutines.jvm.internal.b.b(Log.e(str2, message));
}
str = n.a;
kotlin.jvm.internal.r.e(str, "access$getTAG$p(...)");
e.reject(str, e2.getMessage(), e2);
}
return null;
}
}
public static final class I extends AbstractC1735t implements gi.a {
public static final I a = new I();
public I() {
super(0);
}
@Override
public final ni.p invoke() {
return kotlin.jvm.internal.M.p(String.class);
}
}
public static final class J extends AbstractC1735t implements gi.a {
public static final J a = new J();
public J() {
super(0);
}
@Override
public final ni.p invoke() {
return kotlin.jvm.internal.M.p(InfoOptions.class);
}
}
public static final class K extends AbstractC1735t implements gi.l {
public K() {
super(1);
}
@Override
public final Object invoke(Object[] objArr) {
String c;
kotlin.jvm.internal.r.f(objArr, "<name for destructuring parameter 0>");
String str = (String) objArr[0];
c = n.c(str);
Uri parse = Uri.parse(c);
m mVar = m.this;
kotlin.jvm.internal.r.c(parse);
mVar.W(parse, EnumC1880c.WRITE);
m.this.W(parse, EnumC1880c.READ);
m.this.P(parse);
if (!kotlin.jvm.internal.r.b(parse.getScheme(), "file")) {
throw new q(str);
}
return m.this.R(m.this.o0(parse)).toString();
}
}
public static final class L extends AbstractC1735t implements gi.p {
public L() {
super(2);
}
public final void a(Object[] objArr, wg.n promise) {
String c;
kotlin.jvm.internal.r.f(objArr, "<anonymous parameter 0>");
kotlin.jvm.internal.r.f(promise, "promise");
c = n.c((String) promise);
Uri parse = Uri.parse(c);
m mVar = m.this;
kotlin.jvm.internal.r.c(parse);
mVar.W(parse, EnumC1880c.READ);
if (!m.this.g0(parse)) {
throw new IOException("The URI '" + parse + "' is not a Storage Access Framework URI. Try using FileSystem.readDirectoryAsync instead.");
}
Q0.a h = Q0.a.h(m.this.Z(), parse);
if (h == null || !h.f() || !h.k()) {
throw new j(parse);
}
Q0.a[] m = h.m();
kotlin.jvm.internal.r.e(m, "listFiles(...)");
ArrayList arrayList = new ArrayList(m.length);
for (Q0.a aVar : m) {
arrayList.add(aVar.j().toString());
}
}
@Override
public Object invoke(Object obj, Object obj2) {
a((Object[]) obj, (wg.n) obj2);
return Sh.J.a;
}
}
public static final class M extends AbstractC1735t implements gi.a {
public static final M a = new M();
public M() {
super(0);
}
@Override
public final ni.p invoke() {
return kotlin.jvm.internal.M.p(String.class);
}
}
public static final class N extends AbstractC1735t implements gi.l {
public N() {
super(1);
}
@Override
public final Object invoke(Object[] objArr) {
String c;
kotlin.jvm.internal.r.f(objArr, "<name for destructuring parameter 0>");
c = n.c((String) objArr[0]);
Uri parse = Uri.parse(c);
m mVar = m.this;
kotlin.jvm.internal.r.c(parse);
mVar.W(parse, EnumC1880c.READ);
if (!m.this.g0(parse)) {
throw new IOException("The URI '" + parse + "' is not a Storage Access Framework URI. Try using FileSystem.readDirectoryAsync instead.");
}
Q0.a h = Q0.a.h(m.this.Z(), parse);
if (h == null || !h.f() || !h.k()) {
throw new j(parse);
}
Q0.a[] m = h.m();
kotlin.jvm.internal.r.e(m, "listFiles(...)");
ArrayList arrayList = new ArrayList(m.length);
for (Q0.a aVar : m) {
arrayList.add(aVar.j().toString());
}
return arrayList;
}
}
public static final class O extends AbstractC1735t implements gi.a {
public static final O a = new O();
public O() {
super(0);
}
@Override
public final ni.p invoke() {
return kotlin.jvm.internal.M.p(String.class);
}
}
public static final class P extends AbstractC1735t implements gi.a {
public static final P a = new P();
public P() {
super(0);
}
@Override
public final ni.p invoke() {
return kotlin.jvm.internal.M.p(String.class);
}
}
public static final class Q extends AbstractC1735t implements gi.l {
public Q() {
super(1);
}
@Override
public final Object invoke(Object[] objArr) {
String c;
kotlin.jvm.internal.r.f(objArr, "<name for destructuring parameter 0>");
Object obj = objArr[0];
String str = (String) objArr[1];
c = n.c((String) obj);
Uri parse = Uri.parse(c);
m mVar = m.this;
kotlin.jvm.internal.r.c(parse);
mVar.W(parse, EnumC1880c.WRITE);
if (!m.this.g0(parse)) {
throw new IOException("The URI '" + parse + "' is not a Storage Access Framework URI. Try using FileSystem.makeDirectoryAsync instead.");
}
Q0.a d0 = m.this.d0(parse);
if (d0 != null && !d0.k()) {
throw new f(parse);
}
Q0.a c2 = d0 != null ? d0.c(str) : null;
if (c2 == null) {
throw new f(null);
}
kotlin.jvm.internal.r.c(c2);
return c2.j().toString();
}
}
public static final class R extends AbstractC1735t implements gi.a {
public static final R a = new R();
public R() {
super(0);
}
@Override
public final ni.p invoke() {
return kotlin.jvm.internal.M.p(String.class);
}
}
public static final class S extends AbstractC1735t implements gi.a {
public static final S a = new S();
public S() {
super(0);
}
@Override
public final ni.p invoke() {
return kotlin.jvm.internal.M.p(String.class);
}
}
public static final class T extends AbstractC1735t implements gi.a {
public static final T a = new T();
public T() {
super(0);
}
@Override
public final ni.p invoke() {
return kotlin.jvm.internal.M.p(String.class);
}
}
public static final class U extends AbstractC1735t implements gi.l {
public U() {
super(1);
}
@Override
public final java.lang.Object invoke(java.lang.Object[] r15) {
throw new UnsupportedOperationException("Method not decompiled: Xf.m.U.invoke(java.lang.Object[]):java.lang.Object");
}
}
public static final class V extends AbstractC1735t implements gi.l {
public V() {
super(1);
}
@Override
public final Object invoke(Object[] objArr) {
String c;
kotlin.jvm.internal.r.f(objArr, "<name for destructuring parameter 0>");
Object obj = objArr[0];
Object obj2 = objArr[1];
String str = (String) objArr[2];
String str2 = (String) obj2;
c = n.c((String) obj);
Uri parse = Uri.parse(c);
m mVar = m.this;
kotlin.jvm.internal.r.c(parse);
mVar.W(parse, EnumC1880c.WRITE);
if (!m.this.g0(parse)) {
throw new IOException("The URI '" + parse + "' is not a Storage Access Framework URI.");
}
Q0.a d0 = m.this.d0(parse);
if (d0 == null || !d0.k()) {
throw new g(parse);
}
Q0.a d = d0.d(str, str2);
if (d == null) {
throw new g(null);
}
kotlin.jvm.internal.r.c(d);
return d.j().toString();
}
}
public static final class W extends AbstractC1735t implements gi.p {
public W() {
super(2);
}
public final void a(Object[] objArr, wg.n promise) {
Call a;
kotlin.jvm.internal.r.f(objArr, "<anonymous parameter 0>");
kotlin.jvm.internal.r.f(promise, "promise");
C0874e c0874e = (C0874e) m.this.taskHandlers.get((String) promise);
if (c0874e == null || (a = c0874e.a()) == null) {
return;
}
a.cancel();
}
@Override
public Object invoke(Object obj, Object obj2) {
a((Object[]) obj, (wg.n) obj2);
return Sh.J.a;
}
}
public static final class X extends AbstractC1735t implements gi.a {
public static final X a = new X();
public X() {
super(0);
}
@Override
public final ni.p invoke() {
return kotlin.jvm.internal.M.p(String.class);
}
}
public static final class Y extends AbstractC1735t implements gi.l {
public Y() {
super(1);
}
@Override
public final Object invoke(Object[] objArr) {
Call a;
kotlin.jvm.internal.r.f(objArr, "<name for destructuring parameter 0>");
C0874e c0874e = (C0874e) m.this.taskHandlers.get((String) objArr[0]);
if (c0874e == null || (a = c0874e.a()) == null) {
return null;
}
a.cancel();
return Sh.J.a;
}
}
public static final class Z extends AbstractC1735t implements gi.p {
public Z() {
super(2);
}
public final void a(Object[] objArr, wg.n promise) {
kotlin.jvm.internal.r.f(objArr, "<anonymous parameter 0>");
kotlin.jvm.internal.r.f(promise, "promise");
String str = (String) promise;
C0874e c0874e = (C0874e) m.this.taskHandlers.get(str);
if (c0874e == null) {
throw new IOException("No download object available");
}
if (!(c0874e instanceof C0868b)) {
throw new h();
}
c0874e.a().cancel();
m.this.taskHandlers.remove(str);
new Bundle().putString("resumeData", String.valueOf(m.this.o0(((C0868b) c0874e).b()).length()));
}
@Override
public Object invoke(Object obj, Object obj2) {
a((Object[]) obj, (wg.n) obj2);
return Sh.J.a;
}
}
private static final class C0866a {
private final DownloadOptions a;
private final Call b;
private final File c;
private final boolean d;
private final wg.n e;
public C0866a(DownloadOptions options, Call call, File file, boolean z, wg.n promise) {
kotlin.jvm.internal.r.f(options, "options");
kotlin.jvm.internal.r.f(call, "call");
kotlin.jvm.internal.r.f(file, "file");
kotlin.jvm.internal.r.f(promise, "promise");
this.a = options;
this.b = call;
this.c = file;
this.d = z;
this.e = promise;
}
public final DownloadOptions a() {
return this.a;
}
public final Call b() {
return this.b;
}
public final File c() {
return this.c;
}
public final boolean d() {
return this.d;
}
public final wg.n e() {
return this.e;
}
public boolean equals(Object obj) {
if (this == obj) {
return true;
}
if (!(obj instanceof C0866a)) {
return false;
}
C0866a c0866a = (C0866a) obj;
return kotlin.jvm.internal.r.b(this.a, c0866a.a) && kotlin.jvm.internal.r.b(this.b, c0866a.b) && kotlin.jvm.internal.r.b(this.c, c0866a.c) && this.d == c0866a.d && kotlin.jvm.internal.r.b(this.e, c0866a.e);
}
public int hashCode() {
return (((((((this.a.hashCode() * 31) + this.b.hashCode()) * 31) + this.c.hashCode()) * 31) + Boolean.hashCode(this.d)) * 31) + this.e.hashCode();
}
public String toString() {
return "DownloadResumableTaskParams(options=" + this.a + ", call=" + this.b + ", file=" + this.c + ", isResume=" + this.d + ", promise=" + this.e + ")";
}
}
public static final class C0867a0 extends AbstractC1735t implements gi.a {
public static final C0867a0 a = new C0867a0();
public C0867a0() {
super(0);
}
@Override
public final ni.p invoke() {
return kotlin.jvm.internal.M.p(String.class);
}
}
private static final class C0868b extends C0874e {
private final Uri b;
public C0868b(Uri fileUri, Call call) {
super(call);
kotlin.jvm.internal.r.f(fileUri, "fileUri");
kotlin.jvm.internal.r.f(call, "call");
this.b = fileUri;
}
public final Uri b() {
return this.b;
}
}
public static final class C0869b0 extends AbstractC1735t implements gi.l {
public C0869b0() {
super(1);
}
@Override
public final Object invoke(Object[] objArr) {
kotlin.jvm.internal.r.f(objArr, "<name for destructuring parameter 0>");
String str = (String) objArr[0];
C0874e c0874e = (C0874e) m.this.taskHandlers.get(str);
if (c0874e == null) {
throw new IOException("No download object available");
}
if (!(c0874e instanceof C0868b)) {
throw new h();
}
c0874e.a().cancel();
m.this.taskHandlers.remove(str);
File o0 = m.this.o0(((C0868b) c0874e).b());
Bundle bundle = new Bundle();
bundle.putString("resumeData", String.valueOf(o0.length()));
return bundle;
}
}
public interface InterfaceC0870c {
void a(long j, long j2, boolean z);
}
public static final class C0871c0 extends AbstractC1735t implements gi.a {
public static final C0871c0 a = new C0871c0();
public C0871c0() {
super(0);
}
@Override
public final ni.p invoke() {
return kotlin.jvm.internal.M.p(String.class);
}
}
private static final class C0872d extends ResponseBody {
private final ResponseBody c;
private final InterfaceC0870c d;
private nk.g e;
public static final class a extends nk.n {
private long b;
final C0872d c;
a(nk.V v, C0872d c0872d) {
super(v);
this.c = c0872d;
}
public long J1(nk.e sink, long j) {
kotlin.jvm.internal.r.f(sink, "sink");
long J1 = super.J1(sink, j);
this.b += J1 != -1 ? J1 : 0L;
InterfaceC0870c interfaceC0870c = this.c.d;
long j2 = this.b;
ResponseBody responseBody = this.c.c;
interfaceC0870c.a(j2, responseBody != null ? responseBody.j() : -1L, J1 == -1);
return J1;
}
}
public C0872d(ResponseBody responseBody, InterfaceC0870c progressListener) {
kotlin.jvm.internal.r.f(progressListener, "progressListener");
this.c = responseBody;
this.d = progressListener;
}
private final nk.V u(nk.V v) {
return new a(v, this);
}
public long j() {
ResponseBody responseBody = this.c;
if (responseBody != null) {
return responseBody.j();
}
return -1L;
}
public MediaType k() {
ResponseBody responseBody = this.c;
if (responseBody != null) {
return responseBody.k();
}
return null;
}
public nk.g m() {
nk.g gVar = this.e;
if (gVar != null) {
return gVar;
}
ResponseBody responseBody = this.c;
kotlin.jvm.internal.r.c(responseBody);
return nk.G.d(u(responseBody.m()));
}
}
public static final class C0873d0 extends AbstractC1735t implements gi.a {
public static final C0873d0 a = new C0873d0();
public C0873d0() {
super(0);
}
@Override
public final ni.p invoke() {
return kotlin.jvm.internal.M.p(ReadingOptions.class);
}
}
private static class C0874e {
private final Call a;
public C0874e(Call call) {
kotlin.jvm.internal.r.f(call, "call");
this.a = call;
}
public final Call a() {
return this.a;
}
}
public static final class C0875e0 extends AbstractC1735t implements gi.l {
public C0875e0() {
super(1);
}
@Override
public final Object invoke(Object[] objArr) {
String c;
String encodeToString;
kotlin.jvm.internal.r.f(objArr, "<name for destructuring parameter 0>");
Object obj = objArr[0];
ReadingOptions readingOptions = (ReadingOptions) objArr[1];
String str = (String) obj;
c = n.c(str);
Uri parse = Uri.parse(c);
m mVar = m.this;
kotlin.jvm.internal.r.c(parse);
mVar.W(parse, EnumC1880c.READ);
if (readingOptions.getEncoding() != EncodingType.BASE64) {
if (kotlin.jvm.internal.r.b(parse.getScheme(), "file")) {
return sk.e.k(new FileInputStream(m.this.o0(parse)));
}
if (kotlin.jvm.internal.r.b(parse.getScheme(), "asset")) {
return sk.e.k(m.this.i0(parse));
}
if (parse.getScheme() == null) {
return sk.e.k(m.this.j0(str));
}
if (m.this.g0(parse)) {
return sk.e.k(m.this.Z().getContentResolver().openInputStream(parse));
}
throw new IOException("Unsupported scheme for location '" + parse + "'.");
}
InputStream b0 = m.this.b0(parse);
try {
if (readingOptions.getLength() == null || readingOptions.getPosition() == null) {
encodeToString = Base64.encodeToString(m.this.c0(b0), 2);
} else {
byte[] bArr = new byte[readingOptions.getLength().intValue()];
b0.skip(readingOptions.getPosition().intValue());
encodeToString = Base64.encodeToString(bArr, 0, b0.read(bArr, 0, readingOptions.getLength().intValue()), 2);
}
Sh.J j = Sh.J.a;
di.c.a(b0, null);
return encodeToString;
} catch (Throwable th2) {
try {
throw th2;
} catch (Throwable th3) {
di.c.a(b0, th2);
throw th3;
}
}
}
}
public class C0876f {
public static final int[] a;
static {
int[] iArr = new int[FileSystemUploadType.values().length];
try {
iArr[FileSystemUploadType.BINARY_CONTENT.ordinal()] = 1;
} catch (NoSuchFieldError unused) {
}
try {
iArr[FileSystemUploadType.MULTIPART.ordinal()] = 2;
} catch (NoSuchFieldError unused2) {
}
a = iArr;
}
}
public static final class C0877f0 extends AbstractC1735t implements gi.a {
public static final C0877f0 a = new C0877f0();
public C0877f0() {
super(0);
}
@Override
public final ni.p invoke() {
return kotlin.jvm.internal.M.p(String.class);
}
}
public static final class C0878g implements Callback {
final wg.n a;
final m b;
C0878g(wg.n nVar, m mVar) {
this.a = nVar;
this.b = mVar;
}
public void a(Call call, IOException e) {
String str;
String str2;
kotlin.jvm.internal.r.f(call, "call");
kotlin.jvm.internal.r.f(e, "e");
str = n.a;
Log.e(str, String.valueOf(e.getMessage()));
wg.n nVar = this.a;
str2 = n.a;
kotlin.jvm.internal.r.e(str2, "access$getTAG$p(...)");
nVar.reject(str2, e.getMessage(), e);
}
public void e(Call call, Response response) {
kotlin.jvm.internal.r.f(call, "call");
kotlin.jvm.internal.r.f(response, "response");
Bundle bundle = new Bundle();
m mVar = this.b;
ResponseBody a = response.a();
bundle.putString("body", a != null ? a.n() : null);
bundle.putInt("status", response.j());
bundle.putBundle("headers", mVar.q0(response.t()));
response.close();
this.a.resolve(bundle);
}
}
public static final class C0879g0 extends AbstractC1735t implements gi.a {
public static final C0879g0 a = new C0879g0();
public C0879g0() {
super(0);
}
@Override
public final ni.p invoke() {
return kotlin.jvm.internal.M.p(String.class);
}
}
static final class C0880h implements s {
public static final C0880h a = new C0880h();
C0880h() {
}
@Override
public final RequestBody a(RequestBody requestBody) {
kotlin.jvm.internal.r.f(requestBody, "requestBody");
return requestBody;
}
}
public static final class C0881h0 extends AbstractC1735t implements gi.a {
public static final C0881h0 a = new C0881h0();
public C0881h0() {
super(0);
}
@Override
public final ni.p invoke() {
return kotlin.jvm.internal.M.p(WritingOptions.class);
}
}
public static final class C0882i implements Callback {
final wg.n a;
final m b;
C0882i(wg.n nVar, m mVar) {
this.a = nVar;
this.b = mVar;
}
public void a(Call call, IOException e) {
String str;
String str2;
kotlin.jvm.internal.r.f(call, "call");
kotlin.jvm.internal.r.f(e, "e");
if (call.H()) {
this.a.resolve(null);
return;
}
str = n.a;
Log.e(str, String.valueOf(e.getMessage()));
wg.n nVar = this.a;
str2 = n.a;
kotlin.jvm.internal.r.e(str2, "access$getTAG$p(...)");
nVar.reject(str2, e.getMessage(), e);
}
public void e(Call call, Response response) {
kotlin.jvm.internal.r.f(call, "call");
kotlin.jvm.internal.r.f(response, "response");
Bundle bundle = new Bundle();
ResponseBody a = response.a();
m mVar = this.b;
bundle.putString("body", a != null ? a.n() : null);
bundle.putInt("status", response.j());
bundle.putBundle("headers", mVar.q0(response.t()));
response.close();
this.a.resolve(bundle);
}
}
public static final class i0 extends AbstractC1735t implements gi.a {
public static final i0 a = new i0();
public i0() {
super(0);
}
@Override
public final ni.p invoke() {
return kotlin.jvm.internal.M.p(FileSystemUploadOptions.class);
}
}
public static final class C0883j implements c {
private long a = -1;
final String b;
final m c;
C0883j(String str, m mVar) {
this.b = str;
this.c = mVar;
}
@Override
public void a(long j, long j2) {
Bundle bundle = new Bundle();
Bundle bundle2 = new Bundle();
long currentTimeMillis = System.currentTimeMillis();
if (currentTimeMillis > this.a + 100 || j == j2) {
this.a = currentTimeMillis;
bundle2.putDouble("totalBytesSent", j);
bundle2.putDouble("totalBytesExpectedToSend", j2);
bundle.putString("uuid", this.b);
bundle.putBundle("data", bundle2);
this.c.k("expo-file-system.uploadProgress", bundle);
}
}
}
public static final class j0 extends AbstractC1735t implements gi.p {
public j0() {
super(2);
}
public final void a(Object[] objArr, wg.n promise) {
kotlin.jvm.internal.r.f(objArr, "<name for destructuring parameter 0>");
kotlin.jvm.internal.r.f(promise, "promise");
Object obj = objArr[0];
Object obj2 = objArr[1];
Object obj3 = objArr[2];
FileSystemUploadOptions fileSystemUploadOptions = (FileSystemUploadOptions) objArr[3];
String str = (String) obj3;
C0883j c0883j = new C0883j(str, m.this);
m mVar = m.this;
Request T = mVar.T((String) obj, (String) obj2, fileSystemUploadOptions, new C0884k(c0883j));
OkHttpClient e0 = m.this.e0();
kotlin.jvm.internal.r.c(e0);
Call b = e0.b(T);
m.this.taskHandlers.put(str, new C0874e(b));
FirebasePerfOkHttpClient.enqueue(b, new C0882i(promise, m.this));
}
@Override
public Object invoke(Object obj, Object obj2) {
a((Object[]) obj, (wg.n) obj2);
return Sh.J.a;
}
}
static final class C0884k implements s {
final c a;
C0884k(c cVar) {
this.a = cVar;
}
@Override
public final RequestBody a(RequestBody requestBody) {
kotlin.jvm.internal.r.f(requestBody, "requestBody");
return new b(requestBody, this.a);
}
}
public static final class k0 extends AbstractC1735t implements gi.a {
public static final k0 a = new k0();
public k0() {
super(0);
}
@Override
public final ni.p invoke() {
return kotlin.jvm.internal.M.p(String.class);
}
}
public static final class C0885l implements Callback {
final wg.n a;
final m b;
final Uri c;
final DownloadOptions d;
C0885l(wg.n nVar, m mVar, Uri uri, DownloadOptions downloadOptions) {
this.a = nVar;
this.b = mVar;
this.c = uri;
this.d = downloadOptions;
}
public void a(Call call, IOException e) {
String str;
String str2;
kotlin.jvm.internal.r.f(call, "call");
kotlin.jvm.internal.r.f(e, "e");
str = n.a;
Log.e(str, String.valueOf(e.getMessage()));
wg.n nVar = this.a;
str2 = n.a;
kotlin.jvm.internal.r.e(str2, "access$getTAG$p(...)");
nVar.reject(str2, e.getMessage(), e);
}
public void e(Call call, Response response) {
kotlin.jvm.internal.r.f(call, "call");
kotlin.jvm.internal.r.f(response, "response");
m mVar = this.b;
Uri uri = this.c;
kotlin.jvm.internal.r.e(uri, "$uri");
File o0 = mVar.o0(uri);
o0.delete();
nk.f c = nk.G.c(nk.G.j(o0, false, 1, (Object) null));
ResponseBody a = response.a();
kotlin.jvm.internal.r.c(a);
c.Y1(a.m());
c.close();
Bundle bundle = new Bundle();
m mVar2 = this.b;
DownloadOptions downloadOptions = this.d;
bundle.putString("uri", Uri.fromFile(o0).toString());
bundle.putInt("status", response.j());
bundle.putBundle("headers", mVar2.q0(response.t()));
if (downloadOptions.getMd5()) {
bundle.putString("md5", mVar2.h0(o0));
}
response.close();
this.a.resolve(bundle);
}
}
public static final class l0 extends AbstractC1735t implements gi.a {
public static final l0 a = new l0();
public l0() {
super(0);
}
@Override
public final ni.p invoke() {
return kotlin.jvm.internal.M.g(String.class);
}
}
static final class C0095m extends kotlin.coroutines.jvm.internal.l implements gi.p {
int a;
final C0866a c;
C0095m(C0866a c0866a, Xh.d dVar) {
super(2, dVar);
this.c = c0866a;
}
@Override
public final Object invoke(Cj.M m, Xh.d dVar) {
return ((C0095m) create(m, dVar)).invokeSuspend(Sh.J.a);
}
@Override
public final Xh.d create(Object obj, Xh.d dVar) {
return m.this.new C0095m(this.c, dVar);
}
@Override
public final Object invokeSuspend(Object obj) {
Object e = Yh.b.e();
int i = this.a;
if (i == 0) {
t.b(obj);
m mVar = m.this;
C0866a c0866a = this.c;
this.a = 1;
if (mVar.U(c0866a, this) == e) {
return e;
}
} else {
if (i != 1) {
throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
}
t.b(obj);
}
return Sh.J.a;
}
}
public static final class m0 extends AbstractC1735t implements gi.a {
public static final m0 a = new m0();
public m0() {
super(0);
}
@Override
public final ni.p invoke() {
return kotlin.jvm.internal.M.p(DownloadOptions.class);
}
}
public static final class C0886n implements InterfaceC0870c {
private long a = -1;
final String b;
final String c;
final m d;
C0886n(String str, String str2, m mVar) {
this.b = str;
this.c = str2;
this.d = mVar;
}
@Override
public void a(long j, long j2, boolean z) {
Bundle bundle = new Bundle();
Bundle bundle2 = new Bundle();
String str = this.b;
long parseLong = j + (str != null ? Long.parseLong(str) : 0L);
String str2 = this.b;
long parseLong2 = j2 + (str2 != null ? Long.parseLong(str2) : 0L);
long currentTimeMillis = System.currentTimeMillis();
if (currentTimeMillis > this.a + 100 || parseLong == parseLong2) {
this.a = currentTimeMillis;
bundle2.putDouble("totalBytesWritten", parseLong);
bundle2.putDouble("totalBytesExpectedToWrite", parseLong2);
bundle.putString("uuid", this.c);
bundle.putBundle("data", bundle2);
this.d.k("expo-file-system.downloadProgress", bundle);
}
}
}
public static final class n0 extends AbstractC1735t implements gi.p {
public n0() {
super(2);
}
public final void a(Object[] objArr, wg.n promise) {
String c;
Call b;
kotlin.jvm.internal.r.f(objArr, "<name for destructuring parameter 0>");
kotlin.jvm.internal.r.f(promise, "promise");
Object obj = objArr[0];
Object obj2 = objArr[1];
DownloadOptions downloadOptions = (DownloadOptions) objArr[2];
String str = (String) obj;
c = n.c((String) obj2);
Uri parse = Uri.parse(c);
m mVar = m.this;
kotlin.jvm.internal.r.c(parse);
mVar.W(parse, EnumC1880c.WRITE);
m.this.P(parse);
if (!Aj.o.P(str, ":", false, 2, (Object) null)) {
Context Z = m.this.Z();
InputStream openRawResource = Z.getResources().openRawResource(Z.getResources().getIdentifier(str, "raw", Z.getPackageName()));
kotlin.jvm.internal.r.e(openRawResource, "openRawResource(...)");
nk.g d = nk.G.d(nk.G.l(openRawResource));
File o0 = m.this.o0(parse);
o0.delete();
nk.f c2 = nk.G.c(nk.G.j(o0, false, 1, (Object) null));
c2.Y1(d);
c2.close();
Bundle bundle = new Bundle();
bundle.putString("uri", Uri.fromFile(o0).toString());
boolean md5 = downloadOptions.getMd5();
if ((md5 ? Boolean.valueOf(md5) : null) != null) {
bundle.putString("md5", m.this.h0(o0));
}
promise.resolve(bundle);
return;
}
if (!kotlin.jvm.internal.r.b("file", parse.getScheme())) {
throw new IOException("Unsupported scheme for location '" + parse + "'.");
}
Request.Builder l = new Request.Builder().l(str);
if (downloadOptions.getHeaders() != null) {
for (Map.Entry<String, String> entry : downloadOptions.getHeaders().entrySet()) {
l.a(entry.getKey(), entry.getValue());
}
}
OkHttpClient e0 = m.this.e0();
if (e0 != null && (b = e0.b(l.b())) != null) {
FirebasePerfOkHttpClient.enqueue(b, new C0885l(promise, m.this, parse, downloadOptions));
r6 = Sh.J.a;
}
if (r6 == null) {
promise.i(new o());
}
}
@Override
public Object invoke(Object obj, Object obj2) {
a((Object[]) obj, (wg.n) obj2);
return Sh.J.a;
}
}
public static final class C0887o extends AbstractC1735t implements gi.l {
public C0887o() {
super(1);
}
@Override
public final Object invoke(Object[] objArr) {
String c;
kotlin.jvm.internal.r.f(objArr, "<name for destructuring parameter 0>");
Object obj = objArr[0];
Object obj2 = objArr[1];
WritingOptions writingOptions = (WritingOptions) objArr[2];
String str = (String) obj2;
c = n.c((String) obj);
Uri parse = Uri.parse(c);
m mVar = m.this;
kotlin.jvm.internal.r.c(parse);
mVar.W(parse, EnumC1880c.WRITE);
EncodingType encoding = writingOptions.getEncoding();
OutputStream f0 = m.this.f0(parse);
try {
if (encoding == EncodingType.BASE64) {
f0.write(Base64.decode(str, 0));
} else {
OutputStreamWriter outputStreamWriter = new OutputStreamWriter(f0);
try {
outputStreamWriter.write(str);
Sh.J j = Sh.J.a;
di.c.a(outputStreamWriter, null);
} finally {
}
}
Sh.J j2 = Sh.J.a;
di.c.a(f0, null);
return Sh.J.a;
} finally {
}
}
}
public static final class o0 extends AbstractC1735t implements gi.a {
public static final o0 a = new o0();
public o0() {
super(0);
}
@Override
public final ni.p invoke() {
return kotlin.jvm.internal.M.p(String.class);
}
}
public static final class C0888p extends AbstractC1735t implements gi.a {
public static final C0888p a = new C0888p();
public C0888p() {
super(0);
}
@Override
public final ni.p invoke() {
return kotlin.jvm.internal.M.p(String.class);
}
}
public static final class p0 extends AbstractC1735t implements gi.a {
public static final p0 a = new p0();
public p0() {
super(0);
}
@Override
public final ni.p invoke() {
return kotlin.jvm.internal.M.p(String.class);
}
}
public static final class C0889q extends AbstractC1735t implements gi.a {
public static final C0889q a = new C0889q();
public C0889q() {
super(0);
}
@Override
public final ni.p invoke() {
return kotlin.jvm.internal.M.p(DeletingOptions.class);
}
}
public static final class q0 extends AbstractC1735t implements gi.a {
public static final q0 a = new q0();
public q0() {
super(0);
}
@Override
public final ni.p invoke() {
return kotlin.jvm.internal.M.p(String.class);
}
}
public static final class C0890r extends AbstractC1735t implements gi.l {
public C0890r() {
super(1);
}
@Override
public final Object invoke(Object[] objArr) {
String c;
kotlin.jvm.internal.r.f(objArr, "<name for destructuring parameter 0>");
Object obj = objArr[0];
DeletingOptions deletingOptions = (DeletingOptions) objArr[1];
c = n.c((String) obj);
Uri parse = Uri.parse(c);
Uri withAppendedPath = Uri.withAppendedPath(parse, "..");
m mVar = m.this;
kotlin.jvm.internal.r.c(withAppendedPath);
mVar.X(withAppendedPath, EnumC1880c.WRITE, "Location '" + parse + "' isn't deletable.");
if (kotlin.jvm.internal.r.b(parse.getScheme(), "file")) {
m mVar2 = m.this;
kotlin.jvm.internal.r.c(parse);
File o0 = mVar2.o0(parse);
if (o0.exists()) {
if (Build.VERSION.SDK_INT >= 26) {
sk.d.j(o0);
} else {
m.this.Y(o0);
}
} else if (!deletingOptions.getIdempotent()) {
throw new l(parse);
}
} else {
m mVar3 = m.this;
kotlin.jvm.internal.r.c(parse);
if (!mVar3.g0(parse)) {
throw new IOException("Unsupported scheme for location '" + parse + "'.");
}
Q0.a d0 = m.this.d0(parse);
if (d0 != null && d0.f()) {
d0.e();
} else if (!deletingOptions.getIdempotent()) {
throw new l(parse);
}
}
return Sh.J.a;
}
}
public static final class r0 extends AbstractC1735t implements gi.a {
public static final r0 a = new r0();
public r0() {
super(0);
}
@Override
public final ni.p invoke() {
return kotlin.jvm.internal.M.p(DownloadOptions.class);
}
}
public static final class C0891s extends AbstractC1735t implements gi.p {
public C0891s() {
super(2);
}
public final void a(Object[] objArr, wg.n promise) {
String c;
String c2;
kotlin.jvm.internal.r.f(objArr, "<anonymous parameter 0>");
kotlin.jvm.internal.r.f(promise, "promise");
RelocatingOptions relocatingOptions = (RelocatingOptions) promise;
c = n.c(relocatingOptions.getFrom());
Uri parse = Uri.parse(c);
m mVar = m.this;
Uri withAppendedPath = Uri.withAppendedPath(parse, "..");
kotlin.jvm.internal.r.e(withAppendedPath, "withAppendedPath(...)");
EnumC1880c enumC1880c = EnumC1880c.WRITE;
mVar.X(withAppendedPath, enumC1880c, "Location '" + parse + "' isn't movable.");
c2 = n.c(relocatingOptions.getTo());
Uri parse2 = Uri.parse(c2);
m mVar2 = m.this;
kotlin.jvm.internal.r.c(parse2);
mVar2.W(parse2, enumC1880c);
if (kotlin.jvm.internal.r.b(parse.getScheme(), "file")) {
m mVar3 = m.this;
kotlin.jvm.internal.r.c(parse);
if (!mVar3.o0(parse).renameTo(m.this.o0(parse2))) {
throw new i(parse, parse2);
}
return;
}
m mVar4 = m.this;
kotlin.jvm.internal.r.c(parse);
if (!mVar4.g0(parse)) {
throw new IOException("Unsupported scheme for location '" + parse + "'.");
}
Q0.a d0 = m.this.d0(parse);
if (d0 == null || !d0.f()) {
throw new i(parse, parse2);
}
m.this.p0(d0, m.this.o0(parse2), false);
}
@Override
public Object invoke(Object obj, Object obj2) {
a((Object[]) obj, (wg.n) obj2);
return Sh.J.a;
}
}
public static final class s0 extends AbstractC1735t implements gi.a {
public static final s0 a = new s0();
public s0() {
super(0);
}
@Override
public final ni.p invoke() {
return kotlin.jvm.internal.M.g(String.class);
}
}
public static final class C0892t extends AbstractC1735t implements gi.a {
public static final C0892t a = new C0892t();
public C0892t() {
super(0);
}
@Override
public final ni.p invoke() {
return kotlin.jvm.internal.M.p(RelocatingOptions.class);
}
}
public static final class t0 extends AbstractC1735t implements gi.a {
public static final t0 a = new t0();
public t0() {
super(0);
}
@Override
public final ni.p invoke() {
return kotlin.jvm.internal.M.g(String.class);
}
}
public static final class C0893u extends AbstractC1735t implements gi.l {
public C0893u() {
super(1);
}
@Override
public final Object invoke(Object[] objArr) {
String c;
String c2;
kotlin.jvm.internal.r.f(objArr, "<name for destructuring parameter 0>");
RelocatingOptions relocatingOptions = (RelocatingOptions) objArr[0];
c = n.c(relocatingOptions.getFrom());
Uri parse = Uri.parse(c);
m mVar = m.this;
Uri withAppendedPath = Uri.withAppendedPath(parse, "..");
kotlin.jvm.internal.r.e(withAppendedPath, "withAppendedPath(...)");
EnumC1880c enumC1880c = EnumC1880c.WRITE;
mVar.X(withAppendedPath, enumC1880c, "Location '" + parse + "' isn't movable.");
c2 = n.c(relocatingOptions.getTo());
Uri parse2 = Uri.parse(c2);
m mVar2 = m.this;
kotlin.jvm.internal.r.c(parse2);
mVar2.W(parse2, enumC1880c);
if (kotlin.jvm.internal.r.b(parse.getScheme(), "file")) {
m mVar3 = m.this;
kotlin.jvm.internal.r.c(parse);
if (!mVar3.o0(parse).renameTo(m.this.o0(parse2))) {
throw new i(parse, parse2);
}
} else {
m mVar4 = m.this;
kotlin.jvm.internal.r.c(parse);
if (!mVar4.g0(parse)) {
throw new IOException("Unsupported scheme for location '" + parse + "'.");
}
Q0.a d0 = m.this.d0(parse);
if (d0 == null || !d0.f()) {
throw new i(parse, parse2);
}
m.this.p0(d0, m.this.o0(parse2), false);
}
return Sh.J.a;
}
}
public static final class u0 extends AbstractC1735t implements gi.p {
public u0() {
super(2);
}
public final void a(Object[] objArr, wg.n promise) {
String c;
OkHttpClient.Builder C;
OkHttpClient.Builder a;
kotlin.jvm.internal.r.f(objArr, "<name for destructuring parameter 0>");
kotlin.jvm.internal.r.f(promise, "promise");
Object obj = objArr[0];
Object obj2 = objArr[1];
Object obj3 = objArr[2];
Object obj4 = objArr[3];
String str = (String) objArr[4];
DownloadOptions downloadOptions = (DownloadOptions) obj4;
String str2 = (String) obj3;
String str3 = (String) obj;
c = n.c((String) obj2);
Uri parse = Uri.parse(c);
m mVar = m.this;
kotlin.jvm.internal.r.c(parse);
mVar.P(parse);
if (!kotlin.jvm.internal.r.b(parse.getScheme(), "file")) {
throw new IOException("Unsupported scheme for location '" + parse + "'.");
}
C0886n c0886n = new C0886n(str, str2, m.this);
OkHttpClient e0 = m.this.e0();
OkHttpClient c2 = (e0 == null || (C = e0.C()) == null || (a = C.a(new G0(c0886n))) == null) ? null : a.c();
if (c2 == null) {
promise.i(new o());
return;
}
Request.Builder builder = new Request.Builder();
if (str != null) {
builder.a("Range", "bytes=" + str + "-");
}
if (downloadOptions.getHeaders() != null) {
for (Map.Entry<String, String> entry : downloadOptions.getHeaders().entrySet()) {
builder.a(entry.getKey(), entry.getValue());
}
}
Call b = c2.b(builder.l(str3).b());
m.this.taskHandlers.put(str2, new C0868b(parse, b));
Cj.i.d(m.this.moduleCoroutineScope, (Xh.g) null, (Cj.O) null, m.this.new C0095m(new C0866a(downloadOptions, b, m.this.o0(parse), str != null, promise), null), 3, (Object) null);
}
@Override
public Object invoke(Object obj, Object obj2) {
a((Object[]) obj, (wg.n) obj2);
return Sh.J.a;
}
}
public static final class C0894v extends AbstractC1735t implements gi.p {
public C0894v() {
super(2);
}
public final void a(Object[] objArr, wg.n promise) {
String c;
String c2;
kotlin.jvm.internal.r.f(objArr, "<anonymous parameter 0>");
kotlin.jvm.internal.r.f(promise, "promise");
RelocatingOptions relocatingOptions = (RelocatingOptions) promise;
c = n.c(relocatingOptions.getFrom());
Uri parse = Uri.parse(c);
m mVar = m.this;
kotlin.jvm.internal.r.c(parse);
mVar.X(parse, EnumC1880c.READ, "Location '" + parse + "' isn't readable.");
c2 = n.c(relocatingOptions.getTo());
Uri parse2 = Uri.parse(c2);
m mVar2 = m.this;
kotlin.jvm.internal.r.c(parse2);
mVar2.W(parse2, EnumC1880c.WRITE);
if (kotlin.jvm.internal.r.b(parse.getScheme(), "file")) {
File o0 = m.this.o0(parse);
File o02 = m.this.o0(parse2);
if (o0.isDirectory()) {
sk.d.c(o0, o02);
return;
} else {
sk.d.f(o0, o02);
return;
}
}
if (m.this.g0(parse)) {
Q0.a d0 = m.this.d0(parse);
if (d0 == null || !d0.f()) {
throw new k(parse);
}
m.this.p0(d0, m.this.o0(parse2), true);
return;
}
if (kotlin.jvm.internal.r.b(parse.getScheme(), "content")) {
sk.e.c(m.this.Z().getContentResolver().openInputStream(parse), new FileOutputStream(m.this.o0(parse2)));
return;
}
if (kotlin.jvm.internal.r.b(parse.getScheme(), "asset")) {
sk.e.c(m.this.i0(parse), new FileOutputStream(m.this.o0(parse2)));
return;
}
if (parse.getScheme() == null) {
sk.e.c(m.this.j0(relocatingOptions.getFrom()), new FileOutputStream(m.this.o0(parse2)));
return;
}
throw new IOException("Unsupported scheme for location '" + parse + "'.");
}
@Override
public Object invoke(Object obj, Object obj2) {
a((Object[]) obj, (wg.n) obj2);
return Sh.J.a;
}
}
public static final class v0 extends AbstractC1735t implements gi.p {
public v0() {
super(2);
}
public final void a(Object[] objArr, wg.n promise) {
String c;
kotlin.jvm.internal.r.f(objArr, "<name for destructuring parameter 0>");
kotlin.jvm.internal.r.f(promise, "promise");
String str = (String) objArr[0];
if (m.this.dirPermissionsRequest != null) {
throw new p();
}
Intent intent = new Intent("android.intent.action.OPEN_DOCUMENT_TREE");
if (Build.VERSION.SDK_INT >= 26 && str != null) {
c = n.c(str);
Uri parse = Uri.parse(c);
if (parse != null) {
intent.putExtra("android.provider.extra.INITIAL_URI", parse);
}
}
m.this.dirPermissionsRequest = promise;
m.this.f().z().startActivityForResult(intent, 5394);
}
@Override
public Object invoke(Object obj, Object obj2) {
a((Object[]) obj, (wg.n) obj2);
return Sh.J.a;
}
}
public static final class C0895w extends AbstractC1735t implements gi.a {
public static final C0895w a = new C0895w();
public C0895w() {
super(0);
}
@Override
public final ni.p invoke() {
return kotlin.jvm.internal.M.p(RelocatingOptions.class);
}
}
public static final class w0 extends AbstractC1735t implements gi.a {
public static final w0 a = new w0();
public w0() {
super(0);
}
@Override
public final ni.p invoke() {
return kotlin.jvm.internal.M.p(String.class);
}
}
public static final class C0896x extends AbstractC1735t implements gi.l {
public C0896x() {
super(1);
}
@Override
public final Object invoke(Object[] objArr) {
String c;
String c2;
kotlin.jvm.internal.r.f(objArr, "<name for destructuring parameter 0>");
RelocatingOptions relocatingOptions = (RelocatingOptions) objArr[0];
c = n.c(relocatingOptions.getFrom());
Uri parse = Uri.parse(c);
m mVar = m.this;
kotlin.jvm.internal.r.c(parse);
mVar.X(parse, EnumC1880c.READ, "Location '" + parse + "' isn't readable.");
c2 = n.c(relocatingOptions.getTo());
Uri parse2 = Uri.parse(c2);
m mVar2 = m.this;
kotlin.jvm.internal.r.c(parse2);
mVar2.W(parse2, EnumC1880c.WRITE);
if (kotlin.jvm.internal.r.b(parse.getScheme(), "file")) {
File o0 = m.this.o0(parse);
File o02 = m.this.o0(parse2);
if (o0.isDirectory()) {
sk.d.c(o0, o02);
} else {
sk.d.f(o0, o02);
}
return Sh.J.a;
}
if (m.this.g0(parse)) {
Q0.a d0 = m.this.d0(parse);
if (d0 == null || !d0.f()) {
throw new k(parse);
}
m.this.p0(d0, m.this.o0(parse2), true);
return Sh.J.a;
}
if (kotlin.jvm.internal.r.b(parse.getScheme(), "content")) {
return Integer.valueOf(sk.e.c(m.this.Z().getContentResolver().openInputStream(parse), new FileOutputStream(m.this.o0(parse2))));
}
if (kotlin.jvm.internal.r.b(parse.getScheme(), "asset")) {
return Integer.valueOf(sk.e.c(m.this.i0(parse), new FileOutputStream(m.this.o0(parse2))));
}
if (parse.getScheme() == null) {
return Integer.valueOf(sk.e.c(m.this.j0(relocatingOptions.getFrom()), new FileOutputStream(m.this.o0(parse2))));
}
throw new IOException("Unsupported scheme for location '" + parse + "'.");
}
}
public static final class x0 extends AbstractC1735t implements gi.a {
public static final x0 a = new x0();
public x0() {
super(0);
}
@Override
public final ni.p invoke() {
return kotlin.jvm.internal.M.p(String.class);
}
}
public static final class C0897y extends AbstractC1735t implements gi.a {
public static final C0897y a = new C0897y();
public C0897y() {
super(0);
}
@Override
public final ni.p invoke() {
return kotlin.jvm.internal.M.p(String.class);
}
}
public static final class y0 extends AbstractC1735t implements gi.a {
public static final y0 a = new y0();
public y0() {
super(0);
}
@Override
public final ni.p invoke() {
return kotlin.jvm.internal.M.p(FileSystemUploadOptions.class);
}
}
public static final class C0898z extends AbstractC1735t implements gi.a {
public static final C0898z a = new C0898z();
public C0898z() {
super(0);
}
@Override
public final ni.p invoke() {
return kotlin.jvm.internal.M.p(String.class);
}
}
public static final class z0 extends AbstractC1735t implements gi.p {
final Fg.b b;
public z0(Fg.b bVar) {
super(2);
this.b = bVar;
}
public final void a(Object[] objArr, wg.n promise) {
Sh.J j;
kotlin.jvm.internal.r.f(objArr, "<name for destructuring parameter 0>");
kotlin.jvm.internal.r.f(promise, "promise");
Object obj = objArr[0];
Object obj2 = objArr[1];
FileSystemUploadOptions fileSystemUploadOptions = (FileSystemUploadOptions) objArr[2];
m mVar = m.this;
Request T = mVar.T((String) obj, (String) obj2, fileSystemUploadOptions, C0880h.a);
OkHttpClient e0 = m.this.e0();
if (e0 != null) {
FirebasePerfOkHttpClient.enqueue(e0.b(T), new C0878g(promise, m.this));
j = Sh.J.a;
} else {
j = null;
}
if (j == null) {
promise.i(new o());
}
}
@Override
public Object invoke(Object obj, Object obj2) {
a((Object[]) obj, (wg.n) obj2);
return Sh.J.a;
}
}
public final void P(Uri uri) {
File o02 = o0(uri);
File parentFile = o02.getParentFile();
if (parentFile == null || !parentFile.exists()) {
throw new IOException("Directory for '" + o02.getPath() + "' doesn't exist. Please make sure directory '" + o02.getParent() + "' exists before calling downloadAsync.");
}
}
private final void Q(Uri uri) {
File o02 = o0(uri);
if (o02.exists()) {
return;
}
throw new IOException("Directory for '" + o02.getPath() + "' doesn't exist.");
}
public final Uri R(File file) {
Uri h = androidx.core.content.b.h(f().z().getApplication(), f().z().getApplication().getPackageName() + ".FileSystemFileProvider", file);
kotlin.jvm.internal.r.e(h, "getUriForFile(...)");
return h;
}
private final RequestBody S(FileSystemUploadOptions options, s decorator, File file) {
int i = C0876f.a[options.getUploadType().ordinal()];
if (i == 1) {
return decorator.a(RequestBody.a.a(file, (MediaType) null));
}
if (i != 2) {
throw new Sh.q();
}
MultipartBody.Builder f = new MultipartBody.Builder((String) null, 1, (DefaultConstructorMarker) null).f(MultipartBody.l);
Map<String, String> parameters = options.getParameters();
if (parameters != null) {
for (Map.Entry<String, String> entry : parameters.entrySet()) {
f.a(entry.getKey(), entry.getValue().toString());
}
}
String mimeType = options.getMimeType();
if (mimeType == null) {
mimeType = URLConnection.guessContentTypeFromName(file.getName());
kotlin.jvm.internal.r.e(mimeType, "guessContentTypeFromName(...)");
}
String fieldName = options.getFieldName();
if (fieldName == null) {
fieldName = file.getName();
}
kotlin.jvm.internal.r.c(fieldName);
f.b(fieldName, file.getName(), decorator.a(RequestBody.a.a(file, MediaType.e.b(mimeType))));
return f.e();
}
public final Request T(String url, String fileUriString, FileSystemUploadOptions options, s decorator) {
String c;
c = n.c(fileUriString);
Uri parse = Uri.parse(c);
kotlin.jvm.internal.r.c(parse);
W(parse, EnumC1880c.READ);
Q(parse);
Request.Builder l = new Request.Builder().l(url);
Map<String, String> headers = options.getHeaders();
if (headers != null) {
for (Map.Entry<String, String> entry : headers.entrySet()) {
l.a(entry.getKey(), entry.getValue());
}
}
return l.g(options.getHttpMethod().getValue(), S(options, decorator, o0(parse))).b();
}
public final Object U(C0866a c0866a, Xh.d dVar) {
return Cj.i.g(b0.b(), new H0(c0866a, this, null), dVar);
}
public final void V(File dir) {
if (dir.isDirectory() || dir.mkdirs()) {
return;
}
throw new IOException("Couldn't create directory '" + dir + "'");
}
public final void W(Uri uri, EnumC1880c permission) {
if (permission == EnumC1880c.READ) {
X(uri, permission, "Location '" + uri + "' isn't readable.");
}
if (permission == EnumC1880c.WRITE) {
X(uri, permission, "Location '" + uri + "' isn't writable.");
}
X(uri, permission, "Location '" + uri + "' doesn't have permission '" + permission.name() + "'.");
}
public final void X(Uri uri, EnumC1880c permission, String errorMsg) {
EnumSet n02 = n0(uri);
if (n02 == null || !n02.contains(permission)) {
throw new IOException(errorMsg);
}
}
public final void Y(File file) {
if (!file.isDirectory()) {
if (file.delete()) {
return;
}
throw new IOException("Unable to delete file: " + file);
}
File[] listFiles = file.listFiles();
if (listFiles == null) {
throw new IOException("Failed to list contents of " + file);
}
IOException e = null;
for (File file2 : listFiles) {
try {
kotlin.jvm.internal.r.c(file2);
Y(file2);
} catch (IOException e2) {
e = e2;
}
}
if (e != null) {
throw e;
}
if (file.delete()) {
return;
}
throw new IOException("Unable to delete directory " + file + ".");
}
public final Context Z() {
Context y = f().y();
if (y != null) {
return y;
}
throw new expo.modules.kotlin.exception.e();
}
public final long a0(File file) {
Object obj;
if (!file.isDirectory()) {
return file.length();
}
File[] listFiles = file.listFiles();
if (listFiles == null) {
return 0L;
}
ArrayList arrayList = new ArrayList(listFiles.length);
for (File file2 : listFiles) {
kotlin.jvm.internal.r.c(file2);
arrayList.add(Long.valueOf(a0(file2)));
}
Iterator it = arrayList.iterator();
if (it.hasNext()) {
Object next = it.next();
while (it.hasNext()) {
next = Long.valueOf(((Number) next).longValue() + ((Number) it.next()).longValue());
}
obj = next;
} else {
obj = null;
}
Long l = (Long) obj;
if (l != null) {
return l.longValue();
}
return 0L;
}
public final InputStream b0(Uri uri) {
if (kotlin.jvm.internal.r.b(uri.getScheme(), "file")) {
return new FileInputStream(o0(uri));
}
if (kotlin.jvm.internal.r.b(uri.getScheme(), "asset")) {
return i0(uri);
}
if (g0(uri)) {
InputStream openInputStream = Z().getContentResolver().openInputStream(uri);
kotlin.jvm.internal.r.c(openInputStream);
return openInputStream;
}
throw new IOException("Unsupported scheme for location '" + uri + "'.");
}
public final byte[] c0(InputStream inputStream) {
ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();
byte[] bArr = new byte[1024];
while (true) {
try {
int read = inputStream.read(bArr);
if (read == -1) {
break;
}
byteArrayOutputStream.write(bArr, 0, read);
} catch (Throwable th2) {
try {
byteArrayOutputStream.close();
} catch (IOException unused) {
}
throw th2;
}
}
byte[] byteArray = byteArrayOutputStream.toByteArray();
kotlin.jvm.internal.r.e(byteArray, "toByteArray(...)");
try {
byteArrayOutputStream.close();
} catch (IOException unused2) {
}
return byteArray;
}
public final Q0.a d0(Uri uri) {
Q0.a g = Q0.a.g(Z(), uri);
return (g == null || !g.l()) ? Q0.a.h(Z(), uri) : g;
}
public final synchronized OkHttpClient e0() {
try {
if (this.client == null) {
OkHttpClient.Builder builder = new OkHttpClient.Builder();
TimeUnit timeUnit = TimeUnit.SECONDS;
this.client = builder.f(60L, timeUnit).N(60L, timeUnit).O(60L, timeUnit).c();
}
} catch (Throwable th2) {
throw th2;
}
return this.client;
}
public final OutputStream f0(Uri uri) {
OutputStream openOutputStream;
if (kotlin.jvm.internal.r.b(uri.getScheme(), "file")) {
openOutputStream = new FileOutputStream(o0(uri));
} else {
if (!g0(uri)) {
throw new IOException("Unsupported scheme for location '" + uri + "'.");
}
openOutputStream = Z().getContentResolver().openOutputStream(uri);
kotlin.jvm.internal.r.c(openOutputStream);
}
kotlin.jvm.internal.r.c(openOutputStream);
return openOutputStream;
}
public final boolean g0(Uri uri) {
if (!kotlin.jvm.internal.r.b(uri.getScheme(), "content")) {
return false;
}
String host = uri.getHost();
return host != null ? Aj.o.K(host, "com.android.externalstorage", false, 2, (Object) null) : false;
}
public final String h0(File file) {
FileInputStream fileInputStream = new FileInputStream(file);
try {
char[] a = qk.a.a(rk.a.d(fileInputStream));
kotlin.jvm.internal.r.e(a, "encodeHex(...)");
String str = new String(a);
di.c.a(fileInputStream, null);
return str;
} finally {
}
}
public final InputStream i0(Uri uri) {
String path = uri.getPath();
if (path == null) {
throw new IllegalArgumentException("Required value was null.");
}
kotlin.jvm.internal.r.e(path, "requireNotNull(...)");
String substring = path.substring(1);
kotlin.jvm.internal.r.e(substring, "substring(...)");
InputStream open = Z().getAssets().open(substring);
kotlin.jvm.internal.r.e(open, "open(...)");
return open;
}
public final InputStream j0(String resourceName) {
int identifier = Z().getResources().getIdentifier(resourceName, "raw", Z().getPackageName());
if (identifier != 0 || (identifier = Z().getResources().getIdentifier(resourceName, "drawable", Z().getPackageName())) != 0) {
InputStream openRawResource = Z().getResources().openRawResource(identifier);
kotlin.jvm.internal.r.e(openRawResource, "openRawResource(...)");
return openRawResource;
}
throw new FileNotFoundException("No resource found with the name '" + resourceName + "'");
}
public final String k0(String uriStr) {
String substring = uriStr.substring(Aj.o.b0(uriStr, ':', 0, false, 6, (Object) null) + 3);
kotlin.jvm.internal.r.e(substring, "substring(...)");
return substring;
}
private final EnumSet l0(String path) {
InterfaceC1879b q = f().q();
if (q != null) {
return q.a(Z(), path);
}
return null;
}
private final EnumSet m0(Uri uri) {
Q0.a d0 = d0(uri);
EnumSet noneOf = EnumSet.noneOf(EnumC1880c.class);
if (d0 != null) {
if (d0.a()) {
noneOf.add(EnumC1880c.READ);
}
if (d0.b()) {
noneOf.add(EnumC1880c.WRITE);
}
}
kotlin.jvm.internal.r.e(noneOf, "apply(...)");
return noneOf;
}
private final EnumSet n0(Uri uri) {
return g0(uri) ? m0(uri) : kotlin.jvm.internal.r.b(uri.getScheme(), "content") ? EnumSet.of(EnumC1880c.READ) : kotlin.jvm.internal.r.b(uri.getScheme(), "asset") ? EnumSet.of(EnumC1880c.READ) : kotlin.jvm.internal.r.b(uri.getScheme(), "file") ? l0(uri.getPath()) : uri.getScheme() == null ? EnumSet.of(EnumC1880c.READ) : EnumSet.noneOf(EnumC1880c.class);
}
public final File o0(Uri uri) {
if (uri.getPath() != null) {
String path = uri.getPath();
kotlin.jvm.internal.r.c(path);
return new File(path);
}
throw new IOException("Invalid Uri: " + uri);
}
public final void p0(Q0.a documentFile, File outputDir, boolean copy) {
if (!documentFile.f()) {
return;
}
if (!outputDir.isDirectory()) {
File parentFile = outputDir.getParentFile();
if (parentFile != null && !parentFile.exists() && !parentFile.mkdirs()) {
throw new IOException("Couldn't create folder in output dir.");
}
} else if (!outputDir.exists() && !outputDir.mkdirs()) {
throw new IOException("Couldn't create folder in output dir.");
}
if (documentFile.k()) {
Q0.a[] m = documentFile.m();
kotlin.jvm.internal.r.e(m, "listFiles(...)");
for (Q0.a aVar : m) {
kotlin.jvm.internal.r.c(aVar);
p0(aVar, outputDir, copy);
}
if (copy) {
return;
}
documentFile.e();
return;
}
String i = documentFile.i();
if (i == null) {
return;
}
File file = outputDir.isDirectory() ? new File(outputDir.getPath(), i) : new File(outputDir.getPath());
InputStream openInputStream = Z().getContentResolver().openInputStream(documentFile.j());
try {
FileOutputStream fileOutputStream = new FileOutputStream(file);
try {
sk.e.c(openInputStream, fileOutputStream);
di.c.a(fileOutputStream, null);
di.c.a(openInputStream, null);
if (copy) {
return;
}
documentFile.e();
} finally {
}
} catch (Throwable th2) {
try {
throw th2;
} catch (Throwable th3) {
di.c.a(openInputStream, th2);
throw th3;
}
}
}
public final Bundle q0(Headers headers) {
Bundle bundle = new Bundle();
int size = headers.size();
for (int i = 0; i < size; i++) {
String c = headers.c(i);
if (bundle.containsKey(c)) {
bundle.putString(c, bundle.getString(c) + ", " + headers.m(i));
} else {
bundle.putString(c, headers.m(i));
}
}
return bundle;
}
@Override
@SuppressLint({"WrongConstant", "DiscouragedApi"})
public Fg.c g() {
Class cls;
Object obj;
Object obj2;
Object obj3;
Dg.a kVar;
Dg.a kVar2;
Dg.a kVar3;
Dg.a kVar4;
Dg.a kVar5;
Class cls2;
Object obj4;
Boolean bool;
Dg.a eVar;
Object obj5;
Boolean bool2;
Dg.a kVar6;
w1.a.c("[ExpoModulesCore] " + (getClass() + ".ModuleDefinition"));
try {
Fg.b bVar = new Fg.b(this);
bVar.n("ExponentFileSystem");
bVar.c(x.a("documentDirectory", Uri.fromFile(Z().getFilesDir()).toString() + "/"), x.a("cacheDirectory", Uri.fromFile(Z().getCacheDir()).toString() + "/"), x.a("bundleDirectory", "asset:///"));
bVar.d("expo-file-system.downloadProgress", "expo-file-system.uploadProgress");
Map r = bVar.r();
Cg.e eVar2 = Cg.e.a;
r.put(eVar2, new Cg.a(eVar2, new E0()));
C0714c c0714c = C0714c.a;
ni.d b = kotlin.jvm.internal.M.b(String.class);
Boolean bool3 = Boolean.FALSE;
C0712a c0712a = (C0712a) c0714c.a().get(new Pair(b, bool3));
if (c0712a == null) {
obj2 = wg.n.class;
cls = DeletingOptions.class;
obj = Sh.J.class;
c0712a = new C0712a(new Lg.K(kotlin.jvm.internal.M.b(String.class), false, C0897y.a));
} else {
cls = DeletingOptions.class;
obj = Sh.J.class;
obj2 = wg.n.class;
}
C0712a c0712a2 = (C0712a) c0714c.a().get(new Pair(kotlin.jvm.internal.M.b(InfoOptions.class), bool3));
if (c0712a2 == null) {
c0712a2 = new C0712a(new Lg.K(kotlin.jvm.internal.M.b(InfoOptions.class), false, J.a));
}
C0712a[] c0712aArr = {c0712a, c0712a2};
U u = new U();
Class cls3 = Integer.TYPE;
bVar.j().put("getInfoAsync", kotlin.jvm.internal.r.b(Bundle.class, cls3) ? new Dg.k("getInfoAsync", c0712aArr, u) : kotlin.jvm.internal.r.b(Bundle.class, Boolean.TYPE) ? new Dg.h("getInfoAsync", c0712aArr, u) : kotlin.jvm.internal.r.b(Bundle.class, Double.TYPE) ? new Dg.i("getInfoAsync", c0712aArr, u) : kotlin.jvm.internal.r.b(Bundle.class, Float.TYPE) ? new Dg.j("getInfoAsync", c0712aArr, u) : kotlin.jvm.internal.r.b(Bundle.class, String.class) ? new Dg.m("getInfoAsync", c0712aArr, u) : new Dg.e("getInfoAsync", c0712aArr, u));
C0712a c0712a3 = (C0712a) c0714c.a().get(new Pair(kotlin.jvm.internal.M.b(String.class), bool3));
if (c0712a3 == null) {
c0712a3 = new C0712a(new Lg.K(kotlin.jvm.internal.M.b(String.class), false, C0871c0.a));
}
C0712a c0712a4 = (C0712a) c0714c.a().get(new Pair(kotlin.jvm.internal.M.b(ReadingOptions.class), bool3));
if (c0712a4 == null) {
c0712a4 = new C0712a(new Lg.K(kotlin.jvm.internal.M.b(ReadingOptions.class), false, C0873d0.a));
}
bVar.j().put("readAsStringAsync", new Dg.e("readAsStringAsync", new C0712a[]{c0712a3, c0712a4}, new C0875e0()));
C0712a c0712a5 = (C0712a) c0714c.a().get(new Pair(kotlin.jvm.internal.M.b(String.class), bool3));
if (c0712a5 == null) {
c0712a5 = new C0712a(new Lg.K(kotlin.jvm.internal.M.b(String.class), false, C0877f0.a));
}
C0712a c0712a6 = (C0712a) c0714c.a().get(new Pair(kotlin.jvm.internal.M.b(String.class), bool3));
if (c0712a6 == null) {
c0712a6 = new C0712a(new Lg.K(kotlin.jvm.internal.M.b(String.class), false, C0879g0.a));
}
C0712a c0712a7 = (C0712a) c0714c.a().get(new Pair(kotlin.jvm.internal.M.b(WritingOptions.class), bool3));
if (c0712a7 == null) {
c0712a7 = new C0712a(new Lg.K(kotlin.jvm.internal.M.b(WritingOptions.class), false, C0881h0.a));
}
C0712a[] c0712aArr2 = {c0712a5, c0712a6, c0712a7};
C0887o c0887o = new C0887o();
Object obj6 = obj;
bVar.j().put("writeAsStringAsync", kotlin.jvm.internal.r.b(obj6, cls3) ? new Dg.k("writeAsStringAsync", c0712aArr2, c0887o) : kotlin.jvm.internal.r.b(obj6, Boolean.TYPE) ? new Dg.h("writeAsStringAsync", c0712aArr2, c0887o) : kotlin.jvm.internal.r.b(obj6, Double.TYPE) ? new Dg.i("writeAsStringAsync", c0712aArr2, c0887o) : kotlin.jvm.internal.r.b(obj6, Float.TYPE) ? new Dg.j("writeAsStringAsync", c0712aArr2, c0887o) : kotlin.jvm.internal.r.b(obj6, String.class) ? new Dg.m("writeAsStringAsync", c0712aArr2, c0887o) : new Dg.e("writeAsStringAsync", c0712aArr2, c0887o));
C0712a c0712a8 = (C0712a) c0714c.a().get(new Pair(kotlin.jvm.internal.M.b(String.class), bool3));
if (c0712a8 == null) {
c0712a8 = new C0712a(new Lg.K(kotlin.jvm.internal.M.b(String.class), false, C0888p.a));
}
C0712a c0712a9 = (C0712a) c0714c.a().get(new Pair(kotlin.jvm.internal.M.b(cls), bool3));
if (c0712a9 == null) {
c0712a9 = new C0712a(new Lg.K(kotlin.jvm.internal.M.b(cls), false, C0889q.a));
}
C0712a[] c0712aArr3 = {c0712a8, c0712a9};
C0890r c0890r = new C0890r();
bVar.j().put("deleteAsync", kotlin.jvm.internal.r.b(obj6, cls3) ? new Dg.k("deleteAsync", c0712aArr3, c0890r) : kotlin.jvm.internal.r.b(obj6, Boolean.TYPE) ? new Dg.h("deleteAsync", c0712aArr3, c0890r) : kotlin.jvm.internal.r.b(obj6, Double.TYPE) ? new Dg.i("deleteAsync", c0712aArr3, c0890r) : kotlin.jvm.internal.r.b(obj6, Float.TYPE) ? new Dg.j("deleteAsync", c0712aArr3, c0890r) : kotlin.jvm.internal.r.b(obj6, String.class) ? new Dg.m("deleteAsync", c0712aArr3, c0890r) : new Dg.e("deleteAsync", c0712aArr3, c0890r));
Object obj7 = obj2;
if (kotlin.jvm.internal.r.b(RelocatingOptions.class, obj7)) {
kVar = new Dg.f("moveAsync", new C0712a[0], new C0891s());
obj3 = Bundle.class;
} else {
C0712a c0712a10 = (C0712a) c0714c.a().get(new Pair(kotlin.jvm.internal.M.b(RelocatingOptions.class), bool3));
if (c0712a10 == null) {
obj3 = Bundle.class;
c0712a10 = new C0712a(new Lg.K(kotlin.jvm.internal.M.b(RelocatingOptions.class), false, C0892t.a));
} else {
obj3 = Bundle.class;
}
C0712a[] c0712aArr4 = {c0712a10};
C0893u c0893u = new C0893u();
kVar = kotlin.jvm.internal.r.b(obj6, cls3) ? new Dg.k("moveAsync", c0712aArr4, c0893u) : kotlin.jvm.internal.r.b(obj6, Boolean.TYPE) ? new Dg.h("moveAsync", c0712aArr4, c0893u) : kotlin.jvm.internal.r.b(obj6, Double.TYPE) ? new Dg.i("moveAsync", c0712aArr4, c0893u) : kotlin.jvm.internal.r.b(obj6, Float.TYPE) ? new Dg.j("moveAsync", c0712aArr4, c0893u) : kotlin.jvm.internal.r.b(obj6, String.class) ? new Dg.m("moveAsync", c0712aArr4, c0893u) : new Dg.e("moveAsync", c0712aArr4, c0893u);
}
bVar.j().put("moveAsync", kVar);
if (kotlin.jvm.internal.r.b(RelocatingOptions.class, obj7)) {
kVar2 = new Dg.f("copyAsync", new C0712a[0], new C0894v());
} else {
C0712a c0712a11 = (C0712a) c0714c.a().get(new Pair(kotlin.jvm.internal.M.b(RelocatingOptions.class), bool3));
if (c0712a11 == null) {
c0712a11 = new C0712a(new Lg.K(kotlin.jvm.internal.M.b(RelocatingOptions.class), false, C0895w.a));
}
C0712a[] c0712aArr5 = {c0712a11};
C0896x c0896x = new C0896x();
kVar2 = kotlin.jvm.internal.r.b(Object.class, cls3) ? new Dg.k("copyAsync", c0712aArr5, c0896x) : kotlin.jvm.internal.r.b(Object.class, Boolean.TYPE) ? new Dg.h("copyAsync", c0712aArr5, c0896x) : kotlin.jvm.internal.r.b(Object.class, Double.TYPE) ? new Dg.i("copyAsync", c0712aArr5, c0896x) : kotlin.jvm.internal.r.b(Object.class, Float.TYPE) ? new Dg.j("copyAsync", c0712aArr5, c0896x) : kotlin.jvm.internal.r.b(Object.class, String.class) ? new Dg.m("copyAsync", c0712aArr5, c0896x) : new Dg.e("copyAsync", c0712aArr5, c0896x);
}
bVar.j().put("copyAsync", kVar2);
C0712a c0712a12 = (C0712a) c0714c.a().get(new Pair(kotlin.jvm.internal.M.b(String.class), bool3));
if (c0712a12 == null) {
c0712a12 = new C0712a(new Lg.K(kotlin.jvm.internal.M.b(String.class), false, C0898z.a));
}
C0712a c0712a13 = (C0712a) c0714c.a().get(new Pair(kotlin.jvm.internal.M.b(MakeDirectoryOptions.class), bool3));
if (c0712a13 == null) {
c0712a13 = new C0712a(new Lg.K(kotlin.jvm.internal.M.b(MakeDirectoryOptions.class), false, A.a));
}
C0712a[] c0712aArr6 = {c0712a12, c0712a13};
B b2 = new B();
bVar.j().put("makeDirectoryAsync", kotlin.jvm.internal.r.b(obj6, cls3) ? new Dg.k("makeDirectoryAsync", c0712aArr6, b2) : kotlin.jvm.internal.r.b(obj6, Boolean.TYPE) ? new Dg.h("makeDirectoryAsync", c0712aArr6, b2) : kotlin.jvm.internal.r.b(obj6, Double.TYPE) ? new Dg.i("makeDirectoryAsync", c0712aArr6, b2) : kotlin.jvm.internal.r.b(obj6, Float.TYPE) ? new Dg.j("makeDirectoryAsync", c0712aArr6, b2) : kotlin.jvm.internal.r.b(obj6, String.class) ? new Dg.m("makeDirectoryAsync", c0712aArr6, b2) : new Dg.e("makeDirectoryAsync", c0712aArr6, b2));
if (kotlin.jvm.internal.r.b(String.class, obj7)) {
kVar3 = new Dg.f("readDirectoryAsync", new C0712a[0], new C());
} else {
C0712a c0712a14 = (C0712a) c0714c.a().get(new Pair(kotlin.jvm.internal.M.b(String.class), Boolean.TRUE));
if (c0712a14 == null) {
c0712a14 = new C0712a(new Lg.K(kotlin.jvm.internal.M.b(String.class), true, D.a));
}
C0712a[] c0712aArr7 = {c0712a14};
E e = new E();
kVar3 = kotlin.jvm.internal.r.b(List.class, cls3) ? new Dg.k("readDirectoryAsync", c0712aArr7, e) : kotlin.jvm.internal.r.b(List.class, Boolean.TYPE) ? new Dg.h("readDirectoryAsync", c0712aArr7, e) : kotlin.jvm.internal.r.b(List.class, Double.TYPE) ? new Dg.i("readDirectoryAsync", c0712aArr7, e) : kotlin.jvm.internal.r.b(List.class, Float.TYPE) ? new Dg.j("readDirectoryAsync", c0712aArr7, e) : kotlin.jvm.internal.r.b(List.class, String.class) ? new Dg.m("readDirectoryAsync", c0712aArr7, e) : new Dg.e("readDirectoryAsync", c0712aArr7, e);
}
bVar.j().put("readDirectoryAsync", kVar3);
C0712a[] c0712aArr8 = new C0712a[0];
F f = new F();
bVar.j().put("getTotalDiskCapacityAsync", kotlin.jvm.internal.r.b(Double.class, cls3) ? new Dg.k("getTotalDiskCapacityAsync", c0712aArr8, f) : kotlin.jvm.internal.r.b(Double.class, Boolean.TYPE) ? new Dg.h("getTotalDiskCapacityAsync", c0712aArr8, f) : kotlin.jvm.internal.r.b(Double.class, Double.TYPE) ? new Dg.i("getTotalDiskCapacityAsync", c0712aArr8, f) : kotlin.jvm.internal.r.b(Double.class, Float.TYPE) ? new Dg.j("getTotalDiskCapacityAsync", c0712aArr8, f) : kotlin.jvm.internal.r.b(Double.class, String.class) ? new Dg.m("getTotalDiskCapacityAsync", c0712aArr8, f) : new Dg.e("getTotalDiskCapacityAsync", c0712aArr8, f));
C0712a[] c0712aArr9 = new C0712a[0];
G g = new G();
bVar.j().put("getFreeDiskStorageAsync", kotlin.jvm.internal.r.b(Double.class, cls3) ? new Dg.k("getFreeDiskStorageAsync", c0712aArr9, g) : kotlin.jvm.internal.r.b(Double.class, Boolean.TYPE) ? new Dg.h("getFreeDiskStorageAsync", c0712aArr9, g) : kotlin.jvm.internal.r.b(Double.class, Double.TYPE) ? new Dg.i("getFreeDiskStorageAsync", c0712aArr9, g) : kotlin.jvm.internal.r.b(Double.class, Float.TYPE) ? new Dg.j("getFreeDiskStorageAsync", c0712aArr9, g) : kotlin.jvm.internal.r.b(Double.class, String.class) ? new Dg.m("getFreeDiskStorageAsync", c0712aArr9, g) : new Dg.e("getFreeDiskStorageAsync", c0712aArr9, g));
if (kotlin.jvm.internal.r.b(String.class, obj7)) {
kVar4 = new Dg.f("getContentUriAsync", new C0712a[0], new H());
} else {
C0712a c0712a15 = (C0712a) c0714c.a().get(new Pair(kotlin.jvm.internal.M.b(String.class), bool3));
if (c0712a15 == null) {
c0712a15 = new C0712a(new Lg.K(kotlin.jvm.internal.M.b(String.class), false, I.a));
}
C0712a[] c0712aArr10 = {c0712a15};
K k = new K();
kVar4 = kotlin.jvm.internal.r.b(String.class, cls3) ? new Dg.k("getContentUriAsync", c0712aArr10, k) : kotlin.jvm.internal.r.b(String.class, Boolean.TYPE) ? new Dg.h("getContentUriAsync", c0712aArr10, k) : kotlin.jvm.internal.r.b(String.class, Double.TYPE) ? new Dg.i("getContentUriAsync", c0712aArr10, k) : kotlin.jvm.internal.r.b(String.class, Float.TYPE) ? new Dg.j("getContentUriAsync", c0712aArr10, k) : kotlin.jvm.internal.r.b(String.class, String.class) ? new Dg.m("getContentUriAsync", c0712aArr10, k) : new Dg.e("getContentUriAsync", c0712aArr10, k);
}
bVar.j().put("getContentUriAsync", kVar4);
if (kotlin.jvm.internal.r.b(String.class, obj7)) {
kVar5 = new Dg.f("readSAFDirectoryAsync", new C0712a[0], new L());
} else {
C0712a c0712a16 = (C0712a) c0714c.a().get(new Pair(kotlin.jvm.internal.M.b(String.class), bool3));
if (c0712a16 == null) {
c0712a16 = new C0712a(new Lg.K(kotlin.jvm.internal.M.b(String.class), false, M.a));
}
C0712a[] c0712aArr11 = {c0712a16};
N n = new N();
kVar5 = kotlin.jvm.internal.r.b(List.class, cls3) ? new Dg.k("readSAFDirectoryAsync", c0712aArr11, n) : kotlin.jvm.internal.r.b(List.class, Boolean.TYPE) ? new Dg.h("readSAFDirectoryAsync", c0712aArr11, n) : kotlin.jvm.internal.r.b(List.class, Double.TYPE) ? new Dg.i("readSAFDirectoryAsync", c0712aArr11, n) : kotlin.jvm.internal.r.b(List.class, Float.TYPE) ? new Dg.j("readSAFDirectoryAsync", c0712aArr11, n) : kotlin.jvm.internal.r.b(List.class, String.class) ? new Dg.m("readSAFDirectoryAsync", c0712aArr11, n) : new Dg.e("readSAFDirectoryAsync", c0712aArr11, n);
}
bVar.j().put("readSAFDirectoryAsync", kVar5);
C0712a c0712a17 = (C0712a) c0714c.a().get(new Pair(kotlin.jvm.internal.M.b(String.class), bool3));
if (c0712a17 == null) {
c0712a17 = new C0712a(new Lg.K(kotlin.jvm.internal.M.b(String.class), false, O.a));
}
C0712a c0712a18 = (C0712a) c0714c.a().get(new Pair(kotlin.jvm.internal.M.b(String.class), bool3));
if (c0712a18 == null) {
c0712a18 = new C0712a(new Lg.K(kotlin.jvm.internal.M.b(String.class), false, P.a));
}
C0712a[] c0712aArr12 = {c0712a17, c0712a18};
Q q = new Q();
bVar.j().put("makeSAFDirectoryAsync", kotlin.jvm.internal.r.b(String.class, cls3) ? new Dg.k("makeSAFDirectoryAsync", c0712aArr12, q) : kotlin.jvm.internal.r.b(String.class, Boolean.TYPE) ? new Dg.h("makeSAFDirectoryAsync", c0712aArr12, q) : kotlin.jvm.internal.r.b(String.class, Double.TYPE) ? new Dg.i("makeSAFDirectoryAsync", c0712aArr12, q) : kotlin.jvm.internal.r.b(String.class, Float.TYPE) ? new Dg.j("makeSAFDirectoryAsync", c0712aArr12, q) : kotlin.jvm.internal.r.b(String.class, String.class) ? new Dg.m("makeSAFDirectoryAsync", c0712aArr12, q) : new Dg.e("makeSAFDirectoryAsync", c0712aArr12, q));
C0712a c0712a19 = (C0712a) c0714c.a().get(new Pair(kotlin.jvm.internal.M.b(String.class), bool3));
if (c0712a19 == null) {
c0712a19 = new C0712a(new Lg.K(kotlin.jvm.internal.M.b(String.class), false, R.a));
}
C0712a c0712a20 = (C0712a) c0714c.a().get(new Pair(kotlin.jvm.internal.M.b(String.class), bool3));
if (c0712a20 == null) {
c0712a20 = new C0712a(new Lg.K(kotlin.jvm.internal.M.b(String.class), false, S.a));
}
C0712a c0712a21 = (C0712a) c0714c.a().get(new Pair(kotlin.jvm.internal.M.b(String.class), bool3));
if (c0712a21 == null) {
c0712a21 = new C0712a(new Lg.K(kotlin.jvm.internal.M.b(String.class), false, T.a));
}
C0712a[] c0712aArr13 = {c0712a19, c0712a20, c0712a21};
V v = new V();
bVar.j().put("createSAFFileAsync", kotlin.jvm.internal.r.b(String.class, cls3) ? new Dg.k("createSAFFileAsync", c0712aArr13, v) : kotlin.jvm.internal.r.b(String.class, Boolean.TYPE) ? new Dg.h("createSAFFileAsync", c0712aArr13, v) : kotlin.jvm.internal.r.b(String.class, Double.TYPE) ? new Dg.i("createSAFFileAsync", c0712aArr13, v) : kotlin.jvm.internal.r.b(String.class, Float.TYPE) ? new Dg.j("createSAFFileAsync", c0712aArr13, v) : kotlin.jvm.internal.r.b(String.class, String.class) ? new Dg.m("createSAFFileAsync", c0712aArr13, v) : new Dg.e("createSAFFileAsync", c0712aArr13, v));
ni.d b3 = kotlin.jvm.internal.M.b(String.class);
Boolean bool4 = Boolean.TRUE;
C0712a c0712a22 = (C0712a) c0714c.a().get(new Pair(b3, bool4));
if (c0712a22 == null) {
c0712a22 = new C0712a(new Lg.K(kotlin.jvm.internal.M.b(String.class), true, s0.a));
}
bVar.j().put("requestDirectoryPermissionsAsync", new Dg.f("requestDirectoryPermissionsAsync", new C0712a[]{c0712a22}, new v0()));
C0712a c0712a23 = (C0712a) c0714c.a().get(new Pair(kotlin.jvm.internal.M.b(String.class), bool3));
if (c0712a23 == null) {
c0712a23 = new C0712a(new Lg.K(kotlin.jvm.internal.M.b(String.class), false, w0.a));
}
C0712a c0712a24 = (C0712a) c0714c.a().get(new Pair(kotlin.jvm.internal.M.b(String.class), bool3));
if (c0712a24 == null) {
cls2 = cls3;
c0712a24 = new C0712a(new Lg.K(kotlin.jvm.internal.M.b(String.class), false, x0.a));
} else {
cls2 = cls3;
}
C0712a c0712a25 = (C0712a) c0714c.a().get(new Pair(kotlin.jvm.internal.M.b(FileSystemUploadOptions.class), bool3));
if (c0712a25 == null) {
obj4 = obj7;
c0712a25 = new C0712a(new Lg.K(kotlin.jvm.internal.M.b(FileSystemUploadOptions.class), false, y0.a));
} else {
obj4 = obj7;
}
bVar.j().put("uploadAsync", new Dg.f("uploadAsync", new C0712a[]{c0712a23, c0712a24, c0712a25}, new z0(bVar)));
C0712a c0712a26 = (C0712a) c0714c.a().get(new Pair(kotlin.jvm.internal.M.b(String.class), bool3));
if (c0712a26 == null) {
c0712a26 = new C0712a(new Lg.K(kotlin.jvm.internal.M.b(String.class), false, A0.a));
}
C0712a c0712a27 = (C0712a) c0714c.a().get(new Pair(kotlin.jvm.internal.M.b(String.class), bool3));
if (c0712a27 == null) {
c0712a27 = new C0712a(new Lg.K(kotlin.jvm.internal.M.b(String.class), false, B0.a));
}
C0712a c0712a28 = (C0712a) c0714c.a().get(new Pair(kotlin.jvm.internal.M.b(String.class), bool3));
if (c0712a28 == null) {
c0712a28 = new C0712a(new Lg.K(kotlin.jvm.internal.M.b(String.class), false, C0.a));
}
C0712a c0712a29 = (C0712a) c0714c.a().get(new Pair(kotlin.jvm.internal.M.b(FileSystemUploadOptions.class), bool3));
if (c0712a29 == null) {
bool = bool4;
c0712a29 = new C0712a(new Lg.K(kotlin.jvm.internal.M.b(FileSystemUploadOptions.class), false, i0.a));
} else {
bool = bool4;
}
bVar.j().put("uploadTaskStartAsync", new Dg.f("uploadTaskStartAsync", new C0712a[]{c0712a26, c0712a27, c0712a28, c0712a29}, new j0()));
C0712a c0712a30 = (C0712a) c0714c.a().get(new Pair(kotlin.jvm.internal.M.b(String.class), bool3));
if (c0712a30 == null) {
c0712a30 = new C0712a(new Lg.K(kotlin.jvm.internal.M.b(String.class), false, k0.a));
}
Boolean bool5 = bool;
C0712a c0712a31 = (C0712a) c0714c.a().get(new Pair(kotlin.jvm.internal.M.b(String.class), bool5));
if (c0712a31 == null) {
c0712a31 = new C0712a(new Lg.K(kotlin.jvm.internal.M.b(String.class), true, l0.a));
}
C0712a c0712a32 = (C0712a) c0714c.a().get(new Pair(kotlin.jvm.internal.M.b(DownloadOptions.class), bool3));
if (c0712a32 == null) {
c0712a32 = new C0712a(new Lg.K(kotlin.jvm.internal.M.b(DownloadOptions.class), false, m0.a));
}
bVar.j().put("downloadAsync", new Dg.f("downloadAsync", new C0712a[]{c0712a30, c0712a31, c0712a32}, new n0()));
Object obj8 = obj4;
if (kotlin.jvm.internal.r.b(String.class, obj8)) {
eVar = new Dg.f("networkTaskCancelAsync", new C0712a[0], new W());
} else {
C0712a c0712a33 = (C0712a) c0714c.a().get(new Pair(kotlin.jvm.internal.M.b(String.class), bool3));
if (c0712a33 == null) {
c0712a33 = new C0712a(new Lg.K(kotlin.jvm.internal.M.b(String.class), false, X.a));
}
eVar = new Dg.e("networkTaskCancelAsync", new C0712a[]{c0712a33}, new Y());
}
bVar.j().put("networkTaskCancelAsync", eVar);
C0712a c0712a34 = (C0712a) c0714c.a().get(new Pair(kotlin.jvm.internal.M.b(String.class), bool3));
if (c0712a34 == null) {
c0712a34 = new C0712a(new Lg.K(kotlin.jvm.internal.M.b(String.class), false, o0.a));
}
C0712a c0712a35 = (C0712a) c0714c.a().get(new Pair(kotlin.jvm.internal.M.b(String.class), bool3));
if (c0712a35 == null) {
c0712a35 = new C0712a(new Lg.K(kotlin.jvm.internal.M.b(String.class), false, p0.a));
}
C0712a c0712a36 = (C0712a) c0714c.a().get(new Pair(kotlin.jvm.internal.M.b(String.class), bool3));
if (c0712a36 == null) {
obj5 = obj8;
c0712a36 = new C0712a(new Lg.K(kotlin.jvm.internal.M.b(String.class), false, q0.a));
} else {
obj5 = obj8;
}
C0712a c0712a37 = (C0712a) c0714c.a().get(new Pair(kotlin.jvm.internal.M.b(DownloadOptions.class), bool3));
if (c0712a37 == null) {
bool2 = bool3;
c0712a37 = new C0712a(new Lg.K(kotlin.jvm.internal.M.b(DownloadOptions.class), false, r0.a));
} else {
bool2 = bool3;
}
C0712a c0712a38 = (C0712a) c0714c.a().get(new Pair(kotlin.jvm.internal.M.b(String.class), bool5));
if (c0712a38 == null) {
c0712a38 = new C0712a(new Lg.K(kotlin.jvm.internal.M.b(String.class), true, t0.a));
}
bVar.j().put("downloadResumableStartAsync", new Dg.f("downloadResumableStartAsync", new C0712a[]{c0712a34, c0712a35, c0712a36, c0712a37, c0712a38}, new u0()));
if (kotlin.jvm.internal.r.b(String.class, obj5)) {
kVar6 = new Dg.f("downloadResumablePauseAsync", new C0712a[0], new Z());
} else {
C0712a c0712a39 = (C0712a) c0714c.a().get(new Pair(kotlin.jvm.internal.M.b(String.class), bool2));
if (c0712a39 == null) {
c0712a39 = new C0712a(new Lg.K(kotlin.jvm.internal.M.b(String.class), false, C0867a0.a));
}
C0712a[] c0712aArr14 = {c0712a39};
C0869b0 c0869b0 = new C0869b0();
Object obj9 = obj3;
kVar6 = kotlin.jvm.internal.r.b(obj9, cls2) ? new Dg.k("downloadResumablePauseAsync", c0712aArr14, c0869b0) : kotlin.jvm.internal.r.b(obj9, Boolean.TYPE) ? new Dg.h("downloadResumablePauseAsync", c0712aArr14, c0869b0) : kotlin.jvm.internal.r.b(obj9, Double.TYPE) ? new Dg.i("downloadResumablePauseAsync", c0712aArr14, c0869b0) : kotlin.jvm.internal.r.b(obj9, Float.TYPE) ? new Dg.j("downloadResumablePauseAsync", c0712aArr14, c0869b0) : kotlin.jvm.internal.r.b(obj9, String.class) ? new Dg.m("downloadResumablePauseAsync", c0712aArr14, c0869b0) : new Dg.e("downloadResumablePauseAsync", c0712aArr14, c0869b0);
}
bVar.j().put("downloadResumablePauseAsync", kVar6);
Map r2 = bVar.r();
Cg.e eVar3 = Cg.e.o;
r2.put(eVar3, new Cg.d(eVar3, new D0()));
Map r3 = bVar.r();
Cg.e eVar4 = Cg.e.b;
r3.put(eVar4, new Cg.a(eVar4, new F0()));
Fg.c p = bVar.p();
w1.a.f();
return p;
} catch (Throwable th2) {
w1.a.f();
throw th2;
}
}
}