| import streamlit as st |
| import asyncio |
| import os |
| import time |
| import subprocess |
| import threading |
| from datetime import datetime |
| from TikTokLive import TikTokLiveClient |
|
|
| |
| |
| |
| TIKTOK_USERNAME = "@ah_md107" |
| YOUTUBE_STREAM_KEY = "qf5b-15f0-fks9-kwvb-d1q5" |
| POLL_INTERVAL = 60 |
| YT_RTMP_URL = f"rtmp://a.rtmp.youtube.com/live2/{YOUTUBE_STREAM_KEY}" |
|
|
| |
| |
| |
|
|
| def run_monitor(): |
| """ูุฐู ุงูุฏุงูุฉ ูู ุงูุชู ุชุธู ุชุนู
ู ุญุชู ูู ุฃุบููุช ุงูุตูุญุฉ""" |
| print("โ
ุจุฏุฃ ู
ุญุฑู ุงูู
ุฑุงูุจุฉ ุงูุชููุงุฆู 24/7...") |
| while True: |
| try: |
| |
| client = TikTokLiveClient(unique_id=TIKTOK_USERNAME) |
| is_live = asyncio.run(client.is_live()) |
|
|
| if is_live: |
| print(f"[{datetime.now().strftime('%H:%M')}] ๐ด ุงูุจุซ ุจุฏุฃ! ุฌุงุฑู ุงูููู ุฅูู ููุชููุจ...") |
|
|
| |
| cmd = ( |
| f"streamlink https://www.tiktok.com/{TIKTOK_USERNAME}/live best --hls-live-edge 3 --stdout | " |
| f"ffmpeg -thread_queue_size 8192 -i pipe:0 " |
| f"-c:v copy " |
| f"-c:a aac -ar 48000 -b:a 192k -ac 2 " |
| f"-af 'highpass=f=200,lowpass=f=3000,aresample=async=1' " |
| f"-buffer_size 1024k " |
| f"-fflags +genpts+igndts " |
| f"-max_interleave_delta 0 " |
| f"-f flv {YT_RTMP_URL}" |
| ) |
|
|
| process = subprocess.Popen(cmd, shell=True) |
| process.wait() |
| print("โน๏ธ ุงูุชูู ุงูุจุซุ ุงูุนูุฏุฉ ููุถุน ุงูู
ุฑุงูุจุฉ...") |
| else: |
| |
| pass |
|
|
| except Exception as e: |
| print(f"โ ๏ธ ุชูุจูู: {e}") |
|
|
| time.sleep(POLL_INTERVAL) |
|
|
| |
| if "background_started" not in st.session_state: |
| |
| for thread in threading.enumerate(): |
| if thread.name == "TikTokMonitorThread": |
| st.session_state.background_started = True |
| break |
| else: |
| |
| monitor_thread = threading.Thread(target=run_monitor, name="TikTokMonitorThread", daemon=True) |
| monitor_thread.start() |
| st.session_state.background_started = True |
|
|
| |
| |
| |
|
|
| st.set_page_config(page_title="AutoStreamer 24/7", page_icon="๐ด") |
|
|
| |
| st.markdown(""" |
| <style> |
| .status-box { |
| padding: 20px; border-radius: 15px; background-color: #0e1117; |
| border: 1px solid #262730; text-align: center; |
| } |
| .live-tag { color: #ff4b4b; font-weight: bold; animation: pulse 2s infinite; } |
| @keyframes pulse { 0% { opacity: 1; } 50% { opacity: 0.5; } 100% { opacity: 1; } } |
| </style> |
| """, unsafe_allow_html=True) |
|
|
| st.title("๐ด ูุธุงู
ุงูุจุซ ุงูุชููุงุฆู ุงูู
ุณุชู
ุฑ") |
|
|
| st.markdown(f""" |
| <div class="status-box"> |
| <h3>ุญุงูุฉ ุงููุธุงู
: <span style="color: #00ff00;">ู
ุชุตู ููุนู
ู โ
</span></h3> |
| <p>ูุชู
ู
ุฑุงูุจุฉ ุงูุญุณุงุจ: <b>{TIKTOK_USERNAME}</b></p> |
| <p class="live-tag">ุงููุธุงู
ูุนู
ู ูู ุฎูููุฉ ุงูุณูุฑูุฑ ุงูุขู</p> |
| </div> |
| """, unsafe_allow_html=True) |
|
|
| st.success("โน๏ธ ูู
ููู ุฅุบูุงู ูุฐู ุงูุตูุญุฉ ุงูุขู. ุงูุณูุฑูุฑ ุณูููู
ุจุฑุตุฏ ุงูุจุซ ูุฑูุนู ุชููุงุฆูุงู ูู ุฃู ููุช (ุงูููู
ุ ุบุฏุงูุ ุฃู ุฃู ููุช).") |
|
|
| st.info("๐ก ุจู
ุฌุฑุฏ ุฃู ูุจุฏุฃ ุตุงุญุจ ุงูุญุณุงุจ ุงูุจุซุ ุณูููู
ุงููุธุงู
ุจูุชุญู ููุฑุงู ููููู ุฅูู ููุงุชู ุนูู ููุชููุจ.") |
|
|
| |
| if st.button("ุชุญุฏูุซ ุงูุญุงูุฉ"): |
| st.rerun() |
|
|
| st.write(f"ุขุฎุฑ ูุญุต ุชู
ูู: {datetime.now().strftime('%Y-%m-%d %H:%M:%S')}") |
|
|
