package com.benq.platform.test;

import F1.AbstractC0121g;
import F1.AbstractC0125i;
import F1.H;
import F1.I;
import F1.W;
import F1.n0;
import F1.y0;
import android.R;
import android.os.Bundle;
import android.util.Log;
import android.view.View;
import android.widget.ArrayAdapter;
import android.widget.SpinnerAdapter;
import android.widget.TextView;
import android.widget.Toast;
import androidx.appcompat.app.AppCompatActivity;
import androidx.media3.datasource.DataSchemeDataSource;
import androidx.media3.decoder.midi.MidiDecoder;
import com.benq.platform.AudioRecordController;
import com.benq.platform.databinding.ActivityAudioRecordTestBinding;
import com.cvte.vman.BuildConfig;
import com.mstar.android.tv.TvLanguage;
import java.io.BufferedOutputStream;
import java.io.ByteArrayOutputStream;
import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.OutputStream;
import java.nio.charset.Charset;
import java.text.SimpleDateFormat;
import java.util.Arrays;
import java.util.Date;
import java.util.Locale;
import n1.l;
import o1.AbstractC0676l;
import okhttp3.HttpUrl;
import r1.AbstractC0707b;

/* JADX INFO: loaded from: classes.dex */
public final class AudioRecordTestActivity extends AppCompatActivity {
    public static final Companion Companion = new Companion(null);
    private static final String TAG = "AudioRecordTest";
    private long accumulatedDurationMs;
    private ActivityAudioRecordTestBinding binding;
    private volatile boolean isRecording;
    private long readCalls;
    private n0 readLoopJob;
    private long segmentStartMs;
    private long totalBytes;
    private final ByteArrayOutputStream pcmBuffer = new ByteArrayOutputStream();
    private int configuredSampleRate = MidiDecoder.DEFAULT_SAMPLE_RATE;
    private int configuredChannels = 1;
    private int configuredAudioSource = 1;

    public static final class Companion {
        public /* synthetic */ Companion(kotlin.jvm.internal.g gVar) {
            this();
        }

        private Companion() {
        }
    }

    /* JADX INFO: renamed from: com.benq.platform.test.AudioRecordTestActivity$onSaveWav$1, reason: invalid class name */
    @kotlin.coroutines.jvm.internal.f(c = "com.benq.platform.test.AudioRecordTestActivity$onSaveWav$1", f = "AudioRecordTestActivity.kt", l = {TvLanguage.GA, TvLanguage.GERMANMIDDLEHIGH}, m = "invokeSuspend")
    static final class AnonymousClass1 extends kotlin.coroutines.jvm.internal.l implements y1.p {
        final /* synthetic */ byte[] $data;
        int label;

        /* JADX INFO: renamed from: com.benq.platform.test.AudioRecordTestActivity$onSaveWav$1$1, reason: invalid class name and collision with other inner class name */
        @kotlin.coroutines.jvm.internal.f(c = "com.benq.platform.test.AudioRecordTestActivity$onSaveWav$1$1", f = "AudioRecordTestActivity.kt", l = {}, m = "invokeSuspend")
        static final class C00661 extends kotlin.coroutines.jvm.internal.l implements y1.p {
            final /* synthetic */ byte[] $data;
            final /* synthetic */ File $wavFile;
            int label;
            final /* synthetic */ AudioRecordTestActivity this$0;

            /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
            C00661(AudioRecordTestActivity audioRecordTestActivity, File file, byte[] bArr, q1.d dVar) {
                super(2, dVar);
                this.this$0 = audioRecordTestActivity;
                this.$wavFile = file;
                this.$data = bArr;
            }

            @Override // kotlin.coroutines.jvm.internal.a
            public final q1.d create(Object obj, q1.d dVar) {
                return new C00661(this.this$0, this.$wavFile, this.$data, dVar);
            }

            @Override // y1.p
            public final Object invoke(H h2, q1.d dVar) {
                return ((C00661) create(h2, dVar)).invokeSuspend(n1.s.f5871a);
            }

            @Override // kotlin.coroutines.jvm.internal.a
            public final Object invokeSuspend(Object obj) {
                AbstractC0707b.d();
                if (this.label != 0) {
                    throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                }
                n1.m.b(obj);
                this.this$0.log("Saved WAV: " + this.$wavFile.getAbsolutePath() + " (" + this.$data.length + " bytes)");
                AudioRecordTestActivity audioRecordTestActivity = this.this$0;
                String name = this.$wavFile.getName();
                StringBuilder sb = new StringBuilder();
                sb.append("Saved: ");
                sb.append(name);
                audioRecordTestActivity.toast(sb.toString());
                return n1.s.f5871a;
            }
        }

