Skip to content

Commit

Permalink
yta, ytv, song, video fix?
Browse files Browse the repository at this point in the history
  • Loading branch information
@sataniceypz
sataniceypz authored Sep 6, 2024
1 parent 5f97648 commit 3624797
Showing 1 changed file with 53 additions and 237 deletions.
290 changes: 53 additions & 237 deletions plugins/yt.js
View file
Original file line number Diff line number Diff line change
Expand Up @@ -2,249 +2,65 @@ const {
izumi,
mode,
isUrl,
getJson,
PREFIX,
AddMp3Meta,
getBuffer,
toAudio,
yta,
ytv,
ytsdl,
parsedUrl,
ytv,
ytsdl,
parsedUrl
} = require("../lib");
const config = require("../config");
const fetch = require("node-fetch");
const yts = require('yt-search');
const fg = require('api-dylux');
const config = require('../config');
const patterns = [
{ pattern: "song ?(.*)", desc: "YouTube downloader", type: "downloader" },
{ pattern: "video ?(.*)", desc: "YouTube downloader", type: "downloader" },
{ pattern: "yta ?(.*)", desc: "YouTube downloader", type: "downloader" },
{ pattern: "ytv ?(.*)", desc: "YouTube downloader", type: "downloader" }
];

patterns.forEach(({ pattern, desc, type }) => {
izumi(
{
pattern: "yta ?(.*)",
fromMe: mode,
desc: "Download audio from YouTube",
type: "downloader",
},
async (message, match) => {
match = match || message.reply_message.text;
if (!match) return await message.reply("Give me a YouTube link");
if (!isUrl(match)) return await message.reply("Give me a valid YouTube link");

// Extract video ID using regex
let videoId = match.match(/(?:youtu\.be\/|youtube\.com\/(?:watch\?v=|embed\/|v\/|shorts\/|user\/\S+|(?:c\/|channel\/|user\/)\S+|[^=]+v=))([^&?]+)/);
if (!videoId || !videoId[1]) return await message.reply("Could not extract video ID. Please provide a valid YouTube link.");

let cleanUrl = `https://youtu.be/${videoId[1]}`;

try {
let response = await fetch(`https://api.eypz.c0m.in/ytdl?url=${encodeURIComponent(cleanUrl)}`);
let media = await response.json();

if (!media.status) throw new Error("Download failed");

let { title, mp4, description, duration } = media.result;
await message.reply(`Downloading: ${title}\n\nDescription: _${description}_\n> Duration: ${duration}`);

let videoBuffer = await getBuffer(mp4);
let audioBuffer = await toAudio(videoBuffer, 'mp4');

return await message.sendMessage(
message.jid,
audioBuffer,
{
mimetype: "audio/mpeg",
filename: `${title}.mp3`,
quoted: message.data
},
"audio"
);
} catch (error) {
console.error("Error downloading audio:", error);
return await message.reply(`Failed to download audio: ${error.message}`);
}
}
);

izumi(
{
pattern: "ytv ?(.*)",
fromMe: mode,
desc: "Download video from YouTube",
type: "downloader",
},
async (message, match) => {
match = match || message.reply_message.text;
if (!match) return await message.reply("Give me a YouTube link");
if (!isUrl(match)) return await message.reply("Give me a valid YouTube link");

// Extract video ID using regex
let videoId = match.match(/(?:youtu\.be\/|youtube\.com\/(?:watch\?v=|embed\/|v\/|shorts\/|user\/\S+|(?:c\/|channel\/|user\/)\S+|[^=]+v=))([^&?]+)/);
if (!videoId || !videoId[1]) return await message.reply("Could not extract video ID. Please provide a valid YouTube link.");

let cleanUrl = `https://youtu.be/${videoId[1]}`;

try {
let response = await fetch(`https://api.eypz.c0m.in/ytdl?url=${encodeURIComponent(cleanUrl)}`);
let media = await response.json();

if (!media.status) throw new Error("Download failed");

let { title, mp4, description, duration } = media.result;
await message.reply(`Downloading: ${title}\n\nDescription: _${description}_\n> Duration: ${duration}`);

return await message.sendMessage(
message.jid,
mp4,
{
mimetype: "video/mp4",
filename: `${title}.mp4`,
quoted: message.data
},
"video"
);
} catch (error) {
console.error("Error downloading video:", error);
return await message.reply(`Failed to download video: ${error.message}`);
}
}
);
izumi({
pattern: 'video ?(.*)',
fromMe: mode,
desc: 'Search YouTube and return the MP4 URL.',
type: 'downloader'
}, async (message, match, client) => {
const query = match || '';
const searchUrl = `https://api.eypz.c0m.in/ytdl/search?query=${encodeURIComponent(query)}`;

try {
const searchResponse = await fetch(searchUrl);
const searchData = await searchResponse.json();

if (searchData.results.length > 0) {
const firstResult = searchData.results[0];
const firstResultLink = firstResult.url;
const ytdlUrl = `https://api.eypz.c0m.in/ytdl?url=${encodeURIComponent(firstResultLink)}`;

const ytdlResponse = await fetch(ytdlUrl);
const ytdlData = await ytdlResponse.json();

if (ytdlData?.result?.mp4) {
const title = ytdlData.result.title || 'the file';
await message.reply(`Downloading ${title}...`);
await message.sendFile(ytdlData.result.mp4);
} else {
await message.reply('No MP4 URL found.');
}
} else {
await message.reply('No search results found.');
}
} catch (error) {
await message.reply('An error occurred while processing your request.');
}
});
izumi({
pattern: 'song ?(.*)',
fromMe: mode,
desc: 'Search YouTube and return the MP4 URL.',
type: 'downloader'
}, async (message, match, client) => {
const query = match || '';
const searchUrl = `https://api.eypz.c0m.in/ytdl/search?query=${encodeURIComponent(query)}`;

try {
const searchResponse = await fetch(searchUrl);
const searchData = await searchResponse.json();

if (searchData.results.length > 0) {
const firstResult = searchData.results[0];
const firstResultLink = firstResult.url;
const ytdlUrl = `https://api.eypz.c0m.in/ytdl?url=${encodeURIComponent(firstResultLink)}`;

const ytdlResponse = await fetch(ytdlUrl);
const ytdlData = await ytdlResponse.json();

if (ytdlData?.result?.mp4) {
const title = ytdlData.result.title || 'the file';
await message.reply(`Downloading ${title}...`);
let videoBuffer = await getBuffer(ytdlData.result.mp4);

let audioBuffer = await toAudio(videoBuffer, 'ytdlData.result.mp4');

return await message.sendMessage(
message.jid,
audioBuffer,
{
mimetype: "audio/mpeg",
filename: `${title}.mp3`,
quoted: message.data
},
"audio"
);
} else {
await message.reply('No MP4 URL found.');
}
} else {
await message.reply('No search results found.');
{
pattern: pattern,
fromMe: true,
desc: desc,
type: type
},
async (message, match) => {
try {
const search = await yts(match);
const data = search.videos[0];

if (!data) return await message.reply("No results found.");

const url = data.url;

if (pattern === "song ?(.*)" || pattern === "yta ?(.*)") {
let down = await fg.yta(url);
let downloadUrl = down.dl_url;

await message.reply(`_Downloading ${data.title}_`);

await client.sendMessage(message.jid, { audio: { url: downloadUrl }, mimetype: 'audio/mp4' }, { quoted: message.data });
await client.sendMessage(
message.jid,
{ document: { url: downloadUrl }, mimetype: 'audio/mpeg', fileName: `${data.title}.mp3`, caption: `_${data.title}_`},
{ quoted: message.data }
);
} else if (pattern === "video ?(.*)" || pattern === "ytv ?(.*)") {
let videoDown = await fg.ytv(url);
let videoUrl = videoDown.dl_url;

await message.reply(`_Downloading ${data.title}_`);

await client.sendMessage(message.jid, { video: { url: videoUrl }, mimetype: 'video/mp4', fileName: `${data.title}.mp4` }, { quoted: message.data });
}
} catch (error) {
await message.reply('An error occurred while processing your request.');
}
});
izumi(
{
pattern: "yts ?(.*)",
fromMe: mode,
desc: "Search YouTube videos",
type: "downloader",
},
async (message, match, m) => {
try {
match = match || message.reply_message.text;

if (!match) {
await message.reply("Please provide a search query to find YouTube videos.\nExample: `.youtube Naruto AMV`");
return;
}

const response = await getJson(`https://api.eypz.c0m.in/ytdl/search?query=${encodeURIComponent(match)}`);

if (!response || response.length === 0) {
await message.reply("Sorry, no YouTube videos found for your search query.");
return;
} catch (e) {
console.log(e);
await message.reply(`Error: ${e.message}`);
}

// Format the response into a readable message
const formattedMessage = formatYouTubeMessage(response);

// Construct context info message
const contextInfoMessage = {
text: formattedMessage,
contextInfo: {
mentionedJid: [],
forwardingScore: 1,
isForwarded: true,
forwardedNewsletterMessageInfo: {
newsletterJid: '120363298577467093@newsletter',
newsletterName: "Iᴢᴜᴍɪ-ᴠ3",
serverMessageId: -1
}
}
};

// Send the formatted message with context info
await message.client.sendMessage(message.jid, contextInfoMessage);

} catch (error) {
console.error("Error fetching YouTube videos:", error);
await message.reply("Error fetching YouTube videos. Please try again later.");
}
}
);

function formatYouTubeMessage(apiResponse) {
const videos = apiResponse.results; // Extract the video results array
let message = "*YouTube Search Results:*\n\n";

videos.forEach((video, index) => {
message += `${index + 1}. *Title:* ${video.title}\n *Author:* ${video.author}\n *Duration:* ${video.duration}\n *Link:* ${video.url}\n\n`;
});

return message;
}
);
});

0 comments on commit 3624797

Please sign in to comment.