mangayomi-mirror/lib/services/http_service/cloudflare/cloudflare_bypass.dart

import 'package:flutter_inappwebview/flutter_inappwebview.dart';
import 'package:html/dom.dart' as dom;
import 'package:html/dom.dart';
import 'package:mangayomi/main.dart';
import 'package:mangayomi/models/settings.dart';
import 'package:mangayomi/services/http_service/cloudflare/cookie.dart';
import 'package:riverpod_annotation/riverpod_annotation.dart';
part 'cloudflare_bypass.g.dart';

@riverpod
Future<dom.Document?> cloudflareBypassDom(CloudflareBypassDomRef ref,
    {required String url,
    required String source,
    required bool useUserAgent}) async {
  // log(source);
  bool isOk = false;
  dom.Document? htmll;
  final ua = isar.settings.getSync(227)!.userAgent!;
  HeadlessInAppWebView? headlessWebViewJapScan;
  headlessWebViewJapScan = HeadlessInAppWebView(
    onLoadStop: (controller, u) async {
      String? html;
      html = await controller.evaluateJavascript(
          source: "window.document.getElementsByTagName('html')[0].outerHTML;");
      await Future.doWhile(() async {
        if (html == null ||
            html!.contains("Just a moment") ||
            html!.contains("https://challenges.cloudflare.com")) {
          html = await controller.evaluateJavascript(
              source:
                  "window.document.getElementsByTagName('html')[0].outerHTML;");
          return true;
        }
        return false;
      });
      html = await controller.evaluateJavascript(
          source: "window.document.getElementsByTagName('html')[0].outerHTML;");
      htmll = dom.Document.html(html!);
      isOk = true;
      headlessWebViewJapScan!.dispose();
    },
    initialSettings: useUserAgent ? InAppWebViewSettings(userAgent: ua) : null,
    initialUrlRequest: URLRequest(
      url: WebUri.uri(Uri.parse(url)),
    ),
  );

  headlessWebViewJapScan.run();

  await Future.doWhile(() async {
    await Future.delayed(const Duration(seconds: 1));
    if (isOk == true) {
      return false;
    }
    return true;
  });
  await ref.watch(setCookieProvider(source, url).future);
  return htmll;
}

@riverpod
Future<String> cloudflareBypassHtml(CloudflareBypassHtmlRef ref,
    {required String url,
    required String source,
    required bool useUserAgent}) async {
  final ua = isar.settings.getSync(227)!.userAgent!;
  bool isOk = false;
  String? html;
  HeadlessInAppWebView? headlessWebViewJapScan;
  headlessWebViewJapScan = HeadlessInAppWebView(
    onLoadStop: (controller, u) async {
      html = await controller.evaluateJavascript(
          source: "window.document.getElementsByTagName('html')[0].outerHTML;");
      await Future.doWhile(() async {
        if (html == null ||
            html!.contains("Just a moment") ||
            html!.contains("Un instant…")) {
          html = await controller.evaluateJavascript(
              source:
                  "window.document.getElementsByTagName('html')[0].outerHTML;");
          return true;
        }
        return false;
      });
      html = await controller.evaluateJavascript(
          source: "window.document.getElementsByTagName('html')[0].outerHTML;");
      isOk = true;
      headlessWebViewJapScan!.dispose();
    },
    initialSettings: useUserAgent ? InAppWebViewSettings(userAgent: ua) : null,
    initialUrlRequest: URLRequest(
      url: WebUri.uri(Uri.parse(url)),
    ),
  );

  headlessWebViewJapScan.run();
  await Future.doWhile(() async {
    await Future.delayed(const Duration(seconds: 1));
    if (isOk == true) {
      return false;
    }
    return true;
  });
  await ref.watch(setCookieProvider(source, url).future);
  return html!;
}