Recherche avancée
Médias (1)
-
The pirate bay depuis la Belgique
1er avril 2013, par
Mis à jour : Avril 2013
Langue : français
Type : Image
Autres articles (64)
-
Publier sur MédiaSpip
13 juin 2013Puis-je poster des contenus à partir d’une tablette Ipad ?
Oui, si votre Médiaspip installé est à la version 0.2 ou supérieure. Contacter au besoin l’administrateur de votre MédiaSpip pour le savoir -
Contribute to documentation
13 avril 2011Documentation is vital to the development of improved technical capabilities.
MediaSPIP welcomes documentation by users as well as developers - including : critique of existing features and functions articles contributed by developers, administrators, content producers and editors screenshots to illustrate the above translations of existing documentation into other languages
To contribute, register to the project users’ mailing (...) -
Selection of projects using MediaSPIP
2 mai 2011, parThe examples below are representative elements of MediaSPIP specific uses for specific projects.
MediaSPIP farm @ Infini
The non profit organizationInfini develops hospitality activities, internet access point, training, realizing innovative projects in the field of information and communication technologies and Communication, and hosting of websites. It plays a unique and prominent role in the Brest (France) area, at the national level, among the half-dozen such association. Its members (...)
Sur d’autres sites (8352)
-
ERROR "Tag [3][0][0][0] incompatible with output codec id '86016' (mp4a)" while writing headers for output mp4 file from a UDP stream
8 mai 2023, par lokit khemkaI have a running UDP stream, that I simulating using FFMPEG command :


ffmpeg -stream_loop -1 -re -i ./small_bunny_1080p_60fps.mp4 -v 0 -vcodec mpeg4 -f mpegts udp://127.0.0.1:23000


The video file is obtained from the github link : https://github.com/leandromoreira/ffmpeg-libav-tutorial


I keep getting error response, when I calling the function
avformat_write_header. The output format ismp4, output video codec isav1and output audio codec is same as input audio codec.

I tried to create a "minimal reproducible code", however, I think it is still not completely minimal, but it reproduces the exact error.


#include <libavcodec></libavcodec>avcodec.h>
#include <libavformat></libavformat>avformat.h>
#include <libavutil></libavutil>timestamp.h>
#include <libavutil></libavutil>opt.h>
#include <libswscale></libswscale>swscale.h>
#include 
#include 
#include 

#include 
#include 

typedef struct StreamingContext{
 AVFormatContext* avfc;
 const AVCodec *video_avc;
 const AVCodec *audio_avc;
 AVStream *video_avs;
 AVStream *audio_avs;
 AVCodecContext *video_avcc;
 AVCodecContext *audio_avcc;
 int video_index;
 int audio_index;
 char* filename;
 struct SwsContext *sws_ctx;
}StreamingContext;


typedef struct StreamingParams{
 char copy_video;
 char copy_audio;
 char *output_extension;
 char *muxer_opt_key;
 char *muxer_opt_value;
 char *video_codec;
 char *audio_codec;
 char *codec_priv_key;
 char *codec_priv_value;
}StreamingParams;

void logging(const char *fmt, ...)
{
 va_list args;
 fprintf(stderr, "LOG: ");
 va_start(args, fmt);
 vfprintf(stderr, fmt, args);
 va_end(args);
 fprintf(stderr, "\n");
}

int fill_stream_info(AVStream *avs, const AVCodec **avc, AVCodecContext **avcc)
{
 *avc = avcodec_find_decoder(avs->codecpar->codec_id);
 *avcc = avcodec_alloc_context3(*avc);
 if (avcodec_parameters_to_context(*avcc, avs->codecpar) < 0)
 {
 logging("Failed to fill Codec Context.");
 return -1;
 }
 avcodec_open2(*avcc, *avc, NULL);
 return 0;
}

int open_media(const char *in_filename, AVFormatContext **avfc)
{
 *avfc = avformat_alloc_context();
 if (avformat_open_input(avfc, in_filename, NULL, NULL) != 0)
 {
 logging("Failed to open input file %s", in_filename);
 return -1;
 }

 if (avformat_find_stream_info(*avfc, NULL) < 0)
 {
 logging("Failed to get Stream Info.");
 return -1;
 }
}

