Recherche avancée

Sur d’autres sites (4986)

• Discord.js music bot : TypeError : this.inputMedia.pipe is not a function

  7 août 2019, par Ivs

  I’m writing a music Discord bot using Discord.js. The bot uses ytdl-core, node-opus, and I have installed ffmpeg on my OS (Ubuntu 19.04). When I try to make the bot join a voice channel and start playing a YouTube URL, it throws the following error :

  TypeError: this.inputMedia.pipe is not a function
  
      at FfmpegProcess.connectStream (/home/ivan/.../node_modules/discord.js/node_modules/prism-media/src/transcoders/ffmpeg/FfmpegProcess.js:73:21)
  
      at new FfmpegProcess (/home/ivan/.../node_modules/discord.js/node_modules/prism-media/src/transcoders/ffmpeg/FfmpegProcess.js:28:14)
  
      at FfmpegTranscoder.transcode (/home/ivan/.../node_modules/discord.js/node_modules/prism-media/src/transcoders/ffmpeg/Ffmpeg.js:34:18)
  
      at MediaTranscoder.transcode (/home/ivan/.../node_modules/discord.js/node_modules/prism-media/src/transcoders/MediaTranscoder.js:27:31)
  
      at Prism.transcode (/home/ivan/.../node_modules/discord.js/node_modules/prism-media/src/Prism.js:13:28)
  
      at AudioPlayer.playUnknownStream (/home/ivan/.../node_modules/discord.js/src/client/voice/player/AudioPlayer.js:97:35)
  
      at VoiceConnection.playStream (/home/ivan/.../node_modules/discord.js/src/client/voice/VoiceConnection.js:478:24)
  
      at voiceChannel.join.then.connection (/home/ivan/.../commands/play.js:32:47)
  
      at process._tickCallback (internal/process/next_tick.js:68:7)

  Here is my code :

  const ytdl = require("ytdl-core");
  
  
  
  exports.run = (client, message, args, config) => {
  
      return new Promise((resolve, reject) => {
  
          if (args.length !== 1) {
  
              message.channel.send("Play command takes 1 YouTube link.");
  
              reject("Wrong number of arguments");
  
              return;
  
          }
  
          const voiceChannel = message.member.voiceChannel;
  
          if(!voiceChannel) {
  
              message.channel.send("You need to connect to a voice channel first");
  
              reject("Not connected to voice channel");
  
              return;
  
          }
  
          const perms = voiceChannel.permissionsFor(message.client.user);
  
          if (!perms.has("CONNECT")) {
  
              message.channel.send("You need to add the 'connect' permission for this bot");
  
              reject("NO CONNECT PERMISSION");
  
              return;
  
          }
  
          if (!perms.has("SPEAK")) {
  
              message.channel.send("You need to add the 'speak' permission for this bot");
  
              reject("NO SPEAK PERMISSION");
  
              return;
  
          }
  
          const streamOptions = { seek: 0, volume: 1, passes: 2 };
  
          voiceChannel.join()
  
              .then(connection => {
  
                  const stream = ytdl(args[0], {filter: 'audioonly'});
  
                  const dispatcher = connection.playStream(ytdl, streamOptions);
  
                  dispatcher.on("end", reason => {
  
                      console.log("reason: " + reason);
  
                      voiceChannel.leave();
  
                  })
  
                  dispatcher.on("error", err => {
  
                      console.log(err);
  
                  })
  
              })
  
          .catch(err => console.log(err));
  
      });    
  
  }

  I have tried reinstalling ffmpeg, node and npm, discord.js and node-opus. I have the newest version of Discord.js installed, and ffmpeg version 4.1.3-0ubuntu1. Anyone have any suggestions ?

  Thanks.

