正在查看： CallApp v2.226 应用的 MobileFuseAssetManager.java JAVA 源代码文件
本页面展示 JAVA 反编译生成的源代码文件，支持语法高亮显示。 仅供安全研究与技术分析使用，严禁用于任何非法用途。请遵守相关法律法规。
页面标题
页面副标题
CallApp v2.226 - MobileFuseAssetManager.java 源代码
package com.mobilefuse.sdk.assetsmanager;
import android.content.Context;
import bv.f;
import bv.h;
import com.mobilefuse.sdk.AppLifecycleHelper;
import com.mobilefuse.sdk.DebuggingKt;
import com.mobilefuse.sdk.StabilityHelper;
import com.mobilefuse.sdk.Utils;
import com.mobilefuse.sdk.common.BuildConfig;
import com.mobilefuse.sdk.concurrency.Schedulers;
import com.mobilefuse.sdk.concurrency.SchedulersKt;
import com.mobilefuse.sdk.exception.Either;
import com.mobilefuse.sdk.exception.ExceptionHandlingStrategy;
import com.mobilefuse.sdk.exception.SuccessResult;
import com.mobilefuse.sdk.exception.TryKt;
import com.mobilefuse.sdk.network.client.HttpGetRequest;
import com.mobilefuse.sdk.rx.Flow;
import com.mobilefuse.sdk.rx.FlowCollector;
import com.mobilefuse.sdk.rx.FlowKt;
import com.mobilefuse.sdk.utils.TestableLazy;
import com.pubmatic.sdk.nativead.POBNativeConstants;
import com.vungle.ads.internal.presenter.e;
import java.io.File;
import java.util.Map;
import kotlin.Metadata;
import kotlin.NoWhenBranchMatchedException;
import kotlin.jvm.internal.Intrinsics;
import kotlin.jvm.internal.l0;
import kotlin.jvm.internal.m0;
import kotlin.jvm.internal.v;
import kotlin.reflect.KProperty;
import kotlin.text.Charsets;
import kotlin.text.StringsKt;
import org.jetbrains.annotations.NotNull;
@Metadata(bv = {1, 0, 3}, d1 = {"\u0000T\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0007\n\u0002\u0018\u0002\n\u0002\b\u0007\n\u0002\u0010\u0002\n\u0002\b\u0002\n\u0002\u0010\u000e\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u0012\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0018\u0002\n\u0002\b\f\n\u0002\u0018\u0002\n\u0002\b\u0002\bÆ\u0002\u0018\u00002\u00020\u0001B\u0007\b\u0002¢\u0006\u0002\u0010\u0002J\b\u0010\u0013\u001a\u00020\u0014H\u0002J\u0018\u0010\u0015\u001a\u00020\u00142\u0006\u0010\u0016\u001a\u00020\u00172\u0006\u0010\u0018\u001a\u00020\u0019H\u0016J\u0016\u0010\u001a\u001a\n\u0012\u0006\u0012\u0004\u0018\u00010\u00170\u001b2\u0006\u0010\u0016\u001a\u00020\u0017J\u001a\u0010\u001c\u001a\u0004\u0018\u00010\u001d2\u0006\u0010\u0016\u001a\u00020\u00172\u0006\u0010\u001e\u001a\u00020\u001fH\u0016J\u001e\u0010 \u001a\u00020\u00142\u0006\u0010\u0016\u001a\u00020\u00172\u0006\u0010\u001e\u001a\u00020\u001f2\u0006\u0010\u0018\u001a\u00020\u0019J\u001e\u0010!\u001a\n\u0012\u0006\u0012\u0004\u0018\u00010\u00170\u001b2\u0006\u0010\u0016\u001a\u00020\u00172\u0006\u0010\u001e\u001a\u00020\u001fJ\u0018\u0010\"\u001a\u0004\u0018\u00010\u00172\u0006\u0010\u0016\u001a\u00020\u00172\u0006\u0010\u001e\u001a\u00020\u001fJ\u0017\u0010#\u001a\u0004\u0018\u00010$2\u0006\u0010\u0016\u001a\u00020\u0017H\u0001¢\u0006\u0002\b%J\u0010\u0010&\u001a\u00020\u00142\u0006\u0010\u0016\u001a\u00020\u0017H\u0002J\u001d\u0010'\u001a\u00020\u00142\u0006\u0010(\u001a\u00020\u00172\u0006\u0010)\u001a\u00020\u0017H\u0001¢\u0006\u0002\b*J\b\u0010+\u001a\u00020\u0014H\u0016J\u0016\u0010,\u001a\u00020\u00142\u0006\u0010-\u001a\u00020\u00042\u0006\u0010.\u001a\u00020\fJ\u0015\u0010/\u001a\u00020\u00142\u0006\u00100\u001a\u000201H\u0001¢\u0006\u0002\b2R+\u0010\u0005\u001a\u00020\u00042\u0006\u0010\u0003\u001a\u00020\u00048B@BX\u0082\u008e\u0002¢\u0006\u0012\n\u0004\b\n\u0010\u000b\u001a\u0004\b\u0006\u0010\u0007\"\u0004\b\b\u0010\tR+\u0010\r\u001a\u00020\f2\u0006\u0010\u0003\u001a\u00020\f8B@BX\u0082\u008e\u0002¢\u0006\u0012\n\u0004\b\u0012\u0010\u000b\u001a\u0004\b\u000e\u0010\u000f\"\u0004\b\u0010\u0010\u0011¨\u00063"}, d2 = {"Lcom/mobilefuse/sdk/assetsmanager/MobileFuseAssetManager;", "Lcom/mobilefuse/sdk/assetsmanager/AssetManager;", "()V", "<set-?>", "Lcom/mobilefuse/sdk/assetsmanager/MobileFuseAssetManagerService;", "assetService", "getAssetService", "()Lcom/mobilefuse/sdk/assetsmanager/MobileFuseAssetManagerService;", "setAssetService", "(Lcom/mobilefuse/sdk/assetsmanager/MobileFuseAssetManagerService;)V", "assetService$delegate", "Lcom/mobilefuse/sdk/utils/TestableLazy;", "Lcom/mobilefuse/sdk/assetsmanager/AssetSharedPrefsResolver;", "sharedPrefsResolver", "getSharedPrefsResolver", "()Lcom/mobilefuse/sdk/assetsmanager/AssetSharedPrefsResolver;", "setSharedPrefsResolver", "(Lcom/mobilefuse/sdk/assetsmanager/AssetSharedPrefsResolver;)V", "sharedPrefsResolver$delegate", "deleteAllCacheFiles", "", "getSpecificAssetAbsolutePath", "fileName", "", "callback", "Lcom/mobilefuse/sdk/assetsmanager/ResultCallback;", "getSpecificAssetAbsolutePathFlow", "Lcom/mobilefuse/sdk/rx/Flow;", "getSpecificAssetBytes", "", POBNativeConstants.NATIVE_CONTEXT, "Landroid/content/Context;", "getSpecificAssetContent", "getSpecificAssetContentFlow", "getSpecificAssetContentSync", "getSpecificAssetFile", "Ljava/io/File;", "getSpecificAssetFile$mobilefuse_sdk_common_release", "removeAssetFile", "requestAndSaveSpecificAsset", "key", "value", "requestAndSaveSpecificAsset$mobilefuse_sdk_common_release", "requestAssetsManifest", "updateDependencies", "service", "sharedPrefs", "validateUnixTimeAndSave", "response", "Lcom/mobilefuse/sdk/assetsmanager/MobileFuseAssetManifestResponse;", "validateUnixTimeAndSave$mobilefuse_sdk_common_release", "mobilefuse-sdk-common_release"}, k = 1, mv = {1, 4, 3})
public final class MobileFuseAssetManager implements AssetManager {
static final KProperty[] $$delegatedProperties;
@NotNull
public static final MobileFuseAssetManager INSTANCE;
private static final TestableLazy assetService;
private static final TestableLazy sharedPrefsResolver;
static {
v vVar = new v(MobileFuseAssetManager.class, "assetService", "getAssetService()Lcom/mobilefuse/sdk/assetsmanager/MobileFuseAssetManagerService;", 0);
m0 m0Var = l0.a;
$$delegatedProperties = new KProperty[]{m0Var.f(vVar), com.explorestack.protobuf.a.r(MobileFuseAssetManager.class, "sharedPrefsResolver", "getSharedPrefsResolver()Lcom/mobilefuse/sdk/assetsmanager/AssetSharedPrefsResolver;", 0, m0Var)};
INSTANCE = new MobileFuseAssetManager();
assetService = new TestableLazy(MobileFuseAssetManager$assetService$2.INSTANCE);
sharedPrefsResolver = new TestableLazy(MobileFuseAssetManager$sharedPrefsResolver$2.INSTANCE);
}
private MobileFuseAssetManager() {
}
public final void deleteAllCacheFiles() {
ExceptionHandlingStrategy exceptionHandlingStrategy = ExceptionHandlingStrategy.LogAndIgnore;
try {
File filesDir = AppLifecycleHelper.getGlobalContext().getFilesDir();
MobileFuseAssetManager mobileFuseAssetManager = INSTANCE;
File file = new File(filesDir, mobileFuseAssetManager.getAssetService().getASSET_FOLDER_NAME());
if (file.exists()) {
h.h(file);
}
mobileFuseAssetManager.getSharedPrefsResolver().removeAssetPreference();
} catch (Throwable th) {
int i = TryKt.WhenMappings.$EnumSwitchMapping$0[exceptionHandlingStrategy.ordinal()];
if (i == 1) {
StabilityHelper.logException("[Automatically caught]", th);
} else if (i != 2) {
throw new NoWhenBranchMatchedException();
}
}
}
private final MobileFuseAssetManagerService getAssetService() {
return (MobileFuseAssetManagerService) assetService.getValue(this, $$delegatedProperties[0]);
}
public final AssetSharedPrefsResolver getSharedPrefsResolver() {
return (AssetSharedPrefsResolver) sharedPrefsResolver.getValue(this, $$delegatedProperties[1]);
}
private final void removeAssetFile(String fileName) {
SchedulersKt.safelyRunOnBgThread$default(null, new MobileFuseAssetManager$removeAssetFile$1(fileName), 1, null);
}
private final void setAssetService(MobileFuseAssetManagerService mobileFuseAssetManagerService) {
assetService.setValue(this, $$delegatedProperties[0], mobileFuseAssetManagerService);
}
public final void setSharedPrefsResolver(AssetSharedPrefsResolver assetSharedPrefsResolver) {
sharedPrefsResolver.setValue(this, $$delegatedProperties[1], assetSharedPrefsResolver);
}
@Override
public void getSpecificAssetAbsolutePath(@NotNull String fileName, @NotNull final ResultCallback callback) {
Intrinsics.checkNotNullParameter(fileName, "fileName");
Intrinsics.checkNotNullParameter(callback, "callback");
getSpecificAssetAbsolutePathFlow(fileName).collect(new FlowCollector() {
@Override
public final void emit(@NotNull Either<? extends Throwable, ? extends T> either) {
Intrinsics.checkNotNullParameter(either, "result");
if (either instanceof SuccessResult) {
ResultCallback.this.onResult((String) ((SuccessResult) either).getValue());
}
}
@Override
public void emitError(@NotNull Throwable th) {
Intrinsics.checkNotNullParameter(th, e.ERROR);
FlowCollector.DefaultImpls.emitError(this, th);
}
@Override
public void emitSuccess(T t) {
FlowCollector.DefaultImpls.emitSuccess(this, t);
}
});
}
@NotNull
public final Flow<String> getSpecificAssetAbsolutePathFlow(@NotNull String fileName) {
Intrinsics.checkNotNullParameter(fileName, "fileName");
return FlowKt.flow(new MobileFuseAssetManager$getSpecificAssetAbsolutePathFlow$$inlined$catchElse$1(FlowKt.flow(new MobileFuseAssetManager$emitOn$$inlined$transformOnThread$1(FlowKt.flow(new MobileFuseAssetManager$getSpecificAssetAbsolutePathFlow$1(fileName)), Schedulers.IO))));
}
@Override
public byte[] getSpecificAssetBytes(@NotNull String fileName, @NotNull Context context) {
Intrinsics.checkNotNullParameter(fileName, "fileName");
Intrinsics.checkNotNullParameter(context, POBNativeConstants.NATIVE_CONTEXT);
try {
File specificAssetFile$mobilefuse_sdk_common_release = getSpecificAssetFile$mobilefuse_sdk_common_release(fileName);
if (specificAssetFile$mobilefuse_sdk_common_release != null) {
return f.a(specificAssetFile$mobilefuse_sdk_common_release);
}
String assetContent = Utils.getAssetContent(context, "mobilefuse/" + fileName);
Intrinsics.checkNotNullExpressionValue(assetContent, "Utils.getAssetContent(co…\"mobilefuse/${fileName}\")");
byte[] bytes = assetContent.getBytes(Charsets.UTF_8);
Intrinsics.checkNotNullExpressionValue(bytes, "this as java.lang.String).getBytes(charset)");
return bytes;
} catch (Throwable th) {
StabilityHelper.logException(this, th);
return null;
}
}
public final void getSpecificAssetContent(@NotNull String fileName, @NotNull Context context, @NotNull final ResultCallback callback) {
Intrinsics.checkNotNullParameter(fileName, "fileName");
Intrinsics.checkNotNullParameter(context, POBNativeConstants.NATIVE_CONTEXT);
Intrinsics.checkNotNullParameter(callback, "callback");
getSpecificAssetContentFlow(fileName, context).collect(new FlowCollector() {
@Override
public final void emit(@NotNull Either<? extends Throwable, ? extends T> either) {
Intrinsics.checkNotNullParameter(either, "result");
if (either instanceof SuccessResult) {
ResultCallback.this.onResult((String) ((SuccessResult) either).getValue());
}
}
@Override
public void emitError(@NotNull Throwable th) {
Intrinsics.checkNotNullParameter(th, e.ERROR);
FlowCollector.DefaultImpls.emitError(this, th);
}
@Override
public void emitSuccess(T t) {
FlowCollector.DefaultImpls.emitSuccess(this, t);
}
});
}
@NotNull
public final Flow<String> getSpecificAssetContentFlow(@NotNull String fileName, @NotNull Context context) {
Intrinsics.checkNotNullParameter(fileName, "fileName");
Intrinsics.checkNotNullParameter(context, POBNativeConstants.NATIVE_CONTEXT);
return FlowKt.flow(new MobileFuseAssetManager$getSpecificAssetContentFlow$$inlined$catchElse$1(FlowKt.flow(new MobileFuseAssetManager$emitOn$$inlined$transformOnThread$2(FlowKt.flow(new MobileFuseAssetManager$getSpecificAssetContentFlow$1(fileName, context)), Schedulers.IO))));
}
public final String getSpecificAssetContentSync(@NotNull String fileName, @NotNull Context context) {
Intrinsics.checkNotNullParameter(fileName, "fileName");
Intrinsics.checkNotNullParameter(context, POBNativeConstants.NATIVE_CONTEXT);
File specificAssetFile$mobilefuse_sdk_common_release = getSpecificAssetFile$mobilefuse_sdk_common_release(fileName);
if (specificAssetFile$mobilefuse_sdk_common_release != null) {
return f.c(specificAssetFile$mobilefuse_sdk_common_release, Charsets.UTF_8);
}
return Utils.getAssetContent(context, "mobilefuse/" + fileName);
}
public final File getSpecificAssetFile$mobilefuse_sdk_common_release(@NotNull String fileName) {
Intrinsics.checkNotNullParameter(fileName, "fileName");
try {
File file = new File(new File(AppLifecycleHelper.getGlobalContext().getFilesDir(), getAssetService().getASSET_FOLDER_NAME()), fileName);
if (file.exists()) {
return file;
}
return null;
} catch (Throwable th) {
StabilityHelper.logException(this, th);
return null;
}
}
public final void requestAndSaveSpecificAsset$mobilefuse_sdk_common_release(@NotNull final String key, @NotNull final String value) {
Intrinsics.checkNotNullParameter(key, "key");
Intrinsics.checkNotNullParameter(value, "value");
ExceptionHandlingStrategy exceptionHandlingStrategy = ExceptionHandlingStrategy.LogAndIgnore;
try {
INSTANCE.getAssetService().resolveAssetPath(BuildConfig.BASE_ASSET_URL + key, key).collect(new FlowCollector() {
@Override
public final void emit(@NotNull Either<? extends Throwable, ? extends T> either) {
AssetSharedPrefsResolver sharedPrefsResolver2;
Intrinsics.checkNotNullParameter(either, "result");
if ((either instanceof SuccessResult) && ((Boolean) ((SuccessResult) either).getValue()).booleanValue()) {
MobileFuseAssetManager mobileFuseAssetManager = MobileFuseAssetManager.INSTANCE;
sharedPrefsResolver2 = mobileFuseAssetManager.getSharedPrefsResolver();
sharedPrefsResolver2.saveAssetsPreferences(key, value);
DebuggingKt.logDebug$default(mobileFuseAssetManager, "Save preference for specific asset file: " + key, null, 2, null);
}
}
@Override
public void emitError(@NotNull Throwable th) {
Intrinsics.checkNotNullParameter(th, e.ERROR);
FlowCollector.DefaultImpls.emitError(this, th);
}
@Override
public void emitSuccess(T t) {
FlowCollector.DefaultImpls.emitSuccess(this, t);
}
});
} catch (Throwable th) {
int i = TryKt.WhenMappings.$EnumSwitchMapping$0[exceptionHandlingStrategy.ordinal()];
if (i == 1) {
StabilityHelper.logException("[Automatically caught]", th);
} else if (i != 2) {
throw new NoWhenBranchMatchedException();
}
}
}
@Override
public void requestAssetsManifest() {
FlowKt.flow(new MobileFuseAssetManager$requestAssetsManifest$$inlined$map$1(FlowKt.flow(new MobileFuseAssetManager$runOn$$inlined$transformForConcurrency$1(getAssetService().getAssetManifestJson(new HttpGetRequest("https://cdn.mobilefuse.com/sdk/assets/android/1.9.2/manifest.json", null, false, false, 0L, 26, null)), Schedulers.IO)))).collect(new FlowCollector() {
@Override
public final void emit(@NotNull Either<? extends Throwable, ? extends T> either) {
Intrinsics.checkNotNullParameter(either, "result");
if (either instanceof SuccessResult) {
}
}
@Override
public void emitError(@NotNull Throwable th) {
Intrinsics.checkNotNullParameter(th, e.ERROR);
FlowCollector.DefaultImpls.emitError(this, th);
}
@Override
public void emitSuccess(T t) {
FlowCollector.DefaultImpls.emitSuccess(this, t);
}
});
}
public final void updateDependencies(@NotNull MobileFuseAssetManagerService service, @NotNull AssetSharedPrefsResolver sharedPrefs) {
Intrinsics.checkNotNullParameter(service, "service");
Intrinsics.checkNotNullParameter(sharedPrefs, "sharedPrefs");
setAssetService(service);
setSharedPrefsResolver(sharedPrefs);
}
public final void validateUnixTimeAndSave$mobilefuse_sdk_common_release(@NotNull MobileFuseAssetManifestResponse response) {
Intrinsics.checkNotNullParameter(response, "response");
try {
Map<String, String> paths = response.getPaths();
for (String str : getAssetService().getDEFAULT_ASSETS_LIST()) {
if (paths.containsKey(str)) {
String str2 = paths.get(str);
long parseLong = str2 != null ? Long.parseLong(str2) : 0L;
MobileFuseAssetManager mobileFuseAssetManager = INSTANCE;
String resolveAssetsPreferences = mobileFuseAssetManager.getSharedPrefsResolver().resolveAssetsPreferences(str);
if (resolveAssetsPreferences == null) {
resolveAssetsPreferences = null;
}
if (resolveAssetsPreferences != null && !StringsKt.J(resolveAssetsPreferences) && parseLong <= Long.parseLong(resolveAssetsPreferences)) {
}
mobileFuseAssetManager.requestAndSaveSpecificAsset$mobilefuse_sdk_common_release(str, String.valueOf(parseLong));
} else {
INSTANCE.removeAssetFile(str);
}
}
} catch (Throwable th) {
StabilityHelper.logException(this, th);
}
}
}