Bug fixes for SQL testing

app/main.py

@@ -600,45 +600,3 @@ async def generate_id_random(response: Response = Response):
 
     return HTMLResponse(content=html_list, status_code=200)
 # ### END ### API Main ### generate_id_random() ###
-
-
-# ### BEGIN ### API Main ### sql_test() ###
-# ### TEST TEST TEST ### #
-@app.get('/sql_test', tags=['Testing'], response_class=PlainTextResponse)
-async def sql_test(response: Response = Response):
-    log.setLevel(logging.DEBUG) # DEBUG, INFO, WARN, WARNING, ERROR, EXCEPTION, CRITICAL
-    log.debug(locals())
-
-    return mk_resp(data=False, status_code=501, response=response)
-
-    log.info('Getting all accounts from DB...')
-
-    sql = text(
-        """
-        SELECT id, id_random, name, enable
-        FROM `account`
-        """
-        )
-    try:
-        result = db.execute(sql)
-    except Exception as e:
-        log.error('*** An exception happened. ***')
-        log.error(repr(e))
-        log.error('***')
-        log.error(str(e))
-        log.error('^^^ exception ^^^')
-    else:
-        if result.rowcount:
-            record_li = [dict(record) for record in result.fetchall()]
-            log.debug(record_li)
-        else:
-            log.error('No records found. Something went wrong.')
-
-    log.info('Got the account list')
-
-    response_data = {}
-    response_data['message'] = 'This is the Aether API using FastAPI.'
-    response_data['data'] = record_li
-
-    return json.dumps(response_data, indent=4) # , sort_keys=True
-# ### END ### API Main ### sql_test() ###

app/routers/api.py

@@ -1,7 +1,11 @@
 import datetime, jwt, time
+# WARNING: Uncommenting JSONResponse import causes circular import issues
+# from fastapi import APIRouter, Body, Depends, Header, HTTPException, Path, Query, Response, status, JSONResponse
 from fastapi import APIRouter, Body, Depends, Header, HTTPException, Path, Query, Response, status
 from pydantic import BaseModel, EmailStr, Field
 from typing import Dict, List, Optional, Set, Union
+from sqlalchemy import text
+from app.db_connection import db
 
 from app.lib_general import log, logging, sign_jwt, decode_jwt, common_route_params, Common_Route_Params, common_route_params_min, Common_Route_Params_Min
 from app.config import settings
@@ -443,3 +447,25 @@ async def get_api_object_id(
     if object_id := redis_lookup_id_random(record_id_random=object_id_random, table_name=object_type):
         return mk_resp(data={ 'object_id': object_id}, status_code=400)
     else: return mk_resp(data=None, status_code=400)
+
+
+# WARNING: The following endpoint is commented out because it causes circular import issues due to JSONResponse import. -Scott 2026-01-13
+# # ### BEGIN ### API API ### sql_test() ###
+# @router.get('/sql_test', tags=['Testing'], response_class=JSONResponse)
+# async def sql_test(response: Response = Response):
+#     log.setLevel(logging.DEBUG)
+#     log.debug(locals())
+
+#     sql = text("SELECT NOW() as current_time, VERSION() as version")
+#     try:
+#         result_proxy = db.execute(sql)
+#         result = result_proxy.fetchone()
+#         data = {
+#             "current_time": str(result[0]),
+#             "version": result[1]
+#         }
+#         return mk_resp(data=data, response=response)
+#     except Exception as e:
+#         log.error(f'SQL Test failed: {str(e)}')
+#         return mk_resp(data=False, status_code=500, details=str(e), response=response)
+# # ### END ### API API ### sql_test() ###