int prepare_decoder(StreamingContext *sc)
{
 for (int i = 0; i < (int)sc->avfc->nb_streams; i++)
 {
 if (sc->avfc->streams[i]->codecpar->codec_type == AVMEDIA_TYPE_VIDEO)
 {
 sc->video_avs = sc->avfc->streams[i];
 sc->video_index = i;

 if (fill_stream_info(sc->video_avs, &sc->video_avc, &sc->video_avcc))
 {
 return -1;
 }
 }
 else if (sc->avfc->streams[i]->codecpar->codec_type == AVMEDIA_TYPE_AUDIO)
 {
 sc->audio_avs = sc->avfc->streams[i];
 sc->audio_index = i;

 if (fill_stream_info(sc->audio_avs, &sc->audio_avc, &sc->audio_avcc))
 {
 return -1;
 }
 }
 else
 {
 logging("Skipping Streams other than Audio and Video.");
 }
 }
 return 0;
}

int prepare_video_encoder(StreamingContext *encoder_sc, AVCodecContext *decoder_ctx, AVRational input_framerate,
 StreamingParams sp, int scaled_frame_width, int scaled_frame_height)
{
 encoder_sc->video_avs = avformat_new_stream(encoder_sc->avfc, NULL);
 encoder_sc->video_avc = avcodec_find_encoder_by_name(sp.video_codec);
 if (!encoder_sc->video_avc)
 {
 logging("Cannot find the Codec.");
 return -1;
 }

 encoder_sc->video_avcc = avcodec_alloc_context3(encoder_sc->video_avc);
 if (!encoder_sc->video_avcc)
 {
 logging("Could not allocate memory for Codec Context.");
 return -1;
 }

 av_opt_set(encoder_sc->video_avcc->priv_data, "preset", "fast", 0);
 if (sp.codec_priv_key && sp.codec_priv_value)
 av_opt_set(encoder_sc->video_avcc->priv_data, sp.codec_priv_key, sp.codec_priv_value, 0);

 encoder_sc->video_avcc->height = scaled_frame_height;
 encoder_sc->video_avcc->width = scaled_frame_width;
 encoder_sc->video_avcc->sample_aspect_ratio = decoder_ctx->sample_aspect_ratio;

 if (encoder_sc->video_avc->pix_fmts)
 encoder_sc->video_avcc->pix_fmt = encoder_sc->video_avc->pix_fmts[0];
 else
 encoder_sc->video_avcc->pix_fmt = decoder_ctx->pix_fmt;

 encoder_sc->video_avcc->bit_rate = 2 * 1000 * 1000;

 encoder_sc->video_avcc->time_base = av_inv_q(input_framerate);
 encoder_sc->video_avs->time_base = encoder_sc->video_avcc->time_base;

 

 if (avcodec_open2(encoder_sc->video_avcc, encoder_sc->video_avc, NULL) < 0)
 {
 logging("Could not open the Codec.");
 return -1;
 }
 avcodec_parameters_from_context(encoder_sc->video_avs->codecpar, encoder_sc->video_avcc);
 return 0;
}


int prepare_copy(AVFormatContext *avfc, AVStream **avs, AVCodecParameters *decoder_par)
{
 *avs = avformat_new_stream(avfc, NULL);
 avcodec_parameters_copy((*avs)->codecpar, decoder_par);
 return 0;
}

int encode_video(StreamingContext *decoder, StreamingContext *encoder, AVFrame *input_frame)
{
 if (input_frame)
 input_frame->pict_type = AV_PICTURE_TYPE_NONE;

 AVPacket *output_packet = av_packet_alloc();


 int response = avcodec_send_frame(encoder->video_avcc, input_frame);

 while (response >= 0)
 {
 response = avcodec_receive_packet(encoder->video_avcc, output_packet);
 if (response == AVERROR(EAGAIN) || response == AVERROR_EOF)
 {
 break;
 }

 output_packet->stream_index = decoder->video_index;
 output_packet->duration = encoder->video_avs->time_base.den / encoder->video_avs->time_base.num / decoder->video_avs->avg_frame_rate.num * decoder->video_avs->avg_frame_rate.den;

 av_packet_rescale_ts(output_packet, decoder->video_avs->time_base, encoder->video_avs->time_base);
 response = av_interleaved_write_frame(encoder->avfc, output_packet);
 }

 av_packet_unref(output_packet);
 av_packet_free(&output_packet);

 return 0;
}

