yaso_meth/mih-project
2
4
Fork 2
Code Issues 8 Pull Requests Actions Packages Projects Releases 1 Wiki Activity

update api to point to correct db

Browse Source
This commit is contained in:
yaso-meth
2024-07-26 12:34:46 +02:00
parent 3499140a45
commit 028bf5254d
1 changed files with 57 additions and 56 deletions
Download Patch File Download Diff File Expand all files Collapse all files

113
backend/routers/users.py
View File

@@ -7,6 +7,8 @@ from supertokens_python.recipe.session.framework.fastapi import verify_session
from supertokens_python.recipe.session import SessionContainer from supertokens_python.recipe.session import SessionContainer
from fastapi import Depends from fastapi import Depends
import database.dbConnection
router = APIRouter() router = APIRouter()
class userRequest(BaseModel): class userRequest(BaseModel):
@@ -23,58 +25,58 @@ class userUpdateRequest(BaseModel):
fnam: str fnam: str
lname: str lname: str
#get user by email & doc Office ID # #get user by email & doc Office ID
@router.get("/users/profile/{email}", tags="users") # @router.get("/users/profile/{email}", tags="users")
async def read_all_users(email: str, session: SessionContainer = Depends(verify_session())): # async def read_all_users(email: str, session: SessionContainer = Depends(verify_session())):
db = database.dbConnection.dbConnect() # db = database.dbConnection.dbAppDataConnect()
cursor = db.cursor() # cursor = db.cursor()
query = "SELECT * FROM users where email = %s" # query = "SELECT * FROM users where email = %s"
cursor.execute(query, (email.lower(),)) # cursor.execute(query, (email.lower(),))
items = [ # items = [
{"idusers": item[0], # {"idusers": item[0],
"email": item[1], # "email": item[1],
"docOffice_id": item[2], # "docOffice_id": item[2],
"fname":item[3], # "fname":item[3],
"lname":item[4], # "lname":item[4],
"type": item[5], # "type": item[5],
"app_id": item[6], # "app_id": item[6],
"username": item[7], # "username": item[7],
} # }
for item in cursor.fetchall() # for item in cursor.fetchall()
]# # ]#
cursor.close() # cursor.close()
db.close() # db.close()
return items[0] # return items[0]
# Get List of all files # # Get List of all files
@router.get("/users/", tags="users") # @router.get("/users/", tags="users")
async def read_all_users(session: SessionContainer = Depends(verify_session())): # async def read_all_users(session: SessionContainer = Depends(verify_session())):
db = database.dbConnection.dbConnect() # db = database.dbConnection.dbAppDataConnect()
cursor = db.cursor() # cursor = db.cursor()
query = "SELECT * FROM users" # query = "SELECT * FROM users"
cursor.execute(query) # cursor.execute(query)
items = [ # items = [
{ # {
"idUser": item[0], # "idUser": item[0],
"email": item[1], # "email": item[1],
"docOffice_id": item[2], # "docOffice_id": item[2],
"fname": item[3], # "fname": item[3],
"lname": item[4], # "lname": item[4],
"type": item[5], # "type": item[5],
"app_id": item[6], # "app_id": item[6],
"username": item[7], # "username": item[7],
} # }
for item in cursor.fetchall() # for item in cursor.fetchall()
] # ]
cursor.close() # cursor.close()
db.close() # db.close()
return items # return items
# Get List of all files # Get List of all files
@router.get("/user/{uid}", tags="users") @router.get("/user/{uid}", tags="users")
async def read_all_users(uid: str, session: SessionContainer = Depends(verify_session())): async def read_all_users(uid: str, session: SessionContainer = Depends(verify_session())):
db = database.dbConnection.dbConnect() db = database.dbConnection.dbAppDataConnect()
cursor = db.cursor() cursor = db.cursor()
query = "SELECT * FROM users where app_id = %s" query = "SELECT * FROM users where app_id = %s"
cursor.execute(query, (uid,)) cursor.execute(query, (uid,))
@@ -82,12 +84,11 @@ async def read_all_users(uid: str, session: SessionContainer = Depends(verify_se
{ {
"idUser": item[0], "idUser": item[0],
"email": item[1], "email": item[1],
"docOffice_id": item[2], "fname": item[2],
"fname": item[3], "lname": item[3],
"lname": item[4], "type": item[4],
"type": item[5], "app_id": item[5],
"app_id": item[6], "username": item[6],
"username": item[7],
} }
for item in cursor.fetchall() for item in cursor.fetchall()
] ]
@@ -98,11 +99,11 @@ async def read_all_users(uid: str, session: SessionContainer = Depends(verify_se
# Insert Patient into table # Insert Patient into table
@router.post("/user/insert/", tags="user", status_code=201) @router.post("/user/insert/", tags="user", status_code=201)
async def insertPatient(itemRequest : userInsertRequest, session: SessionContainer = Depends(verify_session())): async def insertPatient(itemRequest : userInsertRequest, session: SessionContainer = Depends(verify_session())):
db = database.dbConnection.dbConnect() db = database.dbConnection.dbAppDataConnect()
cursor = db.cursor() cursor = db.cursor()
query = "insert into users " query = "insert into users "
query += "(email, docOffice_id, fname, lname, type, app_id, username) " query += "(email, fname, lname, type, app_id, username) "
query += "values (%s, %s, %s, %s,%s, %s, %s)" query += "values (%s, %s, %s, %s, %s, %s)"
userData = (itemRequest.email, "12345","","","personal", userData = (itemRequest.email, "12345","","","personal",
itemRequest.app_id, "") itemRequest.app_id, "")
try: try:
@@ -118,7 +119,7 @@ async def insertPatient(itemRequest : userInsertRequest, session: SessionContain
# Update User on table # Update User on table
@router.put("/user/update/", tags="user") @router.put("/user/update/", tags="user")
async def UpdateUser(itemRequest : userUpdateRequest, session: SessionContainer = Depends(verify_session())): async def UpdateUser(itemRequest : userUpdateRequest, session: SessionContainer = Depends(verify_session())):
db = database.dbConnection.dbConnect() db = database.dbConnection.dbAppDataConnect()
cursor = db.cursor() cursor = db.cursor()
query = "update users " query = "update users "
query += "set username=%s, fname=%s, lname=%s " query += "set username=%s, fname=%s, lname=%s "