init

app/src/main/java/bruhcollective/itaysonlab/libvkx/ILibVkxService.java

@@ -0,0 +1,340 @@
+/*
+ * This file is auto-generated.  DO NOT MODIFY.
+ */
+package bruhcollective.itaysonlab.libvkx;
+
+public interface ILibVkxService extends android.os.IInterface {
+    /**
+     * Default implementation for ILibVkxService.
+     */
+    public static class Default implements ILibVkxService {
+        // Starts playback. playbackContext can be "other" if you don't sure what it is
+
+        @Override
+        public void play(java.util.List<String> audio_ids, int index, String playbackContext) throws android.os.RemoteException {
+        }
+        // A UserID. CHECK FOR THIS TO BE EQUAL BEFORE SENDING ANYTHING TO SERVICE!
+
+        @Override
+        public int getUserId() throws android.os.RemoteException {
+            return 0;
+        }
+        // Cache add/remove
+
+        @Override
+        public void addTrackToCache(int track_id, int owner_id, String access_key) throws android.os.RemoteException {
+        }
+
+        @Override
+        public void deleteTrackFromCache(int track_id, int owner_id) throws android.os.RemoteException {
+        }
+
+        @Override
+        public boolean isTrackCached(int track_id, int owner_id) throws android.os.RemoteException {
+            return false;
+        }
+        // Get a list of cached tracks. The response is close to VK's original response (an audio list)
+        // Also, the items in the list are JSON ones.
+
+        @Override
+        public java.util.List<String> getCache() throws android.os.RemoteException {
+            return null;
+        }
+
+        @Override
+        public android.os.IBinder asBinder() {
+            return null;
+        }
+    }
+
+    /**
+     * Local-side IPC implementation stub class.
+     */
+    public static abstract class Stub extends android.os.Binder implements ILibVkxService {
+        private static final String DESCRIPTOR = "bruhcollective.itaysonlab.libvkx.ILibVkxService";
+
+        /**
+         * Construct the stub at attach it to the interface.
+         */
+        public Stub() {
+            this.attachInterface(this, DESCRIPTOR);
+        }
+
+        /**
+         * Cast an IBinder object into an bruhcollective.itaysonlab.libvkx.ILibVkxService interface,
+         * generating a proxy if needed.
+         */
+        public static ILibVkxService asInterface(android.os.IBinder obj) {
+            if ((obj == null)) {
+                return null;
+            }
+            android.os.IInterface iin = obj.queryLocalInterface(DESCRIPTOR);
+            if (((iin != null) && (iin instanceof ILibVkxService))) {
+                return ((ILibVkxService) iin);
+            }
+            return new Proxy(obj);
+        }
+
+        @Override
+        public android.os.IBinder asBinder() {
+            return this;
+        }
+
+        @Override
+        public boolean onTransact(int code, android.os.Parcel data, android.os.Parcel reply, int flags) throws android.os.RemoteException {
+            String descriptor = DESCRIPTOR;
+            switch (code) {
+                case INTERFACE_TRANSACTION: {
+                    reply.writeString(descriptor);
+                    return true;
+                }
+                case TRANSACTION_play: {
+                    data.enforceInterface(descriptor);
+                    java.util.List<String> _arg0;
+                    _arg0 = data.createStringArrayList();
+                    int _arg1;
+                    _arg1 = data.readInt();
+                    String _arg2;
+                    _arg2 = data.readString();
+                    this.play(_arg0, _arg1, _arg2);
+                    reply.writeNoException();
+                    return true;
+                }
+                case TRANSACTION_getUserId: {
+                    data.enforceInterface(descriptor);
+                    int _result = this.getUserId();
+                    reply.writeNoException();
+                    reply.writeInt(_result);
+                    return true;
+                }
+                case TRANSACTION_addTrackToCache: {
+                    data.enforceInterface(descriptor);
+                    int _arg0;
+                    _arg0 = data.readInt();
+                    int _arg1;
+                    _arg1 = data.readInt();
+                    String _arg2;
+                    _arg2 = data.readString();
+                    this.addTrackToCache(_arg0, _arg1, _arg2);
+                    reply.writeNoException();
+                    return true;
+                }
+                case TRANSACTION_deleteTrackFromCache: {
+                    data.enforceInterface(descriptor);
+                    int _arg0;
+                    _arg0 = data.readInt();
+                    int _arg1;
+                    _arg1 = data.readInt();
+                    this.deleteTrackFromCache(_arg0, _arg1);
+                    reply.writeNoException();
+                    return true;
+                }
+                case TRANSACTION_isTrackCached: {
+                    data.enforceInterface(descriptor);
+                    int _arg0;
+                    _arg0 = data.readInt();
+                    int _arg1;
+                    _arg1 = data.readInt();
+                    boolean _result = this.isTrackCached(_arg0, _arg1);
+                    reply.writeNoException();
+                    reply.writeInt(((_result) ? (1) : (0)));
+                    return true;
+                }
+                case TRANSACTION_getCache: {
+                    data.enforceInterface(descriptor);
+                    java.util.List<String> _result = this.getCache();
+                    reply.writeNoException();
+                    reply.writeStringList(_result);
+                    return true;
+                }
+                default: {
+                    return super.onTransact(code, data, reply, flags);
+                }
+            }
+        }
+
+        private static class Proxy implements ILibVkxService {
+            private android.os.IBinder mRemote;
+
+            Proxy(android.os.IBinder remote) {
+                mRemote = remote;
+            }
+
+            @Override
+            public android.os.IBinder asBinder() {
+                return mRemote;
+            }
+
+            public String getInterfaceDescriptor() {
+                return DESCRIPTOR;
+            }
+            // Starts playback. playbackContext can be "other" if you don't sure what it is
+
+            @Override
+            public void play(java.util.List<String> audio_ids, int index, String playbackContext) throws android.os.RemoteException {
+                android.os.Parcel _data = android.os.Parcel.obtain();
+                android.os.Parcel _reply = android.os.Parcel.obtain();
+                try {
+                    _data.writeInterfaceToken(DESCRIPTOR);
+                    _data.writeStringList(audio_ids);
+                    _data.writeInt(index);
+                    _data.writeString(playbackContext);
+                    boolean _status = mRemote.transact(Stub.TRANSACTION_play, _data, _reply, 0);
+                    if (!_status && getDefaultImpl() != null) {
+                        getDefaultImpl().play(audio_ids, index, playbackContext);
+                        return;
+                    }
+                    _reply.readException();
+                } finally {
+                    _reply.recycle();
+                    _data.recycle();
+                }
+            }
+            // A UserID. CHECK FOR THIS TO BE EQUAL BEFORE SENDING ANYTHING TO SERVICE!
+
+            @Override
+            public int getUserId() throws android.os.RemoteException {
+                android.os.Parcel _data = android.os.Parcel.obtain();
+                android.os.Parcel _reply = android.os.Parcel.obtain();
+                int _result;
+                try {
+                    _data.writeInterfaceToken(DESCRIPTOR);
+                    boolean _status = mRemote.transact(Stub.TRANSACTION_getUserId, _data, _reply, 0);
+                    if (!_status && getDefaultImpl() != null) {
+                        return getDefaultImpl().getUserId();
+                    }
+                    _reply.readException();
+                    _result = _reply.readInt();
+                } finally {
+                    _reply.recycle();
+                    _data.recycle();
+                }
+                return _result;
+            }
+            // Cache add/remove
+
+            @Override
+            public void addTrackToCache(int track_id, int owner_id, String access_key) throws android.os.RemoteException {
+                android.os.Parcel _data = android.os.Parcel.obtain();
+                android.os.Parcel _reply = android.os.Parcel.obtain();
+                try {
+                    _data.writeInterfaceToken(DESCRIPTOR);
+                    _data.writeInt(track_id);
+                    _data.writeInt(owner_id);
+                    _data.writeString(access_key);
+                    boolean _status = mRemote.transact(Stub.TRANSACTION_addTrackToCache, _data, _reply, 0);
+                    if (!_status && getDefaultImpl() != null) {
+                        getDefaultImpl().addTrackToCache(track_id, owner_id, access_key);
+                        return;
+                    }
+                    _reply.readException();
+                } finally {
+                    _reply.recycle();
+                    _data.recycle();
+                }
+            }
+
+            @Override
+            public void deleteTrackFromCache(int track_id, int owner_id) throws android.os.RemoteException {
+                android.os.Parcel _data = android.os.Parcel.obtain();
+                android.os.Parcel _reply = android.os.Parcel.obtain();
+                try {
+                    _data.writeInterfaceToken(DESCRIPTOR);
+                    _data.writeInt(track_id);
+                    _data.writeInt(owner_id);
+                    boolean _status = mRemote.transact(Stub.TRANSACTION_deleteTrackFromCache, _data, _reply, 0);
+                    if (!_status && getDefaultImpl() != null) {
+                        getDefaultImpl().deleteTrackFromCache(track_id, owner_id);
+                        return;
+                    }
+                    _reply.readException();
+                } finally {
+                    _reply.recycle();
+                    _data.recycle();
+                }
+            }
+
+            @Override
+            public boolean isTrackCached(int track_id, int owner_id) throws android.os.RemoteException {
+                android.os.Parcel _data = android.os.Parcel.obtain();
+                android.os.Parcel _reply = android.os.Parcel.obtain();
+                boolean _result;
+                try {
+                    _data.writeInterfaceToken(DESCRIPTOR);
+                    _data.writeInt(track_id);
+                    _data.writeInt(owner_id);
+                    boolean _status = mRemote.transact(Stub.TRANSACTION_isTrackCached, _data, _reply, 0);
+                    if (!_status && getDefaultImpl() != null) {
+                        return getDefaultImpl().isTrackCached(track_id, owner_id);
+                    }
+                    _reply.readException();
+                    _result = (0 != _reply.readInt());
+                } finally {
+                    _reply.recycle();
+                    _data.recycle();
+                }
+                return _result;
+            }
+            // Get a list of cached tracks. The response is close to VK's original response (an audio list)
+            // Also, the items in the list are JSON ones.
+
+            @Override
+            public java.util.List<String> getCache() throws android.os.RemoteException {
+                android.os.Parcel _data = android.os.Parcel.obtain();
+                android.os.Parcel _reply = android.os.Parcel.obtain();
+                java.util.List<String> _result;
+                try {
+                    _data.writeInterfaceToken(DESCRIPTOR);
+                    boolean _status = mRemote.transact(Stub.TRANSACTION_getCache, _data, _reply, 0);
+                    if (!_status && getDefaultImpl() != null) {
+                        return getDefaultImpl().getCache();
+                    }
+                    _reply.readException();
+                    _result = _reply.createStringArrayList();
+                } finally {
+                    _reply.recycle();
+                    _data.recycle();
+                }
+                return _result;
+            }
+
+            public static ILibVkxService sDefaultImpl;
+        }
+
+        static final int TRANSACTION_play = (android.os.IBinder.FIRST_CALL_TRANSACTION + 1);
+        static final int TRANSACTION_getUserId = (android.os.IBinder.FIRST_CALL_TRANSACTION + 2);
+        static final int TRANSACTION_addTrackToCache = (android.os.IBinder.FIRST_CALL_TRANSACTION + 3);
+        static final int TRANSACTION_deleteTrackFromCache = (android.os.IBinder.FIRST_CALL_TRANSACTION + 4);
+        static final int TRANSACTION_isTrackCached = (android.os.IBinder.FIRST_CALL_TRANSACTION + 5);
+        static final int TRANSACTION_getCache = (android.os.IBinder.FIRST_CALL_TRANSACTION + 6);
+
+        public static boolean setDefaultImpl(ILibVkxService impl) {
+            if (Proxy.sDefaultImpl == null && impl != null) {
+                Proxy.sDefaultImpl = impl;
+                return true;
+            }
+            return false;
+        }
+
+        public static ILibVkxService getDefaultImpl() {
+            return Proxy.sDefaultImpl;
+        }
+    }
+    // Starts playback. playbackContext can be "other" if you don't sure what it is
+
+    public void play(java.util.List<String> audio_ids, int index, String playbackContext) throws android.os.RemoteException;
+    // A UserID. CHECK FOR THIS TO BE EQUAL BEFORE SENDING ANYTHING TO SERVICE!
+
+    public int getUserId() throws android.os.RemoteException;
+    // Cache add/remove
+
+    public void addTrackToCache(int track_id, int owner_id, String access_key) throws android.os.RemoteException;
+
+    public void deleteTrackFromCache(int track_id, int owner_id) throws android.os.RemoteException;
+
+    public boolean isTrackCached(int track_id, int owner_id) throws android.os.RemoteException;
+    // Get a list of cached tracks. The response is close to VK's original response (an audio list)
+    // Also, the items in the list are JSON ones.
+
+    public java.util.List<String> getCache() throws android.os.RemoteException;
+}

