import os
import psycopg2
# from pprint import pprint
from dotenv import load_dotenv
import model
import view


if __name__ == '__main__':
    load_dotenv(verbose=True)
    cur = None
    try:
        conn = psycopg2.connect(user=os.getenv('db_user'),
                                password=os.getenv('db_password'),
                                host=os.getenv('db_host'),
                                port=os.getenv('db_port'),
                                database=os.getenv('db_database'))
        cur = conn.cursor()
        query = model.get_events()
        results = model.database_select(cur, query)
        broadcast = []
        for result in results:
            is_broadcast = model.is_broadcast(cur, result[0])
            if not is_broadcast:
                text = model.create_links(result[2])
                print(result[1])
                print(text)
                view.broadcast(text)
                model.record_broadcast(cur, result[0])
        conn.commit()
    except (Exception, psycopg2.Error) as error:
        print("PostgreSQL error from psycopg2:", error)