Several modules are controlled from the, “Main_Control_Script.py”. Once per hour the following are run:

RedditScraper.py
PriceApp.py
Analysis.py
/TradeMaker/Trade_Script.py
from github import Github
from time import sleep
import pandas as pd
import subprocess
import datetime
import glob
import os
import csv

count = 0

# How many time to run the loop (once per hour)
while count < 7:
    count = count + 1
    exec(open("RedditScraper.py").read())

    sleep(2)
# Get latest output from the scraper and add it and delete old one
    list_of_files = glob.glob('./*.csv') # * means all if need specific format then *.csv
    latest_file = max(list_of_files, key=os.path.getctime)
    latestFile = pd.read_csv(latest_file, encoding ='utf-8')
    latestFile = latestFile.iloc[0:1]
    latestFile.Hour=pd.datetime.now()
    mainFile = pd.read_csv('./ScrappedData/ScrappedReddit.csv', encoding='utf-8')
    os.remove("./ScrappedData/ScrappedReddit.csv")
    
    sleep(2)

    latestFileNew = latestFile[mainFile.columns]
    out = pd.concat([mainFile, latestFileNew])
    out.to_csv('./ScrappedData/ScrappedReddit.csv', index=False)

    sleep(2)

# Run price scraper
    exec(open("PriceApp.py").read())

    sleep(2)

# Run analysis and make predictions
    exec(open("Analysis.py").read())

    sleep(2)


# Upload data to GitHub
    # Set user info
    g = Github("f3e423110fbea4df9a0a9ada58caea3700641a14")
    repo = g.get_user().get_repo('tradr')
    all_files = []
    contents = repo.get_contents("")
    while contents:
        file_content = contents.pop(0)
        if file_content.type == "dir":
            contents.extend(repo.get_contents(file_content.path))
        else:
            file = file_content
            all_files.append(str(file).replace('ContentFile(path="','').replace('")',''))


    # Upload Price Data
    with open('./PriceData.csv', 'r') as file:
        content = file.read()

    
    git_prefix = 'Data/PriceGrabber/'
    git_file = git_prefix + 'PriceData.csv'

    if git_file in all_files:
        contents = repo.get_contents(git_file)
        repo.update_file(contents.path, "committing files", content, contents.sha, branch="main")
        print(git_file + ' UPDATED')
    else:
        repo.create_file(git_file, "committing files", content, branch="main")
        print(git_file + ' CREATED')
        
    # Scrapped Reddit
    with open('./ScrappedData/ScrappedReddit.csv', 'r') as file:
        content = file.read()

    # Upload Scrapped Reddit Data
    git_prefix = 'Data/ScrappedData/'
    git_file = git_prefix + 'ScrappedReddit.csv'

    if git_file in all_files:
        contents = repo.get_contents(git_file)
        repo.update_file(contents.path, "committing files", content, contents.sha, branch="main")
        print(git_file + ' UPDATED')
    else:
        repo.create_file(git_file, "committing files", content, branch="main")
        print(git_file + ' CREATED')

    sleep(2)

# Make trades using SignalInput.csv

    main_path = '/home/iii/MEGA/NYC Data/tradr/Data/TradeMaker/'
    python_path = f"{main_path}venv/bin/python3"
    args = [python_path, f"{main_path}trade_script.py",
    "/home/iii/MEGA/NYC Data/tradr/Data/SignalInput.csv"]
    process_info = subprocess.run(args)
    print(process_info.returncode)

# Wait one hour (or whatever)
    sleep(3600)