app/src/main/java/bruhcollective/itaysonlab/libvkx/client/ClientConstants.java

@@ -0,0 +1,6 @@
+package bruhcollective.itaysonlab.libvkx.client;
+
+public class ClientConstants {
+    public final static String ACTION = "bruhcollective.itaysonlab.libvkx.LIBVKX_SERVICE";
+    public final static String PACKAGE = "ua.itaysonlab.vkx";
+}

app/src/main/java/bruhcollective/itaysonlab/libvkx/client/LibVKXClient.java

@@ -0,0 +1,80 @@
+package bruhcollective.itaysonlab.libvkx.client;
+
+import android.content.Context;
+import android.os.RemoteException;
+
+import bruhcollective.itaysonlab.libvkx.ILibVkxService;
+
+import com.vk.core.b.PackageManagerHelper;
+import com.vk.dto.music.MusicTrack;
+import com.vk.music.PlayerRefer;
+
+import java.util.ArrayList;
+import java.util.Iterator;
+import java.util.List;
+
+import ru.vtosters.lite.utils.Helper;
+import ru.vtosters.lite.utils.Prefs;
+import ru.vtosters.lite.utils.Helper;
+import ru.vtosters.lite.utils.Prefs;
+
+/* loaded from: classes6.dex */
+public class LibVKXClient {
+    private static LibVKXClientImpl impl;
+
+    public static LibVKXClientImpl getInstance(Context context) {
+        if (impl == null) {
+            impl = new LibVKXClientImpl(context);
+        }
+        return impl;
+    }
+
+    public static LibVKXClientImpl getInstance() {
+        LibVKXClientImpl libVKXClientImpl = impl;
+        return libVKXClientImpl == null ? getInstance(Helper.GetContext()) : libVKXClientImpl;
+    }
+
+    public static boolean isVkxInstalled() {
+        return PackageManagerHelper.b(ClientConstants.PACKAGE, 128) != null;
+    }
+
+    public static boolean isIntegrationEnabled() {
+        return Prefs.BooleanFalse("libvkx_integration") && isVkxInstalled();
+    }
+
+    public static boolean play(MusicTrack musicTrack, List<MusicTrack> list, PlayerRefer playerRefer) {
+        if (!isIntegrationEnabled()) {
+            return false;
+        }
+
+        LibVKXClientImpl.LibVKXAction action = iLibVkxService -> LibVKXClient.lambdaplay(list, musicTrack, playerRefer, iLibVkxService);
+
+        return getInstance().runOnService(action);
+    }
+
+    /* JADX INFO: Access modifiers changed from: package-private */
+    public static /* synthetic */ void lambdaplay(List list, MusicTrack musicTrack, PlayerRefer playerRefer, ILibVkxService iLibVkxService) {
+        int indexOf = list.indexOf(musicTrack);
+        ArrayList arrayList = new ArrayList();
+        Iterator it = list.iterator();
+        while (it.hasNext()) {
+            arrayList.add(asId((MusicTrack) it.next()));
+        }
+        if (indexOf == -1) {
+            indexOf = 0;
+        }
+        try {
+            iLibVkxService.play(arrayList, indexOf, "");
+        } catch (RemoteException e) {
+            e.printStackTrace();
+        }
+    }
+
+    private static String asId(MusicTrack musicTrack) {
+        String str = musicTrack.c + "_" + musicTrack.b;
+        if (musicTrack.s == null || musicTrack.s.equals("")) {
+            return str;
+        }
+        return str + "_" + musicTrack.s;
+    }
+}