        /* JADX INFO: renamed from: com.benq.platform.test.AudioRecordTestActivity$onSaveWav$1$2, reason: invalid class name */
        @kotlin.coroutines.jvm.internal.f(c = "com.benq.platform.test.AudioRecordTestActivity$onSaveWav$1$2", f = "AudioRecordTestActivity.kt", l = {}, m = "invokeSuspend")
        static final class AnonymousClass2 extends kotlin.coroutines.jvm.internal.l implements y1.p {
            final /* synthetic */ Exception $e;
            int label;
            final /* synthetic */ AudioRecordTestActivity this$0;

            /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
            AnonymousClass2(AudioRecordTestActivity audioRecordTestActivity, Exception exc, q1.d dVar) {
                super(2, dVar);
                this.this$0 = audioRecordTestActivity;
                this.$e = exc;
            }

            @Override // kotlin.coroutines.jvm.internal.a
            public final q1.d create(Object obj, q1.d dVar) {
                return new AnonymousClass2(this.this$0, this.$e, dVar);
            }

            @Override // y1.p
            public final Object invoke(H h2, q1.d dVar) {
                return ((AnonymousClass2) create(h2, dVar)).invokeSuspend(n1.s.f5871a);
            }

            @Override // kotlin.coroutines.jvm.internal.a
            public final Object invokeSuspend(Object obj) {
                AbstractC0707b.d();
                if (this.label != 0) {
                    throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                }
                n1.m.b(obj);
                this.this$0.log("Save failed: " + this.$e.getMessage());
                this.this$0.toast("Save failed");
                return n1.s.f5871a;
            }
        }

        /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
        AnonymousClass1(byte[] bArr, q1.d dVar) {
            super(2, dVar);
            this.$data = bArr;
        }

        @Override // kotlin.coroutines.jvm.internal.a
        public final q1.d create(Object obj, q1.d dVar) {
            return AudioRecordTestActivity.this.new AnonymousClass1(this.$data, dVar);
        }

        @Override // y1.p
        public final Object invoke(H h2, q1.d dVar) {
            return ((AnonymousClass1) create(h2, dVar)).invokeSuspend(n1.s.f5871a);
        }

        @Override // kotlin.coroutines.jvm.internal.a
        public final Object invokeSuspend(Object obj) {
            Object objD = AbstractC0707b.d();
            int i2 = this.label;
            try {
                if (i2 == 0) {
                    n1.m.b(obj);
                    File file = new File("/storage/emulated/0/Download");
                    if (!file.exists()) {
                        file.mkdirs();
                    }
                    File file2 = new File(file, "benq_audio_" + new SimpleDateFormat("yyyyMMdd_HHmmss", Locale.US).format(new Date()) + ".wav");
                    AudioRecordTestActivity audioRecordTestActivity = AudioRecordTestActivity.this;
                    audioRecordTestActivity.writeWav(file2, this.$data, audioRecordTestActivity.configuredSampleRate, AudioRecordTestActivity.this.configuredChannels);
                    y0 y0VarC = W.c();
                    C00661 c00661 = new C00661(AudioRecordTestActivity.this, file2, this.$data, null);
                    this.label = 1;
                    if (AbstractC0121g.g(y0VarC, c00661, this) == objD) {
                        return objD;
                    }
                } else {
                    if (i2 != 1 && i2 != 2) {
                        throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                    }
                    n1.m.b(obj);
                }
            } catch (Exception e2) {
                Log.e(AudioRecordTestActivity.TAG, "saveWav failed", e2);
                y0 y0VarC2 = W.c();
                AnonymousClass2 anonymousClass2 = new AnonymousClass2(AudioRecordTestActivity.this, e2, null);
                this.label = 2;
                if (AbstractC0121g.g(y0VarC2, anonymousClass2, this) == objD) {
                    return objD;
                }
            }
            return n1.s.f5871a;
        }
    }

    /* JADX INFO: renamed from: com.benq.platform.test.AudioRecordTestActivity$startReadLoop$1, reason: invalid class name and case insensitive filesystem */
    @kotlin.coroutines.jvm.internal.f(c = "com.benq.platform.test.AudioRecordTestActivity$startReadLoop$1", f = "AudioRecordTestActivity.kt", l = {130, 133, TvLanguage.CRIMEANTATAR}, m = "invokeSuspend")
    static final class C04141 extends kotlin.coroutines.jvm.internal.l implements y1.p {
        private /* synthetic */ Object L$0;
        Object L$1;
        int label;

        /* JADX INFO: renamed from: com.benq.platform.test.AudioRecordTestActivity$startReadLoop$1$2, reason: invalid class name */
        @kotlin.coroutines.jvm.internal.f(c = "com.benq.platform.test.AudioRecordTestActivity$startReadLoop$1$2", f = "AudioRecordTestActivity.kt", l = {}, m = "invokeSuspend")
        static final class AnonymousClass2 extends kotlin.coroutines.jvm.internal.l implements y1.p {
            int label;
            final /* synthetic */ AudioRecordTestActivity this$0;

            /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
            AnonymousClass2(AudioRecordTestActivity audioRecordTestActivity, q1.d dVar) {
                super(2, dVar);
                this.this$0 = audioRecordTestActivity;
            }

