Некорректное переключение аудио. Где может крыться проблема?

Question

[Никита Обухов]

Ошибка происходит в методе next_track_callback, play_next.
При нажатии на кнопку play next происходит вызов next_track_callback.

Ожидаемый результат:
Добавить в очередь несколько композиций
Нажать кнопку переключения трека
Аудио останавливается, из очереди достается ссылка на следующий трек, корректируется отображаемый embed

Фактический результат:
После нажатия кнопки переключения трека, происходит переключение аудио и корректирование эмбеда не менее 2х раз.
Подозреваю, что проблема в работе либо voice_client.stop(), либо в параметре after метода voice_client.play(after = ...)

def play_next(self):

        self.voice_client.pause()
        self.voice_client.stop().  #проблема тут

        if self.music_queue.__len__() > 0:
            print("next comp")
            track_name, url = self.music_queue[0]['title'], self.music_queue[0]['url']
            if self.embed.fields.__len__() == 0:
                self.embed.add_field(name="Playing now", value=track_name, inline=True)
            else:
                self.embed.set_field_at(index=0, name="Playing now", value=track_name, inline=True)
            print("before = " + str(len(self.music_queue)))
            self.music_queue.pop(0)
            print("after = " + str(len(self.music_queue)))
            try:
                #after next_track_callback was called, and play_next called, track switches twice
                self.que_fetch()
                FFMPEG_OPTIONS = {'before_options': '-reconnect 1 -reconnect_streamed 1 -reconnect_delay_max 5', 'options': '-vn'}
                source = disnake.PCMVolumeTransformer(disnake.FFmpegPCMAudio(source=url, **FFMPEG_OPTIONS,executable=r"dependencies\FFMPEG\bin\ffmpeg.exe"))

                self.voice_client.play(source= source, after=lambda e: self.play_next())#или здесь
                self.is_playing = True

            except disnake.ClientException as e:
                print("player playing!:    ", e)
            except Exception as e:
                print(e)


        else:
            print("stopping!")
            self.embed.clear_fields()
            coro = self.stopall()
            asyncio.run_coroutine_threadsafe(coro=coro, loop=self.bot.loop).result()

            return

Работа кнопки

async def next_track_callback(self, interaction: disnake.Interaction):
        await interaction.response.defer()
        self.play_next()

В консоли ошибок нет

Comments

[Алексей Черемисин]

0) Вы предлагаете взять Ваш код и его запустить у себя на компухтере?! Серьезно?!
1) Приведите код ошибки!
2) Приведите место, где именно происходит проблема и локализуйте место ошибки.
3) Код вставляйте в теги code
4) Какие библиотеки используете? Pyaudio? Gstreamer?
5) Действительно ли вопрос настолько сложен?

[Никита Обухов]

Используемая библиотека disnake

def play_next(self):

        self.voice_client.pause()
        self.voice_client.stop() #здесь возможно ошибка

        if self.music_queue.__len__() > 0:
            print("next comp")
            track_name, url = self.music_queue[0]['title'], self.music_queue[0]['url']
            if self.embed.fields.__len__() == 0:
                self.embed.add_field(name="Playing now", value=track_name, inline=True)
            else:
                self.embed.set_field_at(index=0, name="Playing now", value=track_name, inline=True)
            print("before = " + str(len(self.music_queue)))
            self.music_queue.pop(0)
            print("after = " + str(len(self.music_queue)))
            try:
                #after next_track_callback was called, and play_next called, track switches twice
                self.que_fetch()
                FFMPEG_OPTIONS = {'before_options': '-reconnect 1 -reconnect_streamed 1 -reconnect_delay_max 5', 'options': '-vn'}
                source = disnake.PCMVolumeTransformer(disnake.FFmpegPCMAudio(source=url, **FFMPEG_OPTIONS,executable=r"dependencies\FFMPEG\bin\ffmpeg.exe"))

                self.voice_client.play(source= source, after=lambda e: self.play_next()) # и тут возможно тоже
                self.is_playing = True

            except disnake.ClientException as e:
                print("player playing!:    ", e)
            except Exception as e:
                print(e)


        else:
            print("stopping!")
            self.embed.clear_fields()
            coro = self.stopall()
            asyncio.run_coroutine_threadsafe(coro=coro, loop=self.bot.loop).result()

            return

async def next_track_callback(self, interaction: disnake.Interaction):
        await interaction.response.defer()
        self.play_next()

[Алексей Черемисин]

