revanced-manager/lib/services/patcher_api.dart

import 'dart:io';

import 'package:collection/collection.dart';
import 'package:device_apps/device_apps.dart';
import 'package:flutter/foundation.dart';
import 'package:flutter/services.dart';
import 'package:flutter_file_dialog/flutter_file_dialog.dart';
import 'package:injectable/injectable.dart';
import 'package:install_plugin/install_plugin.dart';
import 'package:path_provider/path_provider.dart';
import 'package:revanced_manager/app/app.locator.dart';
import 'package:revanced_manager/models/patch.dart';
import 'package:revanced_manager/models/patched_application.dart';
import 'package:revanced_manager/services/manager_api.dart';
import 'package:revanced_manager/services/root_api.dart';
import 'package:share_plus/share_plus.dart';

@lazySingleton
class PatcherAPI {
  static const patcherChannel =
  MethodChannel('app.revanced.manager.flutter/patcher');
  final ManagerAPI _managerAPI = locator<ManagerAPI>();
  final RootAPI _rootAPI = RootAPI();
  late Directory _dataDir;
  late Directory _tmpDir;
  late File _keyStoreFile;
  List<Patch> _patches = [];
  List<Patch> _universalPatches = [];
  List<String> _compatiblePackages = [];
  Map filteredPatches = <String, List<Patch>>{};
  File? outFile;

  Future<void> initialize() async {
    await loadPatches();
    await _managerAPI.downloadIntegrations();
    final Directory appCache = await getTemporaryDirectory();
    _dataDir = await getExternalStorageDirectory() ?? appCache;
    _tmpDir = Directory('${appCache.path}/patcher');
    _keyStoreFile = File('${_dataDir.path}/revanced-manager.keystore');
    cleanPatcher();
  }

  void cleanPatcher() {
    if (_tmpDir.existsSync()) {
      _tmpDir.deleteSync(recursive: true);
    }
  }

  List<String> getCompatiblePackages() {
    final List<String> compatiblePackages = [];
    for (final Patch patch in _patches) {
      for (final Package package in patch.compatiblePackages) {
        if (!compatiblePackages.contains(package.name)) {
          compatiblePackages.add(package.name);
        }
      }
    }
    return compatiblePackages;
  }

  List<Patch> getUniversalPatches() {
    return _patches.where((patch) => patch.compatiblePackages.isEmpty).toList();
  }

  Future<void> loadPatches() async {
    try {
      if (_patches.isEmpty) {
        _patches = await _managerAPI.getPatches();
      }
    } on Exception catch (e) {
      if (kDebugMode) {
        print(e);
      }
      _patches = List.empty();
    }

    _compatiblePackages = getCompatiblePackages();
    _universalPatches = getUniversalPatches();
  }

  Future<List<ApplicationWithIcon>> getFilteredInstalledApps(
      bool showUniversalPatches,) async {
    final List<ApplicationWithIcon> filteredApps = [];
    final bool allAppsIncluded =
        _universalPatches.isNotEmpty && showUniversalPatches;
    if (allAppsIncluded) {
      final appList = await DeviceApps.getInstalledApplications(
        includeAppIcons: true,
        onlyAppsWithLaunchIntent: true,
      );

      for (final app in appList) {
        filteredApps.add(app as ApplicationWithIcon);
      }
    }
    for (final packageName in _compatiblePackages) {
      try {
        if (!filteredApps.any((app) => app.packageName == packageName)) {
          final ApplicationWithIcon? app = await DeviceApps.getApp(
            packageName,
            true,
          ) as ApplicationWithIcon?;
          if (app != null) {
            filteredApps.add(app);
          }
        }
      } on Exception catch (e) {
        if (kDebugMode) {
          print(e);
        }
      }
    }
    return filteredApps;
  }

  List<Patch> getFilteredPatches(String packageName) {
    if (!_compatiblePackages.contains(packageName)) {
      return _universalPatches;
    }

    final List<Patch> patches = _patches
        .where(
          (patch) =>
      patch.compatiblePackages.isEmpty ||
          !patch.name.contains('settings') &&
              patch.compatiblePackages
                  .any((pack) => pack.name == packageName),
    )
        .toList();
    if (!_managerAPI.areUniversalPatchesEnabled()) {
      filteredPatches[packageName] = patches
          .where((patch) => patch.compatiblePackages.isNotEmpty)
          .toList();
    } else {
      filteredPatches[packageName] = patches;
    }
    return filteredPatches[packageName];
  }

  Future<List<Patch>> getAppliedPatches(List<String> appliedPatches,) async {
    return _patches
        .where((patch) => appliedPatches.contains(patch.name))
        .toList();
  }