            @Override // kotlin.coroutines.jvm.internal.a
            public final q1.d create(Object obj, q1.d dVar) {
                return new AnonymousClass2(this.this$0, dVar);
            }

            @Override // y1.p
            public final Object invoke(H h2, q1.d dVar) {
                return ((AnonymousClass2) create(h2, dVar)).invokeSuspend(n1.s.f5871a);
            }

            @Override // kotlin.coroutines.jvm.internal.a
            public final Object invokeSuspend(Object obj) {
                AbstractC0707b.d();
                if (this.label != 0) {
                    throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                }
                n1.m.b(obj);
                this.this$0.updateStatus("RECORDING");
                return n1.s.f5871a;
            }
        }

        /* JADX INFO: renamed from: com.benq.platform.test.AudioRecordTestActivity$startReadLoop$1$3, reason: invalid class name */
        @kotlin.coroutines.jvm.internal.f(c = "com.benq.platform.test.AudioRecordTestActivity$startReadLoop$1$3", f = "AudioRecordTestActivity.kt", l = {}, m = "invokeSuspend")
        static final class AnonymousClass3 extends kotlin.coroutines.jvm.internal.l implements y1.p {
            int label;
            final /* synthetic */ AudioRecordTestActivity this$0;

            /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
            AnonymousClass3(AudioRecordTestActivity audioRecordTestActivity, q1.d dVar) {
                super(2, dVar);
                this.this$0 = audioRecordTestActivity;
            }

            @Override // kotlin.coroutines.jvm.internal.a
            public final q1.d create(Object obj, q1.d dVar) {
                return new AnonymousClass3(this.this$0, dVar);
            }

            @Override // y1.p
            public final Object invoke(H h2, q1.d dVar) {
                return ((AnonymousClass3) create(h2, dVar)).invokeSuspend(n1.s.f5871a);
            }

            @Override // kotlin.coroutines.jvm.internal.a
            public final Object invokeSuspend(Object obj) {
                AbstractC0707b.d();
                if (this.label != 0) {
                    throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                }
                n1.m.b(obj);
                this.this$0.log("read() returned RESULT_FAILED, stopping loop");
                return n1.s.f5871a;
            }
        }

        /* JADX INFO: renamed from: com.benq.platform.test.AudioRecordTestActivity$startReadLoop$1$4, reason: invalid class name */
        @kotlin.coroutines.jvm.internal.f(c = "com.benq.platform.test.AudioRecordTestActivity$startReadLoop$1$4", f = "AudioRecordTestActivity.kt", l = {}, m = "invokeSuspend")
        static final class AnonymousClass4 extends kotlin.coroutines.jvm.internal.l implements y1.p {
            int label;
            final /* synthetic */ AudioRecordTestActivity this$0;

            /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
            AnonymousClass4(AudioRecordTestActivity audioRecordTestActivity, q1.d dVar) {
                super(2, dVar);
                this.this$0 = audioRecordTestActivity;
            }

            @Override // kotlin.coroutines.jvm.internal.a
            public final q1.d create(Object obj, q1.d dVar) {
                return new AnonymousClass4(this.this$0, dVar);
            }

            @Override // y1.p
            public final Object invoke(H h2, q1.d dVar) {
                return ((AnonymousClass4) create(h2, dVar)).invokeSuspend(n1.s.f5871a);
            }

            @Override // kotlin.coroutines.jvm.internal.a
            public final Object invokeSuspend(Object obj) {
                AbstractC0707b.d();
                if (this.label != 0) {
                    throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                }
                n1.m.b(obj);
                this.this$0.updateStatus("STOPPED");
                return n1.s.f5871a;
            }
        }

        C04141(q1.d dVar) {
            super(2, dVar);
        }

        @Override // kotlin.coroutines.jvm.internal.a
        public final q1.d create(Object obj, q1.d dVar) {
            C04141 c04141 = AudioRecordTestActivity.this.new C04141(dVar);
            c04141.L$0 = obj;
            return c04141;
        }

        @Override // y1.p
        public final Object invoke(H h2, q1.d dVar) {
            return ((C04141) create(h2, dVar)).invokeSuspend(n1.s.f5871a);
        }

