from os import listdir,system as ss
from time import sleep
import subprocess
#Theards
import threading
#Time&Date
from datetime import date
import time
#Config
import config


#DEV-MODE#
dev = False
##########

#Import config
tw = int(config.time)
prefix = config.prefix
rad = config.radio

if dev == False:
	wait = tw*60
else:
	wait = tw

#Check bitrate and upload
def tg(i,tim,prefix,group):
	ss("rm t")
	ss("ffprobe "+i+" 2> t")
	bit = int(subprocess.check_output("cat t | grep bitrate | grep Duration | awk -F \" \" '{print $6}'", shell=True))

	if bit != 128:
		ss("lame --mp3input -b 128 "+i+" tt")
		ss("mv tt "+i)

	ss("telegram-upload "+i+" --to "+group+" --caption "+tim)
	ss("mkdir "+prefix+tim)
	ss("mv "+i+" "+prefix+tim+"/")


#Upload in telegram
def upload():
	today = date.today()
	files = listdir()
	#Set date&time
	tim = today.strftime("%d.%m.%Y_"+time.strftime("%H:%M", time.localtime()))

	for i in files:
		if rad.get(i) == None:
			pass
		else:
			print("SUCCESS")
			tg(i,tim,prefix,rad[i][1])
'''
		if i == "nashepunks.mp3":
			tg(i,tim,prefix,"https://t.me/getnetradio_nashe0punk")

		elif i == "nrj.mp3":
			tg(i,tim,prefix,"https://t.me/getnetradio_nrj")

		elif i == "retrofm.mp3":
                        tg(i,tim,prefix,"https://t.me/getnetradio_retrofm")
		else:
			pass
'''

while True:
	#Download function
	def rad_down(ch):
		ss("wget "+ch)
	#Run download
	for i in rad:
		th = threading.Thread(target=rad_down, args=(rad[i][0],))
		th.start()

	#Wait
	sleep(wait)

	#Stop download
	ss("killall wget")

	#Upload
	upload()

	if dev == True:
		break