@commands.command()
    @commands.has_role('voice')
    async def lock(self, ctx):
        if ctx.author.voice and ctx.author.voice.channel:
            channel = ctx.author.voice.channel
            await channel.set_permissions(disnake.utils.get(ctx.guild.roles, id=970693132607979560), connect = False)
            await ctx.send('Канал закрыт')
    
    @lock.error
    async def lock_error(self, ctx, error):
        if isinstance(error, commands.MissingRole):
            await ctx.send("Вы не владеете этим каналом или же вы не создали свой канал")

    @commands.command()
    @commands.has_role('voice')
    async def unlock(self, ctx):
        if ctx.author.voice and ctx.author.voice.channel:
            channel = ctx.author.voice.channel
            await channel.set_permissions(disnake.utils.get(ctx.guild.roles, id=970693132607979560), connect = True)
            await ctx.send('Канал открыт')

    @unlock.error
    async def unlock_error(self, ctx, error):
        if isinstance(error, commands.MissingRole):
            await ctx.send("Вы не владеете этим каналом или же вы не создали свой канал")

    @commands.Cog.listener()
    async def on_message(self, message):
        if not message.author.bot:
            if not message.content.startswith('*'):
                base = sqlite3.connect('cogs/Warn.db')
                cur = base.cursor()
                base.execute('CREATE TABLE IF NOT EXISTS message(guildid INT, userid INT, messages INT, xp INT, lvl INT, nextlvlxp INT)')
                base.commit()

                messages = cur.execute(f'SELECT userid FROM message WHERE guildid == ? and userid == ?', [message.guild.id, message.author.id]).fetchone()

                if messages == None:
                    a = random.randint(1, 5)
                    cur.execute(f"INSERT INTO message VALUES ({message.guild.id}, {message.author.id}, 1, {a}, 1, 50)")
                    base.commit()
                else:
                    if len(message.content) >=  1:
                        cur.execute(f"UPDATE message SET messages = messages + 1 WHERE guildid = {message.guild.id} and userid={message.author.id}")
                        base.commit()
                        a = random.randint(1, 5)
                        cur.execute(f"UPDATE message SET xp = xp + {a} WHERE guildid = {message.guild.id} and userid={message.author.id}")
                        base.commit()
                        xp = cur.execute(f'SELECT xp FROM message WHERE guildid == ? and userid == ?', [message.guild.id, message.author.id]).fetchone()
                        next_lvl_xp = cur.execute(f'SELECT nextlvlxp FROM message WHERE guildid == ? and userid == ?', [message.guild.id, message.author.id]).fetchone()
                        if xp > next_lvl_xp:
                            cur.execute(f"UPDATE message SET lvl = lvl + 1 WHERE guildid = {message.guild.id} and userid={message.author.id}")
                            base.commit()
                            cur.execute(f"UPDATE message SET nextlvlxp = nextlvlxp + 100 WHERE guildid = {message.guild.id} and userid={message.author.id}")
                            base.commit()
                            lvl = cur.execute(f'SELECT lvl FROM message WHERE guildid == ? and userid == ?', [message.guild.id, message.author.id]).fetchone()
                            await message.channel.send(f'{message.author.mention} поздравляю вы достигли {lvl[0]} уровня')

    @commands.command()
    @commands.cooldown(1, 30, commands.BucketType.user)
    @commands.is_nsfw()
    async def search(self, ctx, *, message):
        api = PornhubApi()
        result = api.search.search(message, page = random.randint(1,2))
        for vid in result.videos:
            emb = disnake.Embed( title = f'{vid.title}', description="Ссылка для перехода на видео", url=f'{vid.url}', colour = disnake.Color.blue() )
            await ctx.send (embed=emb)
            return

    @search.error
    async def search_error(self, ctx, error):
        if isinstance ( error, commands.MissingRequiredArgument):
            gif1 = "https://images-ext-1.discordapp.net/external/fQhwLkamgTrE6eiSvEcFBv3JBZi_lH3RjPaNsBU_LFM/https/c.tenor.com/EfhPfbG0hnMAAAAC/slap-handa-seishuu.gif"
            emb = disnake.Embed(description = f'{ctx.author.mention} напишите сообщение.', colour = disnake.Color.blue() )
            emb.set_image(url=gif1)
            await ctx.send ( embed = emb)
            print(f"[Logs:error] Необходимо написать сообщение {ctx.author} | *search")

        if isinstance ( error, commands.NSFWChannelRequired):
            gif1 = "https://images-ext-1.discordapp.net/external/fQhwLkamgTrE6eiSvEcFBv3JBZi_lH3RjPaNsBU_LFM/https/c.tenor.com/EfhPfbG0hnMAAAAC/slap-handa-seishuu.gif"
            emb = disnake.Embed(description = f'{ctx.author.mention} вы не в nsfw канале.', colour = disnake.Color.blue() )
            emb.set_image(url=gif1)
            await ctx.send ( embed = emb)
            print(f"[Logs:error] Не в nsfw канале {ctx.author} | *say")

        if isinstance(error, commands.CommandOnCooldown):
            retry_after = str(datetime.timedelta(seconds=error.retry_after)).split('.')[0]
            await ctx.send(f'**Команда заработает через: {retry_after}**')