CLI.Streamer.py

# imports
from asyncio import sleep
import asyncio
import json
import os
from vidgear.gears import CamGear
from vidgear.gears import WriteGear
import cv2
import argparse
import colorama

# Define command line arguments using argparse
parser = argparse.ArgumentParser(description="Aparat Streamer CLI for J-UI",
                                 formatter_class=argparse.ArgumentDefaultsHelpFormatter)
parser.add_argument("-k", "--key", help="Stream key") # Stream key argument
parser.add_argument("-l", "--location", help="Stream vid location") # Stream video location argument
option = parser.parse_args()
print(option)

VIDEO_SOURCE = option.location # Set video source from command line argument
VIDOE_STREAM_KEY = option.key # Set stream key from command line argument

# Loads config
async def main():
    try:
        print(colorama.Fore.GREEN + "Streamer by " + colorama.Style.DIM + "GHALBEYOU\n" + colorama.Style.RESET_ALL + colorama.Fore.GREEN + "GitHub.com/ghalbeyou\n\n              Loading ...")
        await sleep(5)
        os.system("cls")
        
        # Open stream
        stream = CamGear(source=VIDEO_SOURCE, logging=True).start()

        # Define required FFmpeg optimizing parameters for your writer
        # [NOTE]: Added VIDEO_SOURCE as audio-source
        # [WARNING]: VIDEO_SOURCE must contain audio
        output_params = {
            "-i": VIDEO_SOURCE,
            "-acodec": "aac",
            "-ar": 44100,
            "-b:a": 712000,
            "-vcodec": "libx264",
            "-preset": "medium",
            "-b:v": "4500k",
            "-bufsize": "512k",
            "-pix_fmt": "yuv420p",
            "-f": "flv",
        }

        # [WARNING]: Change your YouTube-Live Stream Key here:

        # Define writer with defined parameters and stream key
        writer = WriteGear(
            output_filename="rtmp://rtmp.cdn.asset.aparat.com:443/event/{}".format(VIDOE_STREAM_KEY),
            logging=True,
            **output_params
        )

        # loop over
        while True:

            # Read frames from stream
            frame = stream.read()

            # Check for frame if NoneType
            if frame is None:
                break


            # Write frame to writer
            writer.write(frame)

        # Safely close video stream
        stream.stop()

        # Safely close writer
        writer.close()
    except Exception:
        print("There was as error")


if __name__ == '__main__':
    asyncio.run(main=main())