int remux(AVPacket **pkt, AVFormatContext **avfc, AVRational decoder_tb, AVRational encoder_tb)
{
 av_packet_rescale_ts(*pkt, decoder_tb, encoder_tb);
 if (av_interleaved_write_frame(*avfc, *pkt) < 0)
 {
 logging("Error while copying Stream Packet.");
 return -1;
 }
 return 0;
}

int transcode_video(StreamingContext *decoder, StreamingContext *encoder, AVPacket *input_packet, AVFrame *input_frame)
{
 int response = avcodec_send_packet(decoder->video_avcc, input_packet);
 while (response >= 0)
 {
 response = avcodec_receive_frame(decoder->video_avcc, input_frame);
 
 if (response == AVERROR(EAGAIN) || response == AVERROR_EOF)
 {
 break;
 }
 if (response >= 0)
 {
 if (encode_video(decoder, encoder, input_frame))
 return -1;
 }

 av_frame_unref(input_frame);
 }
 return 0;
}

int main(int argc, char *argv[])
{
 const int scaled_frame_width = 854;
 const int scaled_frame_height = 480;
 StreamingParams sp = {0};
 sp.copy_audio = 1;
 sp.copy_video = 0;
 sp.video_codec = "libsvtav1";
 
 StreamingContext *decoder = (StreamingContext *)calloc(1, sizeof(StreamingContext));
 decoder->filename = "udp://127.0.0.1:23000";

 StreamingContext *encoder = (StreamingContext *)calloc(1, sizeof(StreamingContext));
 encoder->filename = "small_bunny_9.mp4";
 
 if (sp.output_extension)
 {
 strcat(encoder->filename, sp.output_extension);
 }

 open_media(decoder->filename, &decoder->avfc);
 prepare_decoder(decoder);


 avformat_alloc_output_context2(&encoder->avfc, NULL, "mp4", encoder->filename);
 AVRational input_framerate = av_guess_frame_rate(decoder->avfc, decoder->video_avs, NULL);
 prepare_video_encoder(encoder, decoder->video_avcc, input_framerate, sp, scaled_frame_width, scaled_frame_height);

 prepare_copy(encoder->avfc, &encoder->audio_avs, decoder->audio_avs->codecpar);
 

 if (encoder->avfc->oformat->flags & AVFMT_GLOBALHEADER)
 encoder->avfc->flags |= AV_CODEC_FLAG_GLOBAL_HEADER;

 if (!(encoder->avfc->oformat->flags & AVFMT_NOFILE))
 {
 if (avio_open(&encoder->avfc->pb, encoder->filename, AVIO_FLAG_WRITE) < 0)
 {
 logging("could not open the output file");
 return -1;
 }
 }

 
 if (avformat_write_header(encoder->avfc, NULL) < 0)
 {
 logging("an error occurred when opening output file");
 return -1;
 }

 AVFrame *input_frame = av_frame_alloc();
 AVPacket *input_packet = av_packet_alloc();

 while (1)
 {
 int ret = av_read_frame(decoder->avfc, input_packet);
 if(ret<0)
 break;
 if (decoder->avfc->streams[input_packet->stream_index]->codecpar->codec_type == AVMEDIA_TYPE_VIDEO)
 {
 if (transcode_video(decoder, encoder, input_packet, input_frame))
 return -1;
 av_packet_unref(input_packet);

 }
 else if (decoder->avfc->streams[input_packet->stream_index]->codecpar->codec_type == AVMEDIA_TYPE_AUDIO)
 {
 
 if (remux(&input_packet, &encoder->avfc, decoder->audio_avs->time_base, encoder->audio_avs->time_base))
 return -1;
 }
 else
 {
 logging("Ignoring all nonvideo or audio packets.");
 }
 }

 if (encode_video(decoder, encoder, NULL))
 return -1;
 

 av_write_trailer(encoder->avfc);


 if (input_frame != NULL)
 {
 av_frame_free(&input_frame);
 input_frame = NULL;
 }

 if (input_packet != NULL)
 {
 av_packet_free(&input_packet);
 input_packet = NULL;
 }

 avformat_close_input(&decoder->avfc);

 avformat_free_context(decoder->avfc);
 decoder->avfc = NULL;
 avformat_free_context(encoder->avfc);
 encoder->avfc = NULL;

 avcodec_free_context(&decoder->video_avcc);
 decoder->video_avcc = NULL;
 avcodec_free_context(&decoder->audio_avcc);
 decoder->audio_avcc = NULL;

 free(decoder);
 decoder = NULL;
 free(encoder);
 encoder = NULL;

 return 0;
}


