/*
💎 القسم : [ العاب ]
📌 الميزة : [ احزر ]
🏷 النوع : Plugin ESM
♲ الوظيفة : لعبة احزر اسم الشخصية
✍️ بواسطة : https://t.me/YatoCoding
✍️ الدعم : https://t.me/alkaser_0_0
*/

let timeout = 60000
let poin = 500

let handler = async (m, { conn, command, usedPrefix }) => {
    conn.tebakbendera = conn.tebakbendera || {}
    let id = m.chat

    if (id in conn.tebakbendera) {
        conn.reply(m.chat, '❐┃لم يتم الاجابة علي السؤال بعد┃❌ ❯', conn.tebakbendera[id][0])
        throw false
    }

    // جلب البيانات من whois.json
    let src = await (await fetch('https://github.com/anasmods/Nandimonai/raw/main/game/whois.json')).json()
    let json = src[Math.floor(Math.random() * src.length)]

    let caption = `*${command.toUpperCase()}*
❐↞┇الـوقـت⏳↞ ${(timeout / 1000).toFixed(2)} ┇
*استخدم انسحب للأنسحاب*
❐↞┇الـجـائـزة💰↞ ${poin} نقاط┇
➥ 𝗬𝗮𝘁𝗼 𝗕𝗼𝘁
`.trim()

    // إرسال الصورة كرابط مباشر
    let sentMsg = await conn.sendMessage(m.chat, {
        image: { url: json.img },
        caption: caption
    }, { quoted: m })
// ᴍᴏᴅᴇ ʙʏ : https://t.me/YatoCoding
    conn.tebakbendera[id] = [
        sentMsg,
        json,
        poin,
        setTimeout(() => {
            if (conn.tebakbendera[id]) {
                conn.reply(m.chat, `❮ ⌛┇انتهي الوقت┇⌛❯\n❐↞┇الاجـابـة✅↞ ${json.name}┇`, conn.tebakbendera[id][0])
                delete conn.tebakbendera[id]
            }
        }, timeout)
    ]
}

handler.help = ['احزر']
handler.tags = ['game']
handler.command = /^احزر/i

export default handler

import similarity from 'similarity'
const threshold = 0.72
export async function before(m) {
    let id = m.chat
    if (!m.quoted || !m.quoted.fromMe || !m.quoted.isBaileys || !m.text || !/استخدم.*انسحب/i.test(m.quoted.text) || /.*hhint/i.test(m.text))
        return !0
    this.tebakbendera = this.tebakbendera ? this.tebakbendera : {}
    if (!(id in this.tebakbendera))
        return this.reply(m.chat, '*لقد انتهي هذا السؤال اكتب احزر/علم/عين لتظهر أسأله جديده*', m)
    if (m.quoted.id == this.tebakbendera[id][0].id) {
        let isSurrender = /^(انسحب|surr?ender)$/i.test(m.text)
        if (isSurrender) {
            clearTimeout(this.tebakbendera[id][3])
            delete this.tebakbendera[id]
            return this.reply(m.chat, '*طلع فاشل و استسلم :( !*', m)
        }
        let json = JSON.parse(JSON.stringify(this.tebakbendera[id][1]))
// ᴍᴏᴅᴇ ʙʏ : https://t.me/YatoCoding
        if (m.text.toLowerCase() == json.name.toLowerCase().trim()) {
            global.db.data.users[m.sender].exp += this.tebakbendera[id][2]
            this.reply(m.chat, `*❐┃اجـابـة صـحـيـحـة┃✅ ❯*\n\n*❐↞┇الـجـائـزة💰↞${this.tebakbendera[id][2]} نقطه*`, m)
            clearTimeout(this.tebakbendera[id][3])
            delete this.tebakbendera[id]
        } else if (similarity(m.text.toLowerCase(), json.name.toLowerCase().trim()) >= threshold)
            m.reply(`*لقد كنت علي وشك النجاح*!`)
        else
            this.reply(m.chat, `❐┃اجـابـة خـاطـئـة┃❌ ❯`, m)
    }
    return !0
}
export const exp = 0