        @Override // kotlin.coroutines.jvm.internal.a
        public final Object invokeSuspend(Object obj) {
            byte[] bArr;
            H h2;
            Object objD = AbstractC0707b.d();
            int i2 = this.label;
            if (i2 == 0) {
                n1.m.b(obj);
                H h3 = (H) this.L$0;
                bArr = new byte[((AudioRecordTestActivity.this.configuredSampleRate * AudioRecordTestActivity.this.configuredChannels) * 2) / 10];
                h2 = h3;
            } else {
                if (i2 != 1) {
                    if (i2 != 2) {
                        if (i2 != 3) {
                            throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                        }
                        n1.m.b(obj);
                        return n1.s.f5871a;
                    }
                    n1.m.b(obj);
                    y0 y0VarC = W.c();
                    AnonymousClass4 anonymousClass4 = new AnonymousClass4(AudioRecordTestActivity.this, null);
                    this.L$0 = null;
                    this.L$1 = null;
                    this.label = 3;
                    if (AbstractC0121g.g(y0VarC, anonymousClass4, this) == objD) {
                        return objD;
                    }
                    return n1.s.f5871a;
                }
                bArr = (byte[]) this.L$1;
                h2 = (H) this.L$0;
                n1.m.b(obj);
            }
            while (true) {
                if (!I.b(h2) || !AudioRecordTestActivity.this.isRecording) {
                    break;
                }
                int i3 = AudioRecordTestActivity.this.getController().read(bArr, 0, bArr.length);
                if (i3 > 0) {
                    ByteArrayOutputStream byteArrayOutputStream = AudioRecordTestActivity.this.pcmBuffer;
                    AudioRecordTestActivity audioRecordTestActivity = AudioRecordTestActivity.this;
                    synchronized (byteArrayOutputStream) {
                        audioRecordTestActivity.pcmBuffer.write(bArr, 0, i3);
                        n1.s sVar = n1.s.f5871a;
                    }
                    AudioRecordTestActivity.this.totalBytes += (long) i3;
                    AudioRecordTestActivity.this.readCalls++;
                    if (AudioRecordTestActivity.this.readCalls % ((long) 10) == 0) {
                        y0 y0VarC2 = W.c();
                        AnonymousClass2 anonymousClass2 = new AnonymousClass2(AudioRecordTestActivity.this, null);
                        this.L$0 = h2;
                        this.L$1 = bArr;
                        this.label = 1;
                        if (AbstractC0121g.g(y0VarC2, anonymousClass2, this) == objD) {
                            return objD;
                        }
                    } else {
                        continue;
                    }
                } else if (i3 == -1) {
                    y0 y0VarC3 = W.c();
                    AnonymousClass3 anonymousClass3 = new AnonymousClass3(AudioRecordTestActivity.this, null);
                    this.L$0 = null;
                    this.L$1 = null;
                    this.label = 2;
                    if (AbstractC0121g.g(y0VarC3, anonymousClass3, this) == objD) {
                        return objD;
                    }
                }
            }
        }
    }

    private final long currentDurationMs() {
        return this.accumulatedDurationMs + (this.segmentStartMs > 0 ? System.currentTimeMillis() - this.segmentStartMs : 0L);
    }

    private final String currentLabel(String str) {
        if (str != null) {
            return str;
        }
        if (this.isRecording) {
            return "RECORDING";
        }
        n0 n0Var = this.readLoopJob;
        return (n0Var == null || !n0Var.isActive()) ? "IDLE" : "READING";
    }

    static /* synthetic */ String currentLabel$default(AudioRecordTestActivity audioRecordTestActivity, String str, int i2, Object obj) {
        if ((i2 & 1) != 0) {
            str = null;
        }
        return audioRecordTestActivity.currentLabel(str);
    }

    /* JADX INFO: Access modifiers changed from: private */
    public final AudioRecordController getController() {
        return AudioRecordController.getInstance();
    }

    /* JADX INFO: Access modifiers changed from: private */
    public final void log(final String str) {
        Log.d(TAG, str);
        final String str2 = new SimpleDateFormat("HH:mm:ss.SSS", Locale.US).format(new Date());
        runOnUiThread(new Runnable() { // from class: com.benq.platform.test.q
            @Override // java.lang.Runnable
            public final void run() {
                AudioRecordTestActivity.log$lambda$13(this.f3141b, str2, str);
            }
        });
    }

    /* JADX INFO: Access modifiers changed from: private */
    public static final void log$lambda$13(AudioRecordTestActivity this$0, String str, String msg) {
        kotlin.jvm.internal.l.e(this$0, "this$0");
        kotlin.jvm.internal.l.e(msg, "$msg");
        ActivityAudioRecordTestBinding activityAudioRecordTestBinding = this$0.binding;
        if (activityAudioRecordTestBinding == null) {
            kotlin.jvm.internal.l.s("binding");
            activityAudioRecordTestBinding = null;
        }
        activityAudioRecordTestBinding.tvLog.append("[" + str + "] " + msg + "\n");
    }

    private final void logResult(String str, int i2) {
        String strResultLabel = resultLabel(i2);
        log("-> " + str + " result = " + i2 + " (" + strResultLabel + ")");
        ActivityAudioRecordTestBinding activityAudioRecordTestBinding = this.binding;
        if (activityAudioRecordTestBinding == null) {
            kotlin.jvm.internal.l.s("binding");
            activityAudioRecordTestBinding = null;
        }
        TextView textView = activityAudioRecordTestBinding.tvStatus;
        StringBuilder sb = new StringBuilder();
        sb.append("State: " + currentLabel$default(this, null, 1, null) + "\n");
        sb.append("Total bytes: " + this.totalBytes + "\n");
        sb.append("Read calls: " + this.readCalls + "\n");
        sb.append("Duration: " + currentDurationMs() + " ms\n");
        sb.append("Last result: " + str + "=" + i2 + " (" + strResultLabel + ")");
        String string = sb.toString();
        kotlin.jvm.internal.l.d(string, "toString(...)");
        textView.setText(string);
    }