-
FFMPEG : "DLL amfrt64.dll failed to open" on Windows [closed]
22 juillet 2021, par barteckI experienced the following issue.


I'm using ffmpeg to batch resize/compress photos and videos on Windows 10. I used a version 3 and since upgraded to ver 4.4 of ffmpeg the quality of outputs dropped. I found out that I need to modify my script and explicitly define the output encoder, however when defining h264 I always got this error


DLL amfrt64.dll failed to open


cheers
Bart


-
How do i properly setup ffmpeg and fix this "Permission Denied" error im getting ?
8 décembre 2020, par ExaNoriError im getting

C:/Users/Motzumoto/Desktop/AGB/ffmpeg/bin: Permission denied

I already have ffmpeg installed to path on my windows 10 machine, but that didnt fix it, so i just tried to put ffmpeg in my bots directory, that didnt do it either.
Heres my music code if anyone can help
It uses a mixture of youtube-dl and ffmpeg
If there are also any errors that would stop this from working at all it'd be nice if you could show me them, im quite tired of this as of now and im honestly just about to scrap this idea and forget about it


I've tried linking the path to the ffmpeg.exe, that still didnt work, i got the same error, i have no idea what to do


import asyncio
import logging
import math
from urllib import request

import discord
from discord.ext import commands
import youtube_dl
from utils.guilds import Guilds
import ffmpeg
from asyncio import run_coroutine_threadsafe as coroutine

DOWNLOAD_PATH = "audio" # download path of the file
STREAM_INDICATOR_PREFIX = "${STREAM}:"




# options
ytdl_options = {
 "quiet": True,
 "forceipv4": True,
 "noplaylist": True,
 "no_warnings": True,
 "ignoreerrors": True,
 "nooverwrites": True,
 "restrictfilenames": True,
 "nocheckcertificate": True,
 "default_search": "auto",
 "format": "bestaudio/best",
}
ffmpeg_options = {
 "options": "-vn" # indicates that we have disabled video recording in the output file
}

ytdl = youtube_dl.YoutubeDL(ytdl_options) # youtube_dl object

# checks functions
def is_connected(ctx):
 """Check if the bot is connected to a voice channel."""
 
 if ctx.voice_client:
 return True
 
 return False
def is_same_channel(ctx):
 """Check if the bot and the user is in the same channel."""
 
 # try to get their voice channel id if there's any
 try:
 bot_channel_id = ctx.voice_client.channel.id
 user_channel_id = ctx.author.voice.channel.id
 # if one of them is not connected to a voice channel then they're not together
 except AttributeError:
 return False
 
 # check if their voice channel id is the same
 if bot_channel_id == user_channel_id:
 return True
 
 return False
async def checks(ctx):
 """Do some checking."""
 
 # check if the user and the bot is in the same channel
 if not is_same_channel(ctx):
 await ctx.send("I am not with you. How dare you to command me like that.")
 return False
 
 return True

# other function
async def create_source(ctx, query):
 """Creates youtube_dl audio source for discord.py voice client."""
 
 try:
 async with ctx.typing(): # shows that the bot is typing in chat while searching for an audio source
 source = await YTDLSource.from_url(query, ctx.bot.loop) # creates a youtube_dl source
 except IndexError: # if found nothing
 await ctx.send("I found nothing with the given query..")
 return None
 
 return source