💎 القسم : [ العاب ]
📌 الميزة : [ عين ]
🏷 النوع : Plugin ESM
♲ الوظيفة : لعبة التعرف على الشخصية
✍️ بواسطة : https://t.me/YatoCoding
✍️ الدعم : https://t.me/alkaser_0_0

let timeout = 60000
let poin = 500

let handler = async (m, { conn, command }) => {
    conn.tebakAin = conn.tebakAin ? conn.tebakAin : {}
    let id = m.chat
    if (id in conn.tebakAin) {
        conn.reply(m.chat, '❐┃لم يتم الاجابة علي السؤال بعد┃❌ ❯', conn.tebakAin[id].msg)
        throw false
    }

    let src = await (await fetch('https://github.com/anasmods/Nandimonai/raw/main/game/eye.json')).json()
    let json = src[Math.floor(Math.random() * src.length)]
    let caption = `*${command.toUpperCase()}*
❐↞┇الـوقـت⏳↞ ${(timeout / 1000).toFixed(2)} ┇
*استخدم انسحب للأنسحاب*
❐↞┇الـجـائـزة💰↞ ${poin} نقاط┇
➥ 𝗬𝗮𝘁𝗼 𝗕𝗼𝘁
    `.trim()

    let msg = await conn.sendMessage(m.chat, { image: { url: json.img }, caption }, { quoted: m })
// ᴍᴏᴅᴇ ʙʏ : https://t.me/YatoCoding
    conn.tebakAin[id] = {
        msg,
        json,
        poin,
        timeout: setTimeout(() => {
            if (conn.tebakAin[id]) {
                conn.reply(m.chat, `❮ ⌛┇انتهي الوقت┇⌛❯\n❐↞┇الاجـابـة✅↞ ${json.name}┇`, conn.tebakAin[id].msg)
                delete conn.tebakAin[id]
            }
        }, timeout)
    }
}

handler.help = ['عين']
handler.tags = ['games']
handler.command = /^عين/i

export default handler

import similarity from 'similarity'
const threshold = 0.72

export async function before(m) {
    let conn = this
    conn.tebakAin = conn.tebakAin ? conn.tebakAin : {}
    let id = m.chat
    if (!(id in conn.tebakAin)) return !0

    let game = conn.tebakAin[id]
    if (!m.quoted || m.quoted.id !== game.msg.key.id) return !0

    let isSurrender = /^(انسحب|surr?ender)$/i.test(m.text)
    if (isSurrender) {
        clearTimeout(game.timeout)
        delete conn.tebakAin[id]
        return conn.reply(m.chat, '*طلع فاشل و استسلم :( !*', m)
    }
// ᴍᴏᴅᴇ ʙʏ : https://t.me/YatoCoding
    let json = game.json
    if (m.text.toLowerCase() == json.name.toLowerCase().trim()) {
        global.db.data.users[m.sender].exp += game.poin
        conn.reply(m.chat, `*❐┃اجـابـة صـحـيـحـة┃✅ ❯*\n\n*❐↞┇الـجـائـزة💰↞ ${game.poin} نقطه*`, m)
        clearTimeout(game.timeout)
        delete conn.tebakAin[id]
    } else if (similarity(m.text.toLowerCase(), json.name.toLowerCase().trim()) >= threshold) {
        m.reply(`*لقد كنت على وشك النجاح*!`)
    } else {
        conn.reply(m.chat, `❐┃اجـابـة خـاطـئـة┃❌ ❯`, m)
    }
    return !0
}

export const exp = 0

💎 القسم : [ البحث ]
📌 الميزة : [ tiktoksearch ]
🏷 النوع : Plugin ESM
♲ الوظيفة : بحث فيديوهات تيك توك
✍️ بواسطة : https://t.me/YatoCoding
✍️ الدعم : https://t.me/alkaser_0_0

