|
|
|
@ -9,12 +9,12 @@ from configs import dify_config
|
|
|
|
from constants.languages import supported_language
|
|
|
|
from constants.languages import supported_language
|
|
|
|
from controllers.console import api
|
|
|
|
from controllers.console import api
|
|
|
|
from controllers.console.auth.error import (
|
|
|
|
from controllers.console.auth.error import (
|
|
|
|
|
|
|
|
AccountInFreezeError,
|
|
|
|
EmailAlreadyInUseError,
|
|
|
|
EmailAlreadyInUseError,
|
|
|
|
EmailChangeLimitError,
|
|
|
|
EmailChangeLimitError,
|
|
|
|
EmailCodeError,
|
|
|
|
EmailCodeError,
|
|
|
|
InvalidEmailError,
|
|
|
|
InvalidEmailError,
|
|
|
|
InvalidTokenError,
|
|
|
|
InvalidTokenError,
|
|
|
|
AccountInFreezeError
|
|
|
|
|
|
|
|
)
|
|
|
|
)
|
|
|
|
from controllers.console.error import AccountNotFound, EmailSendIpLimitError
|
|
|
|
from controllers.console.error import AccountNotFound, EmailSendIpLimitError
|
|
|
|
from controllers.console.workspace.error import (
|
|
|
|
from controllers.console.workspace.error import (
|
|
|
|
@ -480,17 +480,19 @@ class ChangeEmailResetApi(Resource):
|
|
|
|
parser.add_argument("token", type=str, required=True, nullable=False, location="json")
|
|
|
|
parser.add_argument("token", type=str, required=True, nullable=False, location="json")
|
|
|
|
args = parser.parse_args()
|
|
|
|
args = parser.parse_args()
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
if AccountService.is_account_in_freeze(args["new_email"]):
|
|
|
|
|
|
|
|
raise AccountInFreezeError()
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
if not AccountService.check_email_unique(args["new_email"]):
|
|
|
|
|
|
|
|
raise EmailAlreadyInUseError()
|
|
|
|
|
|
|
|
|
|
|
|
reset_data = AccountService.get_change_email_data(args["token"])
|
|
|
|
reset_data = AccountService.get_change_email_data(args["token"])
|
|
|
|
if not reset_data:
|
|
|
|
if not reset_data:
|
|
|
|
raise InvalidTokenError()
|
|
|
|
raise InvalidTokenError()
|
|
|
|
|
|
|
|
|
|
|
|
AccountService.revoke_change_email_token(args["token"])
|
|
|
|
AccountService.revoke_change_email_token(args["token"])
|
|
|
|
|
|
|
|
|
|
|
|
if not AccountService.check_email_unique(args["new_email"]):
|
|
|
|
|
|
|
|
raise EmailAlreadyInUseError()
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
if AccountService.is_account_in_freeze(args["new_email"]):
|
|
|
|
|
|
|
|
raise AccountInFreezeError()
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
old_email = reset_data.get("old_email", "")
|
|
|
|
old_email = reset_data.get("old_email", "")
|
|
|
|
if current_user.email != old_email:
|
|
|
|
if current_user.email != old_email:
|
|
|
|
|