import discord from discord.ext import commands, tasks from discord import app_commands import os import json import asyncio import aiohttp from datetime import datetime, timedelta from typing import Optional, Dict, List import re from dotenv import load_dotenv load_dotenv() intents = discord.Intents.all() bot = commands.Bot(command_prefix='!', intents=intents, help_command=None) class ConfigManager: def __init__(self, filename='config.json'): self.filename = filename self.config = self.load_config() def load_config(self) -> dict: try: with open(self.filename, 'r') as f: return json.load(f) except FileNotFoundError: default_config = { 'log_channel_id': None, 'minecraft_log_channel_id': None, 'minecraft_server_ip': None, 'minecraft_server_port': 25565, 'blacklist_words': ['badword1', 'badword2', 'offensive'], 'auto_responses': {}, 'server_info': { 'rules': 'Be respectful and have fun!', 'minecraft_ip': 'Not configured yet', 'useful_links': 'No links configured' } } self.save_config(default_config) return default_config def save_config(self, config=None): if config is None: config = self.config with open(self.filename, 'w') as f: json.dump(config, f, indent=4) def get(self, key, default=None): return self.config.get(key, default) def set(self, key, value): self.config[key] = value self.save_config() class UserActivityManager: def __init__(self, filename='user_activity.json'): self.filename = filename self.data = self.load_data() def load_data(self) -> dict: try: with open(self.filename, 'r') as f: return json.load(f) except FileNotFoundError: return {} def save_data(self): with open(self.filename, 'w') as f: json.dump(self.data, f, indent=4) def get_user_data(self, user_id: str) -> dict: if user_id not in self.data: self.data[user_id] = { 'message_count': 0, 'last_active': None, 'afk': False, 'afk_reason': None, 'afk_since': None, 'total_warnings': 0 } return self.data[user_id] def increment_message_count(self, user_id: str): user_data = self.get_user_data(user_id) user_data['message_count'] += 1 user_data['last_active'] = datetime.now().isoformat() self.save_data() def set_afk(self, user_id: str, reason: str): user_data = self.get_user_data(user_id) user_data['afk'] = True user_data['afk_reason'] = reason user_data['afk_since'] = datetime.now().isoformat() self.save_data() def remove_afk(self, user_id: str): user_data = self.get_user_data(user_id) user_data['afk'] = False user_data['afk_reason'] = None user_data['afk_since'] = None self.save_data() def is_afk(self, user_id: str) -> bool: return self.get_user_data(user_id).get('afk', False) def get_afk_info(self, user_id: str) -> tuple: user_data = self.get_user_data(user_id) return user_data.get('afk_reason'), user_data.get('afk_since') def add_warning(self, user_id: str): user_data = self.get_user_data(user_id) user_data['total_warnings'] += 1 self.save_data() class MinecraftManager: def __init__(self): self.server_ip = None self.server_port = 25565 def set_server(self, ip: str, port: int = 25565): self.server_ip = ip self.server_port = port async def get_server_status(self) -> dict: if not self.server_ip: return {'online': False, 'message': 'No Minecraft server configured'} try: from mcstatus import JavaServer server = await JavaServer.async_lookup(f"{self.server_ip}:{self.server_port}") status = await server.async_status() return { 'online': True, 'players_online': status.players.online, 'players_max': status.players.max, 'version': status.version.name, 'latency': status.latency, 'description': status.description } except ImportError: try: async with aiohttp.ClientSession() as session: async with session.get(f'https://api.mcsrvstat.us/2/{self.server_ip}:{self.server_port}') as resp: if resp.status == 200: data = await resp.json() if data.get('online'): return { 'online': True, 'players_online': data.get('players', {}).get('online', 0), 'players_max': data.get('players', {}).get('max', 0), 'version': data.get('version', 'Unknown'), 'latency': 0, 'description': data.get('motd', {}).get('clean', [''])[0] if data.get('motd') else '' } else: return {'online': False, 'message': 'Server is offline'} else: return {'online': False, 'message': 'Could not check server status'} except Exception as e: return {'online': False, 'message': f'Error: {str(e)}'} except Exception as e: return {'online': False, 'message': f'Server appears to be offline or unreachable: {str(e)}'} config_manager = ConfigManager() activity_manager = UserActivityManager() minecraft_manager = MinecraftManager() async def send_log_embed(guild: discord.Guild, title: str, description: str, color: discord.Color, fields: List[tuple] = None): log_channel_id = config_manager.get('log_channel_id') if not log_channel_id: return log_channel = guild.get_channel(log_channel_id) if not log_channel: return embed = discord.Embed( title=title, description=description, color=color, timestamp=datetime.utcnow() ) if fields: for name, value, inline in fields: embed.add_field(name=name, value=value, inline=inline) try: await log_channel.send(embed=embed) except Exception as e: print(f"Failed to send log: {e}") @bot.event async def on_ready(): print(f'Bot is ready! Logged in as {bot.user}') print(f'Bot ID: {bot.user.id}') print(f'Connected to {len(bot.guilds)} server(s)') mc_ip = config_manager.get('minecraft_server_ip') mc_port = config_manager.get('minecraft_server_port', 25565) if mc_ip: minecraft_manager.set_server(mc_ip, mc_port) try: synced = await bot.tree.sync() print(f"Synced {len(synced)} slash commands") except Exception as e: print(f"Failed to sync commands: {e}") await bot.change_presence(activity=discord.Activity(type=discord.ActivityType.watching, name="the server | /help")) @bot.event async def on_member_join(member: discord.Member): await send_log_embed( member.guild, "👋 Member Joined", f"{member.mention} joined the server", discord.Color.green(), [ ("User", f"{member.name}#{member.discriminator}", True), ("ID", str(member.id), True), ("Account Created", member.created_at.strftime("%Y-%m-%d %H:%M:%S"), False) ] ) @bot.event async def on_member_remove(member: discord.Member): await send_log_embed( member.guild, "👋 Member Left", f"{member.name}#{member.discriminator} left the server", discord.Color.red(), [ ("User", f"{member.name}#{member.discriminator}", True), ("ID", str(member.id), True), ("Joined At", member.joined_at.strftime("%Y-%m-%d %H:%M:%S") if member.joined_at else "Unknown", False) ] ) @bot.event async def on_message_delete(message: discord.Message): if message.author.bot: return await send_log_embed( message.guild, "🗑️ Message Deleted", f"Message by {message.author.mention} deleted in {message.channel.mention}", discord.Color.orange(), [ ("Author", f"{message.author.name}#{message.author.discriminator}", True), ("Channel", message.channel.name, True), ("Content", message.content[:1024] if message.content else "*No text content*", False) ] ) @bot.event async def on_message_edit(before: discord.Message, after: discord.Message): if before.author.bot or before.content == after.content: return await send_log_embed( before.guild, "✏️ Message Edited", f"Message by {before.author.mention} edited in {before.channel.mention}", discord.Color.blue(), [ ("Author", f"{before.author.name}#{before.author.discriminator}", True), ("Channel", before.channel.name, True), ("Before", before.content[:512] if before.content else "*No text*", False), ("After", after.content[:512] if after.content else "*No text*", False), ("Jump to Message", f"[Click here]({after.jump_url})", False) ] ) @bot.event async def on_member_update(before: discord.Member, after: discord.Member): if before.roles != after.roles: added_roles = [role for role in after.roles if role not in before.roles] removed_roles = [role for role in before.roles if role not in after.roles] if added_roles: await send_log_embed( after.guild, "📝 Role Added", f"{after.mention} received role(s)", discord.Color.green(), [ ("Member", f"{after.name}#{after.discriminator}", True), ("Roles Added", ", ".join([role.mention for role in added_roles]), False) ] ) if removed_roles: await send_log_embed( after.guild, "📝 Role Removed", f"{after.mention} lost role(s)", discord.Color.red(), [ ("Member", f"{after.name}#{after.discriminator}", True), ("Roles Removed", ", ".join([role.name for role in removed_roles]), False) ] ) if before.nick != after.nick: await send_log_embed( after.guild, "✏️ Nickname Changed", f"{after.mention}'s nickname was changed", discord.Color.blue(), [ ("Member", f"{after.name}#{after.discriminator}", True), ("Before", before.nick if before.nick else "*No nickname*", True), ("After", after.nick if after.nick else "*No nickname*", True) ] ) @bot.event async def on_member_ban(guild: discord.Guild, user: discord.User): await send_log_embed( guild, "🔨 Member Banned", f"{user.mention} was banned from the server", discord.Color.dark_red(), [ ("User", f"{user.name}#{user.discriminator}", True), ("ID", str(user.id), True) ] ) @bot.event async def on_member_unban(guild: discord.Guild, user: discord.User): await send_log_embed( guild, "✅ Member Unbanned", f"{user.mention} was unbanned from the server", discord.Color.green(), [ ("User", f"{user.name}#{user.discriminator}", True), ("ID", str(user.id), True) ] ) @bot.event async def on_message(message: discord.Message): if message.author.bot or not message.guild: await bot.process_commands(message) return user_id = str(message.author.id) if activity_manager.is_afk(user_id): activity_manager.remove_afk(user_id) try: await message.channel.send(f"Welcome back {message.author.mention}! Your AFK status has been removed.", delete_after=5) except: pass activity_manager.increment_message_count(user_id) for mentioned_user in message.mentions: mentioned_id = str(mentioned_user.id) if activity_manager.is_afk(mentioned_id) and mentioned_user.id != message.author.id: afk_reason, afk_since = activity_manager.get_afk_info(mentioned_id) afk_time = datetime.fromisoformat(afk_since) duration = datetime.now() - afk_time hours = int(duration.total_seconds() // 3600) minutes = int((duration.total_seconds() % 3600) // 60) time_str = "" if hours > 0: time_str = f"{hours}h {minutes}m ago" else: time_str = f"{minutes}m ago" embed = discord.Embed( title="💤 User is AFK", description=f"{mentioned_user.mention} is currently AFK", color=discord.Color.blue() ) embed.add_field(name="Reason", value=afk_reason, inline=False) embed.add_field(name="Since", value=time_str, inline=False) try: await message.channel.send(embed=embed, delete_after=10) except: pass blacklist_words = config_manager.get('blacklist_words', []) message_lower = message.content.lower() for word in blacklist_words: if re.search(r'\b' + re.escape(word.lower()) + r'\b', message_lower): try: await message.delete() activity_manager.add_warning(user_id) user_data = activity_manager.get_user_data(user_id) warning_count = user_data['total_warnings'] warning_embed = discord.Embed( title="⚠️ Warning", description=f"{message.author.mention}, your message contained inappropriate language and was removed.", color=discord.Color.red() ) warning_embed.add_field(name="Total Warnings", value=str(warning_count), inline=False) warning_embed.set_footer(text="Please follow server rules") await message.channel.send(embed=warning_embed, delete_after=10) await send_log_embed( message.guild, "🚨 Abusive Language Detected", f"{message.author.mention} sent a message with blacklisted content", discord.Color.dark_red(), [ ("User", f"{message.author.name}#{message.author.discriminator}", True), ("Channel", message.channel.mention, True), ("Message Content", message.content[:500], False), ("Action Taken", "Message deleted and user warned", False), ("Total Warnings", str(warning_count), False) ] ) return except Exception as e: print(f"Error handling blacklist: {e}") auto_responses = config_manager.get('auto_responses', {}) for keyword, response in auto_responses.items(): if keyword.lower() in message_lower: try: await message.channel.send(response) break except: pass await bot.process_commands(message) @bot.tree.command(name="help", description="Display all bot commands and their usage") async def slash_help(interaction: discord.Interaction): embed = discord.Embed( title="🤖 Bot Commands Help", description="Here are all available commands:", color=discord.Color.blue() ) embed.add_field( name="📱 Slash Commands (/)", value="`/help` - Show this help message\n" "`/stats [user]` - View user statistics and activity\n" "`/afk [reason]` - Set your AFK status\n" "`/mcstatus` - Check Minecraft server status\n" "`/serverinfo` - View server information\n" "`/ping` - Check bot response time", inline=False ) embed.add_field( name="⚙️ Admin Configuration (!)", value="`!setlogchannel` - Set the logging channel\n" "`!setmclogchannel` - Set Minecraft logs channel\n" "`!setmcserver [port]` - Set Minecraft server\n" "`!addblacklist ` - Add word to blacklist\n" "`!removeblacklist ` - Remove from blacklist\n" "`!addresponse |` - Add auto-response\n" "`!removeresponse ` - Remove auto-response\n" "`!setserverinfo ` - Set server info", inline=False ) embed.add_field( name="🛡️ Moderation (!)", value="`!kick <@user> [reason]` - Kick a member\n" "`!ban <@user> [reason]` - Ban a member\n" "`!unban ` - Unban a member\n" "`!clear ` - Delete messages (max 100)", inline=False ) embed.set_footer(text="Use /help or !help to see this message") await interaction.response.send_message(embed=embed) @bot.command(name='help') async def prefix_help(ctx): embed = discord.Embed( title="🤖 Bot Commands Help", description="Here are all available commands:", color=discord.Color.blue() ) embed.add_field( name="📱 Slash Commands (/)", value="`/help` - Show this help message\n" "`/stats [user]` - View user statistics and activity\n" "`/afk [reason]` - Set your AFK status\n" "`/mcstatus` - Check Minecraft server status\n" "`/serverinfo` - View server information\n" "`/ping` - Check bot response time", inline=False ) embed.add_field( name="⚙️ Admin Configuration (!)", value="`!setlogchannel` - Set the logging channel\n" "`!setmclogchannel` - Set Minecraft logs channel\n" "`!setmcserver [port]` - Set Minecraft server\n" "`!addblacklist ` - Add word to blacklist\n" "`!removeblacklist ` - Remove from blacklist\n" "`!addresponse |` - Add auto-response\n" "`!removeresponse ` - Remove auto-response\n" "`!setserverinfo ` - Set server info", inline=False ) embed.add_field( name="🛡️ Moderation (!)", value="`!kick <@user> [reason]` - Kick a member\n" "`!ban <@user> [reason]` - Ban a member\n" "`!unban ` - Unban a member\n" "`!clear ` - Delete messages (max 100)", inline=False ) embed.set_footer(text="Use /help or !help to see this message") await ctx.send(embed=embed) @bot.tree.command(name="ping", description="Check bot response time") async def slash_ping(interaction: discord.Interaction): latency = round(bot.latency * 1000) embed = discord.Embed( title="🏓 Pong!", description=f"Bot latency: **{latency}ms**", color=discord.Color.green() ) await interaction.response.send_message(embed=embed) @bot.tree.command(name="stats", description="View user statistics and activity") async def slash_stats(interaction: discord.Interaction, user: Optional[discord.Member] = None): if user is None: user = interaction.user user_data = activity_manager.get_user_data(str(user.id)) embed = discord.Embed( title=f"📊 Statistics for {user.display_name}", color=discord.Color.blue() ) embed.set_thumbnail(url=user.display_avatar.url) embed.add_field(name="Message Count", value=str(user_data['message_count']), inline=True) embed.add_field(name="Total Warnings", value=str(user_data['total_warnings']), inline=True) if user_data['last_active']: last_active = datetime.fromisoformat(user_data['last_active']) embed.add_field(name="Last Active", value=last_active.strftime("%Y-%m-%d %H:%M:%S"), inline=False) if user_data['afk']: embed.add_field(name="AFK Status", value=f"✅ AFK: {user_data['afk_reason']}", inline=False) embed.add_field(name="Joined Server", value=user.joined_at.strftime("%Y-%m-%d %H:%M:%S") if user.joined_at else "Unknown", inline=False) await interaction.response.send_message(embed=embed) @bot.tree.command(name="afk", description="Set your AFK status with an optional reason") async def slash_afk(interaction: discord.Interaction, reason: str = "AFK"): activity_manager.set_afk(str(interaction.user.id), reason) embed = discord.Embed( title="💤 AFK Status Set", description=f"{interaction.user.mention} is now AFK", color=discord.Color.blue() ) embed.add_field(name="Reason", value=reason, inline=False) await interaction.response.send_message(embed=embed) @bot.tree.command(name="mcstatus", description="Check Minecraft server status") async def slash_mcstatus(interaction: discord.Interaction): await interaction.response.defer() status = await minecraft_manager.get_server_status() if status.get('online'): embed = discord.Embed( title="🟢 Minecraft Server Status", description="Server is **ONLINE**", color=discord.Color.green() ) embed.add_field(name="Players", value=f"{status['players_online']}/{status['players_max']}", inline=True) embed.add_field(name="Version", value=status['version'], inline=True) if status.get('latency'): embed.add_field(name="Latency", value=f"{status['latency']:.0f}ms", inline=True) if status.get('description'): embed.add_field(name="MOTD", value=status['description'][:256], inline=False) mc_ip = config_manager.get('minecraft_server_ip') mc_port = config_manager.get('minecraft_server_port', 25565) embed.add_field(name="Server Address", value=f"`{mc_ip}:{mc_port}`", inline=False) else: embed = discord.Embed( title="🔴 Minecraft Server Status", description="Server is **OFFLINE** or unreachable", color=discord.Color.red() ) embed.add_field(name="Message", value=status.get('message', 'Unknown error'), inline=False) embed.timestamp = datetime.utcnow() await interaction.followup.send(embed=embed) @bot.tree.command(name="serverinfo", description="View server information") async def slash_serverinfo(interaction: discord.Interaction): server_info = config_manager.get('server_info', {}) embed = discord.Embed( title="ℹ️ Server Information", color=discord.Color.blue() ) for key, value in server_info.items(): embed.add_field(name=key.replace('_', ' ').title(), value=value, inline=False) embed.set_footer(text=f"Requested by {interaction.user.display_name}") await interaction.response.send_message(embed=embed) @bot.command(name='setlogchannel') @commands.has_permissions(administrator=True) async def set_log_channel(ctx): config_manager.set('log_channel_id', ctx.channel.id) embed = discord.Embed( title="✅ Log Channel Set", description=f"Logging channel has been set to {ctx.channel.mention}", color=discord.Color.green() ) await ctx.send(embed=embed) @bot.command(name='setmclogchannel') @commands.has_permissions(administrator=True) async def set_mc_log_channel(ctx): config_manager.set('minecraft_log_channel_id', ctx.channel.id) embed = discord.Embed( title="✅ Minecraft Log Channel Set", description=f"Minecraft logs will be sent to {ctx.channel.mention}", color=discord.Color.green() ) await ctx.send(embed=embed) @bot.command(name='setmcserver') @commands.has_permissions(administrator=True) async def set_mc_server(ctx, ip: str, port: int = 25565): config_manager.set('minecraft_server_ip', ip) config_manager.set('minecraft_server_port', port) minecraft_manager.set_server(ip, port) server_info = config_manager.get('server_info', {}) server_info['minecraft_ip'] = f"{ip}:{port}" config_manager.set('server_info', server_info) embed = discord.Embed( title="✅ Minecraft Server Configured", description=f"Minecraft server set to `{ip}:{port}`", color=discord.Color.green() ) await ctx.send(embed=embed) @bot.command(name='addblacklist') @commands.has_permissions(administrator=True) async def add_blacklist(ctx, *, word: str): blacklist = config_manager.get('blacklist_words', []) if word.lower() not in [w.lower() for w in blacklist]: blacklist.append(word.lower()) config_manager.set('blacklist_words', blacklist) await ctx.send(f"✅ Added `{word}` to blacklist") else: await ctx.send(f"⚠️ `{word}` is already in blacklist") @bot.command(name='removeblacklist') @commands.has_permissions(administrator=True) async def remove_blacklist(ctx, *, word: str): blacklist = config_manager.get('blacklist_words', []) blacklist = [w for w in blacklist if w.lower() != word.lower()] config_manager.set('blacklist_words', blacklist) await ctx.send(f"✅ Removed `{word}` from blacklist") @bot.command(name='addresponse') @commands.has_permissions(administrator=True) async def add_response(ctx, *, content: str): if '|' not in content: await ctx.send("❌ Format: `!addresponse keyword|response`") return keyword, response = content.split('|', 1) keyword = keyword.strip() response = response.strip() auto_responses = config_manager.get('auto_responses', {}) auto_responses[keyword] = response config_manager.set('auto_responses', auto_responses) await ctx.send(f"✅ Auto-response added for keyword: `{keyword}`") @bot.command(name='removeresponse') @commands.has_permissions(administrator=True) async def remove_response(ctx, *, keyword: str): auto_responses = config_manager.get('auto_responses', {}) if keyword in auto_responses: del auto_responses[keyword] config_manager.set('auto_responses', auto_responses) await ctx.send(f"✅ Removed auto-response for: `{keyword}`") else: await ctx.send(f"❌ No auto-response found for: `{keyword}`") @bot.command(name='setserverinfo') @commands.has_permissions(administrator=True) async def set_server_info(ctx, key: str, *, value: str): server_info = config_manager.get('server_info', {}) server_info[key] = value config_manager.set('server_info', server_info) await ctx.send(f"✅ Server info updated: `{key}` = `{value}`") @bot.command(name='kick') @commands.has_permissions(kick_members=True) async def kick_member(ctx, member: discord.Member, *, reason: str = "No reason provided"): if member.top_role >= ctx.author.top_role: await ctx.send("❌ You cannot kick this member") return try: await member.kick(reason=reason) embed = discord.Embed( title="👢 Member Kicked", description=f"{member.mention} has been kicked", color=discord.Color.orange() ) embed.add_field(name="Reason", value=reason, inline=False) embed.add_field(name="Kicked by", value=ctx.author.mention, inline=False) await ctx.send(embed=embed) await send_log_embed( ctx.guild, "👢 Member Kicked", f"{member.mention} was kicked by {ctx.author.mention}", discord.Color.orange(), [ ("Member", f"{member.name}#{member.discriminator}", True), ("Kicked by", f"{ctx.author.name}#{ctx.author.discriminator}", True), ("Reason", reason, False) ] ) except Exception as e: await ctx.send(f"❌ Failed to kick member: {e}") @bot.command(name='ban') @commands.has_permissions(ban_members=True) async def ban_member(ctx, member: discord.Member, *, reason: str = "No reason provided"): if member.top_role >= ctx.author.top_role: await ctx.send("❌ You cannot ban this member") return try: await member.ban(reason=reason) embed = discord.Embed( title="🔨 Member Banned", description=f"{member.mention} has been banned", color=discord.Color.red() ) embed.add_field(name="Reason", value=reason, inline=False) embed.add_field(name="Banned by", value=ctx.author.mention, inline=False) await ctx.send(embed=embed) await send_log_embed( ctx.guild, "🔨 Member Banned", f"{member.mention} was banned by {ctx.author.mention}", discord.Color.red(), [ ("Member", f"{member.name}#{member.discriminator}", True), ("Banned by", f"{ctx.author.name}#{ctx.author.discriminator}", True), ("Reason", reason, False) ] ) except Exception as e: await ctx.send(f"❌ Failed to ban member: {e}") @bot.command(name='unban') @commands.has_permissions(ban_members=True) async def unban_member(ctx, user_id: int): try: user = await bot.fetch_user(user_id) await ctx.guild.unban(user) embed = discord.Embed( title="✅ Member Unbanned", description=f"{user.mention} has been unbanned", color=discord.Color.green() ) embed.add_field(name="Unbanned by", value=ctx.author.mention, inline=False) await ctx.send(embed=embed) except Exception as e: await ctx.send(f"❌ Failed to unban user: {e}") @bot.command(name='clear') @commands.has_permissions(manage_messages=True) async def clear_messages(ctx, amount: int = 10): if amount > 100: await ctx.send("❌ Cannot delete more than 100 messages at once") return try: deleted = await ctx.channel.purge(limit=amount + 1) msg = await ctx.send(f"✅ Deleted {len(deleted) - 1} messages") await asyncio.sleep(3) await msg.delete() await send_log_embed( ctx.guild, "🗑️ Bulk Message Delete", f"{len(deleted) - 1} messages deleted in {ctx.channel.mention}", discord.Color.orange(), [ ("Channel", ctx.channel.name, True), ("Deleted by", f"{ctx.author.name}#{ctx.author.discriminator}", True), ("Amount", str(len(deleted) - 1), False) ] ) except Exception as e: await ctx.send(f"❌ Failed to delete messages: {e}") @bot.event async def on_command_error(ctx, error): if isinstance(error, commands.MissingPermissions): await ctx.send("❌ You don't have permission to use this command") elif isinstance(error, commands.MissingRequiredArgument): await ctx.send(f"❌ Missing required argument: {error.param.name}") elif isinstance(error, commands.BadArgument): await ctx.send(f"❌ Invalid argument provided") elif isinstance(error, commands.CommandNotFound): pass else: print(f"Command error: {error}") await ctx.send("❌ An error occurred while executing the command") if __name__ == '__main__': token = os.getenv('DISCORD_TOKEN') if not token or token == 'your_discord_bot_token_here': print("ERROR: Please set DISCORD_TOKEN in .env file") exit(1) print("Starting bot...") bot.run(token)