Никита Обухов, Стектрейс ошибки?
И вопрос свой приведите в соответствие.
Я так понимаю, это дискорд? Тоже не помешало бы добавить в вопрос.
И да, уж потрудитесь, подробнее описать Вашу ситуацию, а не вытягивать все за веревочку.

[Никита Обухов]

Алексей Черемисин, да, это дискорд.
В консоли ошибок нет, есть несоответствие между ожидаемым и реальным результатом.

Правда, иногда может прилетать ошибка ClientException: already playing audio. Но я думаю, это отношения к проблеме не имеет.

Насчёт тегов, там можно указывать только один, разве нет? (Не уверен)

Постарался указать все, что может помочь решению вопроса. Прошу прощения, если чего-то не добавил

[Алексей Черемисин]

Никита Обухов, Так поправьте же наконец текст вопроса. И да, тегов можно несколько, discord например еще.

[Никита Обухов]

Алексей Черемисин, может, стоит перейти к решению вопроса?

Каково же ваше решение?

[Влад Григорьев]

Никита Обухов, тут не фриланс, а добровольная помощь, и что б люди хотели помогать и легко понимали в чем помочь, придумали правила, которые вы согласились соблюдать при регистрации.
так что сначала надо оформить вопрос в соответствие с правилами, а потом может кто-то захочет помочь

не нравится можно идти на фриланс, нанимать репетиторов и так далее

[Модератор]

Поддерживаю Влад Григорьев.

Когда вы, Никита Обухов, регистрировались, вы обещали выполнять Регламент. Ваше сообщение нарушило сразу несколько параграфов Регламента - 3.2, 3.6, 3.8, 5.7, 5.12 и др.

Если вы будете продолжать нарушать Регламент, ваши вопросы могут быть удалены, а аккаунт заблокирован модераторами временно или навсегда.
Будьте благоразумны.

[Никита Обухов]

Прошу прощения за мои ошибки, постарался упростить вопрос, сделав его понятным, "без воды"

[fenrir]

Никита Обухов, раз у вас что-то происходит более 1 раза значит тут замешан цикл.
В коде который вы приложили циклов нет, значит его недостаточно.

Убирайте из кода except'ы и приходите с трейсбеками.

[Алексей Черемисин]

Никита Обухов, Вот, видите, обновили вопрос, сделали по правилам, и он стал кому-то интересен. Не благодарите :)

[Никита Обухов]

fenrir, ошибок в консоли нет. Все еще без малейшего понятия, в чем может быть проблема

вот обновленный код с "отладочной" информацией

async def next_track_callback(self, interaction: disnake.Interaction):
        await interaction.response.defer()
        print("NEXT AUDIO BUTTON CLICKED!")
        await self.play_next()

    async def play_next(self):


        self.voice_client.stop()

        if self.music_queue.__len__() > 0:
            print("retrieving next audio")
            track_name, url = self.music_queue[0]['title'], self.music_queue[0]['url']
            if self.embed.fields.__len__() == 0:
                self.embed.add_field(name="Playing now", value=track_name, inline=True)
            else:
                self.embed.set_field_at(index=0, name="Playing now", value=track_name, inline=True)

            self.music_queue.pop(0)
            print("after got link from queue= " + str(len(self.music_queue)))
            #try:
            self.que_fetch()
            FFMPEG_OPTIONS = {'before_options': '-reconnect 1 -reconnect_streamed 1 -reconnect_delay_max 5',
                                  'options': '-vn'}
            source = disnake.PCMVolumeTransformer(
                disnake.FFmpegPCMAudio(source=url, **FFMPEG_OPTIONS,
                                           executable=r"dependencies\FFMPEG\bin\ffmpeg.exe"))

            def play_next_callback(e):
                coro = self.play_next()

                future = asyncio.run_coroutine_threadsafe(coro, self.bot.loop)
                future.result()

            self.voice_client.play(source=source, after=play_next_callback)
            self.is_playing = True

            #except disnake.ClientException as e:
                #print("player playing!: ", e)
            #except Exception as e:
                #print(e)

        else:
            print("stopping!")
            self.embed.clear_fields()
            coro = self.stopall()
            asyncio.run_coroutine_threadsafe(coro=coro, loop=self.bot.loop).result()
            return

<br>
retrieving next audio<br>
after got link from queue= 2<br>
correcting embed<br>
correcting embed<br>
NEXT AUDIO BUTTON CLICKED!<br>
retrieving next audio<br>
after got link from queue= 2<br>
correcting embed<br>
retrieving next audio<br>
after got link from queue= 1<br>
correcting embed<br>
retrieving next audio<br>
after got link from queue= 0<br>
correcting embed<br>
stopping!<br>
<br>