    private final void onConfigure() {
        ActivityAudioRecordTestBinding activityAudioRecordTestBinding = this.binding;
        ActivityAudioRecordTestBinding activityAudioRecordTestBinding2 = null;
        if (activityAudioRecordTestBinding == null) {
            kotlin.jvm.internal.l.s("binding");
            activityAudioRecordTestBinding = null;
        }
        Object selectedItem = activityAudioRecordTestBinding.spinnerSampleRate.getSelectedItem();
        kotlin.jvm.internal.l.c(selectedItem, "null cannot be cast to non-null type kotlin.Int");
        int iIntValue = ((Integer) selectedItem).intValue();
        ActivityAudioRecordTestBinding activityAudioRecordTestBinding3 = this.binding;
        if (activityAudioRecordTestBinding3 == null) {
            kotlin.jvm.internal.l.s("binding");
            activityAudioRecordTestBinding3 = null;
        }
        int selectedItemPosition = activityAudioRecordTestBinding3.spinnerChannelCount.getSelectedItemPosition() + 1;
        ActivityAudioRecordTestBinding activityAudioRecordTestBinding4 = this.binding;
        if (activityAudioRecordTestBinding4 == null) {
            kotlin.jvm.internal.l.s("binding");
        } else {
            activityAudioRecordTestBinding2 = activityAudioRecordTestBinding4;
        }
        int selectedItemPosition2 = activityAudioRecordTestBinding2.spinnerAudioSource.getSelectedItemPosition() + 1;
        this.configuredSampleRate = iIntValue;
        this.configuredChannels = selectedItemPosition;
        this.configuredAudioSource = selectedItemPosition2;
        log("configure(sampleRate=" + iIntValue + ", channels=" + selectedItemPosition + ", audioSource=" + selectedItemPosition2 + ")");
        logResult("configure", getController().configure(iIntValue, selectedItemPosition, selectedItemPosition2));
        updateStatus("CONFIGURED");
    }

    /* JADX INFO: Access modifiers changed from: private */
    public static final void onCreate$lambda$0(AudioRecordTestActivity this$0, View view) {
        kotlin.jvm.internal.l.e(this$0, "this$0");
        this$0.finish();
    }

    /* JADX INFO: Access modifiers changed from: private */
    public static final void onCreate$lambda$1(AudioRecordTestActivity this$0, View view) {
        kotlin.jvm.internal.l.e(this$0, "this$0");
        this$0.onConfigure();
    }

    /* JADX INFO: Access modifiers changed from: private */
    public static final void onCreate$lambda$2(AudioRecordTestActivity this$0, View view) {
        kotlin.jvm.internal.l.e(this$0, "this$0");
        this$0.onStartRecording();
    }

    /* JADX INFO: Access modifiers changed from: private */
    public static final void onCreate$lambda$3(AudioRecordTestActivity this$0, View view) {
        kotlin.jvm.internal.l.e(this$0, "this$0");
        this$0.onStopRecording();
    }

    /* JADX INFO: Access modifiers changed from: private */
    public static final void onCreate$lambda$4(AudioRecordTestActivity this$0, View view) {
        kotlin.jvm.internal.l.e(this$0, "this$0");
        this$0.onRelease();
    }

    /* JADX INFO: Access modifiers changed from: private */
    public static final void onCreate$lambda$5(AudioRecordTestActivity this$0, View view) {
        kotlin.jvm.internal.l.e(this$0, "this$0");
        this$0.onSaveWav();
    }

    /* JADX INFO: Access modifiers changed from: private */
    public static final void onCreate$lambda$6(AudioRecordTestActivity this$0, View view) {
        kotlin.jvm.internal.l.e(this$0, "this$0");
        ActivityAudioRecordTestBinding activityAudioRecordTestBinding = this$0.binding;
        if (activityAudioRecordTestBinding == null) {
            kotlin.jvm.internal.l.s("binding");
            activityAudioRecordTestBinding = null;
        }
        activityAudioRecordTestBinding.tvLog.setText(HttpUrl.FRAGMENT_ENCODE_SET);
    }

    private final void onRelease() {
        this.isRecording = false;
        n0 n0Var = this.readLoopJob;
        if (n0Var != null) {
            n0.a.a(n0Var, null, 1, null);
        }
        log("release()");
        logResult(BuildConfig.BUILD_TYPE, getController().release());
        synchronized (this.pcmBuffer) {
            this.pcmBuffer.reset();
            n1.s sVar = n1.s.f5871a;
        }
        this.totalBytes = 0L;
        this.readCalls = 0L;
        this.accumulatedDurationMs = 0L;
        this.segmentStartMs = 0L;
        updateStatus("RELEASED");
    }

