mangayomi-mirror/lib/services/fetch_sources_list.dart

import 'dart:convert';
import 'package:flutter_riverpod/flutter_riverpod.dart';
import 'package:isar/isar.dart';
import 'package:mangayomi/eval/lib.dart';
import 'package:mangayomi/main.dart';
import 'package:mangayomi/models/changed.dart';
import 'package:mangayomi/models/manga.dart';
import 'package:mangayomi/models/settings.dart';
import 'package:mangayomi/models/source.dart';
import 'package:mangayomi/modules/more/settings/browse/providers/browse_state_provider.dart';
import 'package:mangayomi/modules/more/settings/sync/providers/sync_providers.dart';
import 'package:mangayomi/services/http/m_client.dart';
import 'package:package_info_plus/package_info_plus.dart';

Future<void> fetchSourcesList(
    {int? id,
    required bool refresh,
    required Ref ref,
    required ItemType itemType,
    required Repo? repo}) async {
  final http = MClient.init(reqcopyWith: {'useDartHttpClient': true});
  final url = repo?.jsonUrl;
  if (url == null) return;

  final req = await http.get(Uri.parse(url));

  final sourceList =
      (jsonDecode(req.body) as List).map((e) => Source.fromJson(e)).toList();

  final info = await PackageInfo.fromPlatform();
  isar.writeTxnSync(() async {
    for (var source in sourceList) {
      if (source.appMinVerReq != null) {
        if (compareVersions(info.version, source.appMinVerReq!) > -1) {
          if (source.itemType == itemType) {
            if (id != null) {
              if (id == source.id) {
                final sourc = isar.sources.getSync(id)!;
                final req = await http.get(Uri.parse(source.sourceCodeUrl!));
                final headers =
                    getExtensionService(source..sourceCode = req.body)
                        .getHeaders();
                isar.writeTxnSync(() {
                  isar.sources.putSync(
                    sourc
                      ..headers = jsonEncode(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
                      ..itemType = itemType
                      ..isFullData = source.isFullData ?? false
                      ..appMinVerReq = source.appMinVerReq
                      ..sourceCodeLanguage = source.sourceCodeLanguage
                      ..additionalParams = source.additionalParams ?? ""
                      ..isObsolete = false
                      ..repo = repo,
                  );
                  ref.read(synchingProvider(syncId: 1).notifier).addChangedPart(
                      ActionType.updateExtension,
                      sourc.id,
                      sourc.toJson(),
                      false);
                });
                // 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 available auto update");
                  if (ref.watch(autoUpdateExtensionsStateProvider)) {
                    final req =
                        await http.get(Uri.parse(source.sourceCodeUrl!));
                    final headers =
                        getExtensionService(source..sourceCode = req.body)
                            .getHeaders();
                    isar.writeTxnSync(() {
                      isar.sources.putSync(sourc
                        ..headers = jsonEncode(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
                        ..itemType = itemType
                        ..isFullData = source.isFullData ?? false
                        ..appMinVerReq = source.appMinVerReq
                        ..sourceCodeLanguage = source.sourceCodeLanguage
                        ..additionalParams = source.additionalParams ?? ""
                        ..isObsolete = false
                        ..repo = repo);
                      ref
                          .read(synchingProvider(syncId: 1).notifier)
                          .addChangedPart(ActionType.updateExtension, sourc.id,
                              sourc.toJson(), false);
                    });
                  } else {
                    // log("update aivalable");
                    isar.sources.putSync(sourc..versionLast = source.version);
                  }
                }
              }
            } else {
              final newSource = 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
                ..itemType = itemType
                ..sourceCodeLanguage = source.sourceCodeLanguage
                ..isFullData = source.isFullData ?? false
                ..appMinVerReq = source.appMinVerReq
                ..isObsolete = false
                ..repo = repo;
              isar.sources.putSync(newSource);
              ref.read(synchingProvider(syncId: 1).notifier).addChangedPart(
                  ActionType.addExtension, null, newSource.toJson(), false);
              // log("new source");
            }
          }
        }
      }
    }
  });
  checkIfSourceIsObsolete(sourceList, repo!, itemType, ref);
}

void checkIfSourceIsObsolete(
    List<Source> sourceList, Repo repo, ItemType itemType, Ref ref) {
  for (var source in isar.sources
      .filter()
      .idIsNotNull()
      .itemTypeEqualTo(itemType)
      .findAllSync()) {
    if (sourceList.isNotEmpty && !(source.isLocal ?? false)) {
      final ids =
          sourceList.where((e) => e.id != null).map((e) => e.id).toList();
      if (ids.isNotEmpty) {
        isar.writeTxnSync(() {
          if (source.isObsolete !=
              (!ids.contains(source.id) &&
                  source.repo?.jsonUrl == repo.jsonUrl)) {
            ref.read(synchingProvider(syncId: 1).notifier).addChangedPart(
                ActionType.updateExtension, source.id, source.toJson(), false);
          }
          isar.sources.putSync(source
            ..isObsolete = !ids.contains(source.id) &&
                source.repo?.jsonUrl == repo.jsonUrl);
        });
      }
    }
  }
}

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;
}