/**
 * ANIME LOVERS
 * Author : Gienetic
 * Base   : https://play.google.com/store/apps/details?id=com.aniverseid.animelovers
 * Note : Kaya nya dev apk nya orang indo (mungkin diantara kita :v), maaf ya bang , anggap aja sebagai pengujian apk nya
 sekali lagi maaf ya puh
 */


const axios = require('axios');
const crypto = require('crypto');
const readline = require('readline');
const fs = require('fs');

const API_URL = 'https://apps.animekita.org/api/v1.2.5';

// ==========================================
// CORE ENGINE
// ==========================================

const getHeaders = (isFlutter = false, isPost = false) => {
  const headers = {
    'accept': 'application/json',
    'accept-encoding': 'gzip',
    'host': 'apps.animekita.org',
    'access-control-allow-origin': '*',
    'user-agent': isFlutter ? 'Flutter/2.5.3' : 'Dart/3.9 (dart:io)'
  };
  if (isPost) headers['content-type'] = 'text/plain; charset=utf-8';
  return headers;
};

const loginGuest = async () => {
  const uid = crypto.randomBytes(5).toString('hex');
  const payload = {
    user: `Guest_${uid}`,
    email: `gienetic_${uid}@gmail.com`,
    profil: "https://lh3.googleusercontent.com/a/default"
  };
  try {
    const res = await axios.post(`${API_URL}/model/login.php`, JSON.stringify(payload), {
      headers: getHeaders(false, true)
    });
    return res.data?.data?.[0]?.token || null;
  } catch (err) {
    return null;
  }
};

const getRekomendasi = async () => {
  try {
    const res = await axios.get(`${API_URL}/rekomendasi.php`, {
      headers: getHeaders()
    });
    return res.data || [];
  } catch (err) {
    return [];
  }
};

const getOngoing = async (page = 1) => {
  try {
    const res = await axios.get(`${API_URL}/home/ongoing.php`, {
      headers: getHeaders(),
      params: {
        page,
        type: 'all'
      }
    });
    return res.data || [];
  } catch (err) {
    return [];
  }
};

const getBaruUpload = async (page = 1) => {
  try {
    const res = await axios.get(`${API_URL}/baruupload.php`, {
      headers: getHeaders(),
      params: {
        page
      }
    });
    return res.data || [];
  } catch (err) {
    return [];
  }
};

const getMovie = async (page = 1) => {
  try {
    const res = await axios.get(`${API_URL}/movie.php`, {
      headers: getHeaders(),
      params: {
        page
      }
    });
    return res.data || [];
  } catch (err) {
    return [];
  }
};

// Fungsi Baru: Mendapatkan Jadwal Rilis Mingguan
const getJadwal = async () => {
  try {
    // Method POST, tapi payload kosong sesuai capture
    const res = await axios.post(`${API_URL}/jadwal.php`, "", {
      headers: getHeaders(false, true)
    });
    return res.data?.data || [];
  } catch (err) {
    return [];
  }
};

const searchAnime = async (keyword, page = 1) => {
  try {
    const res = await axios.get(`${API_URL}/search.php`, {
      headers: getHeaders(),
      params: {
        keyword,
        page,
        per_page: 20
      }
    });
    return res.data?.data?.[0] || null;
  } catch (err) {
    return null;
  }
};

const getSeriesDetail = async (seriesSlug, token = "") => {
  const payload = {
    get: "top",
    post_type: "1",
    post_id: seriesSlug,
    token
  };
  try {
    const res = await axios.post(`${API_URL}/series.php?url=${seriesSlug}`, JSON.stringify(payload), {
      headers: getHeaders(false, true)
    });
    return res.data?.data?.[0] || null;
  } catch (err) {
    return null;
  }
};

const getStreamLinks = async (postId, seriesSlug, episode, token) => {
  const payload = {
    post_type: "2",
    post_id: postId,
    series_id: seriesSlug,
    series_url: seriesSlug,
    episode: episode.toString(),
    token
  };
  try {
    const res = await axios.post(`${API_URL}/series/episode/data.php?url=${postId}`, JSON.stringify(payload), {
      headers: getHeaders(true, true)
    });
    return res.data?.data?.[0]?.streams || null;
  } catch (err) {
    return null;
  }
};

module.exports = {
  loginGuest,
  getRekomendasi,
  getOngoing,
  getBaruUpload,
  getMovie,
  getJadwal,
  searchAnime,
  getSeriesDetail,
  getStreamLinks
};

// ==========================================
// CLI ENGINE
// ==========================================

