Add !leaks and !weather commands

cogs/general.py

@@ -1,4 +1,8 @@
 from discord.ext import commands
+import os
+import aiohttp
+import feedparser
+import urllib.parse
 
 class General(commands.Cog):
     def __init__(self, bot):
@@ -8,6 +12,47 @@ class General(commands.Cog):
     async def yuuka(self, ctx):
         await ctx.send('kanpeki!')
 
+    @commands.command()
+    async def leaks(self, ctx):
+        rss_url = os.getenv('TWITTER_RSS_URL')
+        if not rss_url:
+            return await ctx.reply('rss url not configured.')
+            
+        try:
+            async with aiohttp.ClientSession() as session:
+                async with session.get(rss_url) as resp:
+                    text = await resp.text()
+                    
+            feed = feedparser.parse(text)
+            if not feed.entries:
+                return await ctx.reply('no tweets found.')
+                
+            entry = feed.entries[0]
+            title = entry.get('title', '')
+            link = entry.get('link', '')
+            
+            if 'nitter.net' in link:
+                link = link.replace('nitter.net', 'twitter.com').replace('#m', '')
+                
+            await ctx.reply(f'**Latest Leak:**\n{title}\n{link}')
+        except Exception as e:
+            await ctx.reply(f'failed to fetch leaks: {e}')
+
+    @commands.command()
+    async def weather(self, ctx, *, city: str = "kayseri"):
+        try:
+            city_encoded = urllib.parse.quote(city)
+            url = f'https://wttr.in/{city_encoded}?0T'
+            async with aiohttp.ClientSession() as session:
+                async with session.get(url) as resp:
+                    if resp.status == 200:
+                        weather_data = await resp.text()
+                        await ctx.reply(f'```text\n{weather_data.strip()}\n```')
+                    else:
+                        await ctx.reply(f'could not fetch weather for {city}')
+        except Exception as e:
+            await ctx.reply(f'weather fetch failed: {e}')
+
 async def setup(bot):
     await bot.add_cog(General(bot))