Fixed goofy conn connections
This commit is contained in:
parent
043017d10c
commit
af5ee01f0d
10
main
10
main
|
@ -220,7 +220,7 @@ async def apiauthenticate():
|
||||||
conn = get_db_connection()
|
conn = get_db_connection()
|
||||||
secretkey = str(secrets.token_hex(512))
|
secretkey = str(secrets.token_hex(512))
|
||||||
|
|
||||||
clientidcheck = str(conn.execute("SELECT appId FROM oauth WHERE appId = ?", (str(appId)))).fetchone()
|
clientidcheck = str(conn.execute("SELECT appId FROM oauth WHERE appId = ?", (str(appId))).fetchone())
|
||||||
if not str(clientidcheck) == str(appId):
|
if not str(clientidcheck) == str(appId):
|
||||||
return {}, 401
|
return {}, 401
|
||||||
|
|
||||||
|
@ -251,11 +251,11 @@ async def apitokenexchange():
|
||||||
"id_token": str(conn.execute("SELECT openid FROM logins WHERE appId = ? AND code = ?", (str(appId), str(code))).fetchone())
|
"id_token": str(conn.execute("SELECT openid FROM logins WHERE appId = ? AND code = ?", (str(appId), str(code))).fetchone())
|
||||||
}
|
}
|
||||||
|
|
||||||
clientidcheck = str(conn.execute("SELECT appId FROM oauth WHERE appId = ?", (str(appId)))).fetchone()
|
clientidcheck = str(conn.execute("SELECT appId FROM oauth WHERE appId = ?", (str(appId))).fetchone())
|
||||||
if not str(clientidcheck) == str(appId):
|
if not str(clientidcheck) == str(appId):
|
||||||
return {}, 401
|
return {}, 401
|
||||||
|
|
||||||
secretcheck = str(conn.execute("SELECT secret FROM oauth WHERE appId = ?", (str(appId)))).fetchone()
|
secretcheck = str(conn.execute("SELECT secret FROM oauth WHERE appId = ?", (str(appId))).fetchone())
|
||||||
if not str(secretcheck) == str(secret):
|
if not str(secretcheck) == str(secret):
|
||||||
return {}, 402
|
return {}, 402
|
||||||
|
|
||||||
|
@ -274,13 +274,13 @@ async def apicreateauth():
|
||||||
secret = str(secrets.token_hex(512))
|
secret = str(secrets.token_hex(512))
|
||||||
conn = get_db_connection()
|
conn = get_db_connection()
|
||||||
while True:
|
while True:
|
||||||
if not secret == str(conn.execute("SELECT secret FROM oauth WHERE secret = ?", (str(secret)))).fetchone():
|
if not secret == str(conn.execute("SELECT secret FROM oauth WHERE secret = ?", (str(secret))).fetchone()):
|
||||||
break
|
break
|
||||||
else:
|
else:
|
||||||
secret = str(secrets.token_hex(512))
|
secret = str(secrets.token_hex(512))
|
||||||
continue
|
continue
|
||||||
|
|
||||||
if clientId == str(conn.execute("SELECT secret FROM oauth WHERE clientId = ?", (str(clientId)))).fetchone():
|
if clientId == str(conn.execute("SELECT secret FROM oauth WHERE clientId = ?", (str(clientId))).fetchone()):
|
||||||
return 401
|
return 401
|
||||||
|
|
||||||
userCookie = get_session(secretKey)
|
userCookie = get_session(secretKey)
|
||||||
|
|
Reference in New Issue