add new expert handler 'H=E' which calls a script to determine the commandline for FFmpeg or vlc

Author: Zabrimus

README

@@ -111,8 +111,10 @@ Configuration:
            |  |   |   |     |            M3US:
            |  |   |   |     |            STREAM: H=F uses ffmpeg
            |  |   |   |     |                    H=V uses vlc
+           |  |   |   |     |                    H=E calls the script iptv-cmdline-expert.py to get the commandline
            |  |   |   |     |            RADIO:  H=F uses ffmpeg
            |  |   |   |     |                    H=V uses vlc
+           |  |   |   |     |                    H=E calls the script iptv-cmdline-expert.py to get the commandline
            |  |   |   |     Stream address
            |  |   |   |      UDP:  multicast [source@]group address
            |  |   |   |      CURL: HTTP/HTTPS URL; colons (%3A) and pipes (%7C) shall be URL encoded

iptv/iptv-cmdline-expert.py

@@ -0,0 +1,128 @@
+#!/usr/bin/python3
+
+import sys
+import json
+
+def readJson(str):
+    return json.loads(str)
+
+def prepareFFmpegVideo(json_object):
+    # begin command line
+    result = "ffmpeg -hide_banner -re -y" + \
+             " -thread_queue_size " + str(json_object["threads"]) + \
+             " -i \"" + json_object["url"] + "\""
+
+    # add audio urls if they exists
+    if 'audiourl' in json_object:
+        for aurl in json_object['audiourl']:
+            result += " -thread_queue_size " + str(json_object["threads"]) + \
+                      " -i \"" + aurl + "\""
+
+    # copy video
+    result += " -c:v copy"
+
+    # copy audio
+    result += " -c:a copy"
+
+    # copy subtitles
+    # result += " -c:s copy"
+
+    # map video/audio stream
+    if 'audiourl' in json_object:
+        i = 1
+        result += " -map 0:v"
+        for aurl in json_object['audiourl']:
+            result += " -map " + str(i) + ":a"
+            i += 1
+
+    # add video pid
+    result += " -streamid 0:" + str(json_object["vpid"])
+
+    # add audio pid
+    i = 1
+    for apid in json_object['apid']:
+        result += " -streamid " + str(i) + ":" + str(apid)
+        i += 1
+
+    # add all other parameters
+    result += " -f mpegts"
+    result += " -mpegts_transport_stream_id " + str(json_object["tpid"])
+    result += " -mpegts_pmt_start_pid 4096"
+    result += " -mpegts_service_id " + str(json_object["spid"])
+    result += " -mpegts_original_network_id " + str(json_object["nid"])
+    result += " -mpegts_flags system_b"
+    # result += " -mpegts_flags nit"
+    result += " -metadata service_name=\"" + json_object["channelName"] + "\""
+
+    # print ts stream to stdout
+    result += " pipe:1"
+
+    return result
+
+def prepareFFmpegAudio(json_object):
+    # begin command line
+    result = "ffmpeg -hide_banner -re -y" + \
+             " -thread_queue_size " + str(json_object["threads"]) + \
+             " -i \"" + json_object["url"] + "\""
+
+    # copy audio
+    result += " -c:a copy"
+
+    # add audio pid
+    i = 0
+    for apid in json_object['apid']:
+        result += " -streamid " + str(i) + ":" + str(apid)
+        i += 1
+
+    # add all other parameters
+    result += " -f mpegts"
+    result += " -mpegts_transport_stream_id " + str(json_object["tpid"])
+    result += " -mpegts_pmt_start_pid 4096"
+    result += " -mpegts_service_id " + str(json_object["spid"])
+    result += " -mpegts_original_network_id " + str(json_object["nid"])
+    result += " -mpegts_flags system_b"
+    # result += " -mpegts_flags nit"
+    result += " -metadata service_name=\"" + json_object["channelName"] + "\""
+
+    # print ts stream to stdout
+    result += " pipe:1"
+
+    return result
+
+def prepareVlcVideo(json_object):
+    result = "vlc" + " -I" + " dummy" + " -v" + \
+             " --network-caching=4000" + " --live-caching" + " 2000" + \
+             " --http-reconnect" + " --http-user-agent=Mozilla/5.0" + \
+             " --adaptive-logic" + " highest"
+
+    result += " \"" + json_object["url"] + "\""
+    result += " --sout"
+    result += " \"#standard{access=file,mux=ts{use-key-frames,pid-video=" + \
+              str(json_object["vpid"]) + ",pid-audio=" + str(json_object["apid"][0]) + ",pid-spu=4096,tsid="+ str(json_object["tpid"]) + "},dst=-}\""
+
+    return result
+
+def prepareVlcAudio(json_object):
+    result = "vlc" + " -I" + " dummy" + " --verbose=2" + " --no-stats"
+    result += " \"" + json_object["url"] + "\""
+    result += " --sout"
+    result += " \"#transcode{acodec=mpga,ab=320}:standard{access=file,mux=ts{pid-audio=" + str(json_object["apid"][0]) + ",pid-spu=4096,tsid=" + str(json_object["tpid"]) + "},dst=-}\""
+
+    return result
+
+
+if __name__ == '__main__':
+    json_object = readJson(sys.argv[2])
+    # print(json.dumps(json_object, indent=4))
+
+    # Copy of the FFmpeg/vlc calls in vdr-plugin-iptv
+    # Do whatever you want to do. E.g change frame rate, reencode audio, ...
+    # It's your your choice to change the FFmpeg or vlc command line
+    if sys.argv[1] == '1':
+        print(prepareFFmpegVideo(json_object))
+    else:
+        print(prepareVlcAudio(json_object))
+
+
+
+

m3u8handler.cpp

@@ -281,6 +281,7 @@ m3u_stream M3u8Handler::parseM3u(const std::string &webUri, int useYtdlp) {
     result.vpid = -1;
     result.spid = -1;
     result.tpid = -1;
+    result.nid  = -1;
     result.apids.clear();
 
     return result;

protocolradio.cpp

@@ -40,6 +40,7 @@ bool cIptvProtocolRadio::Open() {
                 streams.vpid = 0;
                 streams.spid = Channel->Sid();
                 streams.tpid = Channel->Tid();
+                streams.nid  = Channel->Nid();
 
                 int aidx = 0;
                 while (true) {

source.cpp

@@ -186,7 +186,7 @@ bool cIptvTransponderParameters::Parse(const char *strP) {
                     break;
 
                 case 'H':
-                    if (data[0] == 'F' || data[0] == 'V') {
+                    if (data[0] == 'F' || data[0] == 'V' || data[0] == 'E') {
                         handlerType = data[0];
                     }
                     break;

streambasehandler.cpp

@@ -36,10 +36,14 @@ class StreamBaseHandler {
 
     void checkErrorOut(const std::string &msg);
 
+    std::string convertStreamToJson(bool hasVideo, const m3u_stream &stream);
+
 protected:
     std::vector<std::string> prepareStreamCmdVideoFfmpeg(const m3u_stream &stream);
     std::vector<std::string> prepareStreamCmdAudioFfmpeg(const m3u_stream &stream);
 
     std::vector<std::string> prepareStreamCmdVideoVlc(const m3u_stream &stream);
     std::vector<std::string> prepareStreamCmdAudioVlc(const m3u_stream &stream);
+
+    std::string prepareExpertCmdLine(int isVideo, const std::string &json);
 };