Some changes

Music-Bot.py

@@ -1,9 +1,13 @@
 import asyncio
-from datetime import timedelta
+import datetime
+import re
+from pytube import YouTube
+import aiohttp
 import yt_dlp
 import discord
 import logging
 import argparse
+import os
 from discord.ext import commands
 from discord import Embed
 
@@ -13,16 +17,34 @@ banner = """
   |   |  |   | \__ \  |  (  _____|  |   |  (   |  |   
  _|  _| \__,_| ____/ _| \___|      ____/  \___/  \__| 
 """
+
 version = "0.1"
+branch = "dev"
 success = "**Success ✅**\n"
 warning = "**Warning ℹ️**\n"
 error = "**Error ❗️**\n"
+cache_dir = "cache"
 logging.basicConfig(level=logging.INFO)
 parser = argparse.ArgumentParser()
 parser.add_argument("-t", "--token", help="Bot TOKEN")
+parser.add_argument("-c", "--cores", help="Number of Cores for ffmpeg (Standard 2)")
+parser.add_argument("-p", "--prefix", help="Provides the Prefix for the bot (Standard <)")
 args = parser.parse_args()
 
-if args.token == None:
+
+if args.cores is None:
+    threads = 2
+else:
+    threads = int(args.cores)
+
+
+if args.prefix is None:
+    b_prefix = "<"
+else:
+    b_prefix = str(args.prefix)
+
+
+if args.token is None:
     print(f"{banner}\n\nPLEASE PROVIDE BOT A TOKEN BY RUNNING LIKE THE FOLLOWING:")
     print("\n")
     print(">>> python3 Music-Bot.py -t TOKEN <<<")
@@ -33,7 +55,7 @@ else:
 
     ytdl_format_options = {
         "format": "bestaudio/mp3",
-        "outtmpl": "cache/%(extractor)s-%(id)s-%(title)s.mp3",
+        "outtmpl": f"{cache_dir}/%(extractor)s-%(id)s-%(title)s.mp3",
         "restrictfilenames": True,
         "noplaylist": True,
         "nocheckcertificate": True,
@@ -76,35 +98,59 @@ else:
                 data = data["entries"][0]
 
             filename = data["url"] if stream else ytdl.prepare_filename(data)
-            return cls(discord.FFmpegPCMAudio(filename, **ffmpeg_options), data=data)
+            return cls(discord.FFmpegPCMAudio(source=filename, executable="ffmpeg", pipe=False, stderr=False,
+                                              before_options=f"-threads {threads}", options=ffmpeg_options), data=data)
+
+
+    async def youtube_search(search: str):
+        p = {"search_query": search}
+        # Spoof a user agent header or the request will immediately fail
+        h = {"User-Agent": "Mozilla/5.0"}
+        async with aiohttp.ClientSession() as client:
+            async with client.get("https://www.youtube.com/results", params=p, headers=h) as resp:
+                dom = await resp.text()
+        result = list(set(re.findall(r"watch\?v=(\S{11})", dom)))[0:5]
+        return result
 
 
     intents = discord.Intents.default()
     intents.message_content = True
 
     bot = commands.Bot(
-        command_prefix=commands.when_mentioned_or("!"),
+        command_prefix=commands.when_mentioned_or(b_prefix),
-        description="Relatively simple music bot example",
+        description="BCA Music-Bot",
-        intents=intents,
+        intents=intents, help_command=None
     )
 
 
     @bot.event
     async def on_ready():
         print(banner)
-        print(f"Bot Version: {version}")
+        print(f"Bot Version: {version} ({branch})")
         print(f"Bot: {bot.user} (ID: {bot.user.id})")
+        print(f"Threads for ffmpeg: {threads}")
+        print(f"Prefix: {b_prefix}")
         print(
-            f"Invitation LINK: https://discord.com/api/oauth2/authorize?client_id={bot.user.id}&permissions=968552344896&scope=bot%20applications.commands")
+            f"Invitation LINK: https://discord.com/api/oauth2/authorize?client_id={bot.user.id}"
+            f"&permissions=968552344896&scope=bot%20applications.commands")
         print("------")
 
 
+    @bot.command(name="shutdown")
+    @commands.is_owner()
+    async def _shutdown(ctx):
+        files = os.listdir(cache_dir)
+        async with ctx.channel.typing():
+            for file in files:
+                os.remove(f"{cache_dir}/{file}")
+            await ctx.send(f"{warning}Cleaned up {len(files)} Files...\n\n{success}Shutting down...")
+            await bot.close()
+
+
     @bot.slash_command(name="join", description="Summon the bot into your channel")
     async def join(ctx: commands.Context):
         try:
             channel = ctx.author.voice.channel
-        except Exception as err:
-            print(err)
             if channel is None:
                 await ctx.send(f"{error}You are not in a voice-channel! Could not join...")
             if ctx.voice_client is not None:
@@ -112,6 +158,8 @@ else:
 
             await ctx.respond(f"{success}Connected to `{channel.name}`")
             await channel.connect()
+        except Exception as err:
+            print(err)
 
 
     @bot.slash_command(name="nowplaying", descriprion="Show details what the bot is currently playing")
@@ -145,6 +193,10 @@ else:
                 raise commands.CommandError(err)
             finally:
                 await ctx.send(f"{success}Now playing: `{player.title}`\nRequested by {ctx.author.mention}")
+        while ctx.voice_client.is_playing():
+            await asyncio.sleep(3)
+        else:
+            await ctx.voice_client.disconnect(force=True)
 
 
     @bot.slash_command(name="stream", description="Streams a song from YouTube [Without preloading]")
@@ -154,8 +206,11 @@ else:
             ctx.voice_client.play(
                 player, after=lambda e: print(f"Player error: {e}") if e else None
             )
