| 123456789101112131415161718192021222324252627282930313233 |
- 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])
- text = model.escape_markdown(text)
- 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)
|
