Skip to content

Commit

Permalink
fix: redis key invalid
Browse files Browse the repository at this point in the history
  • Loading branch information
Sotatek-PhucNguyen5 committed Oct 6, 2023
1 parent 3c21025 commit fecdaae
Showing 1 changed file with 6 additions and 3 deletions.
Expand Up @@ -2,6 +2,7 @@

import com.mashape.unirest.http.JsonNode;
import jakarta.servlet.http.HttpServletRequest;
import java.sql.Timestamp;
import java.time.Instant;
import java.util.Collections;
import java.util.HashMap;
Expand Down Expand Up @@ -100,12 +101,14 @@ public SignInResponse signIn(SignInRequest signInRequest) {
attributes.put(CommonConstant.ATTRIBUTE_LOGIN_TIME, List.of(String.valueOf(Instant.now())));
user.setAttributes(attributes);
usersResource.get(user.getId()).update(user);
redisProvider.setValue(user.getId() + "_" + Instant.now(), response.getToken());
redisProvider.setValue(user.getId() + "_" + Instant.now(), response.getRefreshToken());
redisProvider.setValue(user.getId() + Timestamp.from(Instant.now()).getTime(),
response.getToken());
redisProvider.setValue(user.getId() + Timestamp.from(Instant.now()).getTime(),
response.getRefreshToken());
List<String> roles = jwtProvider.getRolesFromJwtToken(response.getToken());
roles.forEach(role -> {
String roleId = keycloakProvider.getRoleIdByRoleName(role);
redisProvider.setValue(roleId + "_" + Instant.now(), user.getId());
redisProvider.setValue(roleId + Timestamp.from(Instant.now()).getTime(), user.getId());
});
return SignInResponse.builder().token(response.getToken()).address(signInRequest.getAddress())
.email(signInRequest.getEmail()).tokenType(CommonConstant.TOKEN_TYPE)
Expand Down

0 comments on commit fecdaae

Please sign in to comment.