package com.kwad.components.offline.c;
import android.content.Context;
import android.os.SystemClock;
import androidx.annotation.NonNull;
import com.ksad.annotation.invoker.InvokeBy;
import com.kwad.components.core.n.b.b;
import com.kwad.components.core.request.g;
import com.kwad.components.core.request.h;
import com.kwad.components.offline.api.BuildConfig;
import com.kwad.components.offline.api.InitCallBack;
import com.kwad.components.offline.api.core.api.ILoggerReporter;
import com.kwad.components.offline.api.tk.ITkOfflineCompo;
import com.kwad.components.offline.api.tk.TkLoggerReporter;
import com.kwad.components.offline.api.tk.model.report.TKDownloadMsg;
import com.kwad.library.solder.lib.i;
import com.kwad.sdk.core.config.d;
import com.kwad.sdk.core.response.model.SdkConfigData;
import com.kwad.sdk.l;
import com.kwad.sdk.service.ServiceProvider;
import com.kwad.sdk.utils.ay;
import java.util.List;
import java.util.concurrent.CopyOnWriteArrayList;
import java.util.concurrent.atomic.AtomicBoolean;
public final class c extends com.kwad.components.core.n.b.a<ITkOfflineCompo> {
private static long ade;
private final List<com.kwad.components.core.n.a.d.a> add;
private final AtomicBoolean adf;
/* access modifiers changed from: package-private */
public static final class a {
private static final c adp = new c((byte) 0);
}
/* synthetic */ c(byte b) {
this();
}
@InvokeBy(invokerClass = b.class, methodId = "initOC")
public static void aj(Context context) {
ade = SystemClock.elapsedRealtime();
tO().init(context);
}
public static c tO() {
return a.adp;
}
@Override // com.kwad.components.core.n.b.a
public final String getTag() {
return "TkInitModule";
}
@Override // com.kwad.components.core.n.b.a
public final boolean isEnabled() {
return ((Boolean) d.b(com.kwad.sdk.core.config.c.asg)).booleanValue();
}
@Override // com.kwad.components.core.n.b.a
public final String oO() {
return "TK";
}
@Override // com.kwad.components.core.n.b.a
public final String oP() {
return ITkOfflineCompo.PACKAGE_NAME;
}
@Override // com.kwad.components.core.n.b.a
public final String oQ() {
return BuildConfig.VERSION_NAME;
}
@Override // com.kwad.components.core.n.b.a
public final String oR() {
return "https://p1-lm.adkwai.com/udata/pkg/KS-Android-KSAdSDk/offline_components/tk/ks_so-tachikomaNoSoRelease-3.3.61-f6023045dd-499.zip";
}
@Override // com.kwad.components.core.n.b.a
public final String oS() {
return "1cc56921ce71b2e71ed20c417225e303";
}
@Override // com.kwad.components.core.n.b.a
public final String oT() {
return "ks_tk_3361";
}
@Override // com.kwad.components.core.n.b.a
public final String oU() {
return ITkOfflineCompo.IMPL;
}
private c() {
this.add = new CopyOnWriteArrayList();
this.adf = new AtomicBoolean(false);
}
public final void b(com.kwad.components.core.n.a.d.a aVar) {
if (aVar != null) {
this.add.remove(aVar);
}
}
/* access modifiers changed from: private */
/* access modifiers changed from: public */
private void b(int i2, int i3, long j, long j2) {
for (com.kwad.components.core.n.a.d.a aVar : this.add) {
try {
aVar.a(i2, i3, j, j2);
} catch (Throwable th) {
ServiceProvider.reportSdkCaughtException(th);
}
}
}
/* access modifiers changed from: private */
public void a(final Context context, final boolean z, final ITkOfflineCompo iTkOfflineCompo) {
final long elapsedRealtime = SystemClock.elapsedRealtime();
final long elapsedRealtime2 = SystemClock.elapsedRealtime() - ade;
iTkOfflineCompo.init(context, new d(), new InitCallBack() {
/* class com.kwad.components.offline.c.c.AnonymousClass1 */
@Override // com.kwad.components.offline.api.InitCallBack
public final void onError(int i2) {
c.this.au(i2);
}
@Override // com.kwad.components.offline.api.InitCallBack
public final void onSuccess(boolean z) {
try {
final b bVar = new b(iTkOfflineCompo);
com.kwad.sdk.components.c.a(com.kwad.components.core.n.a.d.c.class, bVar);
int i2 = 1;
c.this.adf.set(true);
int i3 = z ? 2 : 1;
if (z) {
i2 = 2;
}
c.this.b(i3, i2, SystemClock.elapsedRealtime() - elapsedRealtime, elapsedRealtime2);
TkLoggerReporter.get().reportTKSOLoad(ILoggerReporter.Category.APM_LOG, new TKDownloadMsg().setDownloadState(3).setOfflineLoadTime(elapsedRealtime2).setSoLoadTime(SystemClock.elapsedRealtime() - elapsedRealtime).setInitSdkTimeConsuming(SystemClock.elapsedRealtime() - l.zi().zG()).setThreadPoolCoreSize(i.xj().xd().xE()).setOfflineSource(i2).setSoSource(i3).toJson());
c.this.oN();
g.b(new h() {
/* class com.kwad.components.offline.c.c.AnonymousClass1.AnonymousClass1 */
@Override // com.kwad.components.core.request.h, com.kwad.components.core.request.g.a
public final void d(@NonNull final SdkConfigData sdkConfigData) {
super.d(sdkConfigData);
com.kwad.sdk.utils.g.execute(new ay() {
/* class com.kwad.components.offline.c.c.AnonymousClass1.AnonymousClass1.AnonymousClass1 */
@Override // com.kwad.sdk.utils.ay
public final void doTask() {
AnonymousClass1 r0 = AnonymousClass1.this;
bVar.onConfigRefresh(context, sdkConfigData.toJson());
}
});
}
});
} catch (Throwable th) {
ServiceProvider.reportSdkCaughtException(th);
}
}
});
}
public final void a(com.kwad.components.core.n.a.d.a aVar) {
if (aVar != null) {
try {
if (this.adf.get()) {
aVar.a(1, 1, 0, 0);
}
this.add.add(aVar);
} catch (Throwable th) {
ServiceProvider.reportSdkCaughtException(th);
}
}
}
}