    private final void onSaveWav() {
        byte[] byteArray;
        synchronized (this.pcmBuffer) {
            byteArray = this.pcmBuffer.toByteArray();
        }
        kotlin.jvm.internal.l.d(byteArray, "synchronized(...)");
        if (byteArray.length == 0) {
            toast("No PCM data captured");
        } else {
            AbstractC0125i.d(I.a(W.b()), null, null, new AnonymousClass1(byteArray, null), 3, null);
        }
    }

    private final void onStartRecording() {
        log("startRecording()");
        int iStartRecording = getController().startRecording();
        logResult("startRecording", iStartRecording);
        if (iStartRecording != 0) {
            updateStatus("CONFIGURED");
            return;
        }
        this.isRecording = true;
        this.segmentStartMs = System.currentTimeMillis();
        updateStatus("RECORDING");
        ActivityAudioRecordTestBinding activityAudioRecordTestBinding = this.binding;
        if (activityAudioRecordTestBinding == null) {
            kotlin.jvm.internal.l.s("binding");
            activityAudioRecordTestBinding = null;
        }
        if (activityAudioRecordTestBinding.cbContinuousRead.isChecked()) {
            startReadLoop();
        }
    }

    private final void onStopRecording() {
        this.isRecording = false;
        n0 n0Var = this.readLoopJob;
        if (n0Var != null) {
            n0.a.a(n0Var, null, 1, null);
        }
        if (this.segmentStartMs > 0) {
            this.accumulatedDurationMs += System.currentTimeMillis() - this.segmentStartMs;
            this.segmentStartMs = 0L;
        }
        log("stop()");
        logResult("stop", getController().stop());
        updateStatus("STOPPED");
    }

    private final String resultLabel(int i2) {
        if (i2 == -11) {
            return "NOT_SUPPORTED";
        }
        if (i2 == -10) {
            return "CONFIG_ERROR";
        }
        if (i2 == -2) {
            return "NOT_CONNECTED_RETRY";
        }
        if (i2 == -1) {
            return "FAILED";
        }
        if (i2 == 0) {
            return "SUCCESS";
        }
        return "UNKNOWN(" + i2 + ")";
    }

    private final void setupSpinners() {
        ActivityAudioRecordTestBinding activityAudioRecordTestBinding = this.binding;
        ActivityAudioRecordTestBinding activityAudioRecordTestBinding2 = null;
        if (activityAudioRecordTestBinding == null) {
            kotlin.jvm.internal.l.s("binding");
            activityAudioRecordTestBinding = null;
        }
        activityAudioRecordTestBinding.spinnerSampleRate.setAdapter((SpinnerAdapter) new ArrayAdapter(this, R.layout.simple_spinner_dropdown_item, AbstractC0676l.h(16000, Integer.valueOf(MidiDecoder.DEFAULT_SAMPLE_RATE), 48000)));
        ActivityAudioRecordTestBinding activityAudioRecordTestBinding3 = this.binding;
        if (activityAudioRecordTestBinding3 == null) {
            kotlin.jvm.internal.l.s("binding");
            activityAudioRecordTestBinding3 = null;
        }
        activityAudioRecordTestBinding3.spinnerSampleRate.setSelection(1);
        ActivityAudioRecordTestBinding activityAudioRecordTestBinding4 = this.binding;
        if (activityAudioRecordTestBinding4 == null) {
            kotlin.jvm.internal.l.s("binding");
            activityAudioRecordTestBinding4 = null;
        }
        activityAudioRecordTestBinding4.spinnerChannelCount.setAdapter((SpinnerAdapter) new ArrayAdapter(this, R.layout.simple_spinner_dropdown_item, AbstractC0676l.h("1 (Mono)", "2 (Stereo)")));
        ActivityAudioRecordTestBinding activityAudioRecordTestBinding5 = this.binding;
        if (activityAudioRecordTestBinding5 == null) {
            kotlin.jvm.internal.l.s("binding");
        } else {
            activityAudioRecordTestBinding2 = activityAudioRecordTestBinding5;
        }
        activityAudioRecordTestBinding2.spinnerAudioSource.setAdapter((SpinnerAdapter) new ArrayAdapter(this, R.layout.simple_spinner_dropdown_item, AbstractC0676l.h("1 System", "2 Mic", "3 System + Mic")));
    }

    private final void startReadLoop() {
        n0 n0Var = this.readLoopJob;
        if (n0Var != null) {
            n0.a.a(n0Var, null, 1, null);
        }
        this.readLoopJob = AbstractC0125i.d(I.a(W.b()), null, null, new C04141(null), 3, null);
    }

    /* JADX INFO: Access modifiers changed from: private */
    public final void toast(String str) {
        Toast.makeText(this, str, 0).show();
    }