class Music(commands.Cog, name="music"):
 def __init__(self, bot):
 self.bot = bot
 self.guilds = Guilds() # collection of some guilds that this bot is currently in
 
 async def cog_command_error(self, ctx, error):
 """Catch all errors of this cog."""
 
 # a check on a command has failed
 if isinstance(error, commands.CheckFailure):
 await ctx.send("I'm not connected to any voice channel.")
 # ignore this error because it is already handled at the command itself
 elif isinstance(error, commands.errors.BadArgument):
 pass
 # otherwise, log all the other errors
 else:
 music_logger.exception(error)
 await ctx.send(error)
 
 @commands.command()
 async def join(self, ctx):
 """Invite me to your voice channel."""
 
 try:
 async with ctx.typing(): # shows that the bot is typing in chat while joining the voice channel
 await ctx.author.voice.channel.connect()
 await ctx.send("Alright, I joined your voice channel.")
 # user is not yet connected to a voice channel
 except AttributeError:
 await ctx.send(f"You must be connected to a voice channel first {ctx.author.name}.")
 # bot is already connected to a voice channel
 except discord.ClientException:
 if is_same_channel(ctx):
 await ctx.send("I'm already with you.")
 else:
 await ctx.send("I'm already with somebody else.")
 
 @commands.command()
 @commands.check(is_connected)
 async def leave(self, ctx):
 """Kick me out of your voice channel."""
 
 # do some checking before executing this command
 if not await checks(ctx):
 return
 
 # reset some bot's states
 self.guilds(ctx).has_played_voice = False # reset 'has_played_voice' state
 self.guilds(ctx).queue.clear() # reset the queue
 
 # finally, stop and disconnect the bot
 ctx.voice_client.stop() # stop the bot's voice
 await ctx.voice_client.disconnect() # disconnect the bot from voice channel
 await ctx.send("Ah, alright, cya.")
 
 async def play_source(self, ctx, vc, source):
 """Play an audio to a voice channel."""
 
 def play_next(error):
 """Executes when the voice client is done playing."""
 
 # log the errors if there is any
 if error:
 music_logger.exception(error)
 coroutine(ctx.send(error), self.bot.loop)
 
 # ensure that there is a song in queue
 if self.guilds(ctx).queue.queue:
 coroutine(ctx.invoke(self.bot.get_command("next")), self.bot.loop) # go to the next song
 
 vc.play(source, after=play_next) # play the voice to the voice channel
 await ctx.send(f"Now playing '{source.title}'.")
 
 @commands.command(aliases=("p", "stream"))
 async def play(self, ctx, *, query=""):
 """Play a song for you."""
 
 # check if the query argument is empty
 if not query:
 # if yes, cancel this command
 await ctx.send("What should I play?")
 return
 
 # check if this command is invoked using 'stream' alias
 if ctx.invoked_with == "stream":
 SIP = STREAM_INDICATOR_PREFIX # put prefix to the title of the source that indicates that it must be streamed
 else:
 SIP = ""
 
 # ensure that the bot is connected a voice channel
 try:
 # connect the bot to the user voice channel
 await ctx.author.voice.channel.connect()
 except AttributeError:
 # user is not yet connected to a voice channel
 await ctx.send(f"You must be connected to a voice channel first {ctx.author.name}.")
 return
 except discord.ClientException:
 pass # just ignore if bot is already connected to the voice channel
 
 # do some other checking before executing this command
 if not await checks(ctx):
 return
 
 # create the audio source
 source = await create_source(ctx, SIP + query)
 
 # ensure that there is actually a source
 if source:
 # initialize bot's states if the the queue is still empty
 if not self.guilds(ctx).queue.queue:
 self.guilds(ctx).has_played_voice = True # this means that the bot has played in the voice at least once
 self.guilds(ctx).queue.enqueue(SIP + source.title)
 
 # play the audio
 try:
 await self.play_source(ctx, ctx.voice_client, source)
 # enqueue the source if audio is already playing
 except discord.ClientException:
 self.guilds(ctx).queue.enqueue(SIP + source.title)
 await ctx.send(f"'{source.title}' is added to the queue.")
 
 @commands.command()
 @commands.check(is_connected)
 async def volume(self, ctx, *, vol=None):
 """Adjust my voice volume."""
 
 # do some checking before executing this command
 if not await checks(ctx):
 return
 
 vc = ctx.voice_client # get the voice client
 
 # ensure that the bot is playing voice in order to change the volume
 if not self.guilds(ctx).has_played_voice:
 await ctx.send("I haven't even started yet.")
 return
 elif vc.source is None:
 await ctx.send("I am not playing anything.")
 return
 
 # check if user has passed an argument
 if vol is None:
 await ctx.send("I expect an argument from 0 to 100.")
 return
 
 # cast string argument 'vol' into a float
 try:
 vol = float(vol)
 # except if the argument is not a number
 except ValueError:
 await ctx.send("The argument must only be a number.")
 return
 
 # set the volume
 if vol >= 0 and vol <= 100: # bound the volume from 0 to 100
 vc.source.volume = vol / 100
 else:
 await ctx.send("I expect a value from 0 to 100.")
 
 @commands.command()
 @commands.check(is_connected)
 async def pause(self, ctx):
 """Pause the song."""
 
 # do some checking before executing this command
 if not await checks(ctx):
 return
 
 vc = ctx.voice_client # get the voice client
 
 # ensure that the bot's voice is playing in order to pause
 if vc.is_playing():
 vc.pause()
 await ctx.send("Alright, paused.")
 # the bot haven't played yet
 elif not self.guilds(ctx).has_played_voice:
 await ctx.send("I haven't even started yet.")
 # there is no song in queue
 elif not self.guilds(ctx).queue.queue:
 await ctx.send("I am not playing anything.")
 else:
 await ctx.send("I already paused.")
 
 @commands.command()
 @commands.check(is_connected)
 async def resume(self, ctx):
 """Resume the song."""
 
 # do some checking before executing this command
 if not await checks(ctx):
 return
 
 vc = ctx.voice_client # get the voice client
 
 # ensure that the bot's voice is paused in order to resume
 if vc.is_paused():
 vc.resume()
 await ctx.send("Alright, song resumed")
 # the bot haven't played yet
 elif not self.guilds(ctx).has_played_voice:
 await ctx.send("I haven't even started yet.")
 # there is no song in queue
 elif not self.guilds(ctx).queue.queue:
 await ctx.send("I am not playing anything.")
 else:
 await ctx.send("I am not paused.")
 
 async def update_song(self, ctx):
 """Change the currently playing song."""
 
 vc = ctx.voice_client # get the voice client
 current = self.guilds(ctx).queue.current # get the current song in queue if there's any
 
 # ensure that the queue is not empty
 if current:
 source = await create_source(ctx, current) # create the audio source
 # the bot haven't played yet
 elif not self.guilds(ctx).has_played_voice:
 await ctx.send("I haven't even started yet.")
 return
 else:
 vc.stop() # stop the voice just to be sure
 await ctx.send("No more songs unfortunately.")
 return
 
 # if voice client is already playing, just change the source
 if vc.is_playing():
 vc.source = source
 await ctx.send(f"Now playing '{source.title}'.")
 # otherwise, play the source
 else:
 await self.play_source(ctx, vc, source)
 
 @commands.command()
 @commands.check(is_connected)
 async def next(self, ctx):
 """Skip the current song."""
 
 # do some checking before executing this command
 if not await checks(ctx):
 return
 
 self.guilds(ctx).queue.shift(1) # shift the queue to the left
 await self.update_song(ctx) # change the current song
 
 @commands.command()
 @commands.check(is_connected)
 async def prev(self, ctx):
 """Go back to the previous song."""
 
 # do some checking before executing this command
 if not await checks(ctx):
 return
 
 self.guilds(ctx).queue.shift(-1) # shift the queue to the right
 await self.update_song(ctx) # change the current song
 
 @commands.command()
 @commands.check(is_connected)
 async def removesong(self, ctx, *, index=1):
 """Remove a song in the queue."""
 
 # do some checking before executing this command
 if not await checks(ctx):
 return
 
 index -= 1 # decrement the 'index' to match the zero-based index of Python
 
 # if index is equal to 0, that means remove the currently playing song
 # do some extra stuff before removing the current song
 if index == 0:
 # try to remove a song in queue
 try:
 self.guilds(ctx).queue.dequeue() # dequeue a song in the queue
 self.guilds(ctx).queue.shift(-1) # shift the queue to the right so that the next song will be played instead of the next next song
 await ctx.invoke(self.bot.get_command("next")) # finally, play the next song
 # except when the queue is empty
 except IndexError:
 await ctx.send("I haven't even started yet.")
 # otherwise, just remove a song in queue
 else:
 # try to remove the song in queue
 try:
 self.guilds(ctx).queue.pop(index)
 await ctx.send("Song removed")
 # except if the song is not in the queue
 except IndexError:
 # check if the bot has not started playing yet
 if not self.guilds(ctx).has_played_voice:
 await ctx.send("I haven't even started yet...")
 else:
 await ctx.send(f"I can't remove that {ctx.author.name} because it doesn't exist.")
 @removesong.error
 async def remove_error(self, ctx, error):
 """Error handler for the 'remove' command."""
 
 # check if the argument is bad
 if isinstance(error, commands.errors.BadArgument):
 await ctx.send(f"I can't remove that {ctx.author.name}.")
 await ctx.send("The argument must only be a number or leave it none.")
 
 @commands.command()
 @commands.check(is_connected)
 async def stop(self, ctx):
 """Stop all the songs."""
 
 # do some checking before executing this command
 if not await checks(ctx):
 return
 
 vc = ctx.voice_client # get the voice client
 
 # ensure that the bot is connected to the voice client
 if vc.is_playing() or vc.is_paused():
 self.guilds(ctx).queue.clear() # reset the queue
 ctx.voice_client.stop() # stop the bot's voice
 await ctx.send("Playback stopped")
 # the bot haven't played yet
 elif not self.guilds(ctx).has_played_voice:
 await ctx.send("I haven't even started yet.")
 else:
 await ctx.send("I already stopped.")
 
 @commands.command()
 @commands.check(is_connected)
 async def queue(self, ctx):
 """Show the queue of songs."""
 
 SIP = STREAM_INDICATOR_PREFIX # shorten the variable name
 
 # do some checking before executing this command
 if not await checks(ctx):
 return
 
 # try to send the songs in the queue
 try:
 # format the queue to make it readable
 queue = [
 f"{i}." + (" (STREAM) " if q.startswith(SIP) else " ") + q.split(SIP)[-1]
 for i, q in enumerate(self.guilds(ctx).queue.queue, 1)
 ]
 
 await ctx.send("\n".join(queue))
 # except if it is empty
 except HTTPException:
 await ctx.send("No songs in queue.")