app/src/main/java/bruhcollective/itaysonlab/libvkx/client/LibVKXClientImpl.java

@@ -0,0 +1,128 @@
+package bruhcollective.itaysonlab.libvkx.client;
+
+import android.content.ComponentName;
+import android.content.Context;
+import android.content.Intent;
+import android.content.ServiceConnection;
+import android.content.pm.PackageManager;
+import android.content.pm.ResolveInfo;
+import android.os.IBinder;
+import android.os.RemoteException;
+
+import java.util.List;
+
+import bruhcollective.itaysonlab.libvkx.ILibVkxService;
+import ru.vtosters.lite.utils.Helper;
+
+public class LibVKXClientImpl {
+    private ILibVkxService serviceInstance;
+    private PackageManager pm;
+    private Context ctx;
+    private ServiceConnection cn;
+
+    private boolean isBindFailed = false;
+
+    private LibVKXClientImpl() {
+    }
+
+    public LibVKXClientImpl(Context ctx) {
+        this.ctx = ctx;
+        this.pm = ctx.getPackageManager();
+    }
+
+    public void finish() {
+        if (cn != null) {
+            ctx.unbindService(cn);
+        }
+
+        serviceInstance = null;
+    }
+
+    public <T> T runOnServiceSync(LibVKXActionGeneric<T> action) {
+        if (serviceInstance != null) {
+            return action.run(serviceInstance);
+        } else {
+            return action.defaultValue();
+        }
+    }
+
+    // true - action is ran
+    // false - action is failed, should fallback to default UI/UX
+    public boolean runOnService(LibVKXAction action) {
+        if (serviceInstance != null) {
+            try {
+                if (serviceInstance.getUserId() != Helper.GetUserId()) return false;
+                action.run(serviceInstance);
+                return true;
+            } catch (RemoteException e) {
+                e.printStackTrace();
+                return false;
+            }
+        } else {
+            return requestServiceInit(action);
+        }
+    }
+
+    private boolean requestServiceInit(LibVKXAction runAfterBind) {
+        if (!verifyBindActuality()) return false;
+
+        cn = new ServiceConnection() {
+            @Override
+            public void onServiceConnected(ComponentName name, IBinder service) {
+                serviceInstance = ILibVkxService.Stub.asInterface(service);
+                if (serviceInstance == null) {
+                    // op mycopok...
+                    isBindFailed = true;
+                } else {
+                    try {
+                        if (serviceInstance.getUserId() != Helper.GetUserId()) return;
+                        runAfterBind.run(serviceInstance);
+                    } catch (RemoteException e) {
+                        e.printStackTrace();
+                    }
+                }
+            }
+
+            @Override
+            public void onServiceDisconnected(ComponentName name) {
+                serviceInstance = null;
+            }
+        };
+
+        ctx.bindService(getIntent(), cn, Context.BIND_AUTO_CREATE);
+        return true;
+    }
+
+    private boolean verifyBindActuality() {
+        if (!checkIfAppExists()) return false; // no need
+        if (isBindFailed) return false;
+        return true;
+    }
+
+    private Intent getIntent() {
+        return new Intent(ClientConstants.ACTION).setPackage(ClientConstants.PACKAGE);
+    }
+
+    private boolean checkIfAppExists() {
+        List<ResolveInfo> resolveInfos = pm.queryIntentServices(getIntent(), 0);
+        if (resolveInfos == null || resolveInfos.isEmpty()) return false;
+
+        for (ResolveInfo rs : resolveInfos) {
+            if (rs.serviceInfo.packageName.equals(ClientConstants.PACKAGE)) return true;
+        }
+
+        return false;
+    }
+
+    public interface LibVKXAction {
+        void run(ILibVkxService service);
+    }
+
+    public interface LibVKXActionGeneric<T> {
+        T run(ILibVkxService service);
+
+        default T defaultValue() {
+            return null;
+        }
+    }
+}