    /* JADX INFO: Access modifiers changed from: private */
    public final void updateStatus(String str) {
        ActivityAudioRecordTestBinding activityAudioRecordTestBinding = this.binding;
        if (activityAudioRecordTestBinding == null) {
            kotlin.jvm.internal.l.s("binding");
            activityAudioRecordTestBinding = null;
        }
        TextView textView = activityAudioRecordTestBinding.tvStatus;
        StringBuilder sb = new StringBuilder();
        sb.append("State: " + currentLabel(str) + "\n");
        sb.append("Total bytes: " + this.totalBytes + "\n");
        sb.append("Read calls: " + this.readCalls + "\n");
        sb.append("Duration: " + currentDurationMs() + " ms\n");
        sb.append("Config: " + this.configuredSampleRate + "Hz, ch=" + this.configuredChannels + ", src=" + this.configuredAudioSource + "\n");
        String str2 = String.format("%.2f", Arrays.copyOf(new Object[]{Double.valueOf(((double) this.totalBytes) / 1024.0d)}, 1));
        kotlin.jvm.internal.l.d(str2, "format(...)");
        StringBuilder sb2 = new StringBuilder();
        sb2.append("PCM captured: ");
        sb2.append(str2);
        sb2.append(" KB");
        sb.append(sb2.toString());
        String string = sb.toString();
        kotlin.jvm.internal.l.d(string, "toString(...)");
        textView.setText(string);
    }

    private final void writeIntLE(OutputStream outputStream, int i2) throws IOException {
        outputStream.write(i2 & 255);
        outputStream.write((i2 >> 8) & 255);
        outputStream.write((i2 >> 16) & 255);
        outputStream.write((i2 >> 24) & 255);
    }

    private final void writeShortLE(OutputStream outputStream, int i2) throws IOException {
        outputStream.write(i2 & 255);
        outputStream.write((i2 >> 8) & 255);
    }

    /* JADX INFO: Access modifiers changed from: private */
    public final void writeWav(File file, byte[] bArr, int i2, int i3) throws IOException {
        int i4 = ((i2 * i3) * 16) / 8;
        int i5 = (i3 * 16) / 8;
        int length = bArr.length;
        int i6 = length + 36;
        FileOutputStream fileOutputStream = new FileOutputStream(file);
        try {
            BufferedOutputStream bufferedOutputStream = new BufferedOutputStream(fileOutputStream);
            try {
                Charset charset = E1.d.f531b;
                byte[] bytes = "RIFF".getBytes(charset);
                kotlin.jvm.internal.l.d(bytes, "getBytes(...)");
                bufferedOutputStream.write(bytes);
                writeIntLE(bufferedOutputStream, i6);
                byte[] bytes2 = "WAVE".getBytes(charset);
                kotlin.jvm.internal.l.d(bytes2, "getBytes(...)");
                bufferedOutputStream.write(bytes2);
                byte[] bytes3 = "fmt ".getBytes(charset);
                kotlin.jvm.internal.l.d(bytes3, "getBytes(...)");
                bufferedOutputStream.write(bytes3);
                writeIntLE(bufferedOutputStream, 16);
                writeShortLE(bufferedOutputStream, 1);
                writeShortLE(bufferedOutputStream, i3);
                writeIntLE(bufferedOutputStream, i2);
                writeIntLE(bufferedOutputStream, i4);
                writeShortLE(bufferedOutputStream, i5);
                writeShortLE(bufferedOutputStream, 16);
                byte[] bytes4 = DataSchemeDataSource.SCHEME_DATA.getBytes(charset);
                kotlin.jvm.internal.l.d(bytes4, "getBytes(...)");
                bufferedOutputStream.write(bytes4);
                writeIntLE(bufferedOutputStream, length);
                bufferedOutputStream.write(bArr);
                n1.s sVar = n1.s.f5871a;
                w1.b.a(bufferedOutputStream, null);
                w1.b.a(fileOutputStream, null);
            } finally {
            }
        } finally {
        }
    }