-
         await ctx.respond(f"{success}Now playing: `{player.title}`\nRequested by {ctx.author.mention}")
+        while ctx.voice_client.is_playing():
+            await asyncio.sleep(3)
+        else:
+            await ctx.voice_client.disconnect()
 
 
     @bot.slash_command(name="pause", description="Pauses the playback")
@@ -184,8 +239,84 @@ else:
         await ctx.voice_client.disconnect(force=True)
 
 
+    @bot.slash_command(name="youtube", description="Searches YouTube for a given string and plays the first result")
+    async def youtube(ctx, *, search: str):
+        results = await youtube_search(search=search)
+        embed = Embed(title=f"", color=discord.Color.green())
+        embed.add_field(name="", value="", inline=False)
+        counter = 1
+        for result in results:
+            url = f"https://youtube.com/watch?v={result}"
+            video = YouTube(url)
+            embed.add_field(name="", value=f"{counter} | `[{str(datetime.timedelta(seconds=video.length))}]` "
+                                           f"[{video.title}]({url}{result[counter-1]}) {video.author}", inline=False)
+            counter += 1
+        await ctx.respond(f"{success}**🎶 Search results for `{search}`**")
+        msg = await ctx.send(embed=embed)
+        await msg.add_reaction("1️⃣")
+        await msg.add_reaction("2️⃣")
+        await msg.add_reaction("3️⃣")
+        await msg.add_reaction("4️⃣")
+        await msg.add_reaction("5️⃣")
+        await msg.add_reaction("❌")
+        try:
+            reaction = await bot.wait_for(event='reaction_add', timeout=60.0)
+        except asyncio.TimeoutError:
+            await ctx.send('👎')
+        else:
+            vid_id = "https://youtube.com/watch?v="
+            if str(reaction[0]) == "1️⃣":
+                vid_id += results[0]
+            if str(reaction[0]) == "2️⃣":
+                vid_id += results[1]
+            if str(reaction[0]) == "3️⃣":
+                vid_id += results[2]
+            if str(reaction[0]) == "5️⃣":
+                vid_id += results[3]
+            if str(reaction[0]) == "5️⃣":
+                vid_id += results[4]
+            else:
+                vid_id = None
+            print(vid_id)
+            if vid_id is None:
+                pass
+            else:
+                try:
+                    player = await YTDLSource.from_url(vid_id, loop=bot.loop)
+                    ctx.voice_client.play(
+                        player, after=lambda e: print(f"Player error: {e}") if e else None
+                    )
+                except discord.HTTPException as err:
+                    raise commands.CommandError(err)
+                finally:
+                    await ctx.send(f"{success}Now playing: `{player.title}`\nRequested by {ctx.author.mention}")
+            while ctx.voice_client.is_playing():
+                await asyncio.sleep(3)
+            else:
+                await ctx.voice_client.disconnect(force=True)
+
+        """
+        async with ctx.typing():
+            await ctx.respond("🤖 Your song is queued for download... please wait ", ephemeral=True)
+            try:
+                player = await YTDLSource.from_url(url, loop=bot.loop)
+                ctx.voice_client.play(
+                    player, after=lambda e: print(f"Player error: {e}") if e else None
+                )
+            except discord.HTTPException as err:
+                raise commands.CommandError(err)
+            finally:
+                await ctx.send(f"{success}Now playing: `{player.title}`\nRequested by {ctx.author.mention}")
+        while ctx.voice_client.is_playing():
+            await asyncio.sleep(3)
+        else:
+            await ctx.voice_client.disconnect()
+        """
+
+
     @play.before_invoke
     @stream.before_invoke
+    #@youtube.before_invoke
     async def ensure_voice(ctx: commands.Context):
         if ctx.voice_client is None:
             if ctx.author.voice:
@@ -196,19 +327,22 @@ else:
             ctx.voice_client.stop()
 
 
+
+    """
     @bot.event
     async def on_application_command_error(ctx, error):
         print(f"[on_application_command_error]\n{ctx.author}\n{error}")
         if isinstance(error, discord.ext.commands.CommandError):
-            cool_down_time = int(error.cooldown.get_retry_after())
+            embed = Embed(title=f"{warning}{error}",
-            td = timedelta(seconds=cool_down_time)
-            embed = Embed(title=f"{warning}Dieser Command befindet sich im Cool Down!\n Versuche es in `{td}` nochmal!",
                           color=15158332)
         elif isinstance(error, discord.ext.commands.CommandOnCooldown):
             cool_down_time = int(error.cooldown.get_retry_after())
             td = timedelta(seconds=cool_down_time)
             embed = Embed(title=f"{warning}Dieser Command befindet sich im Cool Down!\n Versuche es in `{td}` nochmal!",
                           color=15158332)
+        elif isinstance(error, discord.ext.commands.is_owner()):
+            embed = Embed(title=f"{warning}{error}",
+                          color=15158332)
         else:
             embed = Embed(title=f"{error}", color=15158332)
         await ctx.respond(embed=embed)
@@ -219,6 +353,6 @@ else:
         print(f"[on_command_error]\n{ctx.author}\n{error}")
         embed = Embed(title=f"{error}", color=15158332)
         await ctx.send(embed=embed)
+    """
 
-
+    bot.run(token=args.token, reconnect=True)
-    bot.run(args.token)

README.md

@@ -10,7 +10,7 @@ Simple Music-Bot for Discord written in Python with <3
 ## How to start
 1. Clone the repository
 2. cd into it
-3. Run the **compiled** version: python3 Music-Bot.pyc -t TOKEN
+3. Run : python3 Music-Bot.pyc -t TOKEN
 4. Click on the invitation-Link in the terminal
 5. DONE <3