  Future<void> runPatcher(String packageName,
      String apkFilePath,
      List<Patch> selectedPatches,) async {
    final File? integrationsFile = await _managerAPI.downloadIntegrations();
    final Map<String, Map<String, dynamic>> options = {};
    for (final patch in selectedPatches) {
      if (patch.options.isNotEmpty) {
        final Map<String, dynamic> patchOptions = {};
        for (final option in patch.options) {
          final patchOption = _managerAPI.getPatchOption(packageName, patch.name, option.key);
          if (patchOption != null) {
            patchOptions[patchOption.key] = patchOption.value;
          }
        }
        options[patch.name] = patchOptions;
      }
    }

    if (integrationsFile != null) {
      _dataDir.createSync();
      _tmpDir.createSync();
      final Directory workDir = _tmpDir.createTempSync('tmp-');
      final File inputFile = File('${workDir.path}/base.apk');
      final File patchedFile = File('${workDir.path}/patched.apk');
      outFile = File('${workDir.path}/out.apk');
      final Directory cacheDir = Directory('${workDir.path}/cache');
      cacheDir.createSync();
      final String originalFilePath = apkFilePath;

      try {
        await patcherChannel.invokeMethod(
          'runPatcher',
          {
            'originalFilePath': originalFilePath,
            'inputFilePath': inputFile.path,
            'patchedFilePath': patchedFile.path,
            'outFilePath': outFile!.path,
            'integrationsPath': integrationsFile.path,
            'selectedPatches': selectedPatches.map((p) => p.name).toList(),
            'options': options,
            'cacheDirPath': cacheDir.path,
            'keyStoreFilePath': _keyStoreFile.path,
            'keystorePassword': _managerAPI.getKeystorePassword(),
          },
        );
      } on Exception catch (e) {
        if (kDebugMode) {
          print(e);
        }
      }
    }
}

Future<void> stopPatcher() async {
  try {
    await patcherChannel.invokeMethod('stopPatcher');
  } on Exception catch (e) {
    if (kDebugMode) {
      print(e);
    }
  }
}

Future<bool> installPatchedFile(PatchedApplication patchedApp) async {
  if (outFile != null) {
    try {
      if (patchedApp.isRooted) {
        final bool hasRootPermissions = await _rootAPI.hasRootPermissions();
        if (hasRootPermissions) {
          return _rootAPI.installApp(
            patchedApp.packageName,
            patchedApp.apkFilePath,
            outFile!.path,
          );
        }
      } else {
        final install = await InstallPlugin.installApk(outFile!.path);
        return install['isSuccess'];
      }
    } on Exception catch (e) {
      if (kDebugMode) {
        print(e);
      }
      return false;
    }
  }
  return false;
}

void exportPatchedFile(String appName, String version) {
  try {
    if (outFile != null) {
      final String newName = _getFileName(appName, version);
      FlutterFileDialog.saveFile(
        params: SaveFileDialogParams(
          sourceFilePath: outFile!.path,
          fileName: newName,
        ),
      );
    }
  } on Exception catch (e) {
    if (kDebugMode) {
      print(e);
    }
  }
}

void sharePatchedFile(String appName, String version) {
  try {
    if (outFile != null) {
      final String newName = _getFileName(appName, version);
      final int lastSeparator = outFile!.path.lastIndexOf('/');
      final String newPath =
          outFile!.path.substring(0, lastSeparator + 1) + newName;
      final File shareFile = outFile!.copySync(newPath);
      Share.shareXFiles([XFile(shareFile.path)]);
    }
  } on Exception catch (e) {
    if (kDebugMode) {
      print(e);
    }
  }
}

String _getFileName(String appName, String version) {
  final String prefix = appName.toLowerCase().replaceAll(' ', '-');
  final String newName = '$prefix-revanced_v$version.apk';
  return newName;
}

Future<void> exportPatcherLog(String logs) async {
  final Directory appCache = await getTemporaryDirectory();
  final Directory logDir = Directory('${appCache.path}/logs');
  logDir.createSync();
  final String dateTime = DateTime.now()
      .toIso8601String()
      .replaceAll('-', '')
      .replaceAll(':', '')
      .replaceAll('T', '')
      .replaceAll('.', '');
  final String fileName = 'revanced-manager_patcher_$dateTime.txt';
  final File log = File('${logDir.path}/$fileName');
  log.writeAsStringSync(logs);
  FlutterFileDialog.saveFile(
    params: SaveFileDialogParams(
      sourceFilePath: log.path,
      fileName: fileName,
    ),
  );
}

String getSuggestedVersion(String packageName) {
  final Map<String, int> versions = {};
  for (final Patch patch in _patches) {
    final Package? package = patch.compatiblePackages.firstWhereOrNull(
          (pack) => pack.name == packageName,
    );
    if (package != null) {
      for (final String version in package.versions) {
        versions.update(
          version,
              (value) => versions[version]! + 1,
          ifAbsent: () => 1,
        );
      }
    }
  }
  if (versions.isNotEmpty) {
    final entries = versions.entries.toList()
      ..sort((a, b) => a.value.compareTo(b.value));
    versions
      ..clear()
      ..addEntries(entries);
    versions.removeWhere((key, value) => value != versions.values.last);
    return (versions.keys.toList()
      ..sort()).last;
  }
  return '';
}}