    @Override // androidx.fragment.app.FragmentActivity, androidx.activity.ComponentActivity, androidx.core.app.ComponentActivity, android.app.Activity
    protected void onCreate(Bundle bundle) {
        super.onCreate(bundle);
        ActivityAudioRecordTestBinding activityAudioRecordTestBindingInflate = ActivityAudioRecordTestBinding.inflate(getLayoutInflater());
        kotlin.jvm.internal.l.d(activityAudioRecordTestBindingInflate, "inflate(...)");
        this.binding = activityAudioRecordTestBindingInflate;
        ActivityAudioRecordTestBinding activityAudioRecordTestBinding = null;
        if (activityAudioRecordTestBindingInflate == null) {
            kotlin.jvm.internal.l.s("binding");
            activityAudioRecordTestBindingInflate = null;
        }
        setContentView(activityAudioRecordTestBindingInflate.getRoot());
        ActivityAudioRecordTestBinding activityAudioRecordTestBinding2 = this.binding;
        if (activityAudioRecordTestBinding2 == null) {
            kotlin.jvm.internal.l.s("binding");
            activityAudioRecordTestBinding2 = null;
        }
        activityAudioRecordTestBinding2.btnBack.setOnClickListener(new View.OnClickListener() { // from class: com.benq.platform.test.j
            @Override // android.view.View.OnClickListener
            public final void onClick(View view) {
                AudioRecordTestActivity.onCreate$lambda$0(this.f3134a, view);
            }
        });
        setupSpinners();
        ActivityAudioRecordTestBinding activityAudioRecordTestBinding3 = this.binding;
        if (activityAudioRecordTestBinding3 == null) {
            kotlin.jvm.internal.l.s("binding");
            activityAudioRecordTestBinding3 = null;
        }
        activityAudioRecordTestBinding3.btnConfigure.setOnClickListener(new View.OnClickListener() { // from class: com.benq.platform.test.k
            @Override // android.view.View.OnClickListener
            public final void onClick(View view) {
                AudioRecordTestActivity.onCreate$lambda$1(this.f3135a, view);
            }
        });
        ActivityAudioRecordTestBinding activityAudioRecordTestBinding4 = this.binding;
        if (activityAudioRecordTestBinding4 == null) {
            kotlin.jvm.internal.l.s("binding");
            activityAudioRecordTestBinding4 = null;
        }
        activityAudioRecordTestBinding4.btnStart.setOnClickListener(new View.OnClickListener() { // from class: com.benq.platform.test.l
            @Override // android.view.View.OnClickListener
            public final void onClick(View view) {
                AudioRecordTestActivity.onCreate$lambda$2(this.f3136a, view);
            }
        });
        ActivityAudioRecordTestBinding activityAudioRecordTestBinding5 = this.binding;
        if (activityAudioRecordTestBinding5 == null) {
            kotlin.jvm.internal.l.s("binding");
            activityAudioRecordTestBinding5 = null;
        }
        activityAudioRecordTestBinding5.btnStop.setOnClickListener(new View.OnClickListener() { // from class: com.benq.platform.test.m
            @Override // android.view.View.OnClickListener
            public final void onClick(View view) {
                AudioRecordTestActivity.onCreate$lambda$3(this.f3137a, view);
            }
        });
        ActivityAudioRecordTestBinding activityAudioRecordTestBinding6 = this.binding;
        if (activityAudioRecordTestBinding6 == null) {
            kotlin.jvm.internal.l.s("binding");
            activityAudioRecordTestBinding6 = null;
        }
        activityAudioRecordTestBinding6.btnRelease.setOnClickListener(new View.OnClickListener() { // from class: com.benq.platform.test.n
            @Override // android.view.View.OnClickListener
            public final void onClick(View view) {
                AudioRecordTestActivity.onCreate$lambda$4(this.f3138a, view);
            }
        });
        ActivityAudioRecordTestBinding activityAudioRecordTestBinding7 = this.binding;
        if (activityAudioRecordTestBinding7 == null) {
            kotlin.jvm.internal.l.s("binding");
            activityAudioRecordTestBinding7 = null;
        }
        activityAudioRecordTestBinding7.btnSaveWav.setOnClickListener(new View.OnClickListener() { // from class: com.benq.platform.test.o
            @Override // android.view.View.OnClickListener
            public final void onClick(View view) {
                AudioRecordTestActivity.onCreate$lambda$5(this.f3139a, view);
            }
        });
        ActivityAudioRecordTestBinding activityAudioRecordTestBinding8 = this.binding;
        if (activityAudioRecordTestBinding8 == null) {
            kotlin.jvm.internal.l.s("binding");
        } else {
            activityAudioRecordTestBinding = activityAudioRecordTestBinding8;
        }
        activityAudioRecordTestBinding.btnClearLog.setOnClickListener(new View.OnClickListener() { // from class: com.benq.platform.test.p
            @Override // android.view.View.OnClickListener
            public final void onClick(View view) {
                AudioRecordTestActivity.onCreate$lambda$6(this.f3140a, view);
            }
        });
        updateStatus("IDLE");
    }

    @Override // androidx.appcompat.app.AppCompatActivity, androidx.fragment.app.FragmentActivity, android.app.Activity
    protected void onDestroy() {
        super.onDestroy();
        this.isRecording = false;
        n0 n0Var = this.readLoopJob;
        if (n0Var != null) {
            n0.a.a(n0Var, null, 1, null);
        }
        try {
            l.a aVar = n1.l.f5861g;
            n1.l.b(Integer.valueOf(getController().stop()));
        } catch (Throwable th) {
            l.a aVar2 = n1.l.f5861g;
            n1.l.b(n1.m.a(th));
        }
        try {
            n1.l.b(Integer.valueOf(getController().release()));
        } catch (Throwable th2) {
            l.a aVar3 = n1.l.f5861g;
            n1.l.b(n1.m.a(th2));
        }
    }
}