mangayomi/lib/modules/browse/extension/providers/fetch_manga_sources.dart

import 'dart:convert';
import 'package:dart_eval/stdlib/core.dart';
import 'package:mangayomi/eval/dart/compiler/compiler.dart';
import 'package:mangayomi/eval/dart/runtime/runtime.dart';
import 'package:mangayomi/main.dart';
import 'package:mangayomi/models/source.dart';
import 'package:mangayomi/modules/more/settings/browse/providers/browse_state_provider.dart';
import 'package:mangayomi/services/http/interceptor.dart';
import 'package:package_info_plus/package_info_plus.dart';
import 'package:riverpod_annotation/riverpod_annotation.dart';
part 'fetch_manga_sources.g.dart';

@riverpod
Future fetchMangaSourcesList(FetchMangaSourcesListRef ref,
    {int? id, required reFresh}) async {
  final http = MInterceptor.init();
  if (ref.watch(checkForExtensionsUpdateStateProvider) || reFresh) {
    final info = await PackageInfo.fromPlatform();
    final req = await http.get(Uri.parse(
        "https://kodjodevf.github.io/mangayomi-extensions/index.json"));
    final res = jsonDecode(req.body) as List;

    final sourceList = res.map((e) => Source.fromJson(e)).toList();

    isar.writeTxnSync(() async {
      for (var source in sourceList) {
        if (source.appMinVerReq != null) {
          if (compareVersions(info.version, source.appMinVerReq!) > -1) {
            if (source.isManga!) {
              if (id != null) {
                if (id == source.id) {
                  final sourc = isar.sources.getSync(id)!;
                  final req = await http.get(Uri.parse(source.sourceCodeUrl!));
                  final headers = await getHeaders(req.body, source.baseUrl!);
                  isar.writeTxnSync(() {
                    isar.sources.putSync(sourc
                      ..headers = headers ?? ""
                      ..isAdded = true
                      ..sourceCode = req.body
                      ..sourceCodeUrl = source.sourceCodeUrl
                      ..id = id
                      ..apiUrl = source.apiUrl
                      ..baseUrl = source.baseUrl
                      ..dateFormat = source.dateFormat
                      ..dateFormatLocale = source.dateFormatLocale
                      ..hasCloudflare = source.hasCloudflare
                      ..iconUrl = source.iconUrl
                      ..typeSource = source.typeSource
                      ..lang = source.lang
                      ..isNsfw = source.isNsfw
                      ..name = source.name
                      ..version = source.version
                      ..versionLast = source.version
                      ..isManga = source.isManga
                      ..isFullData = source.isFullData ?? false
                      ..appMinVerReq = source.appMinVerReq
                      ..additionalParams = source.additionalParams ?? "");
                  });
                  // log("successfully installed or updated");
                }
              } else if (isar.sources.getSync(source.id!) != null) {
                // log("exist");
                final sourc = isar.sources.getSync(source.id!)!;
                if (sourc.isAdded!) {
                  if (compareVersions(sourc.version!, source.version!) < 0) {
                    // log("update aivalable auto update");
                    if (ref.watch(autoUpdateExtensionsStateProvider)) {
                      final req =
                          await http.get(Uri.parse(source.sourceCodeUrl!));
                      final headers =
                          await getHeaders(req.body, source.baseUrl!);
                      isar.writeTxnSync(() {
                        isar.sources.putSync(sourc
                          ..headers = headers ?? ""
                          ..isAdded = true
                          ..sourceCode = req.body
                          ..sourceCodeUrl = source.sourceCodeUrl
                          ..id = source.id
                          ..apiUrl = source.apiUrl
                          ..baseUrl = source.baseUrl
                          ..dateFormat = source.dateFormat
                          ..dateFormatLocale = source.dateFormatLocale
                          ..hasCloudflare = source.hasCloudflare
                          ..iconUrl = source.iconUrl
                          ..typeSource = source.typeSource
                          ..lang = source.lang
                          ..isNsfw = source.isNsfw
                          ..name = source.name
                          ..version = source.version
                          ..versionLast = source.version
                          ..isManga = source.isManga
                          ..isFullData = source.isFullData ?? false
                          ..appMinVerReq = source.appMinVerReq
                          ..additionalParams = source.additionalParams ?? "");
                      });
                    } else {
                      // log("update aivalable");
                      isar.sources.putSync(sourc..versionLast = source.version);
                    }
                  }
                }
              } else {
                isar.sources.putSync(Source()
                  ..sourceCodeUrl = source.sourceCodeUrl
                  ..id = source.id
                  ..sourceCode = source.sourceCode
                  ..apiUrl = source.apiUrl
                  ..baseUrl = source.baseUrl
                  ..dateFormat = source.dateFormat
                  ..dateFormatLocale = source.dateFormatLocale
                  ..hasCloudflare = source.hasCloudflare
                  ..iconUrl = source.iconUrl
                  ..typeSource = source.typeSource
                  ..lang = source.lang
                  ..isNsfw = source.isNsfw
                  ..name = source.name
                  ..version = source.version
                  ..versionLast = source.version
                  ..isManga = source.isManga
                  ..isFullData = source.isFullData ?? false
                  ..appMinVerReq = source.appMinVerReq);
                // log("new source");
              }
            }
          }
        }
      }
    });
  }
}

int compareVersions(String version1, String version2) {
  List<String> v1Components = version1.split('.');
  List<String> v2Components = version2.split('.');

  for (int i = 0; i < v1Components.length && i < v2Components.length; i++) {
    int v1Value = int.parse(
        v1Components.length == i + 1 && v1Components[i].length == 1
            ? "${v1Components[i]}0"
            : v1Components[i]);
    int v2Value = int.parse(
        v2Components.length == i + 1 && v2Components[i].length == 1
            ? "${v2Components[i]}0"
            : v2Components[i]);

    if (v1Value < v2Value) {
      return -1;
    } else if (v1Value > v2Value) {
      return 1;
    }
  }

  if (v1Components.length < v2Components.length) {
    return -1;
  } else if (v1Components.length > v2Components.length) {
    return 1;
  }

  return 0;
}

Future<String?> getHeaders(String codeSource, String baseUrl) async {
  try {
    final bytecode = compilerEval(codeSource);
    final runtime = runtimeEval(bytecode);
    runtime.args = [$String(baseUrl)];
    var res = await runtime.executeLib(
      'package:mangayomi/main.dart',
      'getHeader',
    );
    Map<String, String> headers = {};
    if (res is $Map) {
      headers = res.$reified
          .map((key, value) => MapEntry(key.toString(), value.toString()));
    }
    return jsonEncode(headers);
  } catch (_) {
    return null;
  }
}