Commitd895281

authored

Merge pull request#1270 from lowcoder-org/fix/db_concurrency

mongodb concurrency issue fixed

2 parentsbdd356b +498727e commitd895281Copy full SHA for d895281

File tree

-1

lines changed

-1

lines changed

Lines changed: 2 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -43,6 +43,8 @@ public interface UserService {`
`43`	`43`
`44`	`44`	`Mono<User>addNewConnectionAndReturnUser(StringuserId,AuthUserauthUser);`
`45`	`45`
	`46`	`+Mono<User>saveUser(Useruser);`
	`47`	`+`
`46`	`48`	`Mono<Void>deleteProfilePhoto(Uservisitor);`
`47`	`49`
`48`	`50`	`Mono<Boolean>updatePassword(StringuserId,StringoldPassword,StringnewPassword);`

Lines changed: 5 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -225,6 +225,11 @@ public Mono<User> addNewConnectionAndReturnUser(String userId, AuthUser authUser`
`225`	`225`	`.flatMap(repository::save);`
`226`	`226`	`}`
`227`	`227`
	`228`	`+@Override`
	`229`	`+publicMono<User>saveUser(Useruser) {`
	`230`	`+returnrepository.save(user);`
	`231`	`+ }`
	`232`	`+`
`228`	`233`	`@Override`
`229`	`234`	`publicMono<Void>deleteProfilePhoto(Uservisitor) {`
`230`	`235`	`StringuserAvatar =visitor.getAvatar();`

Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -164,7 +164,7 @@ public Mono<User> updateOrCreateUser(AuthUser authUser, boolean linkExistingUser`
`164`	`164`	`if (findByAuthUserFirst.userExist()) {`
`165`	`165`	`Useruser =findByAuthUserFirst.user();`
`166`	`166`	`updateConnection(authUser,user);`
`167`		`-returnuserService.update(user.getId(),user);`
	`167`	`+returnuserService.saveUser(user);`
`168`	`168`	`}`
`169`	`169`
`170`	`170`	`//If the user connection is not found with login id, but the user is`

Comments

(0)