import subprocess, csv, time, sys,os,json, send2trash

def fromKomb(komb):
    broj = 0
    for i in komb:
        broj = broj*2+int(i)
    
    return broj

header = ["Title","IMDb","Netflix","Hulu","Prime Video","Disney+"]
files = []
writers = []

for i in range(1,16):
    f = open('tv_shows'+str(i)+'.csv', 'w', encoding='utf-8')
    writer = csv.DictWriter(f,header, lineterminator="\n")
    writer.writeheader()
    writers.append(writer)
    files.append(f)

file = open("tv_shows.csv", 'r', encoding='utf-8')
reader = csv.DictReader(file)

for row in reader:
    kombinacija = [row['Netflix'], row['Hulu'], row['Prime Video'], row['Disney+']]

    writers[fromKomb(kombinacija)-1].writerow(row)

file.close()
def checkProces(procesi):
    for proces in procesi:
        if (proces.poll() is None):
            return None
        if (proces.poll() != 0):
            return proces.poll()
    
    return 0

procesi = []

for i in range(1,16):
    files[i-1].close()
    p = subprocess.Popen(["py","radnik.py",'tv_shows'+str(i)+'.csv'])
    procesi.append(p)

while (checkProces(procesi) is None):
    time.sleep(1)


if (checkProces(procesi)!=0):
    print("Neki od radnika je izvrsen neuspesno.")
    sys.exit()


radnici = []

for fileName in os.listdir('.'):
    if fileName.endswith(".json"):
        f = open(fileName)
        jsonData= json.load(f)
        radnici.append(jsonData)
        f.close()
        send2trash.send2trash(fileName)

spisak = radnici[0]['spisak']
min = abs(radnici[0]['medijana']-radnici[0]['srednja'])

for radnik in radnici:
    if (min > abs(radnik['medijana']-radnik['srednja'])):
        min = abs(radnik['medijana']-radnik['srednja'])
        spisak = radnik['spisak']

print(spisak)