| | |
| | | await update_token(db, user.id, access_token, token_dict) |
| | | result = await pdb.execute(select(AppToken).where(AppToken.id == user.id)) |
| | | db_app_token = result.scalars().first() |
| | | if isinstance(access_token, bytes): |
| | | access_token = access_token.decode() |
| | | if not db_app_token: |
| | | app_token_str = json.dumps(token_dict) |
| | | # print(app_token_str) |
| | | app_token = AppToken(id=user.id, token=access_token.decode(), app_token=app_token_str) |
| | | app_token = AppToken(id=user.id, token=access_token, app_token=app_token_str) |
| | | pdb.add(app_token) |
| | | await pdb.commit() |
| | | await pdb.refresh(app_token) |
| | | else: |
| | | db_app_token.token = access_token.decode() |
| | | db_app_token.token = access_token |
| | | db_app_token.app_token = json.dumps(token_dict) |
| | | await pdb.commit() |
| | | await pdb.refresh(db_app_token) |