• ffmpeg Windows stream to Twitch with video from pipe only sends 100 frames and get stuck

  27 mai 2019, par K0IN

  I try to stream rawVideo (a numpy array) to Twitch using Python with ffmpeg on Windows. But after 100 frames i just get stuck.

  My SubProcess Parameter :

  command = [
  
      "ffmpeg.exe",
  
          '-f', 'rawvideo',
  
          '-vcodec','rawvideo',
  
          '-s', '480x640', 
  
          '-pix_fmt', 'rgb24',
  
          '-r', '30',
  
          '-i', '-', 
  
          '-vcodec', 'libx264',
  
          '-b:v' , '5M',
  
          '-acodec', 'aac',
  
          '-b:a', '256k',
  
          '-r','30',
  
          '-f', 'flv', 'rtmp://live-fra.twitch.tv/app/%removed for stackoverflow%'
  
  ]
  
  [...]
  
  pipe = subprocess.Popen( command, stdin=subprocess.PIPE, stderr=subprocess.PIPE, stdout=subprocess.PIPE)

  Sending Frames :

  frames = 0
  
  frame = np.zeros((480, 640, 3))
  
  #print(pipe,dir(pipe))
  
  while 1:
  
      try:
  
          pipe.stdin.write(frame.tobytes())   # < gets stuck here after ~100 frames     
  
          frames += 1
  
          print("frame_send", frames)       
  
      except Exception as e:
  
           out, ffmpeg_error = pipe.communicate()
  
           print("error:" , ffmpeg_error  , e , out )
  
           break
  
      time.sleep( 1 / 30 )

  There were no errors it just stuck on "pipe.stdin.write(frame.tobytes())"

• NodeJS - How to pipe same video stream to multiple clients ?

  6 mai 2019, par SergioBR

  We have a situation trying to serve a video stream.

  Since HTML5 video tag does not support udp to multicast, we are trying to re-use an already converted ffmpeg stream and send it to more than one response. But that does not work.

  The first response gets the stream alright, but the second one does not.
  It seems that the stream cannot be piped out to another response, neither can it be cloned.

  Has anyone done that before ? Any ideas ?

  Thanks in advance !

  Here’s the code :

  var request = require('request');
  
  var http = require('http');
  
  var child_process = require("child_process");
  
  var n = 1;
  
  var stdouts = {};
  
  
  
  http.createServer(function (req, resp) {
  
  
  
  console.log("***** url ["+req.url+"], call "+n);
  
  
  
  if (req.url != "/favicon.ico" && req.url != "/")
  
  {
  
  var params = req.url.substring(1).split("/");
  
  
  
  switch (params[0])
  
  {
  
    case "VIEW":
  
      if (params[1] == "C2FLOOR1" || params[1] == "C2FLOOR2" || params[1] == "C2PORFUN" || params[1] == "C2TESTCAM")
  
        var camera = "rtsp://192.168.16.19:554/Inter/Cameras/Stream?Camera="+params[1];
  
      else
  
        var camera = "http://192.168.16.19:8609/Inter/Cameras/GetStream?Camera="+params[1];
  
  
  
      // Write header
  
      resp.writeHead(200, {'Content-Type': 'video/ogg', 'Connection': 'keep-alive'});
  
  
  
      if (stdouts.hasOwnProperty(params[1]))
  
      {
  
        console.log("Getting stream already created for camera "+params[1]);
  
  
  
        var newStdout = Object.create(stdouts[params[1]]);
  
  
  
        newStdout.pipe(resp);
  
      }
  
      else
  
      {
  
          // Start ffmpeg
  
          var ffmpeg = child_process.spawn("ffmpeg",[
  
          "-i",camera,
  
          "-vcodec","libtheora",
  
          "-qscale:v","7",        // video quality
  
          "-f","ogg",             // File format
  
          "-g","1",               // GOP (Group Of Pictures) size
  
          "-"                     // Output to STDOUT
  
          ]);
  
  
  
          stdouts[params[1]] = ffmpeg.stdout;
  
  
  
          // Pipe the video output to the client response
  
          ffmpeg.stdout.pipe(resp);
  
  
  
      console.log("Initializing camera at "+camera);
  
      }
  
  
  
      // Kill the subprocesses when client disconnects
  
  /*
  
      resp.on("close",function(){
  
        ffmpegs[params[1]].kill();
  
        console.log("FIM!");
  
      });
  
  */
  
      break;
  
  }
  
  }
  
  else
  
  {
  
  resp.writeHeader(200, {"Content-Type": "text/html"});
  
  resp.write("WRONG CALL");
  
  resp.end();
  
  }
  
  n++;
  
  
  
  }).listen(8088);
  
  
  
  console.log('Server running at port 8088');