import axios from 'axios';

let sentVideos = new Set(); // لتخزين الفيديوهات التي تم إرسالها لتجنب التكرار

let handler = async (message, { conn, text }) => {
  // إرسال رد فعل عند بدء البحث
  await conn.sendMessage(message.chat, { react: { text: "🎥", key: message.key } });

  // التحقق من إدخال النص
  if (!text) {
    return await conn.sendMessage(message.chat, { text: "⚠️ *الرجاء إدخال اسم الفيديو أو النص المطلوب للبحث عنه.*\n\nمثال: .تصميم سورة المؤمنون" });
  }

  // إضافة كلمة "تصميم" للنص المدخل
  const query = `تصميم ${text}`;

  try {
    // البحث عن الفيديو
    let { data: response } = await axios.get(`https://apis-starlights-team.koyeb.app/starlight/tiktoksearch?text=${query}`);
    let searchResults = response.data;

    // التحقق من وجود نتائج
    if (!searchResults.length) {
      return await conn.sendMessage(message.chat, { text: `⚠️ لم يتم العثور على نتائج لكلمة البحث: *${query}*` });
    }

    // فلترة الفيديوهات التي تم إرسالها بالفعل
    let availableResults = searchResults.filter(result => !sentVideos.has(result.nowm));

    // إذا كانت كل الفيديوهات تم إرسالها بالفعل
    if (availableResults.length === 0) {
      return await conn.sendMessage(message.chat, { text: "⚠️ كل الفيديوهات تم إرسالها بالفعل." });
    }

    // اختيار فيديو عشوائي
    let result = availableResults[Math.floor(Math.random() * availableResults.length)];

    // إضافة الفيديو الذي تم إرساله إلى المجموعة لتجنب تكراره
    sentVideos.add(result.nowm);

    // إرسال الفيديو
    await conn.sendMessage(message.chat, {
      video: { url: result.nowm }, // رابط الفيديو بدون علامة مائية
      caption: `*🔹 تصميم مطلوب 🔹*\n\n📄 *العنوان*: ${result.title}\n🌐 *الرابط*: ${result.link}`
    });
  } catch (error) {
    // الرد في حالة وجود خطأ
    await conn.sendMessage(message.chat, { text: `⚠️ حدث خطأ أثناء البحث: ${error.message}` });
  }
};

handler.help = ['تصميم'];
handler.tags = ['search'];
handler.command = ['تصميم','tiktoksearch']; 

export default handler;

💎 القسم : [ owner - dev ]
📌 الميزة : [ plugin manager ]
🏷 النوع : Plugin ESM
♲ الوظيفة : ادارة الاضافات والميزات بسهولة كـ (اضافة/تعديل/حذف/عرض/كشف/لستة/معلومات/بحث)
✍️ بواسطة : https://t.me/YatoCoding
✍️ الدعم : https://t.me/alkaser_0_0

💎 القسم : [ AI ]
📌 الميزة : [ gemini ]
🏷 النوع : Plugin ESM
♲ الوظيفة : محادثة الذكاء الاصطناعي
✍️ بواسطة : https://t.me/YatoCoding
✍️ الدعم : https://t.me/alkaser_0_0

// plugins/gemini.js
// 𖤍 YATO BOT MD - Gemini AI Text Chat 🧠💬

import https from 'https'
import fs from 'fs'

const agent = new https.Agent({ keepAlive: true })

function syncCookies(jar, setCookies = []) {
  const list = Array.isArray(setCookies) ? setCookies : [setCookies]
  for (const item of list) {
    const pair = item.split(';')[0].split('=')
    if (pair.length >= 2) {
      jar[pair[0].trim()] = pair.slice(1).join('=').trim()
    }
  }
}
// ᴍᴏᴅᴇ ʙʏ : https://t.me/YatoCoding
const buildCookieString = (jar) => Object.entries(jar).map(([k, v]) => `${k}=${v}`).join('; ')

