package com.seewo.ota.k;

import android.os.Handler;
import android.os.Looper;
import android.os.Message;
import android.os.Process;
import android.text.TextUtils;
import android.util.Log;
import com.cvte.vman.impl.FwUpgradeManager;
import e.a.h;
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.util.ArrayList;
import java.util.Iterator;
import java.util.List;

/* JADX INFO: compiled from: LogManager.java */
/* JADX INFO: loaded from: classes.dex */
public class f {

    /* JADX INFO: renamed from: j, reason: collision with root package name */
    private static volatile f f2127j;
    private boolean a;

    /* JADX INFO: renamed from: h, reason: collision with root package name */
    private e.a.r.b f2134h;

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    private boolean f2128b = false;

    /* JADX INFO: renamed from: c, reason: collision with root package name */
    private boolean f2129c = true;

    /* JADX INFO: renamed from: d, reason: collision with root package name */
    private final List<String> f2130d = new ArrayList();

    /* JADX INFO: renamed from: e, reason: collision with root package name */
    private final List<String> f2131e = new ArrayList();

    /* JADX INFO: renamed from: f, reason: collision with root package name */
    private final List<b> f2132f = new ArrayList();

    /* JADX INFO: renamed from: g, reason: collision with root package name */
    private int f2133g = 0;

    /* JADX INFO: renamed from: i, reason: collision with root package name */
    private final Handler f2135i = new a(Looper.getMainLooper());

    /* JADX INFO: compiled from: LogManager.java */
    class a extends Handler {
        a(Looper looper) {
            super(looper);
        }

        @Override // android.os.Handler
        public void handleMessage(Message message) {
            super.handleMessage(message);
            if (message.what == 1001) {
                f.this.m(message.obj);
            }
        }
    }

    /* JADX INFO: compiled from: LogManager.java */
    public interface b {
        void a(String str);
    }

    private f() {
    }

    private void c() {
        this.f2134h = h.E(Boolean.TRUE).T(e.a.x.a.c()).F(new e.a.t.d() { // from class: com.seewo.ota.k.b
            @Override // e.a.t.d
            public final Object apply(Object obj) {
                return this.f2126b.h((Boolean) obj);
            }
        }).P(new e.a.t.c() { // from class: com.seewo.ota.k.a
            @Override // e.a.t.c
            public final void accept(Object obj) {
                Log.d("LogManager", "LogThread finish");
            }
        }, new e.a.t.c() { // from class: com.seewo.ota.k.c
            @Override // e.a.t.c
            public final void accept(Object obj) {
                Throwable th = (Throwable) obj;
                Log.e("LogManager", th.getMessage(), th);
            }
        });
    }

    public static f e() {
        if (f2127j == null) {
            synchronized (f.class) {
                if (f2127j == null) {
                    f2127j = new f();
                }
            }
        }
        return f2127j;
    }

    private boolean f(String str) {
        if (this.f2130d.isEmpty()) {
            return true;
        }
        Iterator<String> it = this.f2130d.iterator();
        while (it.hasNext()) {
            if (str.contains(it.next() + ":")) {
                return true;
            }
        }
        return false;
    }

    private void k(String str) {
        if (!this.f2129c) {
            m(str);
            return;
        }
        Message message = new Message();
        message.what = FwUpgradeManager.TYPE_FW_ZYZH_CAMERA;
        message.obj = str;
        this.f2135i.sendMessage(message);
    }

    /* JADX INFO: Access modifiers changed from: private */
    public void m(Object obj) {
        this.f2131e.add(String.valueOf(obj));
        if (this.f2133g < this.f2131e.size()) {
            Iterator<b> it = this.f2132f.iterator();
            while (it.hasNext()) {
                it.next().a(this.f2131e.get(this.f2133g));
            }
            this.f2133g++;
        }
    }

    public void b(String str) {
        if (TextUtils.isEmpty(str)) {
            return;
        }
        for (String str2 : str.split("\\|")) {
            if (!str2.isEmpty() && !this.f2130d.contains(str2)) {
                this.f2130d.add(str2);
            }
        }
    }

    public synchronized void d() {
        if (!this.a) {
            Log.d("LogManager", "LogThread is destroyed");
            return;
        }
        Log.d("LogManager", "destroyLogThread");
        this.a = false;
        if (this.f2134h != null) {
            this.f2134h.dispose();
        }
        this.f2131e.clear();
        this.f2132f.clear();
        this.f2130d.clear();
        this.f2133g = 0;
    }

    public boolean g() {
        return this.f2128b;
    }

    public /* synthetic */ Boolean h(Boolean bool) throws Exception {
        try {
            Log.d("LogManager", "startCatchLog " + Process.myPid());
            BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(Runtime.getRuntime().exec("logcat --pid=" + Process.myPid()).getInputStream()));
            while (this.a) {
                String line = bufferedReader.readLine();
                if (!TextUtils.isEmpty(line) && (this.f2128b || f(line))) {
                    k(line);
                }
            }
        } catch (Exception e2) {
            Log.e("LogManager", e2.getMessage(), e2);
        }
        return Boolean.TRUE;
    }

    public void l(b bVar) {
        if (!this.f2131e.isEmpty()) {
            StringBuilder sb = new StringBuilder();
            for (int i2 = 0; i2 < this.f2131e.size(); i2++) {
                if (i2 < this.f2133g) {
                    sb.append(this.f2131e.get(i2));
                }
            }
            bVar.a(sb.toString());
        }
        this.f2132f.add(bVar);
    }

    public void n(boolean z) {
        this.f2129c = z;
    }

    public void o(boolean z) {
        this.f2128b = z;
    }

    public synchronized void p() {
        if (this.a) {
            Log.d("LogManager", "LogThread is running");
            return;
        }
        Log.d("LogManager", "startLogThread");
        this.a = true;
        c();
    }
}