1 files changed, 60 insertions, 0 deletions

diff --git a/cogs/ping_commands.py b/cogs/ping_commands.py
new file mode 100644
index 0000000..beb9685
--- /dev/null
+++ b/cogs/ping_commands.py
@@ -0,0 +1,60 @@
+import discord
+from discord.ext import commands
+import asyncio
+from yt_dlp import VideosSearch
+
+class PingCommands(commands.Cog):
+    def __init__(self, bot):
+        self.bot = bot
+
+    @commands.Cog.command()
+    async def vc(self, ctx):
+        # join voice channel
+        pass
+        
+    @commands.slash_command(name="grajcuj", description="grajcuj melodyje")
+    async def play(self, ctx, *, search: str):
+        await ctx.defer()
+        if not (ctx.author.voice and ctx.author.voice.channel):
+            await ctx.followup.send("nie jesteś w kanale głosowym")
+            return
+        channel = ctx.author.voice.channel
+        if ctx.voice_client is not None:
+            vc = ctx.voice_client
+            await vc.move_to(channel)
+        else:
+            vc = await channel.connect()
+        videos_search = VideosSearch(search, limit=1)
+        result = videos_search.result()
+        if not result['result']:
+            await ctx.followup.send("nie znaleziono wideo dla twojego wyszukiwania.", ephemeral=True)
+            return
+        video = result['result'][0]
+        title = video['title']
+        url = video['link']
+
+        # Get direct audio stream URL
+        proc = await asyncio.create_subprocess_exec(
+            "yt-dlp", "-f", "bestaudio", "-g", url,
+            stdout=asyncio.subprocess.PIPE
+        )
+        stdout, _ = await proc.communicate()
+        stream_url = stdout.decode().strip()
+
+        ffmpeg_options = {
+            "before_options": "-probesize 32k -analyzeduration 0 -reconnect 1 -reconnect_streamed 1 -reconnect_delay_max 5",
+            "options": "-vn"
+        }
+        audio = discord.FFmpegPCMAudio(
+            stream_url,
+            before_options=ffmpeg_options["before_options"],
+            options=ffmpeg_options["options"]
+        )
+        if not vc.is_playing():
+            vc.play(audio)
+            await ctx.followup.send(f"gra: {title}")
+        else:
+            await ctx.followup.send(f"dodano do koleyjki: {title}")
+        
+
+