blob: 68ed96962e2f73c63268bc7c21f77009ada8b12e (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
|
from . import StreamProcess
from ..compat import str, is_win32
import pbs
class RTMPStream(StreamProcess):
def __init__(self, session, params):
StreamProcess.__init__(self, session, params)
self.rtmpdump = self.session.options.get("rtmpdump") or (is_win32 and "rtmpdump.exe" or "rtmpdump")
self.params["flv"] = "-"
try:
self.cmd = getattr(pbs, self.rtmpdump)
except pbs.CommandNotFound as err:
raise StreamError(("Unable to find {0} command").format(str(err)))
def open(self):
if "jtv" in self.params and not self._has_jtv_support():
raise StreamError("Installed rtmpdump does not support --jtv argument")
return StreamProcess.open(self)
def _has_jtv_support(self):
try:
help = self.cmd(help=True, _err_to_out=True)
except pbs.ErrorReturnCode as err:
raise StreamError(("Error while checking rtmpdump compatibility: {0}").format(str(err.stdout, "ascii")))
for line in help.split("\n"):
if line[:5] == "--jtv":
return True
return False
|