Cleaner for WhatsApp v2.9.6 - MyFirebaseMessagingService.java 源代码

package com.lookandfeel.cleanerforwhatsapp.shared;

import android.content.ContentResolver;
import android.content.UriPermission;
import android.database.Cursor;
import android.net.Uri;
import android.os.Build;
import android.preference.PreferenceManager;
import android.provider.DocumentsContract;
import android.util.Log;
import com.google.firebase.messaging.FirebaseMessagingService;
import com.google.firebase.messaging.S;
import com.lookandfeel.cleanerforwhatsapp.database.AppDatabase;
import e4.C0322c;
import g4.C0351a;
import java.io.Closeable;
import java.util.ArrayList;
import java.util.Iterator;
import java.util.LinkedList;
import java.util.List;

public class MyFirebaseMessagingService extends FirebaseMessagingService {
    AppDatabase y;

    private void U(Closeable closeable) {
        if (closeable != null) {
            try {
                closeable.close();
            } catch (RuntimeException e) {
                throw e;
            } catch (Exception unused) {
            }
        }
    }

    private boolean V(String str) {
        return "vnd.android.document/directory".equals(str);
    }

    public void W(Q.a aVar) {
        q0(aVar.f());
    }

    public void X(Q.a aVar) {
        q0(aVar.f());
    }

    public void a0(Q.a aVar) {
        q0(aVar.f());
    }

    public void d0(Q.a aVar) {
        q0(aVar.f());
    }

    public void g0(Q.a aVar) {
        q0(aVar.f());
    }

    public void i0(Q.a aVar) {
        w0(aVar.f());
    }

    public void j0(Q.a aVar) {
        q0(aVar.f());
    }

