def setup(self):
self.redis = await aioredis.create_redis((config.REDIS_HOST, config.REDIS_PORT,), encoding='utf8')
self.__processed_status = await self.get_processed_ids()
self.client = aiohttp.ClientSession()
extension_manager = extension.ExtensionManager(namespace='ofensivaria.bot.commands',
invoke_on_load=True,
invoke_args=(self, self.redis, self.client))
commands = extension_manager.map(self.__extension_manager_callback)
self.commands = [obj for name, obj in sorted(commands)]
prepare_tasks = [c.prepare() for c in self.commands]
await asyncio.gather(*prepare_tasks)
self.__setup = True
评论列表
文章目录