@@ -1,4 +1,5 @@ import logging + from typing import Any, Tuple from uuid import UUID @@ -292,6 +293,9 @@ class UserService: # For Social Auth pipeline def update_profile_picture_social(*args, **kwargs): + logger.info(f'{args=} from update_profile_picture_social') + logger.info(f'{kwargs=} from update_profile_picture_social') + response = kwargs['response'] air_user: CustomUserModel = kwargs['user'] @@ -308,13 +312,116 @@ def update_profile_picture_social(*args, **kwargs): def confirm_oauth_email(user: Any | None = None, *args, **kwargs): + logger.info(f'{user=} from confirm_oauth_email') + logger.info(f'{args=} from confirm_oauth_email') + logger.info(f'{kwargs=} from confirm_oauth_email') if user: user.is_confirmed = True user.save() def detect_email(backend, response, details, **kwargs): + logger.info(f'{backend=} from detect_email') + logger.info(f'{response=} from detect_email') + logger.info(f'{details=} from detect_email') + logger.info(f'{kwargs=} from detect_email') if backend.name == 'yandex-oauth2' and not response.get('default_email') and response.get('login'): details['email'] = f'{response["login"]}@yandex.ru' details['username'] = response['login'] return kwargs | {'backend': backend} | {'response': response} | {'details': details} + + +def social_details(backend, details, response, *args, **kwargs): + from social_core.pipeline.social_auth import social_details as oauth_social_details + logger.info(f'{backend=} from social_details') + logger.info(f'{details=} from social_details') + logger.info(f'{response=} from social_details') + logger.info(f'{args=} from social_details') + logger.info(f'{kwargs=} from social_details') + oauth_social_details(backend, details, response, *args, **kwargs) + + +def social_uid(backend, details, response, *args, **kwargs): + from social_core.pipeline.social_auth import social_uid as oauth_social_uid + logger.info(f'{backend=} from social_uid') + logger.info(f'{details=} from social_uid') + logger.info(f'{response=} from social_uid') + logger.info(f'{args=} from social_uid') + logger.info(f'{kwargs=} from social_uid') + oauth_social_uid(backend, details, response, *args, **kwargs) + + +def social_user(backend, uid, user=None, *args, **kwargs): + from social_core.pipeline.social_auth import social_user as oauth_social_user + logger.info(f'{backend=} from social_user') + logger.info(f'{uid=} from social_user') + logger.info(f'{user=} from social_user') + logger.info(f'{args=} from social_user') + logger.info(f'{kwargs=} from social_user') + oauth_social_user(backend, uid, user, *args, **kwargs) + + +def get_username(strategy, details, backend, user=None, *args, **kwargs): + from social_core.pipeline.user import get_username as oauth_get_username + logger.info(f'{strategy=} from get_username') + logger.info(f'{details=} from get_username') + logger.info(f'{backend=} from get_username') + logger.info(f'{user=} from get_username') + logger.info(f'{args=} from get_username') + logger.info(f'{kwargs=} from get_username') + oauth_get_username(strategy, details, backend, user=None, *args, **kwargs) + + +def associate_by_email(backend, details, user=None, *args, **kwargs): + from social_core.pipeline.social_auth import associate_by_email as oauth_associate_by_email + logger.info(f'{backend=} from associate_by_email') + logger.info(f'{details=} from associate_by_email') + logger.info(f'{user=} from associate_by_email') + logger.info(f'{args=} from associate_by_email') + logger.info(f'{kwargs=} from associate_by_email') + oauth_associate_by_email(backend, details, user=None, *args, **kwargs) + + +def create_user(strategy, details, backend, user=None, *args, **kwargs): + from social_core.pipeline.user import create_user as oauth_create_user + logger.info(f'{strategy=} from create_user') + logger.info(f'{details=} from create_user') + logger.info(f'{backend=} from create_user') + logger.info(f'{user=} from create_user') + logger.info(f'{args=} from create_user') + logger.info(f'{kwargs=} from create_user') + oauth_create_user(strategy, details, backend, user=None, *args, **kwargs) + + +def associate_user(backend, uid, user=None, social=None, *args, **kwargs): + from social_core.pipeline.social_auth import associate_user as oauth_associate_user + logger.info(f'{backend=} from associate_user') + logger.info(f'{uid=} from associate_user') + logger.info(f'{user=} from associate_user') + logger.info(f'{social=} from associate_user') + logger.info(f'{args=} from associate_user') + logger.info(f'{kwargs=} from associate_user') + oauth_associate_user(backend, uid, user=None, social=None, *args, **kwargs) + + +def load_extra_data(backend, details, response, uid, user, *args, **kwargs): + from social_core.pipeline.social_auth import load_extra_data as oauth_load_extra_data + logger.info(f'{backend=} from load_extra_data') + logger.info(f'{details=} from load_extra_data') + logger.info(f'{response=} from load_extra_data') + logger.info(f'{uid=} from load_extra_data') + logger.info(f'{user=} from load_extra_data') + logger.info(f'{args=} from load_extra_data') + logger.info(f'{kwargs=} from load_extra_data') + oauth_load_extra_data(backend, details, response, uid, user, *args, **kwargs) + + +def user_details(strategy, details, backend, user=None, *args, **kwargs): + from social_core.pipeline.user import user_details as oauth_user_details + logger.info(f'{strategy=} from user_details') + logger.info(f'{details=} from user_details') + logger.info(f'{backend=} from user_details') + logger.info(f'{user=} from user_details') + logger.info(f'{args=} from user_details') + logger.info(f'{kwargs=} from user_details') + oauth_user_details(strategy, details, backend, user=None, *args, **kwargs)