Answer 1

[Umys]

Для решения этой проблемы я предлагаю обернуть вызов self.play_next() в after в функцию для предотвращения непосредственного вызова. И работать с asyncio, чтобы вызов коллбэк функции был корректным.

Попробуйте обновить вашу функцию play_next следующим образом:

async def play_next(self):
self.voice_client.pause()
self.voice_client.stop()

if self.music_queue.__len__() > 0:
print("next comp")
track_name, url = self.music_queue[0]['title'], self.music_queue[0]['url']
if self.embed.fields.__len__() == 0:
self.embed.add_field(name="Playing now", value=track_name, inline=True)
else:
self.embed.set_field_at(index=0, name="Playing now", value=track_name, inline=True)
print("before = " + str(len(self.music_queue)))
self.music_queue.pop(0)
print("after = " + str(len(self.music_queue)))
try:
self.que_fetch()
FFMPEG_OPTIONS = {'before_options': '-reconnect 1 -reconnect_streamed 1 -reconnect_delay_max 5', 'options': '-vn'}
source = disnake.PCMVolumeTransformer(disnake.FFmpegPCMAudio(source=url, **FFMPEG_OPTIONS,executable=r"dependencies\FFMPEG\bin\ffmpeg.exe"))

def play_next_callback(e):
coro = self.play_next()
future = asyncio.run_coroutine_threadsafe(coro, self.bot.loop)
future.result()

self.voice_client.play(source= source, after=play_next_callback)
self.is_playing = True

except disnake.ClientException as e:
print("player playing!: ", e)
except Exception as e:
print(e)

else:
print("stopping!")
self.embed.clear_fields()
coro = self.stopall()
asyncio.run_coroutine_threadsafe(coro=coro, loop=self.bot.loop).result()

return

Также обновите вашу функцию next_track_callback до версии с префиксом "async":

async def next_track_callback(self, interaction: disnake.Interaction):
await interaction.response.defer()
await self.play_next()

Попробуйте)

Comments

[Никита Обухов]

Благодарю за помощь. Протестирую в ближайшее время

[Никита Обухов]

Umys , это не сработало, к сожалению. Для меня неизвестно, почему

async def next_track_callback(self, interaction: disnake.Interaction):
        await interaction.response.defer()
        print("NEXT AUDIO BUTTON CLICKED!")
        await self.play_next()

    async def play_next(self):


        self.voice_client.stop()

        if self.music_queue.__len__() > 0:
            print("retrieving next audio")
            track_name, url = self.music_queue[0]['title'], self.music_queue[0]['url']
            if self.embed.fields.__len__() == 0:
                self.embed.add_field(name="Playing now", value=track_name, inline=True)
            else:
                self.embed.set_field_at(index=0, name="Playing now", value=track_name, inline=True)

            self.music_queue.pop(0)
            print("after got link from queue= " + str(len(self.music_queue)))
            #try:
            self.que_fetch()
            FFMPEG_OPTIONS = {'before_options': '-reconnect 1 -reconnect_streamed 1 -reconnect_delay_max 5',
                                  'options': '-vn'}
            source = disnake.PCMVolumeTransformer(
                disnake.FFmpegPCMAudio(source=url, **FFMPEG_OPTIONS,
                                           executable=r"dependencies\FFMPEG\bin\ffmpeg.exe"))

            def play_next_callback(e):
                coro = self.play_next()

                future = asyncio.run_coroutine_threadsafe(coro, self.bot.loop)
                future.result()

            self.voice_client.play(source=source, after=play_next_callback)
            self.is_playing = True

            #except disnake.ClientException as e:
                #print("player playing!: ", e)
            #except Exception as e:
                #print(e)

        else:
            print("stopping!")
            self.embed.clear_fields()
            coro = self.stopall()
            asyncio.run_coroutine_threadsafe(coro=coro, loop=self.bot.loop).result()
            return

<br>
retrieving next audio<br>
after got link from queue= 2<br>
correcting embed<br>
correcting embed<br>
NEXT AUDIO BUTTON CLICKED!<br>
retrieving next audio<br>
after got link from queue= 2<br>
correcting embed<br>
retrieving next audio<br>
after got link from queue= 1<br>
correcting embed<br>
retrieving next audio<br>
after got link from queue= 0<br>
correcting embed<br>
stopping!<br>
<br>