    public void k0() {
        try {
            this.y.B().i();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    public void l0(String str) {
        Log.v("kml_clean", "cleandb");
        Thread thread = new Thread(new Runnable() {
            @Override
            public final void run() {
                MyFirebaseMessagingService.this.k0();
            }
        });
        thread.start();
        try {
            thread.join();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        Log.v("kml_clean", "LaunchCleanTask");
        C0289f.l(getApplicationContext()).b(str);
    }

    public void n0(Q.a aVar) {
        q0(aVar.f());
    }

    public void o0(Q.a aVar) {
        q0(aVar.f());
    }

    public void r0(Q.a aVar) {
        q0(aVar.f());
    }

    public void s0(Q.a aVar) {
        q0(aVar.f());
    }

    public void t0() {
        try {
            this.y.B().d();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    private void u0(Uri uri) {
        Log.v("kml_clean", "debut");
        final String str = uri.getPathSegments().get(1);
        Q.a d = Q.a.d(getApplicationContext(), uri);
        C0351a.b bVar = new C0351a.b();
        if (d != null) {
            String replace = d.e() != null ? d.e().replace("Whatsapp", "WhatsApp") : "WhatsApp";
            Q.a[] h = d.h();
            Q.a i = N.i(h, "Media");
            if (i != null) {
                Q.a[] h2 = i.h();
                final Q.a i2 = N.i(h2, replace + " Images");
                if (i2 != null) {
                    bVar.a(new Runnable() {
                        @Override
                        public final void run() {
                            MyFirebaseMessagingService.this.W(i2);
                        }
                    });
                    final Uri parse = Uri.parse(i2.f().buildUpon().appendPath("Sent").build().toString().replace("/Sent", "%2FSent"));
                    if (parse != null) {
                        bVar.a(new Runnable() {
                            @Override
                            public final void run() {
                                MyFirebaseMessagingService.this.h0(parse);
                            }
                        });
                    }
                    final Uri parse2 = Uri.parse(i2.f().buildUpon().appendEncodedPath("Private").build().toString().replace("/Private", "%2FPrivate"));
                    if (parse2 != null) {
                        bVar.a(new Runnable() {
                            @Override
                            public final void run() {
                                MyFirebaseMessagingService.this.m0(parse2);
                            }
                        });
                    }
                }
                final Q.a i5 = N.i(h2, replace + " Stickers");
                if (i5 != null) {
                    bVar.a(new Runnable() {
                        @Override
                        public final void run() {
                            MyFirebaseMessagingService.this.n0(i5);
                        }
                    });
                }
                final Q.a i6 = N.i(h2, replace + " Video");
                if (i6 != null) {
                    bVar.a(new Runnable() {
                        @Override
                        public final void run() {
                            MyFirebaseMessagingService.this.o0(i6);
                        }
                    });
                    final Uri parse3 = Uri.parse(i6.f().buildUpon().appendPath("Sent").build().toString().replace("/Sent", "%2FSent"));
                    if (parse3 != null) {
                        bVar.a(new Runnable() {
                            @Override
                            public final void run() {
                                MyFirebaseMessagingService.this.p0(parse3);
                            }
                        });
                    }
                    final Uri parse4 = Uri.parse(i6.f().buildUpon().appendEncodedPath("Private").build().toString().replace("/Private", "%2FPrivate"));
                    if (parse4 != null) {
                        bVar.a(new Runnable() {
                            @Override
                            public final void run() {
                                MyFirebaseMessagingService.this.q0(parse4);
                            }
                        });
                    }
                }
                final Q.a i7 = N.i(h2, ".Statuses");
                if (i7 != null) {
                    bVar.a(new Runnable() {
                        @Override
                        public final void run() {
                            MyFirebaseMessagingService.this.r0(i7);
                        }
                    });
                }
                final Q.a i8 = N.i(h2, "WallPaper");
                if (i8 != null) {
                    bVar.a(new Runnable() {
                        @Override
                        public final void run() {
                            MyFirebaseMessagingService.this.s0(i8);
                        }
                    });
                }
                final Q.a i9 = N.i(h2, replace + " Animated Gifs");
                if (i9 != null) {
                    bVar.a(new Runnable() {
                        @Override
                        public final void run() {
                            MyFirebaseMessagingService.this.X(i9);
                        }
                    });
                    final Uri parse5 = Uri.parse(i9.f().buildUpon().appendPath("Sent").build().toString().replace("/Sent", "%2FSent"));
                    if (parse5 != null) {
                        bVar.a(new Runnable() {
                            @Override
                            public final void run() {
                                MyFirebaseMessagingService.this.Y(parse5);
                            }
                        });
                    }
                    final Uri parse6 = Uri.parse(i9.f().buildUpon().appendEncodedPath("Private").build().toString().replace("/Private", "%2FPrivate"));
                    if (parse6 != null) {
                        bVar.a(new Runnable() {
                            @Override
                            public final void run() {
                                MyFirebaseMessagingService.this.Z(parse6);
                            }
                        });
                    }
                }
                final Q.a i10 = N.i(h2, replace + " Audio");
                if (i10 != null) {
                    bVar.a(new Runnable() {
                        @Override
                        public final void run() {
                            MyFirebaseMessagingService.this.a0(i10);
                        }
                    });
                    final Uri parse7 = Uri.parse(i10.f().buildUpon().appendPath("Sent").build().toString().replace("/Sent", "%2FSent"));
                    if (parse7 != null) {
                        bVar.a(new Runnable() {
                            @Override
                            public final void run() {
                                MyFirebaseMessagingService.this.b0(parse7);
                            }
                        });
                    }
                    final Uri parse8 = Uri.parse(i10.f().buildUpon().appendEncodedPath("Private").build().toString().replace("/Private", "%2FPrivate"));
                    if (parse8 != null) {
                        bVar.a(new Runnable() {
                            @Override
                            public final void run() {
                                MyFirebaseMessagingService.this.c0(parse8);
                            }
                        });
                    }
                }
                final Q.a i11 = N.i(h2, replace + " Documents");
                if (i11 != null) {
                    bVar.a(new Runnable() {
                        @Override
                        public final void run() {
                            MyFirebaseMessagingService.this.d0(i11);
                        }
                    });
                    final Uri parse9 = Uri.parse(i11.f().buildUpon().appendPath("Sent").build().toString().replace("/Sent", "%2FSent"));
                    if (parse9 != null) {
                        bVar.a(new Runnable() {
                            @Override
                            public final void run() {
                                MyFirebaseMessagingService.this.e0(parse9);
                            }
                        });
                    }
                    final Uri parse10 = Uri.parse(i11.f().buildUpon().appendEncodedPath("Private").build().toString().replace("/Private", "%2FPrivate"));
                    if (parse10 != null) {
                        bVar.a(new Runnable() {
                            @Override
                            public final void run() {
                                MyFirebaseMessagingService.this.f0(parse10);
                            }
                        });
                    }
                }
                final Q.a i12 = N.i(h2, replace + " Profile Photos");
                if (i12 != null) {
                    bVar.a(new Runnable() {
                        @Override
                        public final void run() {
                            MyFirebaseMessagingService.this.g0(i12);
                        }
                    });
                }
                final Q.a i13 = N.i(h2, replace + " Voice Notes");
                if (i13 != null) {
                    bVar.a(new Runnable() {
                        @Override
                        public final void run() {
                            MyFirebaseMessagingService.this.i0(i13);
                        }
                    });
                }
            }
            final Q.a i14 = N.i(h, "Databases");
            if (i14 != null) {
                bVar.a(new Runnable() {
                    @Override
                    public final void run() {
                        MyFirebaseMessagingService.this.j0(i14);
                    }
                });
            }
            bVar.c(new C0351a.c() {
                @Override
                public final void a() {
                    MyFirebaseMessagingService.this.l0(str);
                }
            }).b().a();
        }
    }

    public void q0(Uri uri) {
        Cursor cursor;
        ContentResolver contentResolver = getContentResolver();
        LinkedList linkedList = new LinkedList();
        linkedList.add(uri);
        int i = 0;
        boolean z = false;
        while (!linkedList.isEmpty()) {
            Uri uri2 = (Uri) linkedList.remove(i);
            String str = "document_id";
            String str2 = "mime_type";
            String str3 = "_size";
            try {
                cursor = contentResolver.query(uri2, new String[]{"document_id", "_display_name", "mime_type", "last_modified", "_size"}, null, null, null);
            } catch (Exception e) {
                e.printStackTrace();
                Log.v("kml_errr", "-" + e.getMessage());
                cursor = null;
            }
            Cursor cursor2 = cursor;
            if (cursor2 != null) {
                try {
                    ArrayList arrayList = new ArrayList();
                    ArrayList arrayList2 = new ArrayList();
                    while (cursor2.moveToNext()) {
                        String string = cursor2.getString(cursor2.getColumnIndex(str));
                        String string2 = cursor2.getString(1);
                        String string3 = cursor2.getString(cursor2.getColumnIndex(str2));
                        String str4 = str;
                        String str5 = str2;
                        long j = cursor2.getLong(3);
                        String str6 = str3;
                        long j2 = cursor2.getLong(cursor2.getColumnIndex(str3));
                        if (!z && V(string3)) {
                            linkedList.add(DocumentsContract.buildChildDocumentsUriUsingTree(uri2, string));
                            z = true;
                        } else if (!V(string3) && !string2.startsWith(".") && !string2.startsWith("stickers.db") && !string2.startsWith("wallpapers.backup") && !string2.startsWith("chatsettingsbackup.db") && !string2.startsWith("commerce_backup.db") && !string2.startsWith("msgstore.db")) {
                            C0322c c0322c = new C0322c();
                            c0322c.b = string;
                            c0322c.c = string2;
                            c0322c.e = Uri.parse(string).toString();
                            c0322c.f = uri2.toString();
                            c0322c.g = j2;
                            c0322c.h = j;
                            c0322c.d = string3;
                            c0322c.i = uri.getPathSegments().get(1);
                            c0322c.j = true;
                            if (this.y.B().j(Uri.parse(string).toString())) {
                                arrayList2.add(Uri.parse(string).toString());
                                if (arrayList2.size() > 900) {
                                    this.y.B().a(arrayList2, Boolean.TRUE);
                                    arrayList2.clear();
                                }
                            } else {
                                arrayList.add(c0322c);
                            }
                        }
                        str = str4;
                        str2 = str5;
                        str3 = str6;
                    }
                    if (arrayList.size() > 0) {
                        this.y.B().c(arrayList);
                    }
                    if (arrayList2.size() > 0) {
                        this.y.B().a(arrayList2, Boolean.TRUE);
                    }
                    U(cursor2);
                } catch (Throwable th) {
                    U(cursor2);
                    throw th;
                }
            }
            i = 0;
        }
    }

    private void w0(Uri uri) {
        Cursor cursor;
        ContentResolver contentResolver;
        ContentResolver contentResolver2;
        ContentResolver contentResolver3 = getContentResolver();
        LinkedList linkedList = new LinkedList();
        linkedList.add(uri);
        while (!linkedList.isEmpty()) {
            Uri uri2 = (Uri) linkedList.remove(0);
            String str = "document_id";
            String str2 = "mime_type";
            try {
                cursor = contentResolver3.query(uri2, new String[]{"document_id", "_display_name", "mime_type", "last_modified", "_size"}, null, null, null);
            } catch (Exception e) {
                e.printStackTrace();
                Log.v("kml_errr", "-" + e.getMessage());
                cursor = null;
            }
            Cursor cursor2 = cursor;
            if (cursor2 != null) {
                try {
                    ArrayList arrayList = new ArrayList();
                    ArrayList arrayList2 = new ArrayList();
                    while (cursor2.moveToNext()) {
                        String string = cursor2.getString(cursor2.getColumnIndex(str));
                        String string2 = cursor2.getString(1);
                        String string3 = cursor2.getString(cursor2.getColumnIndex(str2));
                        long j = cursor2.getLong(3);
                        String str3 = str;
                        String str4 = str2;
                        long j2 = cursor2.getLong(cursor2.getColumnIndex("_size"));
                        if (V(string3)) {
                            linkedList.add(DocumentsContract.buildChildDocumentsUriUsingTree(uri2, string));
                            contentResolver2 = contentResolver3;
                        } else {
                            contentResolver2 = contentResolver3;
                            if (!string2.startsWith(".") && !string2.startsWith("stickers.db") && !string2.startsWith("wallpapers.backup") && !string2.startsWith("chatsettingsbackup.db") && !string2.startsWith("commerce_backup.db") && !string2.startsWith("msgstore.db")) {
                                C0322c c0322c = new C0322c();
                                c0322c.b = string;
                                c0322c.c = string2;
                                c0322c.e = Uri.parse(string).toString();
                                c0322c.f = uri2.toString();
                                c0322c.g = j2;
                                c0322c.h = j;
                                c0322c.d = string3;
                                c0322c.i = uri.getPathSegments().get(1);
                                c0322c.j = true;
                                if (this.y.B().j(Uri.parse(string).toString())) {
                                    arrayList2.add(Uri.parse(string).toString());
                                    if (arrayList2.size() > 900) {
                                        this.y.B().a(arrayList2, Boolean.TRUE);
                                        arrayList2.clear();
                                    }
                                } else {
                                    arrayList.add(c0322c);
                                }
                            }
                        }
                        str = str3;
                        str2 = str4;
                        contentResolver3 = contentResolver2;
                    }
                    contentResolver = contentResolver3;
                    if (arrayList.size() > 0) {
                        this.y.B().c(arrayList);
                    }
                    if (arrayList2.size() > 0) {
                        this.y.B().a(arrayList2, Boolean.TRUE);
                    }
                    U(cursor2);
                } catch (Throwable th) {
                    U(cursor2);
                    throw th;
                }
            } else {
                contentResolver = contentResolver3;
            }
            contentResolver3 = contentResolver;
        }
    }

    @Override
    public void q() {
        super.q();
    }

    @Override
    public void r(S s) {
        super.r(s);
        this.y = (AppDatabase) k0.p.a(getApplicationContext(), AppDatabase.class, "wpcleaner-db").e().f().d();
        String str = (String) s.f().get("task");
        boolean z = PreferenceManager.getDefaultSharedPreferences(getApplicationContext()).getBoolean("perform_clean", false);
        Log.v("kml_clean", str + "-- autoclean:" + z);
        if (str != null) {
            Uri uri = null;
            if (!str.equals("clean")) {
                if (z) {
                    return;
                }
                if (Build.VERSION.SDK_INT < 30) {
                    K.f(getApplicationContext()).a("");
                    return;
                }
                List<UriPermission> persistedUriPermissions = getContentResolver().getPersistedUriPermissions();
                if (persistedUriPermissions.size() > 0) {
                    Iterator<UriPermission> it = persistedUriPermissions.iterator();
                    while (it.hasNext()) {
                        uri = it.next().getUri();
                    }
                    if (uri != null) {
                        K.f(getApplicationContext()).a(uri.getPathSegments().get(1));
                        return;
                    }
                    return;
                }
                return;
            }
            if (z) {
                if (Build.VERSION.SDK_INT < 30) {
                    C0289f.l(getApplicationContext()).b("");
                    return;
                }
                List<UriPermission> persistedUriPermissions2 = getContentResolver().getPersistedUriPermissions();
                if (persistedUriPermissions2.size() > 0) {
                    Iterator<UriPermission> it2 = persistedUriPermissions2.iterator();
                    while (it2.hasNext()) {
                        uri = it2.next().getUri();
                    }
                    if (uri != null) {
                        Thread thread = new Thread(new Runnable() {
                            @Override
                            public final void run() {
                                MyFirebaseMessagingService.this.t0();
                            }
                        });
                        thread.start();
                        try {
                            thread.join();
                        } catch (InterruptedException e) {
                            e.printStackTrace();
                        }
                        u0(uri);
                    }
                }
            }
        }
    }

    @Override
    public void t(String str) {
        super.t(str);
    }
}