Reorganize folders

dart/anime/src/en/animepahe/animepahe.dart

@@ -0,0 +1,317 @@
+import 'package:mangayomi/bridge_lib.dart';
+import 'dart:convert';
+import 'dart:math';
+
+class AnimePahe extends MProvider {
+  AnimePahe(this.source);
+
+  final MSource source;
+
+  final Client client = Client(source);
+
+  @override
+  String get baseUrl => getPreferenceValue(source.id, "preferred_domain");
+
+  @override
+  Future<MPages> getPopular(int page) async {
+    return await getLatestUpdates(page);
+  }
+
+  @override
+  Future<MPages> getLatestUpdates(int page) async {
+    final res =
+        (await client.get(Uri.parse("$baseUrl/api?m=airing&page=$page"))).body;
+    final jsonResult = json.decode(res);
+    final hasNextPage = jsonResult["current_page"] < jsonResult["last_page"];
+    List<MManga> animeList = [];
+    for (var item in jsonResult["data"]) {
+      MManga anime = MManga();
+      anime.name = item["anime_title"];
+      anime.imageUrl = item["snapshot"];
+      anime.link = "/anime/?anime_id=${item["id"]}&name=${item["anime_title"]}";
+      anime.artist = item["fansub"];
+      animeList.add(anime);
+    }
+    return MPages(animeList, hasNextPage);
+  }
+
+  @override
+  Future<MPages> search(String query, int page, FilterList filterList) async {
+    final res =
+        (await client.get(Uri.parse("$baseUrl/api?m=search&l=8&q=$query")))
+            .body;
+    final jsonResult = json.decode(res);
+    List<MManga> animeList = [];
+    for (var item in jsonResult["data"]) {
+      MManga anime = MManga();
+      anime.name = item["title"];
+      anime.imageUrl = item["poster"];
+      anime.link = "/anime/?anime_id=${item["id"]}&name=${item["title"]}";
+      animeList.add(anime);
+    }
+    return MPages(animeList, false);
+  }
+
+  @override
+  Future<MManga> getDetail(String url) async {
+    final statusList = [
+      {"Currently Airing": 0, "Finished Airing": 1}
+    ];
+    MManga anime = MManga();
+    final id = substringBefore(substringAfterLast(url, "?anime_id="), "&name=");
+    final name = substringAfterLast(url, "&name=");
+    final session = await getSession(name, id);
+    final res =
+        (await client.get(Uri.parse("$baseUrl/anime/$session?anime_id=$id")))
+            .body;
+    final document = parseHtml(res);
+    final status =
+        (document.xpathFirst('//div/p[contains(text(),"Status:")]/text()') ??
+                "")
+            .replaceAll("Status:\n", "")
+            .trim();
+    anime.status = parseStatus(status, statusList);
+
+    anime.name = document.selectFirst("div.title-wrapper > h1 > span").text;
+    anime.author =
+        (document.xpathFirst('//div/p[contains(text(),"Studio:")]/text()') ??
+                "")
+            .replaceAll("Studio:\n", "")
+            .trim();
+    anime.imageUrl = document.selectFirst("div.anime-poster a").attr("href");
+    anime.genre =
+        xpath(res, '//*[contains(@class,"anime-genre")]/ul/li/text()');
+    final synonyms =
+        (document.xpathFirst('//div/p[contains(text(),"Synonyms:")]/text()') ??
+                "")
+            .replaceAll("Synonyms:\n", "")
+            .trim();
+    anime.description = document.selectFirst("div.anime-summary").text;
+    if (synonyms.isNotEmpty) {
+      anime.description += "\n\n$synonyms";
+    }
+    final epUrl = "$baseUrl/api?m=release&id=$session&sort=episode_desc&page=1";
+    final resEp = (await client.get(Uri.parse(epUrl))).body;
+    final episodes = await recursivePages(epUrl, resEp, session);
+
+    anime.chapters = episodes;
+    return anime;
+  }
+
+  Future<List<MChapter>> recursivePages(
+      String url, String res, String session) async {
+    final jsonResult = json.decode(res);
+    final page = jsonResult["current_page"];
+    final hasNextPage = page < jsonResult["last_page"];
+    List<MManga> animeList = [];
+    for (var item in jsonResult["data"]) {
+      MChapter episode = MChapter();
+      episode.name = "Episode ${item["episode"]}";
+      episode.url = "/play/$session/${item["session"]}";
+      episode.dateUpload =
+          parseDates([item["created_at"]], "yyyy-MM-dd HH:mm:ss", "en")[0];
+      animeList.add(episode);
+    }
+    if (hasNextPage) {
+      final newUrl = "${substringBeforeLast(url, "&page=")}&page=${page + 1}";
+      final newRes = (await client.get(Uri.parse(newUrl))).body;
+      animeList.addAll(await recursivePages(newUrl, newRes, session));
+    }
+    return animeList;
+  }
+
+  Future<String> getSession(String title, String animeId) async {
+    final res =
+        (await client.get(Uri.parse("$baseUrl/api?m=search&q=$title"))).body;
+    return substringBefore(
+        substringAfter(
+            substringAfter(res, "\"id\":$animeId"), "\"session\":\""),
+        "\"");
+  }
+
+  @override
+  Future<List<MVideo>> getVideoList(String url) async {
+    final res = (await client.get(Uri.parse("$baseUrl$url")));
+    final document = parseHtml(res.body);
+    final downloadLinks = document.select("div#pickDownload > a");
+    final buttons = document.select("div#resolutionMenu > button");
+    List<MVideo> videos = [];
+    for (var i = 0; i < buttons.length; i++) {
+      final btn = buttons[i];
+      final kwikLink = btn.attr("data-src");
+      final quality = btn.text;
+      final paheWinLink = downloadLinks[i].attr("href");
+      if (getPreferenceValue(source.id, "preffered_link_type")) {
+        final noRedirectClient =
+            Client(source, json.encode({"followRedirects": false}));
+        final kwikHeaders =
+            (await noRedirectClient.get(Uri.parse("${paheWinLink}/i"))).headers;
+        final kwikUrl =
+            "https://${substringAfterLast(getMapValue(json.encode(kwikHeaders), "location"), "https://")}";
+        final reskwik = (await client
+            .get(Uri.parse(kwikUrl), headers: {"Referer": "https://kwik.cx/"}));
+        final matches = RegExp(r'\("(\S+)",\d+,"(\S+)",(\d+),(\d+)')
+            .firstMatch(reskwik.body);
+        final token = decrypt(matches!.group(1)!, matches.group(2)!,
+            matches.group(3)!, int.parse(matches.group(4)!));
+        final url = RegExp(r'action="([^"]+)"').firstMatch(token)!.group(1)!;
+        final tok = RegExp(r'value="([^"]+)"').firstMatch(token)!.group(1)!;
+        var code = 419;
+        var tries = 0;
+        String location = "";
+
+        while (code != 302 && tries < 20) {
+          String cookie =
+              getMapValue(json.encode(res.request.headers), "cookie");
+          cookie +=
+              "; ${getMapValue(json.encode(reskwik.headers), "set-cookie").replaceAll("path=/;", "")}";
+          final resNo =
+              await Client(source, json.encode({"followRedirects": false}))
+                  .post(Uri.parse(url), headers: {
+            "referer": reskwik.request.url.toString(),
+            "cookie": cookie,
+            "user-agent":
+                getMapValue(json.encode(res.request.headers), "user-agent")
+          }, body: {
+            "_token": tok
+          });
+          code = resNo.statusCode;
+          tries++;
+          location = getMapValue(json.encode(resNo.headers), "location");
+        }
+        if (tries > 19) {
+          throw ("Failed to extract the stream uri from kwik.");
+        }
+        MVideo video = MVideo();
+        video
+          ..url = location
+          ..originalUrl = location
+          ..quality = quality;
+        videos.add(video);
+      } else {
+        final ress = (await client.get(Uri.parse(kwikLink),
+            headers: {"Referer": "https://animepahe.com"}));
+        final script = substringAfterLast(
+            xpath(ress.body,
+                    '//script[contains(text(),"eval(function")]/text()')
+                .first,
+            "eval(function(");
+        final videoUrl = substringBefore(
+            substringAfter(unpackJsAndCombine("eval(function($script"),
+                "const source=\\'"),
+            "\\';");
+        MVideo video = MVideo();
+        video
+          ..url = videoUrl
+          ..originalUrl = videoUrl
+          ..quality = quality
+          ..headers = {"referer": "https://kwik.cx"};
+        videos.add(video);
+      }
+    }
+    return sortVideos(videos);
+  }
+
+  String getString(String ctn, int sep) {
+    int b = 10;
+    String cm =
+        "0123456789abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ+/";
+    final n = cm.substring(0, b);
+    double mx = 0;
+    for (var index = 0; index < ctn.length; index++) {
+      mx += (int.tryParse(ctn[ctn.length - index - 1], radix: 10) ?? 0.0)
+              .toInt() *
+          (pow(sep, index));
+    }
+    var m = '';
+    while (mx > 0) {
+      m = n[(mx % b).toInt()] + m;
+      mx = (mx - (mx % b)) / b;
+    }
+    return m.isNotEmpty ? m : '0';
+  }
+
+  String decrypt(String fS, String key, String v1, int v2) {
+    var html = "";
+    var i = 0;
+    final ld = int.parse(v1);
+    while (i < fS.length) {
+      var s = "";
+      while (fS[i] != key[v2]) {
+        s += fS[i];
+        i++;
+      }
+      for (var index = 0; index < key.length; index++) {
+        s = s.replaceAll(key[index], index.toString());
+      }
+      html += String.fromCharCode(int.parse(getString(s, v2)) - ld);
+      i++;
+    }
+
+    return html;
+  }
+
+  List<MVideo> sortVideos(List<MVideo> videos) {
+    String quality = getPreferenceValue(source.id, "preferred_quality");
+
+    videos.sort((MVideo a, MVideo b) {
+      int qualityMatchA = 0;
+      if (a.quality.contains(quality)) {
+        qualityMatchA = 1;
+      }
+      int qualityMatchB = 0;
+      if (b.quality.contains(quality)) {
+        qualityMatchB = 1;
+      }
+      if (qualityMatchA != qualityMatchB) {
+        return qualityMatchB - qualityMatchA;
+      }
+
+      final regex = RegExp(r'(\d+)p');
+      final matchA = regex.firstMatch(a.quality);
+      final matchB = regex.firstMatch(b.quality);
+      final int qualityNumA = int.tryParse(matchA?.group(1) ?? '0') ?? 0;
+      final int qualityNumB = int.tryParse(matchB?.group(1) ?? '0') ?? 0;
+      return qualityNumB - qualityNumA;
+    });
+
+    return videos;
+  }
+
+  @override
+  List<dynamic> getSourcePreferences() {
+    return [
+      ListPreference(
+          key: "preferred_domain",
+          title: "Preferred domain",
+          summary: "",
+          valueIndex: 1,
+          entries: [
+            "animepahe.com",
+            "animepahe.ru",
+            "animepahe.org"
+          ],
+          entryValues: [
+            "https://animepahe.com",
+            "https://animepahe.ru",
+            "https://animepahe.org"
+          ]),
+      SwitchPreferenceCompat(
+          key: "preffered_link_type",
+          title: "Use HLS links",
+          summary: "Enable this if you are having Cloudflare issues.",
+          value: false),
+      ListPreference(
+          key: "preferred_quality",
+          title: "Preferred Quality",
+          summary: "",
+          valueIndex: 0,
+          entries: ["1080p", "720p", "360p"],
+          entryValues: ["1080", "720", "360"]),
+    ];
+  }
+}
+
+AnimePahe main(MSource source) {
+  return AnimePahe(source);
+}

dart/anime/src/en/animepahe/source.dart

@@ -0,0 +1,16 @@
+import '../../../../../model/source.dart';
+
+Source get animepaheSource => _animepaheSource;
+const _animepaheVersion = "0.0.35";
+const _animepaheSourceCodeUrl =
+    "https://raw.githubusercontent.com/kodjodevf/mangayomi-extensions/$branchName/dart/anime/src/en/animepahe/animepahe.dart";
+Source _animepaheSource = Source(
+    name: "AnimePahe",
+    baseUrl: "https://www.animepahe.ru",
+    lang: "en",
+    typeSource: "single",
+    iconUrl:
+        "https://raw.githubusercontent.com/kodjodevf/mangayomi-extensions/$branchName/dart/anime/src/en/animepahe/icon.png",
+    sourceCodeUrl: _animepaheSourceCodeUrl,
+    version: _animepaheVersion,
+    isManga: false);