importinspectfromtypingimportAnnotated,Any,Genericfromfastapi_users.authentication.strategy.dbimportAPfromfastapi_users.modelsimportID,UPfromfastapi_users_db_sqlalchemyimport (SQLAlchemyBaseOAuthAccountTable,SQLAlchemyUserDatabase,)fromfastapi_users_db_sqlalchemy.access_tokenimportSQLAlchemyAccessTokenDatabasefromsqlalchemy.ext.asyncioimportAsyncSessionfromsqlalchemy.ormimportSessionclassFakeAsyncSession:def__init__(self,session:Session):self.session=sessiondef__getattr__(self,name:str)->Any:"""        If the method being called is async in AsyncSession, create a fake async version        for Session so callers can `await` as usual. Think `commit`, `refresh`,        `delete`, etc.        """async_session_attr=getattr(AsyncSession,name,None)session_attr=getattr(self.session,name)ifnotinspect.iscoroutinefunction(async_session_attr):returnsession_attrasyncdefasync_wrapper(*args,**kwargs):returnsession_attr(*args,**kwargs)returnasync_wrapperclassUserDatabase(Generic[UP,ID],SQLAlchemyUserDatabase[UP,ID]):session:Sessiondef__init__(self,session:AsyncSession,user_table:type[UP],oauth_account_table:type[SQLAlchemyBaseOAuthAccountTable]|None=None,    ):super().__init__(session,user_table,oauth_account_table)self.session=FakeAsyncSession(session)classAccessTokenDatabase(Generic[AP],SQLAlchemyAccessTokenDatabase[AP]):session:Sessiondef__init__(self,session:AsyncSession,access_token_table:type[AP]):super().__init__(session,access_token_table)self.session=FakeAsyncSession(session)