function cleanText(text) {
  if (!text) return ''
  text = text.replace(/https?:\/\/[a-z0-9.-]*googleusercontent\.com\/[^\s\n"<>]+/gi, '')
  return text
    .replace(/&#(\d+);/g, (_, n) => String.fromCodePoint(parseInt(n, 10)))
    .replace(/&#x([0-9a-f]+);/gi, (_, h) => String.fromCodePoint(parseInt(h, 16)))
    .replace(/&amp;/g, '&')
    .replace(/&lt;/g, '<')
    .replace(/&gt;/g, '>')
    .replace(/&quot;/g, '"')
    .replace(/&apos;/g, "'")
    .replace(/ /g, ' ')
    .trim()
}

function request(url, { method = 'GET', headers = {}, body = null, stream = false } = {}) {
  return new Promise((resolve, reject) => {
    const u = new URL(url)
    const opts = {
      hostname: u.hostname,
      path: u.pathname + u.search,
      method,
      headers: body ? { ...headers, 'content-length': Buffer.byteLength(body) } : headers,
      agent,
      maxHeaderSize: 1048576
    }

    const req = https.request(opts, res => {
      if (stream) return resolve({ res, headers: res.headers })
      const chunks = []
      res.on('data', c => chunks.push(c))
      res.on('end', () => resolve({ text: Buffer.concat(chunks).toString(), headers: res.headers }))
    })

    req.on('error', reject)
    if (body) req.write(body)
    req.end()
  })
}

async function startSession(cookieStr = null) {
  const cookies = {}

  if (!cookieStr) {
    try {
      if (fs.existsSync('cookies.json')) {
        const cookieData = JSON.parse(fs.readFileSync('cookies.json', 'utf8'))
        if (cookieData && Array.isArray(cookieData.cookies)) {
          cookieData.cookies.forEach(c => cookies[c.name] = c.value)
        }
      }
    } catch (err) {
      console.error('Failed to load cookies.json:', err.message)
    }
  } else {
    for (const pair of cookieStr.split(';')) {
      const idx = pair.indexOf('=')
      if (idx > 0) cookies[pair.slice(0, idx).trim()] = pair.slice(idx + 1).trim()
    }
  }

  const pageRes = await request('https://gemini.google.com/app', {
    headers: {
      'user-agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.36',
      ...(Object.keys(cookies).length > 0 ? { 'cookie': buildCookieString(cookies) } : {})
    }
  })
  syncCookies(cookies, pageRes.headers['set-cookie'])

  const cfb2hMatch = pageRes.text.match(/"cfb2h":\s*"(.*?)"/)
  const buildLabel = cfb2hMatch ? cfb2hMatch[1] : 'boq_assistant-bard-web-server_20260709.09_p0'

  const atMatch = pageRes.text.match(/"SNlM0e":"([^"]+)"/)
  const sidMatch = pageRes.text.match(/"FdrFJe":"(-?\d+)"/)
  const atToken = atMatch ? atMatch[1] : null
  const fSid = sidMatch ? sidMatch[1] : null

  const batchRes = await request('https://gemini.google.com/_/BardChatUi/data/batchexecute?rpcids=maGuAc&source-path=%2F&hl=en-US&_reqid=1&rt=c', {
    method: 'POST',
    headers: {
      'content-type': 'application/x-www-form-urlencoded;charset=UTF-8',
      'cookie': buildCookieString(cookies)
    },
    body: 'f.req=[[["maGuAc","[0]",null,"generic"]]]&'
  })
  syncCookies(cookies, batchRes.headers['set-cookie'])

  const sessionId = Array.from({ length: 19 }, () => Math.floor(Math.random() * 10)).join('')

  return {
    cookies,
    buildLabel,
    sessionId,
    atToken,
    fSid,
    reqId: Math.floor(Math.random() * 90000) + 10000
  }
}

function buildStreamRequest(prompt, metadata, auth) {
  const queryParams = new URLSearchParams({ hl: 'en-US', _reqid: String(auth.reqId), rt: 'c' })
  if (auth.buildLabel) queryParams.set('bl', auth.buildLabel)
  if (auth.fSid) queryParams.set('f.sid', auth.fSid)
  else if (auth.sessionId) queryParams.set('f.sid', auth.sessionId)

  const payload = [
    [prompt, 0, null, null, null, null, 0], ['en-US'],
    metadata, null, null, null, [1], 1, null, null, 1, 0, null, null, null, null, null, [[0]], 1,
    null, null, null, null, null,
    ['', '', '', null, null, null, null, null, 0, null, 1, null, null, null, []],
    null, null, 1, null, null, null, null, null, null, null,
    [1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17, 18, 19, 20],
    1, null, null, null, null, [1]
  ]

  const bodyParams = new URLSearchParams({ 'f.req': JSON.stringify([null, JSON.stringify(payload)]) })
  if (auth.atToken) bodyParams.set('at', auth.atToken)
  const body = bodyParams.toString()

  return {
    url: `https://gemini.google.com/_/BardChatUi/data/assistant.lamda.BardFrontendService/StreamGenerate?${queryParams}`,
    headers: {
      'content-type': 'application/x-www-form-urlencoded;charset=UTF-8',
      'x-same-domain': '1',
      'origin': 'https://gemini.google.com',
      'referer': 'https://gemini.google.com/',
      'cookie': buildCookieString(auth.cookies)
    },
    body
  }
}
// ᴍᴏᴅᴇ ʙʏ : https://t.me/YatoCoding
// ------------------- [ Handler الشات النصي فقط ] -------------------

const handler = async (m, { conn, text, usedPrefix, command }) => {
  if (!text) {
    return m.reply(`💡 *طريقة الاستخدام:*\n\nاكتب سؤالك بعد الأمر مباشرة، مثال:\n\`${usedPrefix + command} اكتب لي كود بايثون بسيط\`\n\`${usedPrefix + command} من هو ياتو؟\``)
  }

  await conn.sendPresenceUpdate('composing', m.chat)

  try {
    const auth = await startSession()
    const metadata = ['', '', '', null, null, null, null, null, null, '']
    const req = buildStreamRequest(text, metadata, auth)
    
    const { res } = await request(req.url, { method: 'POST', headers: req.headers, body: req.body, stream: true })

    let rawText = ''
    let buf = ''

    res.on('data', chunk => {
      buf += chunk.toString('utf8')
      if (buf.startsWith(")]}'")) buf = buf.substring(4).trimStart()

      while (true) {
        const nl = buf.indexOf('\n')
        if (nl === -1) break
        const size = parseInt(buf.substring(0, nl).trim(), 10)
        if (isNaN(size)) { buf = buf.substring(nl + 1); continue }
        if (buf.length < nl + size) break

        const framePayload = buf.substring(nl, nl + size)
        buf = buf.substring(nl + size)

        try {
          const frameData = JSON.parse(framePayload)
          for (const item of (Array.isArray(frameData) ? frameData : [frameData])) {
            const innerStr = item?.[2]
            if (!innerStr) continue
            const pj = JSON.parse(innerStr)
            for (const cand of (pj?.[4] || [])) {
              const raw = cand?.[1]?.[0] || ''
              if (raw) rawText = raw
            }
          }
        } catch (_) {}
      }
    })

    res.on('end', async () => {
      const result = cleanText(rawText)
      if (result) {
        await m.reply(`🧠 *Gemini AI:*\n\n${result}`)
      } else {
        await m.reply('❌ لم أستطع الحصول على إجابة، حاول صياغة السؤال بشكل آخر.')
      }
    })

  } catch (error) {
    console.error('Gemini Plugin Error:', error)
    await m.reply('❌ حدث خطأ أثناء الاتصال بالذكاء الاصطناعي.')
  }
}

handler.help = ['gemini <سؤال>']
handler.tags = ['ai']
handler.command = /^(جيميناي|gemini|جيميني|ai)$/i

export default handler