import os
import time
import paramiko
from dotenv import load_dotenv

repo_root = "c:/Users/lanfr144/Documents/DOPRO1/Antigravity/Food"
load_dotenv(dotenv_path=os.path.join(repo_root, ".env"))

host = os.environ.get('SERVER_HOST', '192.168.130.170')
user = os.environ.get('SERVER_USER', 'francois')
password = os.environ.get('SERVER_PASS', 'BTSai123')

def main():
    ssh = paramiko.SSHClient()
    ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
    try:
        ssh.connect(host, username=user, password=password, timeout=15)
        print("Connected successfully!")
        
        # Start download in background using nohup
        print("Starting download_csv.sh in the background...")
        ssh.exec_command("cd ~/food_project && nohup bash download_csv.sh > download.log 2>&1 &")
        
        # Let's wait a few seconds and monitor file size growth
        time.sleep(3)
        print("Monitoring download file size progress for 30 seconds:")
        for _ in range(6):
            stdin, stdout, stderr = ssh.exec_command("ls -lh ~/food_project/data/en.openfoodfacts.org.products.csv")
            out = stdout.read().decode('utf-8').strip()
            print(f"File status: {out}")
            time.sleep(5)
            
    except Exception as e:
        print(f"Error: {e}")
    finally:
        ssh.close()

if __name__ == "__main__":
    main()