class YTDLSource(discord.PCMVolumeTransformer):
 """Creates a youtube_dl audio source with volume control."""
 
 def __init__(self, source, *, data, volume=1):
 super().__init__(source, volume)
 self.data = data
 self.title = data.get("title")
 self.url = data.get("url")
 
 @classmethod
 async def from_url(cls, url, loop):
 """Get source by URL."""
 
 # check if the URL is must be streamed
 if url.startswith(STREAM_INDICATOR_PREFIX):
 stream = True
 else:
 stream = False
 
 # get data from the given URL
 data = await loop.run_in_executor(
 None,
 (lambda:
 ytdl.extract_info(
 url.split(STREAM_INDICATOR_PREFIX)[-1], # remove the prefix from the URL
 download=not stream
 ))
 )
 ##$$$$ fix error somtimes
 # take the first item from the entries if there's any
 if "entries" in data:
 try:
 data = data["entries"][0]
 except Exception as e:
 music_logger.exception(e)
 return None
 
 filepath = data["url"] if stream else ytdl.prepare_filename(data) # source url or download path of the file, depends on the 'stream' parameter
 return cls(discord.FFmpegPCMAudio("C:/Users/Motzumoto/Desktop/AGB/ffmpeg/bin", **ffmpeg_options), data=data) # create and return the source

def setup(bot):
 bot.add_cog(Music(bot))



Syndiquer tout le site
