from config import config from titanembeds.redisqueue import RedisQueue from titanembeds.commands import Commands from titanembeds.socketio import SocketIOInterface from titanembeds.poststats import DiscordBotsOrg, BotsDiscordPw from collections import deque from raven import Client as RavenClient import raven import discord import aiohttp import asyncio import sys import logging import json logging.basicConfig(filename='titanbot.log',level=logging.INFO,format='%(asctime)s %(message)s', datefmt='%m/%d/%Y %I:%M:%S %p') handler = logging.FileHandler(config.get("logging-location", "titanbot.log")) logging.getLogger('TitanBot') logging.getLogger('sqlalchemy') try: raven_client = RavenClient(config["sentry-dsn"]) except raven.exceptions.InvalidDsn: pass class Titan(discord.AutoShardedClient): def __init__(self): super().__init__(max_messages=20000) self.aiosession = aiohttp.ClientSession(loop=self.loop) self.http.user_agent += ' TitanEmbeds-Bot' self.redisqueue = RedisQueue(self, config["redis-uri"]) self.command = Commands(self, config) self.socketio = SocketIOInterface(self, config["redis-uri"]) self.delete_list = deque(maxlen=100) # List of msg ids to prevent duplicate delete self.discordBotsOrg = None self.botsDiscordPw = None def _cleanup(self): try: self.loop.run_until_complete(self.logout()) except: # Can be ignored pass pending = asyncio.Task.all_tasks() gathered = asyncio.gather(*pending) try: gathered.cancel() self.loop.run_until_complete(gathered) gathered.exception() except: # Can be ignored pass def run(self): try: self.loop.run_until_complete(self.start()) except discord.errors.LoginFailure: print("Invalid bot token in config!") finally: try: self._cleanup() except Exception as e: print("Error in cleanup:", e) self.loop.close() async def start(self): await self.redisqueue.connect() self.loop.create_task(self.redisqueue.subscribe()) await super().start(config["bot-token"]) async def on_ready(self): print('Titan [DiscordBot]') print('Logged in as the following user:') print(self.user.name) print(self.user.id) print('------') print("Shard count: " + str(self.shard_count)) print("------") game = discord.Game(name="Embed your Discord server! Visit https://TitanEmbeds.com/") await self.change_presence(status=discord.Status.online, activity=game) self.discordBotsOrg = DiscordBotsOrg(self.user.id, config.get("discord-bots-org-token", None)) self.botsDiscordPw = BotsDiscordPw(self.user.id, config.get("bots-discord-pw-token", None)) await self.postStats() async def on_message(self, message): await self.socketio.on_message(message) await self.redisqueue.push_message(message) msg_arr = message.content.split() # split the message if len(message.content.split()) > 1 and message.guild: #making sure there is actually stuff in the message and have arguments and check if it is sent in server (not PM) if msg_arr[0] == "<@{}>".format(self.user.id) or msg_arr[0] == "<@!{}>".format(self.user.id): #make sure it is mention msg_cmd = msg_arr[1].lower() # get command if msg_cmd == "__init__": return cmd = getattr(self.command, msg_cmd, None) #check if cmd exist, if not its none if cmd: # if cmd is not none... async with message.channel.typing(): #this looks nice await getattr(self.command, msg_cmd)(message) #actually run cmd, passing in msg obj async def on_message_edit(self, message_before, message_after): await self.redisqueue.update_message(message_after) await self.socketio.on_message_update(message_after) async def on_message_delete(self, message): self.delete_list.append(message.id) await self.redisqueue.delete_message(message) await self.socketio.on_message_delete(message) async def on_reaction_add(self, reaction, user): await self.redisqueue.update_message(reaction.message) await self.socketio.on_reaction_add(reaction.message) async def on_reaction_remove(self, reaction, user): await self.redisqueue.update_message(reaction.message) await self.socketio.on_reaction_remove(reaction.message) async def on_reaction_clear(self, message, reactions): await self.redisqueue.update_message(message) await self.socketio.on_reaction_clear(message) async def on_guild_join(self, guild): await self.redisqueue.update_guild(guild) await self.postStats() async def on_guild_remove(self, guild): await self.redisqueue.delete_guild(guild) await self.postStats() async def on_guild_update(self, guildbefore, guildafter): await self.redisqueue.update_guild(guildafter) await self.socketio.on_guild_update(guildafter) async def on_guild_role_create(self, role): if role.name == self.user.name and role.managed: await asyncio.sleep(2) await self.redisqueue.update_guild(role.guild) await self.socketio.on_guild_role_create(role) async def on_guild_role_delete(self, role): if role.guild.me not in role.guild.members: return await self.redisqueue.update_guild(role.guild) await self.socketio.on_guild_role_delete(role) async def on_guild_role_update(self, rolebefore, roleafter): await self.redisqueue.update_guild(roleafter.guild) await self.socketio.on_guild_role_update(roleafter) async def on_channel_delete(self, channel): if channel.guild: await self.redisqueue.update_guild(channel.guild) await self.socketio.on_channel_delete(channel) async def on_channel_create(self, channel): if channel.guild: await self.redisqueue.update_guild(channel.guild) await self.socketio.on_channel_create(channel) async def on_guild_channel_update(self, channelbefore, channelafter): await self.redisqueue.update_guild(channelafter.guild) await self.socketio.on_channel_update(channelafter) async def on_member_join(self, member): await self.redisqueue.add_member(member) await self.socketio.on_guild_member_add(member) async def on_member_remove(self, member): await self.redisqueue.remove_member(member) await self.socketio.on_guild_member_remove(member) async def on_member_update(self, memberbefore, memberafter): await self.redisqueue.update_member(memberafter) await self.socketio.on_guild_member_update(memberafter) async def on_member_ban(self, guild, user): if self.user.id == user.id: return await self.redisqueue.ban_member(guild, user) async def on_guild_emojis_update(self, guild, before, after): if len(after) == 0: await self.redisqueue.update_guild(guild) await self.socketio.on_guild_emojis_update(before) else: await self.redisqueue.update_guild(guild) await self.socketio.on_guild_emojis_update(after) async def on_webhooks_update(self, channel): await self.redisqueue.update_guild(channel.guild) async def on_raw_message_edit(self, payload): message_id = payload.message_id data = payload.data if not self.in_messages_cache(int(message_id)): channel = self.get_channel(int(data["channel_id"])) message = await channel.get_message(int(message_id)) await self.on_message_edit(None, message) async def on_raw_message_delete(self, payload): message_id = payload.message_id channel_id = payload.channel_id if not self.in_messages_cache(int(message_id)): await asyncio.sleep(1) await self.process_raw_message_delete(int(message_id), int(channel_id)) async def raw_bulk_message_delete(self, payload): message_ids = payload.message_ids channel_id = payload.channel_id await asyncio.sleep(1) for msgid in message_ids: msgid = int(msgid) if not self.in_messages_cache(msgid): await self.process_raw_message_delete(msgid, int(channel_id)) async def process_raw_message_delete(self, msg_id, channel_id): if msg_id in self.delete_list: self.delete_list.remove(msg_id) return channel = self.get_channel(int(channel_id)) data = {'content': "What fun is there in making sense?", 'type': 0, 'edited_timestamp': None, 'id': msg_id, 'channel_id': channel_id, 'timestamp': '2017-01-15T02:59:58+00:00'} msg = discord.Message(channel=channel, state=self._connection, data=data) # Procreate a fake message object await self.on_message_delete(msg) async def on_raw_reaction_add(self, payload): message_id = payload.message_id if not self.in_messages_cache(message_id): channel = self.get_channel(payload.channel_id) message = await channel.get_message(message_id) await self.on_reaction_add(message.reactions[0], None) async def on_raw_reaction_remove(self, payload): message_id = payload.message_id if not self.in_messages_cache(message_id): partial = payload.emoji emoji = self._connection._upgrade_partial_emoji(partial) channel = self.get_channel(payload.channel_id) message = await channel.get_message(message_id) message._add_reaction({"me": payload.user_id == self.user.id}, emoji, payload.user_id) reaction = message._remove_reaction({}, emoji, payload.user_id) await self.on_reaction_remove(reaction, None) async def on_raw_reaction_clear(self, payload): message_id = payload.message_id if not self.in_messages_cache(message_id): channel = self.get_channel(payload.channel_id) message = await channel.get_message(message_id) await self.on_reaction_clear(message, []) def in_messages_cache(self, msg_id): for msg in self._connection._messages: if msg.id == msg_id: return True return False async def postStats(self): count = len(self.guilds) shard_count = self.shard_count shard_id = self.shard_id await self.discordBotsOrg.post(count, shard_count, shard_id) await self.botsDiscordPw.post(count, shard_count, shard_id)