Compare commits
No commits in common. "8d8adafcd302058c4b19f5d314372e36ee9e78a5" and "2e5cd2a6f154452e2146298d6180516f849c01a1" have entirely different histories.
8d8adafcd3
...
2e5cd2a6f1
@ -1,55 +1,25 @@
|
|||||||
package de.szut.casino.user;
|
package de.szut.casino.user;
|
||||||
|
|
||||||
import de.szut.casino.user.dto.CreateUserDto;
|
import de.szut.casino.user.dto.CreateUserDto;
|
||||||
import de.szut.casino.user.dto.GetUserDto;
|
|
||||||
import jakarta.validation.Valid;
|
import jakarta.validation.Valid;
|
||||||
import lombok.extern.slf4j.Slf4j;
|
|
||||||
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Autowired;
|
||||||
import org.springframework.http.HttpHeaders;
|
|
||||||
import org.springframework.http.HttpStatus;
|
|
||||||
import org.springframework.http.ResponseEntity;
|
import org.springframework.http.ResponseEntity;
|
||||||
import org.springframework.web.bind.annotation.*;
|
import org.springframework.web.bind.annotation.*;
|
||||||
|
|
||||||
@Slf4j
|
|
||||||
@RestController
|
@RestController
|
||||||
public class UserController {
|
public class UserController {
|
||||||
|
|
||||||
@Autowired
|
@Autowired
|
||||||
private UserService userService;
|
private UserService userService;
|
||||||
|
|
||||||
|
|
||||||
@GetMapping("/user/{id}")
|
@GetMapping("/user/{id}")
|
||||||
public ResponseEntity<?> getUser(@PathVariable String id) {
|
public ResponseEntity<?> getUser(@PathVariable String id) {
|
||||||
if (id == null || !userService.exists(id)) {
|
|
||||||
return ResponseEntity.notFound().build();
|
|
||||||
}
|
|
||||||
return ResponseEntity.ok(userService.getUser(id));
|
return ResponseEntity.ok(userService.getUser(id));
|
||||||
}
|
}
|
||||||
|
|
||||||
@PostMapping("/user")
|
@PostMapping("/user")
|
||||||
public ResponseEntity<?> createUser(@RequestBody @Valid CreateUserDto userData) {
|
public ResponseEntity<?> createUser(@RequestBody @Valid CreateUserDto userData) {
|
||||||
if (userService.exists(userData.getKeycloakId())) {
|
|
||||||
|
|
||||||
return this.redirect("/user/" + userData.getKeycloakId());
|
|
||||||
}
|
|
||||||
|
|
||||||
return ResponseEntity.ok(userService.createUser(userData));
|
return ResponseEntity.ok(userService.createUser(userData));
|
||||||
}
|
}
|
||||||
|
|
||||||
@GetMapping("/user")
|
|
||||||
public ResponseEntity<GetUserDto> getCurrentUser(@RequestHeader("Authorization") String token) {
|
|
||||||
GetUserDto userData = userService.getCurrentUser(token);
|
|
||||||
|
|
||||||
if (userData == null) {
|
|
||||||
return ResponseEntity.notFound().build();
|
|
||||||
}
|
|
||||||
|
|
||||||
return ResponseEntity.ok(userData);
|
|
||||||
}
|
|
||||||
|
|
||||||
private ResponseEntity<Object> redirect(String route) {
|
|
||||||
HttpHeaders headers = new HttpHeaders();
|
|
||||||
headers.add("Location", route);
|
|
||||||
|
|
||||||
return new ResponseEntity<>(headers, HttpStatus.FOUND);
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
@ -1,6 +1,5 @@
|
|||||||
package de.szut.casino.user;
|
package de.szut.casino.user;
|
||||||
|
|
||||||
import jakarta.persistence.Column;
|
|
||||||
import jakarta.persistence.Entity;
|
import jakarta.persistence.Entity;
|
||||||
import jakarta.persistence.GeneratedValue;
|
import jakarta.persistence.GeneratedValue;
|
||||||
import jakarta.persistence.Id;
|
import jakarta.persistence.Id;
|
||||||
@ -14,8 +13,6 @@ public class UserEntity {
|
|||||||
@Id
|
@Id
|
||||||
@GeneratedValue
|
@GeneratedValue
|
||||||
private Long id;
|
private Long id;
|
||||||
@Column(unique = true)
|
|
||||||
private String keycloakId;
|
private String keycloakId;
|
||||||
private String username;
|
private String username;
|
||||||
private float balance;
|
|
||||||
}
|
}
|
||||||
|
@ -1,22 +0,0 @@
|
|||||||
package de.szut.casino.user;
|
|
||||||
|
|
||||||
import de.szut.casino.user.dto.CreateUserDto;
|
|
||||||
import de.szut.casino.user.dto.GetUserDto;
|
|
||||||
import org.springframework.stereotype.Service;
|
|
||||||
|
|
||||||
@Service
|
|
||||||
public class UserMappingService {
|
|
||||||
public GetUserDto mapToGetUserDto(UserEntity user) {
|
|
||||||
return new GetUserDto(user.getKeycloakId(), user.getUsername(), user.getBalance());
|
|
||||||
}
|
|
||||||
|
|
||||||
public UserEntity mapToUserEntity(CreateUserDto createUserDto) {
|
|
||||||
UserEntity user = new UserEntity();
|
|
||||||
user.setKeycloakId(createUserDto.getKeycloakId());
|
|
||||||
user.setUsername(createUserDto.getUsername());
|
|
||||||
user.setBalance(0);
|
|
||||||
|
|
||||||
return user;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
@ -8,8 +8,9 @@ import java.util.Optional;
|
|||||||
|
|
||||||
@Service
|
@Service
|
||||||
public interface UserRepository extends JpaRepository<UserEntity, Long> {
|
public interface UserRepository extends JpaRepository<UserEntity, Long> {
|
||||||
|
boolean existsByUsername(String username);
|
||||||
|
|
||||||
@Query("SELECT u FROM UserEntity u WHERE u.keycloakId = ?1")
|
@Query("SELECT u FROM UserEntity u WHERE u.keycloakId = ?1")
|
||||||
Optional<UserEntity> findOneByKeycloakId(String keycloakId);
|
Optional<UserEntity> findOneByKeycloakId(String keycloakId);
|
||||||
|
|
||||||
boolean existsByKeycloakId(String keycloakId);
|
|
||||||
}
|
}
|
||||||
|
@ -2,21 +2,9 @@ package de.szut.casino.user;
|
|||||||
|
|
||||||
import de.szut.casino.user.dto.CreateUserDto;
|
import de.szut.casino.user.dto.CreateUserDto;
|
||||||
import de.szut.casino.user.dto.GetUserDto;
|
import de.szut.casino.user.dto.GetUserDto;
|
||||||
import de.szut.casino.user.dto.KeycloakUserDto;
|
|
||||||
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Autowired;
|
||||||
import org.springframework.http.HttpEntity;
|
|
||||||
import org.springframework.http.HttpMethod;
|
|
||||||
import org.springframework.http.ResponseEntity;
|
|
||||||
import org.springframework.stereotype.Service;
|
import org.springframework.stereotype.Service;
|
||||||
import org.springframework.web.client.RestTemplate;
|
|
||||||
|
|
||||||
import java.net.URI;
|
|
||||||
import java.net.http.HttpClient;
|
|
||||||
import org.springframework.http.HttpHeaders;
|
|
||||||
import java.net.http.HttpRequest;
|
|
||||||
import java.time.Duration;
|
|
||||||
import java.util.List;
|
|
||||||
import java.util.Map;
|
|
||||||
import java.util.Optional;
|
import java.util.Optional;
|
||||||
|
|
||||||
@Service
|
@Service
|
||||||
@ -24,14 +12,10 @@ public class UserService {
|
|||||||
@Autowired
|
@Autowired
|
||||||
private UserRepository userRepository;
|
private UserRepository userRepository;
|
||||||
|
|
||||||
@Autowired
|
|
||||||
private RestTemplate http;
|
|
||||||
|
|
||||||
@Autowired
|
|
||||||
private UserMappingService mappingService;
|
|
||||||
|
|
||||||
public UserEntity createUser(CreateUserDto createUserDto) {
|
public UserEntity createUser(CreateUserDto createUserDto) {
|
||||||
UserEntity user = mappingService.mapToUserEntity(createUserDto);
|
UserEntity user = new UserEntity();
|
||||||
|
user.setUsername(createUserDto.getUsername());
|
||||||
|
user.setKeycloakId(createUserDto.getKeycloakId());
|
||||||
userRepository.save(user);
|
userRepository.save(user);
|
||||||
|
|
||||||
return user;
|
return user;
|
||||||
@ -39,31 +23,15 @@ public class UserService {
|
|||||||
|
|
||||||
public GetUserDto getUser(String keycloakId) {
|
public GetUserDto getUser(String keycloakId) {
|
||||||
Optional<UserEntity> user = this.userRepository.findOneByKeycloakId(keycloakId);
|
Optional<UserEntity> user = this.userRepository.findOneByKeycloakId(keycloakId);
|
||||||
return user.map(userEntity -> mappingService.mapToGetUserDto(userEntity)).orElse(null);
|
if (user.isPresent()) {
|
||||||
|
System.out.println(user.get());
|
||||||
}
|
GetUserDto getUserDto = new GetUserDto();
|
||||||
|
getUserDto.setKeycloakId(user.get().getKeycloakId());
|
||||||
public GetUserDto getCurrentUser(String token) {
|
getUserDto.setUsername(user.get().getUsername());
|
||||||
KeycloakUserDto userData = getKeycloakUserInfo(token);
|
return getUserDto;
|
||||||
|
|
||||||
if (userData == null) {
|
|
||||||
return null;
|
|
||||||
}
|
}
|
||||||
Optional<UserEntity> user = this.userRepository.findOneByKeycloakId(userData.getSub());
|
System.out.println("User not found: "+keycloakId);
|
||||||
|
|
||||||
return user.map(userEntity -> mappingService.mapToGetUserDto(userEntity)).orElse(null);
|
return null;
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
private KeycloakUserDto getKeycloakUserInfo(String token) {
|
|
||||||
HttpHeaders headers = new HttpHeaders();
|
|
||||||
headers.set("Authorization", token);
|
|
||||||
ResponseEntity<KeycloakUserDto> response = this.http.exchange("http://localhost:9090/realms/LF12/protocol/openid-connect/userinfo", HttpMethod.GET, new HttpEntity<>(headers), KeycloakUserDto.class);
|
|
||||||
|
|
||||||
return response.getBody();
|
|
||||||
}
|
|
||||||
|
|
||||||
public boolean exists(String keycloakId) {
|
|
||||||
return userRepository.existsByKeycloakId(keycloakId);
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@ -12,5 +12,4 @@ import lombok.Setter;
|
|||||||
public class GetUserDto {
|
public class GetUserDto {
|
||||||
private String keycloakId;
|
private String keycloakId;
|
||||||
private String username;
|
private String username;
|
||||||
private float balance;
|
|
||||||
}
|
}
|
||||||
|
@ -1,15 +0,0 @@
|
|||||||
package de.szut.casino.user.dto;
|
|
||||||
|
|
||||||
import lombok.AllArgsConstructor;
|
|
||||||
import lombok.Getter;
|
|
||||||
import lombok.NoArgsConstructor;
|
|
||||||
import lombok.Setter;
|
|
||||||
|
|
||||||
@Getter
|
|
||||||
@Setter
|
|
||||||
@AllArgsConstructor
|
|
||||||
@NoArgsConstructor
|
|
||||||
public class KeycloakUserDto {
|
|
||||||
private String sub;
|
|
||||||
private String preferred_username;
|
|
||||||
}
|
|
@ -1,8 +1,11 @@
|
|||||||
import { CanActivateFn, Router } from '@angular/router';
|
import { ActivatedRouteSnapshot, CanActivateFn, Router, RouterStateSnapshot } from '@angular/router';
|
||||||
import { inject } from '@angular/core';
|
import { inject } from '@angular/core';
|
||||||
import { KeycloakService } from 'keycloak-angular';
|
import { KeycloakService } from 'keycloak-angular';
|
||||||
|
|
||||||
export const authGuard: CanActivateFn = async () => {
|
export const authGuard: CanActivateFn = async (
|
||||||
|
route: ActivatedRouteSnapshot,
|
||||||
|
state: RouterStateSnapshot
|
||||||
|
) => {
|
||||||
const keycloakService = inject(KeycloakService);
|
const keycloakService = inject(KeycloakService);
|
||||||
const router = inject(Router);
|
const router = inject(Router);
|
||||||
|
|
||||||
|
@ -1,4 +1,4 @@
|
|||||||
import { ChangeDetectionStrategy, Component, inject, OnInit } from '@angular/core';
|
import { Component, inject, OnInit } from '@angular/core';
|
||||||
import { UserService } from '../service/user.service';
|
import { UserService } from '../service/user.service';
|
||||||
import { KeycloakService } from 'keycloak-angular';
|
import { KeycloakService } from 'keycloak-angular';
|
||||||
import { Router } from '@angular/router';
|
import { Router } from '@angular/router';
|
||||||
@ -8,19 +8,18 @@ import { Router } from '@angular/router';
|
|||||||
standalone: true,
|
standalone: true,
|
||||||
imports: [],
|
imports: [],
|
||||||
templateUrl: './login-success.component.html',
|
templateUrl: './login-success.component.html',
|
||||||
styleUrl: './login-success.component.css',
|
styleUrl: './login-success.component.css'
|
||||||
changeDetection: ChangeDetectionStrategy.OnPush,
|
|
||||||
})
|
})
|
||||||
export class LoginSuccessComponent implements OnInit {
|
export class LoginSuccessComponent implements OnInit{
|
||||||
private userService: UserService = inject(UserService);
|
private userService: UserService = inject(UserService);
|
||||||
private keycloakService: KeycloakService = inject(KeycloakService);
|
private keycloakService: KeycloakService = inject(KeycloakService);
|
||||||
private router: Router = inject(Router);
|
private router: Router = inject(Router);
|
||||||
|
|
||||||
async ngOnInit() {
|
async ngOnInit() {
|
||||||
const userProfile = await this.keycloakService.loadUserProfile();
|
const userProfile = await this.keycloakService.loadUserProfile();
|
||||||
const user = await this.userService.getOrCreateUser(userProfile);
|
const user = this.userService.getCurrentUser(userProfile);
|
||||||
sessionStorage.setItem('user', JSON.stringify(user));
|
sessionStorage.setItem('user', JSON.stringify(user));
|
||||||
|
|
||||||
this.router.navigate(['']);
|
// this.router.navigate(['']);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@ -1,4 +0,0 @@
|
|||||||
export interface User {
|
|
||||||
keycloakId: string;
|
|
||||||
username: string;
|
|
||||||
}
|
|
@ -1,8 +1,7 @@
|
|||||||
import { inject, Injectable } from '@angular/core';
|
import { inject, Injectable } from '@angular/core';
|
||||||
import { HttpClient } from '@angular/common/http';
|
import { HttpClient } from '@angular/common/http';
|
||||||
import { KeycloakProfile } from 'keycloak-js';
|
import { KeycloakProfile } from 'keycloak-js';
|
||||||
import { Observable } from 'rxjs';
|
import { async } from 'rxjs';
|
||||||
import { User } from '../model/User';
|
|
||||||
|
|
||||||
@Injectable({
|
@Injectable({
|
||||||
providedIn: 'root',
|
providedIn: 'root',
|
||||||
@ -10,28 +9,26 @@ import { User } from '../model/User';
|
|||||||
export class UserService {
|
export class UserService {
|
||||||
private http: HttpClient = inject(HttpClient);
|
private http: HttpClient = inject(HttpClient);
|
||||||
|
|
||||||
public getUser(id: string): Observable<User | null> {
|
public getUser(id: string) {
|
||||||
return this.http.get<User | null>(`/backend/user/${id}`);
|
return this.http.get<{ keycloakId: string, username: string } | null>(`/backend/user/${id}`);
|
||||||
}
|
}
|
||||||
|
|
||||||
public createUser(id: string, username: string): Observable<User> {
|
public createUser(id: string, username: string) {
|
||||||
return this.http.post<User>('/backend/user', {
|
return this.http.post<{ keycloakId: string, username: string }>('/backend/user', {
|
||||||
keycloakId: id,
|
keycloakId: id,
|
||||||
username: username,
|
username: username,
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
public async getOrCreateUser(userProfile: KeycloakProfile) {
|
public async getCurrentUser(userProfile: KeycloakProfile) {
|
||||||
if (userProfile.id == null) {
|
if (userProfile.id == null) {
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
return await this.getUser(userProfile.id)
|
return await this.getUser(userProfile.id).toPromise().then(async user => {
|
||||||
.toPromise()
|
if (user) {
|
||||||
.then(async (user) => {
|
return user;
|
||||||
if (user) {
|
}
|
||||||
return user;
|
return await this.createUser(userProfile.id ?? '', userProfile.username ?? '').toPromise();
|
||||||
}
|
});
|
||||||
return await this.createUser(userProfile.id ?? '', userProfile.username ?? '').toPromise();
|
|
||||||
});
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
Loading…
x
Reference in New Issue
Block a user