IPTV Remote
-Current Channel: {channels[current_index]['name']}
- - -All Channels
-
- """
-
- flat_channel_list = [channel for group in grouped_channels.values() for channel in group]
+ html = f"""
+
+
+ IPMPV
+
+
+
+
+
+
+
+ """
- return html
+ return html
+
+def is_valid_url(url):
+ return re.match(r"^(https?|rtmp|rtmps|udp|tcp):\/\/[\w\-]+(\.[\w\-]+)*(:\d+)?([\/?].*)?$", url) is not None
+
+@app.route("/play_custom")
+def play_custom():
+ global current_index
+ current_index = None
+ url = request.args.get("url")
+
+ if not url or not is_valid_url(url):
+ return jsonify(success=False, error="Invalid or unsupported URL")
+
+ player.loadfile(url)
+ return jsonify(success=True)
+
+@app.route("/hide_osd")
+def hide_osd():
+ to_qt_queue.put({
+ 'action': 'close_osd',
+ })
+ return "", 204
+
+@app.route("/show_osd")
+def show_osd():
+ if current_index is not None:
+ channel_info = {
+ "name": channels[current_index]["name"],
+ "deinterlace": deinterlace,
+ "low_latency": low_latency,
+ "logo": channels[current_index]["logo"]
+ }
+ to_qt_queue.put({
+ 'action': 'show_osd',
+ 'channel_info': channel_info
+ })
+ to_qt_queue.put({
+ 'action': 'update_codecs',
+ 'vcodec': vcodec,
+ 'acodec': acodec,
+ 'video_res': video_res,
+ 'interlaced': interlaced
+ })
+ return "", 204
@app.route("/channel")
def switch_channel():
- index = int(request.args.get("index", current_index))
- play_channel(index)
- return "", 204
+ index = int(request.args.get("index", current_index))
+ play_channel(index)
+ return "", 204
+
+@app.route("/toggle_deinterlace")
+def toggle_deinterlace():
+ global deinterlace
+ deinterlace = not deinterlace
+ if deinterlace:
+ player['vf'] = 'yadif=0'
+ else:
+ player['vf'] = ''
+ return jsonify(state=deinterlace)
+
+@app.route("/stop_player")
+def stop_player():
+ global current_index
+ global osd
+ current_index = None
+ to_qt_queue.put({
+ 'action': 'close_osd',
+ })
+ player.stop()
+ return "", 204
+
+@app.route("/toggle_retroarch")
+def toggle_retroarch():
+ global retroarch_p
+ retroarch_pid = subprocess.run(["pgrep", "-fx", "retroarch"], stdout=subprocess.PIPE).stdout.strip()
+ if retroarch_pid:
+ print("Retroarch already open. Trying to close it.")
+ subprocess.run(["kill", retroarch_pid])
+ retroarch_p.terminate()
+ return jsonify(state=False)
+ else:
+ print("Launching RetroArch")
+ retroarch_env = os.environ.copy()
+ retroarch_env["MESA_GL_VERSION_OVERRIDE"] = "3.3"
+ retroarch_env["DISPLAY"] = ":0"
+ retroarch_p = subprocess.Popen(["/usr/bin/flatpak","run","org.libretro.RetroArch"], env=retroarch_env)
+ return jsonify(state=True)
+
+@app.route("/toggle_latency")
+def toggle_latency():
+ global low_latency
+ low_latency = not low_latency
+ player['audio-buffer'] = '0' if low_latency else '0.2'
+ player['vd-lavc-threads'] = '1' if low_latency else '0'
+ player['cache-pause'] = 'no' if low_latency else 'yes'
+ player['demuxer-lavf-o'] = 'reconnect=1,fflags=+nobuffer' if low_latency else 'reconnect=1'
+ player['demuxer-lavf-probe-info'] = 'nostreams' if low_latency else 'auto'
+ player['demuxer-lavf-analyzeduration'] = '0.1' if low_latency else '0'
+ player['video-sync'] = 'audio'
+ player['interpolation'] = 'no'
+ player['video-latency-hacks'] = 'yes' if low_latency else 'no'
+ player['stream-buffer-size'] = '4k' if low_latency else '128k'
+ print("JSON: ",jsonify(state=low_latency))
+ return jsonify(state=low_latency)
+
+@app.route("/toggle_resolution")
+def toggle_resolution():
+ global resolution,is_wayland
+ new_res = ""
+ if is_wayland:
+ if resolution == "480i":
+ new_res = "720x240"
+ elif resolution == "240p":
+ new_res = "720x480"
+ elif resolution == "576i":
+ new_res = "720x288"
+ elif resolution == "288p":
+ new_res = "720x576"
+
+ else:
+ if resolution == "480i":
+ new_res = "720x240"
+ elif resolution == "240p":
+ new_res = "720x480i"
+ elif resolution == "576i":
+ new_res = "720x288"
+ elif resolution == "288p":
+ new_res = "720x576i"
+
+ if new_res:
+ if is_wayland:
+ wlr_randr_env = os.environ.copy()
+ wlr_randr_env["DISPLAY"] = ":0"
+ subprocess.run(["wlr-randr", "--output", "Composite-1", "--mode", new_res], check=False, env=wlr_randr_env)
+ resolution = get_current_resolution()
+ else:
+ xrandr_env = os.environ.copy()
+ xrandr_env["DISPLAY"] = ":0"
+ subprocess.run(["wlr-randr", "--output", "Composite-1", "--mode", new_res], check=False, env=xrandr_env)
+ resolution = get_current_resolution()
+
+ return jsonify(res=get_current_resolution())
if __name__ == "__main__":
- app.run(host="0.0.0.0", port=5000)
\ No newline at end of file
+ # Start Qt process
+ qt_proc = multiprocessing.Process(target=qt_process)
+ qt_proc.daemon = True
+ qt_proc.start()
+
+ # Start Flask in main thread
+ app.run(host="0.0.0.0", port=5000)
diff --git a/nosignal.png b/nosignal.png
new file mode 100644
index 0000000..ab3c431
Binary files /dev/null and b/nosignal.png differ
diff --git a/novideo.png b/novideo.png
new file mode 100644
index 0000000..1fdbdb6
Binary files /dev/null and b/novideo.png differ
diff --git a/readme.md b/readme.md
deleted file mode 100644
index 62841ab..0000000
--- a/readme.md
+++ /dev/null
@@ -1,2 +0,0 @@
-# impmv
-A small IPTV player for your Raspberry Pi.
diff --git a/requirements.txt b/requirements.txt
new file mode 100644
index 0000000..0a05fe8
--- /dev/null
+++ b/requirements.txt
@@ -0,0 +1,5 @@
+flask
+Pillow
+mpv
+PyQt5
+requests
diff --git a/run.sh b/run.sh
new file mode 100755
index 0000000..54b97a3
--- /dev/null
+++ b/run.sh
@@ -0,0 +1,19 @@
+#!/bin/bash
+
+# Check if virtual environment already exists
+if [ -d "./.venv" ]; then
+ echo "Virtual environment already exists."
+else
+ echo "Creating virtual environment..."
+ python -m venv --system-site-packages ./.venv
+fi
+
+# Activate the virtual environment
+source ./.venv/bin/activate
+
+# Install required packages
+pip install -r requirements.txt
+
+# Run the application
+echo "Starting..."
+python main.py
Welcome to IPMPV
+Current Channel: {channels[current_index]['name'] if current_index is not None else "None"}
+ + """ +# +# - for group, ch_list in grouped_channels.items(): - html += f'{group}'
- for channel in ch_list:
- index = flat_channel_list.index(channel) # Get correct global index
- html += f'''
-
'
+ global deinterlace
+ global low_latency
+ deinterlace_state = "ON" if deinterlace else "OFF"
+ retroarch_state = "ON" if retroarch_p and retroarch_p.poll() is None else "OFF"
+ html += f"""
+
+
+
+
- 
-
-
- '''
- html += 'Toggle OSD
+ + """ + html += f""" +Play Custom URL
+ +All Channels
+
+ """
+
+ for group, ch_list in grouped_channels.items():
+ html += f'
-
-
-
- """
+ html += """
+ {group}'
+ for channel in ch_list:
+ index = flat_channel_list.index(channel) # Get correct global index
+ html += f'''
+
'
- html += """
-
+
+
+
+ '''
+ html += '