if (require.main === module) {
  const rl = readline.createInterface({
    input: process.stdin,
    output: process.stdout
  });
  const ask = (q) => new Promise((resolve) => rl.question(`? ${q}`, resolve));

  let sessionToken = null;

  const saveAndPrintJSON = (filename, data) => {
    const jsonString = JSON.stringify(data, null, 2);
    console.log(`\n=== OUTPUT JSON ===\n${jsonString}\n===================`);
    try {
      fs.writeFileSync(filename, jsonString);
      console.log(`[+] File tersimpan: ${filename}`);
    } catch (e) {
      console.log(`[-] Gagal menyimpan file: ${e.message}`);
    }
  };

  const delay = (ms) => new Promise(res => setTimeout(res, ms));

  const fetchSmart = async (fetchFn, typeName, ...args) => {
    let allData = [];
    let seenIds = new Set();
    let page = 1;
    let keepFetching = true;

    console.log(`\n[*] Mengekstrak data ${typeName}...`);

    while (keepFetching) {
      process.stdout.write(`[~] Fetching page ${page}... `);
      const data = await fetchFn(...args, page);

      let items = [];
      let hasNextPage = true;

      if (data && data.result) {
        items = data.result;
        hasNextPage = data.pagination ? data.pagination.has_next : false;
      } else if (Array.isArray(data)) {
        items = data;
      } else {
        console.log('ERROR FORMAT');
        break;
      }

      if (items.length === 0) {
        console.log('KOSONG (Mencapai batas akhir)');
        break;
      }

      let newItemsCount = 0;
      for (const item of items) {
        const uniqueKey = item.id || item.url;
        if (!seenIds.has(uniqueKey)) {
          seenIds.add(uniqueKey);
          allData.push(item);
          newItemsCount++;
        }
      }

      console.log(`OK (+${newItemsCount} data baru)`);

      if (newItemsCount === 0 || !hasNextPage) {
        keepFetching = false;
      } else {
        page++;
        await delay(800);
      }
    }

    console.log(`[+] Total Data Bersih: ${allData.length} item.`);
    if (allData.length > 0) {
      saveAndPrintJSON(`${typeName.replace(/\s/g, '_').toLowerCase()}.json`, allData);
    }
  };

  const handleStreamExtraction = async () => {
    console.log('\n--- Ekstraksi Stream Video ---');
    const slug = await ask('Slug Anime (contoh: compass-20-sub-indo): ');
    if (!slug.trim()) return;

    process.stdout.write('[~] Memuat detail series... ');
    const detail = await getSeriesDetail(slug, sessionToken);

    if (!detail || !detail.chapter || detail.chapter.length === 0) {
      return console.log('\n[-] Gagal memuat atau anime belum memiliki episode.');
    }
    console.log('OK\n');

    const chapters = detail.chapter.sort((a, b) => parseInt(a.ch) - parseInt(b.ch));
    chapters.forEach(c => console.log(`Ep ${c.ch} \t| ID: ${c.url}`));

    const epSelected = await ask('\nPilih nomor episode: ');
    const targetChapter = chapters.find(c => c.ch === epSelected.trim());

    if (!targetChapter) return console.log('[-] Nomor episode tidak valid.');

    process.stdout.write(`[~] Mengekstrak stream Episode ${targetChapter.ch}... `);
    const streams = await getStreamLinks(targetChapter.url, slug, targetChapter.ch, sessionToken);

    if (!streams) return console.log('\n[-] Ekstraksi gagal atau link stream belum tersedia.');
    console.log('OK');

    saveAndPrintJSON(`stream_${slug}_ep${targetChapter.ch}.json`, streams);
  };

  const runCLI = async () => {
    console.clear();
    console.log("===================================");
    console.log("       ANIMELOVER CLI       ");
    console.log("===================================");

    process.stdout.write('\n[*] Inisiasi sesi anonim... ');
    sessionToken = await loginGuest();
    if (!sessionToken) {
      console.log('GAGAL KONEKSI');
      process.exit(1);
    }
    console.log('OK');

    while (true) {
      console.log('\n[ MAIN DASHBOARD ]');
      console.log('1. Fetch Rekomendasi');
      console.log('2. Fetch Ongoing (Ambil Semua)');
      console.log('3. Fetch Baru Upload (Ambil Semua)');
      console.log('4. Fetch List Movie (Ambil Semua)');
      console.log('5. Search Anime');
      console.log('6. Ekstrak Link Stream Video');
      console.log('7. Fetch Jadwal Rilis (Mingguan)'); // Menu Baru
      console.log('0. Keluar');

      const menu = await ask('\nPilihan: ');

      switch (menu.trim()) {
        case '1':
          console.log('\n[*] Memuat rekomendasi...');
          const rekData = await getRekomendasi();
          console.log(`[+] Total: ${rekData.length} item.`);
          if (rekData.length > 0) saveAndPrintJSON('rekomendasi.json', rekData);
          break;
        case '2':
          await fetchSmart(getOngoing, 'Ongoing');
          break;
        case '3':
          await fetchSmart(getBaruUpload, 'Baru Upload');
          break;
        case '4':
          await fetchSmart(getMovie, 'Movie List');
          break;
        case '5':
          const kw = await ask('Masukkan Kata Kunci: ');
          if (kw.trim()) await fetchSmart((kw, page) => searchAnime(kw, page), `Search_${kw}`, kw);
          break;
        case '6':
          await handleStreamExtraction();
          break;
        case '7':
          console.log('\n[*] Memuat jadwal rilis mingguan...');
          const jadwalData = await getJadwal();
          if (jadwalData && jadwalData.length > 0) {
            console.log(`[+] Jadwal ditemukan untuk ${jadwalData.length} hari.`);
            jadwalData.forEach(hari => {
              console.log(`    - ${hari.day} (${hari.date}): ${hari.animeList?.length || 0} Judul Anime`);
            });
            saveAndPrintJSON('jadwal_rilis.json', jadwalData);
          } else {
            console.log('[-] Data jadwal kosong atau gagal dimuat.');
          }
          break;
        case '0':
          console.log('\n[!] Terminated.');
          rl.close();
          return;
        default:
          console.log('[-] Pilihan tidak valid.');
      }
    }
  };

  runCLI();
}