- /api/rates endpoint now returns a list of entries in a json form
This commit is contained in:
2025-09-06 02:45:47 +03:00
parent 873c061152
commit 1c7e95b119
2 changed files with 8 additions and 4 deletions

View File

@ -53,9 +53,14 @@ def delete_entry(article_url, connection):
def get_all_entries(connection): def get_all_entries(connection):
try: try:
cursor = connection.cursor() cursor = connection.cursor()
cursor.execute('SELECT article_url, rating FROM harticle.articles;') cursor.execute('SELECT article_url FROM harticle.articles;')
entries = cursor.fetchall() urls = cursor.fetchall()
cursor.execute('SELECT rating FROM harticle.articles;')
ratings = cursor.fetchall()
logger.info('All entry pairs have been retrieved successfully') logger.info('All entry pairs have been retrieved successfully')
entries = {}
for i in range(len(urls)):
entries[urls[i][0]] = ratings[i][0]
return entries return entries
except psycopg2.Error as e: except psycopg2.Error as e:
logger.error(f'Failed to fetch DB entries: {e.pgerror}') logger.error(f'Failed to fetch DB entries: {e.pgerror}')
@ -93,4 +98,3 @@ def table_creator(schema_name, table_name, connection):
logger.info(f'Successfully created table {table_name} in schema {schema_name} if it didn\'t exist yet') logger.info(f'Successfully created table {table_name} in schema {schema_name} if it didn\'t exist yet')
except psycopg2.Error as e: except psycopg2.Error as e:
logger.error(f'Error during table creation: {e}') logger.error(f'Error during table creation: {e}')

View File

@ -31,7 +31,7 @@ async def ping():
@router.get('/rates') @router.get('/rates')
async def get_rates(): async def get_rates():
result = dumps(DBwork.get_all_entries(db.connection)) result = DBwork.get_all_entries(db.connection)
return result return result