// code from goatstore
// api: https://store.agi.bd
const axios = require('axios');
const fs = require('fs');
const path = require('path');
const os = require('os');

async function getStreamFromURL(url) {
  const response = await axios.get(url, { responseType: 'stream' });
  return response.data;
}

module.exports = {
  config: {
    name: "tiksrch",
    aliases: [],
    author: "VEX_ADNAN",
    version: "1.0",
    shortDescription: {
      en: "Play TikTok video by number",
    },
    longDescription: {
      en: "Play a TikTok video by providing the video number.",
    },
    category: "Entertainment",
    guide: {
      en: "{p}{n} [keyword]",
    },
  },
  onStart: async function ({ api, event, args }) {
    const keyword = args.join(' ');

    if (!keyword) {
      api.sendMessage({ body: 'Please provide a keyword.\nExample: {p}tiktok dance' }, event.threadID);
      return;
    }


    const videos = await fetchTikTokVideos(keyword);

    if (!videos || videos.length === 0) {
      api.sendMessage({ body: `No TikTok videos found for the keyword: ${keyword}.` }, event.threadID, event.messageID);
      return;
    }

    const videoTitles = videos.map((video, index) => `${index + 1}. ${video.title}`);
    const message = `Choose a video by replying with its number:\n\n${videoTitles.join('\n')}`;

    const tempFilePath = path.join(os.tmpdir(), 'tiktok_response.json');
    fs.writeFileSync(tempFilePath, JSON.stringify(videos));

    api.sendMessage({ body: message }, event.threadID, (err, info) => {
      global.GoatBot.onReply.set(info.messageID, {
        commandName: 'tiktok',
        messageID: info.messageID,
        author: event.senderID,
        tempFilePath,
      });
    });
  },
  onReply: async function ({ api, event, Reply, args }) {
    const { author, commandName, tempFilePath } = Reply;

    if (event.senderID !== author || !tempFilePath) {
      return;
    }

    const videoIndex = parseInt(args[0], 10);

    if (isNaN(videoIndex) || videoIndex <= 0) {
      api.sendMessage({ body: 'Invalid input.\nPlease provide a valid number.' }, event.threadID, event.messageID);
      return;
    }

    try {
      const videos = JSON.parse(fs.readFileSync(tempFilePath, 'utf-8'));

      if (!videos || videos.length === 0 || videoIndex > videos.length) {
        api.sendMessage({ body: 'Invalid video number.\ nPlease choose a number within the range.' }, event.threadID, event.messageID);
        return;
      }

      const selectedVideo = videos[videoIndex - 1];
      const videoUrl = selectedVideo.play;

      if (!videoUrl) {
        api.sendMessage({ body: 'Error: Video not found.' }, event.threadID, event.messageID);
        return;
      }

      const videoStream = await getStreamFromURL(videoUrl);

      await api.sendMessage({
        body: `Here is your TikTok video:`,
        attachment: videoStream,
      }, event.threadID, event.messageID);
    } catch (error) {
      console.error(error);
      api.sendMessage({ body: 'An error occurred while processing the video.\nPlease try again later.' }, event.threadID, event.messageID);
    } finally {

      fs.unlinkSync(tempFilePath);
      global.GoatBot.onReply.delete(event.messageID);
    }
  },
};


async function fetchTikTokVideos(keyword) {
  const options = {
    method: 'GET',
    url: 'https://tiktok-scraper7.p.rapidapi.com/feed/search',
    params: {
      keywords: keyword,
      region: 'bd',
      count: '10',
      cursor: '0',
      publish_time: '0',
      sort_type: '0'
    },
    headers: {
      'X-RapidAPI-Key': 'b38444b5b7mshc6ce6bcd5c9e446p154fa1jsn7bbcfb025b3b',
      'X-RapidAPI-Host': 'tiktok-scraper7.p.rapidapi.com'
    },
  };

  try {
    const response = await axios.request(options);
    return response.data.data.videos;
  } catch (error) {
    console.error(error);
    return null;
  }
          }