Compare commits
14 Commits
feature/do
...
3b5046f1db
| Author | SHA1 | Date | |
|---|---|---|---|
| 3b5046f1db | |||
| 5e2976180c | |||
| 74391f8a46 | |||
| 4049dbbdaa | |||
| 8ff73cda2b | |||
| 08d0b1730a | |||
| 48b2ffd7b2 | |||
| 877e134166 | |||
| ec2bb1bcc6 | |||
| 6c3c94c5a3 | |||
| a34d2ddcf0 | |||
| b3801eb5e7 | |||
| 4dfdb54bb4 | |||
| 0a278530fb |
@@ -3,7 +3,7 @@ WORKDIR /app
|
|||||||
COPY gradlew .
|
COPY gradlew .
|
||||||
COPY gradle/ gradle/
|
COPY gradle/ gradle/
|
||||||
COPY build.gradle.kts settings.gradle.kts ./
|
COPY build.gradle.kts settings.gradle.kts ./
|
||||||
RUN ./gradlew dependencies --no-daemon
|
RUN chmod +x gradlew && ./gradlew dependencies --no-daemon
|
||||||
COPY src/ src/
|
COPY src/ src/
|
||||||
RUN ./gradlew bootJar --no-daemon
|
RUN ./gradlew bootJar --no-daemon
|
||||||
|
|
||||||
|
|||||||
@@ -1,20 +1,13 @@
|
|||||||
# All services use host networking so inter-service traffic goes over loopback with no bridge overhead.
|
|
||||||
# Ports (all bound directly on the host):
|
|
||||||
# API: 8080
|
|
||||||
# MariaDB: 3306
|
|
||||||
# Adminer: 8888
|
|
||||||
# MinIO API: 9000
|
|
||||||
# MinIO Console: 9001
|
|
||||||
|
|
||||||
services:
|
services:
|
||||||
mariadb:
|
mariadb:
|
||||||
image: mariadb:11
|
image: mariadb
|
||||||
network_mode: host
|
|
||||||
environment:
|
environment:
|
||||||
MYSQL_ROOT_PASSWORD: ${DB_ROOT_PASSWORD}
|
MARIADB_ROOT_PASSWORD: ${DB_ROOT_PASSWORD}
|
||||||
MYSQL_DATABASE: ${DB_NAME}
|
MARIADB_DATABASE: ${DB_NAME}
|
||||||
MYSQL_USER: ${DB_USER}
|
MARIADB_USER: ${DB_USER}
|
||||||
MYSQL_PASSWORD: ${DB_PASSWORD}
|
MARIADB_PASSWORD: ${DB_PASSWORD}
|
||||||
|
ports:
|
||||||
|
- 3306:3306
|
||||||
volumes:
|
volumes:
|
||||||
- mariadb_data:/var/lib/mysql
|
- mariadb_data:/var/lib/mysql
|
||||||
healthcheck:
|
healthcheck:
|
||||||
@@ -24,55 +17,54 @@ services:
|
|||||||
timeout: 5s
|
timeout: 5s
|
||||||
retries: 5
|
retries: 5
|
||||||
restart: unless-stopped
|
restart: unless-stopped
|
||||||
|
|
||||||
adminer:
|
adminer:
|
||||||
image: adminer
|
image: adminer
|
||||||
network_mode: host
|
ports:
|
||||||
command: php -S [::]:8888 -t /var/www/html
|
- 8080:8080
|
||||||
restart: unless-stopped
|
restart: unless-stopped
|
||||||
|
|
||||||
minio:
|
minio:
|
||||||
image: minio/minio
|
image: minio/minio
|
||||||
network_mode: host
|
command: server /data --console-address ":9001"
|
||||||
command: server /data --console-address :9001
|
|
||||||
environment:
|
environment:
|
||||||
MINIO_ROOT_USER: ${MINIO_ACCESS_KEY}
|
MINIO_ROOT_USER: ${MINIO_ACCESS_KEY}
|
||||||
MINIO_ROOT_PASSWORD: ${MINIO_SECRET_KEY}
|
MINIO_ROOT_PASSWORD: ${MINIO_SECRET_KEY}
|
||||||
|
ports:
|
||||||
|
- 15900:9000 # API
|
||||||
|
- 15901:9001 # Web UI
|
||||||
volumes:
|
volumes:
|
||||||
- minio_data:/data
|
- minio_data:/data
|
||||||
healthcheck:
|
healthcheck:
|
||||||
test: ["CMD", "curl", "-f", "http://localhost:9000/minio/health/live"]
|
test: ["CMD", "curl", "-f", "http://192.168.187.181:15900/minio/health/live"]
|
||||||
start_period: 10s
|
start_period: 10s
|
||||||
interval: 10s
|
interval: 10s
|
||||||
timeout: 5s
|
timeout: 5s
|
||||||
retries: 5
|
retries: 5
|
||||||
restart: unless-stopped
|
restart: unless-stopped
|
||||||
|
|
||||||
api:
|
api:
|
||||||
build: .
|
image: git.halfbinary.net/aarbit/scavengerhunt-api:2
|
||||||
network_mode: host
|
|
||||||
environment:
|
environment:
|
||||||
DB_URL: jdbc:mariadb://localhost:3306/${DB_NAME}
|
DB_URL: jdbc:mariadb://192.168.187.181:3306/${DB_NAME}
|
||||||
DB_USER: ${DB_USER}
|
DB_USER: ${DB_USER}
|
||||||
DB_PASSWORD: ${DB_PASSWORD}
|
DB_PASSWORD: ${DB_PASSWORD}
|
||||||
JWT_SECRET: ${JWT_SECRET}
|
JWT_SECRET: ${JWT_SECRET}
|
||||||
MINIO_ENDPOINT: http://localhost:9000
|
MINIO_ENDPOINT: http://192.168.187.181:15900
|
||||||
MINIO_ACCESS_KEY: ${MINIO_ACCESS_KEY}
|
MINIO_ACCESS_KEY: ${MINIO_ACCESS_KEY}
|
||||||
MINIO_SECRET_KEY: ${MINIO_SECRET_KEY}
|
MINIO_SECRET_KEY: ${MINIO_SECRET_KEY}
|
||||||
MINIO_BUCKET: ${MINIO_BUCKET}
|
MINIO_BUCKET: ${MINIO_BUCKET}
|
||||||
|
ports:
|
||||||
|
- 15808:8080
|
||||||
depends_on:
|
depends_on:
|
||||||
mariadb:
|
mariadb:
|
||||||
condition: service_healthy
|
condition: service_healthy
|
||||||
minio:
|
minio:
|
||||||
condition: service_healthy
|
condition: service_healthy
|
||||||
healthcheck:
|
healthcheck:
|
||||||
test: ["CMD", "curl", "-f", "http://localhost:8080/actuator/health"]
|
test: ["CMD", "curl", "-f", "http://192.168.187.181:15808/actuator/health"]
|
||||||
start_period: 30s
|
start_period: 30s
|
||||||
interval: 15s
|
interval: 15s
|
||||||
timeout: 5s
|
timeout: 5s
|
||||||
retries: 5
|
retries: 5
|
||||||
restart: unless-stopped
|
restart: unless-stopped
|
||||||
|
|
||||||
volumes:
|
volumes:
|
||||||
mariadb_data:
|
mariadb_data:
|
||||||
minio_data:
|
minio_data:
|
||||||
@@ -27,9 +27,10 @@ class JwtUtil {
|
|||||||
}
|
}
|
||||||
|
|
||||||
// Generate JWT token
|
// Generate JWT token
|
||||||
fun generateToken(email: String): String {
|
fun generateToken(email: String, isAdmin: Boolean): String {
|
||||||
return Jwts.builder()
|
return Jwts.builder()
|
||||||
.subject(email)
|
.subject(email)
|
||||||
|
.claim("isAdmin", isAdmin)
|
||||||
.issuedAt(Date())
|
.issuedAt(Date())
|
||||||
.expiration(Date(System.currentTimeMillis() + jwtExpirationMs))
|
.expiration(Date(System.currentTimeMillis() + jwtExpirationMs))
|
||||||
.signWith(key)
|
.signWith(key)
|
||||||
|
|||||||
@@ -7,7 +7,6 @@ import org.springframework.security.authentication.AuthenticationManager
|
|||||||
import org.springframework.security.config.annotation.authentication.configuration.AuthenticationConfiguration
|
import org.springframework.security.config.annotation.authentication.configuration.AuthenticationConfiguration
|
||||||
import org.springframework.security.config.annotation.method.configuration.EnableMethodSecurity
|
import org.springframework.security.config.annotation.method.configuration.EnableMethodSecurity
|
||||||
import org.springframework.security.config.annotation.web.builders.HttpSecurity
|
import org.springframework.security.config.annotation.web.builders.HttpSecurity
|
||||||
import org.springframework.security.config.annotation.web.configurers.CorsConfigurer
|
|
||||||
import org.springframework.security.config.annotation.web.configurers.CsrfConfigurer
|
import org.springframework.security.config.annotation.web.configurers.CsrfConfigurer
|
||||||
import org.springframework.security.config.annotation.web.configurers.ExceptionHandlingConfigurer
|
import org.springframework.security.config.annotation.web.configurers.ExceptionHandlingConfigurer
|
||||||
import org.springframework.security.config.annotation.web.configurers.SessionManagementConfigurer
|
import org.springframework.security.config.annotation.web.configurers.SessionManagementConfigurer
|
||||||
@@ -16,6 +15,10 @@ import org.springframework.security.crypto.bcrypt.BCryptPasswordEncoder
|
|||||||
import org.springframework.security.crypto.password.PasswordEncoder
|
import org.springframework.security.crypto.password.PasswordEncoder
|
||||||
import org.springframework.security.web.SecurityFilterChain
|
import org.springframework.security.web.SecurityFilterChain
|
||||||
import org.springframework.security.web.authentication.UsernamePasswordAuthenticationFilter
|
import org.springframework.security.web.authentication.UsernamePasswordAuthenticationFilter
|
||||||
|
import org.springframework.web.cors.CorsConfiguration
|
||||||
|
import org.springframework.web.cors.CorsConfigurationSource
|
||||||
|
import org.springframework.web.cors.UrlBasedCorsConfigurationSource
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
@Configuration
|
@Configuration
|
||||||
@@ -48,13 +51,25 @@ class SecurityConfig(private val authEntrypointJwt: AuthEntrypointJwt,
|
|||||||
return BCryptPasswordEncoder()
|
return BCryptPasswordEncoder()
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Bean
|
||||||
|
fun corsConfigurationSource(): CorsConfigurationSource {
|
||||||
|
val config = CorsConfiguration()
|
||||||
|
config.allowedOriginPatterns = listOf("*")
|
||||||
|
config.allowedMethods = listOf("GET", "POST", "PUT", "PATCH", "DELETE", "OPTIONS")
|
||||||
|
config.allowedHeaders = listOf("*")
|
||||||
|
config.allowCredentials = true
|
||||||
|
val source = UrlBasedCorsConfigurationSource()
|
||||||
|
source.registerCorsConfiguration("/**", config)
|
||||||
|
return source
|
||||||
|
}
|
||||||
|
|
||||||
@Bean
|
@Bean
|
||||||
@Throws(Exception::class)
|
@Throws(Exception::class)
|
||||||
fun securityFilterChain(http: HttpSecurity): SecurityFilterChain? {
|
fun securityFilterChain(http: HttpSecurity): SecurityFilterChain? {
|
||||||
// Updated configuration for Spring Security 6.x
|
// Updated configuration for Spring Security 6.x
|
||||||
http
|
http
|
||||||
.csrf { csrf: CsrfConfigurer<HttpSecurity> -> csrf.disable() } // Disable CSRF
|
.csrf { csrf: CsrfConfigurer<HttpSecurity> -> csrf.disable() }
|
||||||
.cors { cors: CorsConfigurer<HttpSecurity> -> cors.disable() } // Disable CORS (or configure if needed)
|
.cors { cors -> cors.configurationSource(corsConfigurationSource()) }
|
||||||
.exceptionHandling { exceptionHandling: ExceptionHandlingConfigurer<HttpSecurity> ->
|
.exceptionHandling { exceptionHandling: ExceptionHandlingConfigurer<HttpSecurity> ->
|
||||||
exceptionHandling.authenticationEntryPoint(
|
exceptionHandling.authenticationEntryPoint(
|
||||||
authEntrypointJwt
|
authEntrypointJwt
|
||||||
@@ -67,7 +82,7 @@ class SecurityConfig(private val authEntrypointJwt: AuthEntrypointJwt,
|
|||||||
}
|
}
|
||||||
.authorizeHttpRequests { authorizeRequests ->
|
.authorizeHttpRequests { authorizeRequests ->
|
||||||
authorizeRequests
|
authorizeRequests
|
||||||
.requestMatchers("/auth/**", "/signup", "/docs/**")
|
.requestMatchers("/auth/**", "/signup", "/docs/**", "/actuator/**")
|
||||||
.permitAll()
|
.permitAll()
|
||||||
.anyRequest().authenticated()
|
.anyRequest().authenticated()
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -24,9 +24,9 @@ class AuthController(private val loginService: LoginService, private val jwtUtil
|
|||||||
@PostMapping("/login")
|
@PostMapping("/login")
|
||||||
fun login(@Valid @RequestBody body: LoginRequest): ResponseEntity<LoginResponse> {
|
fun login(@Valid @RequestBody body: LoginRequest): ResponseEntity<LoginResponse> {
|
||||||
val result = loginService.login(body.toDomain())
|
val result = loginService.login(body.toDomain())
|
||||||
val accessToken = jwtUtils.generateToken(result.email)
|
val accessToken = jwtUtils.generateToken(result.email, result.isAdmin)
|
||||||
val refreshToken = refreshTokenService.generateRefreshToken(result.email)
|
val refreshToken = refreshTokenService.generateRefreshToken(result.email)
|
||||||
val loginResponse = LoginResponse(accessToken, refreshToken)
|
val loginResponse = LoginResponse(accessToken, refreshToken, result.name)
|
||||||
return ResponseEntity.ok(loginResponse)
|
return ResponseEntity.ok(loginResponse)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -9,11 +9,13 @@ import net.halfbinary.scavengerhuntapi.model.converter.toDomain
|
|||||||
import net.halfbinary.scavengerhuntapi.model.converter.toResponse
|
import net.halfbinary.scavengerhuntapi.model.converter.toResponse
|
||||||
import net.halfbinary.scavengerhuntapi.model.request.HuntCreateRequest
|
import net.halfbinary.scavengerhuntapi.model.request.HuntCreateRequest
|
||||||
import net.halfbinary.scavengerhuntapi.model.request.HuntStatus
|
import net.halfbinary.scavengerhuntapi.model.request.HuntStatus
|
||||||
|
import net.halfbinary.scavengerhuntapi.model.request.HuntUpdateRequest
|
||||||
import net.halfbinary.scavengerhuntapi.model.response.HuntResponse
|
import net.halfbinary.scavengerhuntapi.model.response.HuntResponse
|
||||||
import net.halfbinary.scavengerhuntapi.service.HuntService
|
import net.halfbinary.scavengerhuntapi.service.HuntService
|
||||||
import org.springframework.http.ResponseEntity
|
import org.springframework.http.ResponseEntity
|
||||||
import org.springframework.security.access.prepost.PreAuthorize
|
import org.springframework.security.access.prepost.PreAuthorize
|
||||||
import org.springframework.web.bind.annotation.GetMapping
|
import org.springframework.web.bind.annotation.GetMapping
|
||||||
|
import org.springframework.web.bind.annotation.PatchMapping
|
||||||
import org.springframework.web.bind.annotation.PathVariable
|
import org.springframework.web.bind.annotation.PathVariable
|
||||||
import org.springframework.web.bind.annotation.PostMapping
|
import org.springframework.web.bind.annotation.PostMapping
|
||||||
import org.springframework.web.bind.annotation.RequestBody
|
import org.springframework.web.bind.annotation.RequestBody
|
||||||
@@ -44,6 +46,12 @@ class HuntController(private val huntService: HuntService) {
|
|||||||
return ResponseEntity.ok(huntService.getAllHunts(HuntStatus.UNSTARTED).map { it.toResponse() })
|
return ResponseEntity.ok(huntService.getAllHunts(HuntStatus.UNSTARTED).map { it.toResponse() })
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@GetMapping("/ongoing")
|
||||||
|
@Operation(summary = "Gets list of all ongoing Hunts")
|
||||||
|
fun getOngoingHunts(): ResponseEntity<List<HuntResponse>> {
|
||||||
|
return ResponseEntity.ok(huntService.getAllHunts(HuntStatus.ONGOING).map { it.toResponse() })
|
||||||
|
}
|
||||||
|
|
||||||
@PreAuthorize("hasRole('ADMIN')")
|
@PreAuthorize("hasRole('ADMIN')")
|
||||||
@Tag(name = "Admin")
|
@Tag(name = "Admin")
|
||||||
@PostMapping
|
@PostMapping
|
||||||
@@ -52,6 +60,14 @@ class HuntController(private val huntService: HuntService) {
|
|||||||
return ResponseEntity.ok(huntService.createHunt(huntRequest.toDomain()).toResponse())
|
return ResponseEntity.ok(huntService.createHunt(huntRequest.toDomain()).toResponse())
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@PreAuthorize("hasRole('ADMIN')")
|
||||||
|
@Tag(name = "Admin")
|
||||||
|
@PatchMapping("/{id}")
|
||||||
|
@Operation(summary = "Updates details of the specified Hunt")
|
||||||
|
fun updateHunt(@PathVariable("id") huntId: HuntId, @RequestBody body: HuntUpdateRequest): ResponseEntity<HuntResponse> {
|
||||||
|
return ResponseEntity.ok(huntService.updateHunt(huntId, body).toResponse())
|
||||||
|
}
|
||||||
|
|
||||||
@PreAuthorize("hasRole('ADMIN')")
|
@PreAuthorize("hasRole('ADMIN')")
|
||||||
@Tag(name = "Admin")
|
@Tag(name = "Admin")
|
||||||
@GetMapping("/hunter/{hunterId}")
|
@GetMapping("/hunter/{hunterId}")
|
||||||
|
|||||||
@@ -16,7 +16,6 @@ import org.springframework.web.bind.annotation.GetMapping
|
|||||||
import org.springframework.web.bind.annotation.PathVariable
|
import org.springframework.web.bind.annotation.PathVariable
|
||||||
import org.springframework.web.bind.annotation.PostMapping
|
import org.springframework.web.bind.annotation.PostMapping
|
||||||
import org.springframework.web.bind.annotation.RequestMapping
|
import org.springframework.web.bind.annotation.RequestMapping
|
||||||
import org.springframework.web.bind.annotation.RequestParam
|
|
||||||
import org.springframework.web.bind.annotation.RestController
|
import org.springframework.web.bind.annotation.RestController
|
||||||
|
|
||||||
@RestController
|
@RestController
|
||||||
@@ -27,13 +26,13 @@ class HunterController(private val hunterService: HunterService,
|
|||||||
|
|
||||||
@GetMapping("/hunt/ongoing")
|
@GetMapping("/hunt/ongoing")
|
||||||
@Operation(summary = "Gets list of all currently running Hunts (filtered by the calling hunter)")
|
@Operation(summary = "Gets list of all currently running Hunts (filtered by the calling hunter)")
|
||||||
fun getOngoingHunts(authentication: Authentication, @RequestParam status: HuntStatus?): ResponseEntity<List<HuntResponse>> {
|
fun getOngoingHunts(authentication: Authentication): ResponseEntity<List<HuntResponse>> {
|
||||||
val email = authentication.name
|
val email = authentication.name
|
||||||
val isAdmin = hunterService.getHunterByEmail(email).isAdmin
|
val isAdmin = hunterService.getHunterByEmail(email).isAdmin
|
||||||
return if(isAdmin) {
|
return if(isAdmin) {
|
||||||
ResponseEntity.ok(huntService.getAllHunts(HuntStatus.ONGOING).map { it.toResponse() })
|
ResponseEntity.ok(huntService.getAllHunts(HuntStatus.ONGOING).map { it.toResponse() })
|
||||||
} else {
|
} else {
|
||||||
ResponseEntity.ok(huntService.getHuntsByEmail(email, status).map { it.toResponse() })
|
ResponseEntity.ok(huntService.getHuntsByEmail(email, HuntStatus.ONGOING).map { it.toResponse() })
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -8,11 +8,15 @@ import net.halfbinary.scavengerhuntapi.model.ItemId
|
|||||||
import net.halfbinary.scavengerhuntapi.model.converter.toDomain
|
import net.halfbinary.scavengerhuntapi.model.converter.toDomain
|
||||||
import net.halfbinary.scavengerhuntapi.model.converter.toResponse
|
import net.halfbinary.scavengerhuntapi.model.converter.toResponse
|
||||||
import net.halfbinary.scavengerhuntapi.model.request.ItemRequest
|
import net.halfbinary.scavengerhuntapi.model.request.ItemRequest
|
||||||
|
import net.halfbinary.scavengerhuntapi.model.request.ItemUpdateRequest
|
||||||
import net.halfbinary.scavengerhuntapi.model.response.ItemResponse
|
import net.halfbinary.scavengerhuntapi.model.response.ItemResponse
|
||||||
import net.halfbinary.scavengerhuntapi.service.HuntService
|
import net.halfbinary.scavengerhuntapi.service.HuntService
|
||||||
import org.springframework.http.ResponseEntity
|
import org.springframework.http.ResponseEntity
|
||||||
import org.springframework.security.access.prepost.PreAuthorize
|
import org.springframework.security.access.prepost.PreAuthorize
|
||||||
|
import org.springframework.security.core.Authentication
|
||||||
|
import org.springframework.web.bind.annotation.DeleteMapping
|
||||||
import org.springframework.web.bind.annotation.GetMapping
|
import org.springframework.web.bind.annotation.GetMapping
|
||||||
|
import org.springframework.web.bind.annotation.PatchMapping
|
||||||
import org.springframework.web.bind.annotation.PathVariable
|
import org.springframework.web.bind.annotation.PathVariable
|
||||||
import org.springframework.web.bind.annotation.PostMapping
|
import org.springframework.web.bind.annotation.PostMapping
|
||||||
import org.springframework.web.bind.annotation.RequestBody
|
import org.springframework.web.bind.annotation.RequestBody
|
||||||
@@ -24,8 +28,8 @@ import org.springframework.web.bind.annotation.RestController
|
|||||||
class ItemController(private val huntService: HuntService) {
|
class ItemController(private val huntService: HuntService) {
|
||||||
|
|
||||||
@GetMapping
|
@GetMapping
|
||||||
fun getItemsForHunt(@PathVariable huntId: HuntId): ResponseEntity<List<ItemResponse>> {
|
fun getItemsForHunt(@PathVariable huntId: HuntId, authentication: Authentication): ResponseEntity<List<ItemResponse>> {
|
||||||
return ResponseEntity.ok(huntService.getItemsForHunt(huntId).map { it.toResponse() })
|
return ResponseEntity.ok(huntService.getItemsForHunt(huntId, authentication.name).map { it.toResponse() })
|
||||||
}
|
}
|
||||||
|
|
||||||
@GetMapping("/{itemId}")
|
@GetMapping("/{itemId}")
|
||||||
@@ -41,4 +45,21 @@ class ItemController(private val huntService: HuntService) {
|
|||||||
return ResponseEntity.ok(huntService.addItemToHunt(huntId, body.toDomain()).toResponse())
|
return ResponseEntity.ok(huntService.addItemToHunt(huntId, body.toDomain()).toResponse())
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@PreAuthorize("hasRole('ADMIN')")
|
||||||
|
@Tag(name = "Admin")
|
||||||
|
@PatchMapping("/{itemId}")
|
||||||
|
@Operation(summary = "Updates name and/or points for the specified Item in the specified Hunt")
|
||||||
|
fun updateItem(@PathVariable huntId: HuntId, @PathVariable itemId: ItemId, @RequestBody body: ItemUpdateRequest): ResponseEntity<ItemResponse> {
|
||||||
|
return ResponseEntity.ok(huntService.updateItem(huntId, itemId, body).toResponse())
|
||||||
|
}
|
||||||
|
|
||||||
|
@PreAuthorize("hasRole('ADMIN')")
|
||||||
|
@Tag(name = "Admin")
|
||||||
|
@DeleteMapping("/{itemId}")
|
||||||
|
@Operation(summary = "Deletes the specified Item from the specified Hunt")
|
||||||
|
fun deleteItem(@PathVariable huntId: HuntId, @PathVariable itemId: ItemId): ResponseEntity<Unit> {
|
||||||
|
huntService.deleteItem(huntId, itemId)
|
||||||
|
return ResponseEntity.noContent().build()
|
||||||
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
@@ -7,7 +7,9 @@ import net.halfbinary.scavengerhuntapi.model.ItemId
|
|||||||
import net.halfbinary.scavengerhuntapi.model.PhotoId
|
import net.halfbinary.scavengerhuntapi.model.PhotoId
|
||||||
import net.halfbinary.scavengerhuntapi.model.TeamId
|
import net.halfbinary.scavengerhuntapi.model.TeamId
|
||||||
import net.halfbinary.scavengerhuntapi.model.converter.toResponse
|
import net.halfbinary.scavengerhuntapi.model.converter.toResponse
|
||||||
|
import net.halfbinary.scavengerhuntapi.model.converter.toSummaryResponse
|
||||||
import net.halfbinary.scavengerhuntapi.model.request.TeamRequest
|
import net.halfbinary.scavengerhuntapi.model.request.TeamRequest
|
||||||
|
import net.halfbinary.scavengerhuntapi.model.response.HunterSummaryResponse
|
||||||
import net.halfbinary.scavengerhuntapi.model.response.PhotoResponse
|
import net.halfbinary.scavengerhuntapi.model.response.PhotoResponse
|
||||||
import net.halfbinary.scavengerhuntapi.model.response.TeamItemResponse
|
import net.halfbinary.scavengerhuntapi.model.response.TeamItemResponse
|
||||||
import net.halfbinary.scavengerhuntapi.model.response.TeamResponse
|
import net.halfbinary.scavengerhuntapi.model.response.TeamResponse
|
||||||
@@ -47,6 +49,12 @@ class TeamController(private val teamService: TeamService, private val photoServ
|
|||||||
return ResponseEntity.ok(teamService.getTeamFromHunt(huntId, teamId).toResponse())
|
return ResponseEntity.ok(teamService.getTeamFromHunt(huntId, teamId).toResponse())
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@GetMapping("/{teamId}/hunter")
|
||||||
|
@Operation(summary = "Get all Hunters for the specified Team in the specified Hunt")
|
||||||
|
fun getHuntersForTeam(@PathVariable huntId: HuntId, @PathVariable teamId: TeamId): ResponseEntity<List<HunterSummaryResponse>> {
|
||||||
|
return ResponseEntity.ok(teamService.getHuntersForTeam(huntId, teamId).map { it.toSummaryResponse() })
|
||||||
|
}
|
||||||
|
|
||||||
@GetMapping("/{teamId}/item/{itemId}")
|
@GetMapping("/{teamId}/item/{itemId}")
|
||||||
@Operation(summary = "Get found/not found status about the Item for the specified Team, Hunt, and Item")
|
@Operation(summary = "Get found/not found status about the Item for the specified Team, Hunt, and Item")
|
||||||
fun getItemForTeam(@PathVariable huntId: HuntId,
|
fun getItemForTeam(@PathVariable huntId: HuntId,
|
||||||
|
|||||||
@@ -3,6 +3,7 @@ package net.halfbinary.scavengerhuntapi.model.converter
|
|||||||
import net.halfbinary.scavengerhuntapi.model.domain.Hunter
|
import net.halfbinary.scavengerhuntapi.model.domain.Hunter
|
||||||
import net.halfbinary.scavengerhuntapi.model.record.HunterRecord
|
import net.halfbinary.scavengerhuntapi.model.record.HunterRecord
|
||||||
import net.halfbinary.scavengerhuntapi.model.request.HunterSignupRequest
|
import net.halfbinary.scavengerhuntapi.model.request.HunterSignupRequest
|
||||||
|
import net.halfbinary.scavengerhuntapi.model.response.HunterSummaryResponse
|
||||||
|
|
||||||
fun HunterSignupRequest.toDomain(): Hunter {
|
fun HunterSignupRequest.toDomain(): Hunter {
|
||||||
return Hunter(
|
return Hunter(
|
||||||
@@ -20,3 +21,7 @@ fun Hunter.toRecord(): HunterRecord {
|
|||||||
fun HunterRecord.toDomain(): Hunter {
|
fun HunterRecord.toDomain(): Hunter {
|
||||||
return Hunter(id, email, name, password, isAdmin)
|
return Hunter(id, email, name, password, isAdmin)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
fun Hunter.toSummaryResponse(): HunterSummaryResponse {
|
||||||
|
return HunterSummaryResponse(id, name)
|
||||||
|
}
|
||||||
@@ -1,13 +1,16 @@
|
|||||||
package net.halfbinary.scavengerhuntapi.model.domain
|
package net.halfbinary.scavengerhuntapi.model.domain
|
||||||
|
|
||||||
import net.halfbinary.scavengerhuntapi.model.HuntId
|
import net.halfbinary.scavengerhuntapi.model.HuntId
|
||||||
import java.time.LocalDateTime
|
import java.time.OffsetDateTime
|
||||||
import java.util.*
|
import java.util.*
|
||||||
|
|
||||||
data class Hunt(
|
data class Hunt(
|
||||||
val id: HuntId = UUID.randomUUID(),
|
val id: HuntId = UUID.randomUUID(),
|
||||||
val title: String,
|
val title: String,
|
||||||
val startDateTime: LocalDateTime,
|
val startDateTime: OffsetDateTime,
|
||||||
val endDateTime: LocalDateTime,
|
val endDateTime: OffsetDateTime,
|
||||||
val isTerminated: Boolean
|
val isTerminated: Boolean
|
||||||
)
|
) {
|
||||||
|
val isOngoing: Boolean
|
||||||
|
get() = !isTerminated && startDateTime < OffsetDateTime.now() && endDateTime > OffsetDateTime.now()
|
||||||
|
}
|
||||||
@@ -5,7 +5,7 @@ import net.halfbinary.scavengerhuntapi.model.HunterId
|
|||||||
import net.halfbinary.scavengerhuntapi.model.ItemId
|
import net.halfbinary.scavengerhuntapi.model.ItemId
|
||||||
import net.halfbinary.scavengerhuntapi.model.PhotoId
|
import net.halfbinary.scavengerhuntapi.model.PhotoId
|
||||||
import net.halfbinary.scavengerhuntapi.model.PhotoStatus
|
import net.halfbinary.scavengerhuntapi.model.PhotoStatus
|
||||||
import java.time.LocalDateTime
|
import java.time.OffsetDateTime
|
||||||
import java.util.*
|
import java.util.*
|
||||||
|
|
||||||
data class Photo(
|
data class Photo(
|
||||||
@@ -13,7 +13,7 @@ data class Photo(
|
|||||||
val itemId: ItemId,
|
val itemId: ItemId,
|
||||||
val huntId: HuntId,
|
val huntId: HuntId,
|
||||||
val hunterId: HunterId,
|
val hunterId: HunterId,
|
||||||
val foundDateTime: LocalDateTime,
|
val foundDateTime: OffsetDateTime,
|
||||||
val status: PhotoStatus,
|
val status: PhotoStatus,
|
||||||
val statusChangeDateTime: LocalDateTime
|
val statusChangeDateTime: OffsetDateTime
|
||||||
)
|
)
|
||||||
|
|||||||
@@ -4,7 +4,7 @@ import jakarta.persistence.Entity
|
|||||||
import jakarta.persistence.Id
|
import jakarta.persistence.Id
|
||||||
import jakarta.persistence.Table
|
import jakarta.persistence.Table
|
||||||
import net.halfbinary.scavengerhuntapi.model.HuntId
|
import net.halfbinary.scavengerhuntapi.model.HuntId
|
||||||
import java.time.LocalDateTime
|
import java.time.OffsetDateTime
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Represents a scavenger hunt event
|
* Represents a scavenger hunt event
|
||||||
@@ -16,7 +16,7 @@ data class HuntRecord(
|
|||||||
@Id
|
@Id
|
||||||
val id: HuntId,
|
val id: HuntId,
|
||||||
val title: String,
|
val title: String,
|
||||||
val startDateTime: LocalDateTime,
|
val startDateTime: OffsetDateTime,
|
||||||
val endDateTime: LocalDateTime,
|
val endDateTime: OffsetDateTime,
|
||||||
val isTerminated: Boolean
|
val isTerminated: Boolean
|
||||||
)
|
)
|
||||||
@@ -8,7 +8,7 @@ import net.halfbinary.scavengerhuntapi.model.HunterId
|
|||||||
import net.halfbinary.scavengerhuntapi.model.ItemId
|
import net.halfbinary.scavengerhuntapi.model.ItemId
|
||||||
import net.halfbinary.scavengerhuntapi.model.PhotoId
|
import net.halfbinary.scavengerhuntapi.model.PhotoId
|
||||||
import net.halfbinary.scavengerhuntapi.model.PhotoStatus
|
import net.halfbinary.scavengerhuntapi.model.PhotoStatus
|
||||||
import java.time.LocalDateTime
|
import java.time.OffsetDateTime
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Represents a found Item for a Hunt by a Hunter
|
* Represents a found Item for a Hunt by a Hunter
|
||||||
@@ -21,7 +21,7 @@ data class PhotoRecord(
|
|||||||
val itemId: ItemId,
|
val itemId: ItemId,
|
||||||
val huntId: HuntId,
|
val huntId: HuntId,
|
||||||
val hunterId: HunterId,
|
val hunterId: HunterId,
|
||||||
val foundDateTime: LocalDateTime,
|
val foundDateTime: OffsetDateTime,
|
||||||
val status: PhotoStatus,
|
val status: PhotoStatus,
|
||||||
val statusChangeDateTime: LocalDateTime,
|
val statusChangeDateTime: OffsetDateTime,
|
||||||
)
|
)
|
||||||
|
|||||||
@@ -4,7 +4,7 @@ import jakarta.persistence.Entity
|
|||||||
import jakarta.persistence.Id
|
import jakarta.persistence.Id
|
||||||
import jakarta.persistence.Table
|
import jakarta.persistence.Table
|
||||||
import net.halfbinary.scavengerhuntapi.model.RefreshId
|
import net.halfbinary.scavengerhuntapi.model.RefreshId
|
||||||
import java.time.LocalDateTime
|
import java.time.OffsetDateTime
|
||||||
|
|
||||||
@Entity
|
@Entity
|
||||||
@Table(name = "refresh_token")
|
@Table(name = "refresh_token")
|
||||||
@@ -12,5 +12,5 @@ data class RefreshTokenRecord(
|
|||||||
@Id
|
@Id
|
||||||
val token: RefreshId,
|
val token: RefreshId,
|
||||||
val email: String,
|
val email: String,
|
||||||
val expiryDateTime: LocalDateTime
|
val expiryDateTime: OffsetDateTime
|
||||||
)
|
)
|
||||||
|
|||||||
@@ -2,13 +2,13 @@ package net.halfbinary.scavengerhuntapi.model.request
|
|||||||
|
|
||||||
import jakarta.validation.constraints.Future
|
import jakarta.validation.constraints.Future
|
||||||
import jakarta.validation.constraints.NotBlank
|
import jakarta.validation.constraints.NotBlank
|
||||||
import java.time.LocalDateTime
|
import java.time.OffsetDateTime
|
||||||
|
|
||||||
data class HuntCreateRequest(
|
data class HuntCreateRequest(
|
||||||
@field:NotBlank(message = "Hunt title is required")
|
@field:NotBlank(message = "Hunt title is required")
|
||||||
val title: String,
|
val title: String,
|
||||||
@field:Future
|
@field:Future
|
||||||
val startDateTime: LocalDateTime,
|
val startDateTime: OffsetDateTime,
|
||||||
@field:Future
|
@field:Future
|
||||||
val endDateTime: LocalDateTime,
|
val endDateTime: OffsetDateTime,
|
||||||
)
|
)
|
||||||
|
|||||||
@@ -0,0 +1,10 @@
|
|||||||
|
package net.halfbinary.scavengerhuntapi.model.request
|
||||||
|
|
||||||
|
import java.time.OffsetDateTime
|
||||||
|
|
||||||
|
data class HuntUpdateRequest(
|
||||||
|
val title: String?,
|
||||||
|
val startDateTime: OffsetDateTime?,
|
||||||
|
val endDateTime: OffsetDateTime?,
|
||||||
|
val isTerminated: Boolean?
|
||||||
|
)
|
||||||
@@ -0,0 +1,6 @@
|
|||||||
|
package net.halfbinary.scavengerhuntapi.model.request
|
||||||
|
|
||||||
|
data class ItemUpdateRequest(
|
||||||
|
val name: String?,
|
||||||
|
val points: Int?
|
||||||
|
)
|
||||||
@@ -1,9 +1,9 @@
|
|||||||
package net.halfbinary.scavengerhuntapi.model.request
|
package net.halfbinary.scavengerhuntapi.model.request
|
||||||
|
|
||||||
import jakarta.validation.constraints.NotBlank
|
import jakarta.validation.constraints.NotNull
|
||||||
import net.halfbinary.scavengerhuntapi.model.PhotoStatus
|
import net.halfbinary.scavengerhuntapi.model.PhotoStatus
|
||||||
|
|
||||||
data class ReviewPhotoRequest(
|
data class ReviewPhotoRequest(
|
||||||
@field:NotBlank(message = "Status must not be blank")
|
@field:NotNull(message = "Status must not be null")
|
||||||
val status: PhotoStatus
|
val status: PhotoStatus
|
||||||
)
|
)
|
||||||
@@ -1,12 +1,12 @@
|
|||||||
package net.halfbinary.scavengerhuntapi.model.response
|
package net.halfbinary.scavengerhuntapi.model.response
|
||||||
|
|
||||||
import net.halfbinary.scavengerhuntapi.model.HuntId
|
import net.halfbinary.scavengerhuntapi.model.HuntId
|
||||||
import java.time.LocalDateTime
|
import java.time.OffsetDateTime
|
||||||
|
|
||||||
data class HuntResponse(
|
data class HuntResponse(
|
||||||
val id: HuntId,
|
val id: HuntId,
|
||||||
val title: String,
|
val title: String,
|
||||||
val startDateTime: LocalDateTime,
|
val startDateTime: OffsetDateTime,
|
||||||
val endDateTime: LocalDateTime,
|
val endDateTime: OffsetDateTime,
|
||||||
val isTerminated: Boolean
|
val isTerminated: Boolean
|
||||||
)
|
)
|
||||||
|
|||||||
@@ -0,0 +1,8 @@
|
|||||||
|
package net.halfbinary.scavengerhuntapi.model.response
|
||||||
|
|
||||||
|
import net.halfbinary.scavengerhuntapi.model.HunterId
|
||||||
|
|
||||||
|
data class HunterSummaryResponse(
|
||||||
|
val id: HunterId,
|
||||||
|
val name: String
|
||||||
|
)
|
||||||
@@ -4,5 +4,6 @@ import net.halfbinary.scavengerhuntapi.model.RefreshId
|
|||||||
|
|
||||||
data class LoginResponse(
|
data class LoginResponse(
|
||||||
val accessToken: String,
|
val accessToken: String,
|
||||||
val refreshToken: RefreshId
|
val refreshToken: RefreshId,
|
||||||
|
val name: String
|
||||||
)
|
)
|
||||||
|
|||||||
@@ -2,12 +2,12 @@ package net.halfbinary.scavengerhuntapi.model.response
|
|||||||
|
|
||||||
import net.halfbinary.scavengerhuntapi.model.PhotoId
|
import net.halfbinary.scavengerhuntapi.model.PhotoId
|
||||||
import net.halfbinary.scavengerhuntapi.model.PhotoStatus
|
import net.halfbinary.scavengerhuntapi.model.PhotoStatus
|
||||||
import java.time.LocalDateTime
|
import java.time.OffsetDateTime
|
||||||
|
|
||||||
data class PhotoResponse(
|
data class PhotoResponse(
|
||||||
val id: PhotoId,
|
val id: PhotoId,
|
||||||
val hunterName: String,
|
val hunterName: String,
|
||||||
val photoUploadDateTime: LocalDateTime,
|
val photoUploadDateTime: OffsetDateTime,
|
||||||
val photoStatus: PhotoStatus,
|
val photoStatus: PhotoStatus,
|
||||||
val photoStatusChangeDateTime: LocalDateTime,
|
val photoStatusChangeDateTime: OffsetDateTime,
|
||||||
)
|
)
|
||||||
|
|||||||
@@ -1,9 +1,13 @@
|
|||||||
package net.halfbinary.scavengerhuntapi.repository
|
package net.halfbinary.scavengerhuntapi.repository
|
||||||
|
|
||||||
|
import net.halfbinary.scavengerhuntapi.model.HuntId
|
||||||
|
import net.halfbinary.scavengerhuntapi.model.ItemId
|
||||||
import net.halfbinary.scavengerhuntapi.model.record.HuntItemRecord
|
import net.halfbinary.scavengerhuntapi.model.record.HuntItemRecord
|
||||||
import org.springframework.data.jpa.repository.JpaRepository
|
import org.springframework.data.jpa.repository.JpaRepository
|
||||||
import org.springframework.stereotype.Repository
|
import org.springframework.stereotype.Repository
|
||||||
import java.util.*
|
import java.util.*
|
||||||
|
|
||||||
@Repository
|
@Repository
|
||||||
interface HuntItemRepository : JpaRepository<HuntItemRecord, UUID>
|
interface HuntItemRepository : JpaRepository<HuntItemRecord, UUID> {
|
||||||
|
fun findByHuntIdAndItemId(huntId: HuntId, itemId: ItemId): HuntItemRecord?
|
||||||
|
}
|
||||||
|
|||||||
@@ -1,26 +1,31 @@
|
|||||||
package net.halfbinary.scavengerhuntapi.service
|
package net.halfbinary.scavengerhuntapi.service
|
||||||
|
|
||||||
|
import net.halfbinary.scavengerhuntapi.error.exception.ForbiddenException
|
||||||
import net.halfbinary.scavengerhuntapi.error.exception.NotFoundException
|
import net.halfbinary.scavengerhuntapi.error.exception.NotFoundException
|
||||||
import net.halfbinary.scavengerhuntapi.model.HuntId
|
import net.halfbinary.scavengerhuntapi.model.HuntId
|
||||||
import net.halfbinary.scavengerhuntapi.model.HunterId
|
import net.halfbinary.scavengerhuntapi.model.HunterId
|
||||||
|
import net.halfbinary.scavengerhuntapi.model.ItemId
|
||||||
import net.halfbinary.scavengerhuntapi.model.converter.toDomain
|
import net.halfbinary.scavengerhuntapi.model.converter.toDomain
|
||||||
import net.halfbinary.scavengerhuntapi.model.converter.toRecord
|
import net.halfbinary.scavengerhuntapi.model.converter.toRecord
|
||||||
import net.halfbinary.scavengerhuntapi.model.domain.Hunt
|
import net.halfbinary.scavengerhuntapi.model.domain.Hunt
|
||||||
import net.halfbinary.scavengerhuntapi.model.domain.HuntItem
|
import net.halfbinary.scavengerhuntapi.model.domain.HuntItem
|
||||||
import net.halfbinary.scavengerhuntapi.model.domain.Item
|
import net.halfbinary.scavengerhuntapi.model.domain.Item
|
||||||
import net.halfbinary.scavengerhuntapi.model.request.HuntStatus
|
import net.halfbinary.scavengerhuntapi.model.request.HuntStatus
|
||||||
|
import net.halfbinary.scavengerhuntapi.model.request.HuntUpdateRequest
|
||||||
|
import net.halfbinary.scavengerhuntapi.model.request.ItemUpdateRequest
|
||||||
import net.halfbinary.scavengerhuntapi.repository.HuntItemRepository
|
import net.halfbinary.scavengerhuntapi.repository.HuntItemRepository
|
||||||
import net.halfbinary.scavengerhuntapi.repository.HuntRepository
|
import net.halfbinary.scavengerhuntapi.repository.HuntRepository
|
||||||
import net.halfbinary.scavengerhuntapi.repository.ItemRepository
|
import net.halfbinary.scavengerhuntapi.repository.ItemRepository
|
||||||
import org.springframework.data.repository.findByIdOrNull
|
import org.springframework.data.repository.findByIdOrNull
|
||||||
import org.springframework.stereotype.Service
|
import org.springframework.stereotype.Service
|
||||||
import java.time.LocalDateTime
|
import java.time.OffsetDateTime
|
||||||
|
|
||||||
@Service
|
@Service
|
||||||
class HuntService(
|
class HuntService(
|
||||||
private val huntRepository: HuntRepository,
|
private val huntRepository: HuntRepository,
|
||||||
private val itemRepository: ItemRepository,
|
private val itemRepository: ItemRepository,
|
||||||
private val huntItemRepository: HuntItemRepository
|
private val huntItemRepository: HuntItemRepository,
|
||||||
|
private val hunterService: HunterService
|
||||||
) {
|
) {
|
||||||
fun getHunt(huntId: HuntId): Hunt {
|
fun getHunt(huntId: HuntId): Hunt {
|
||||||
return huntRepository.findByIdOrNull(huntId)?.toDomain() ?: throw NotFoundException("No hunt with id $huntId found")
|
return huntRepository.findByIdOrNull(huntId)?.toDomain() ?: throw NotFoundException("No hunt with id $huntId found")
|
||||||
@@ -44,16 +49,16 @@ class HuntService(
|
|||||||
val filteredHunts = when (status) {
|
val filteredHunts = when (status) {
|
||||||
HuntStatus.ONGOING -> {
|
HuntStatus.ONGOING -> {
|
||||||
allHunts
|
allHunts
|
||||||
.filter { !it.isTerminated && it.startDateTime < LocalDateTime.now() && it.endDateTime > LocalDateTime.now() }
|
.filter { !it.isTerminated && it.startDateTime < OffsetDateTime.now() && it.endDateTime > OffsetDateTime.now() }
|
||||||
.toList()
|
.toList()
|
||||||
}
|
}
|
||||||
HuntStatus.CLOSED -> {
|
HuntStatus.CLOSED -> {
|
||||||
allHunts
|
allHunts
|
||||||
.filter { it.isTerminated || it.endDateTime < LocalDateTime.now() }
|
.filter { it.isTerminated || it.endDateTime < OffsetDateTime.now() }
|
||||||
}
|
}
|
||||||
HuntStatus.UNSTARTED -> {
|
HuntStatus.UNSTARTED -> {
|
||||||
allHunts
|
allHunts
|
||||||
.filter { !it.isTerminated && it.startDateTime > LocalDateTime.now() }
|
.filter { !it.isTerminated && it.startDateTime > OffsetDateTime.now() }
|
||||||
}
|
}
|
||||||
else -> { allHunts }
|
else -> { allHunts }
|
||||||
}
|
}
|
||||||
@@ -64,8 +69,22 @@ class HuntService(
|
|||||||
return huntRepository.save(hunt.toRecord()).toDomain()
|
return huntRepository.save(hunt.toRecord()).toDomain()
|
||||||
}
|
}
|
||||||
|
|
||||||
fun getItemsForHunt(huntId: HuntId): List<Item> {
|
fun updateHunt(huntId: HuntId, request: HuntUpdateRequest): Hunt {
|
||||||
huntRepository.findByIdOrNull(huntId) ?: throw NotFoundException("No hunt with id $huntId found")
|
val existing = huntRepository.findByIdOrNull(huntId)
|
||||||
|
?: throw NotFoundException("No hunt with id $huntId found")
|
||||||
|
val updated = existing.copy(
|
||||||
|
title = request.title ?: existing.title,
|
||||||
|
startDateTime = request.startDateTime ?: existing.startDateTime,
|
||||||
|
endDateTime = request.endDateTime ?: existing.endDateTime,
|
||||||
|
isTerminated = request.isTerminated ?: existing.isTerminated
|
||||||
|
)
|
||||||
|
return huntRepository.save(updated).toDomain()
|
||||||
|
}
|
||||||
|
|
||||||
|
fun getItemsForHunt(huntId: HuntId, email: String): List<Item> {
|
||||||
|
val hunt = huntRepository.findByIdOrNull(huntId)?.toDomain() ?: throw NotFoundException("No hunt with id $huntId found")
|
||||||
|
val hunter = hunterService.getHunterByEmail(email)
|
||||||
|
if (!hunter.isAdmin && !hunt.isOngoing) throw ForbiddenException()
|
||||||
return itemRepository.findAllByHuntId(huntId).map { it.toDomain() }
|
return itemRepository.findAllByHuntId(huntId).map { it.toDomain() }
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -75,4 +94,23 @@ class HuntService(
|
|||||||
huntItemRepository.save(HuntItem(huntId = huntId, itemId = savedItem.id).toRecord())
|
huntItemRepository.save(HuntItem(huntId = huntId, itemId = savedItem.id).toRecord())
|
||||||
return savedItem
|
return savedItem
|
||||||
}
|
}
|
||||||
|
|
||||||
|
fun updateItem(huntId: HuntId, itemId: ItemId, request: ItemUpdateRequest): Item {
|
||||||
|
huntItemRepository.findByHuntIdAndItemId(huntId, itemId)
|
||||||
|
?: throw NotFoundException("No item with id $itemId found in hunt $huntId")
|
||||||
|
val existing = itemRepository.findByIdOrNull(itemId)
|
||||||
|
?: throw NotFoundException("No item with id $itemId found")
|
||||||
|
val updated = existing.copy(
|
||||||
|
name = request.name ?: existing.name,
|
||||||
|
points = request.points ?: existing.points
|
||||||
|
)
|
||||||
|
return itemRepository.save(updated).toDomain()
|
||||||
|
}
|
||||||
|
|
||||||
|
fun deleteItem(huntId: HuntId, itemId: ItemId) {
|
||||||
|
val huntItem = huntItemRepository.findByHuntIdAndItemId(huntId, itemId)
|
||||||
|
?: throw NotFoundException("No item with id $itemId found in hunt $huntId")
|
||||||
|
huntItemRepository.delete(huntItem)
|
||||||
|
itemRepository.deleteById(itemId)
|
||||||
|
}
|
||||||
}
|
}
|
||||||
@@ -27,7 +27,7 @@ import org.springframework.stereotype.Service
|
|||||||
import org.springframework.web.multipart.MultipartFile
|
import org.springframework.web.multipart.MultipartFile
|
||||||
import java.io.ByteArrayInputStream
|
import java.io.ByteArrayInputStream
|
||||||
import java.io.ByteArrayOutputStream
|
import java.io.ByteArrayOutputStream
|
||||||
import java.time.LocalDateTime
|
import java.time.OffsetDateTime
|
||||||
|
|
||||||
private const val PHOTO_NOT_FOUND = "Photo not found"
|
private const val PHOTO_NOT_FOUND = "Photo not found"
|
||||||
|
|
||||||
@@ -36,10 +36,15 @@ class PhotoService(
|
|||||||
private val photoRepository: PhotoRepository,
|
private val photoRepository: PhotoRepository,
|
||||||
private val hunterService: HunterService,
|
private val hunterService: HunterService,
|
||||||
private val teamService: TeamService,
|
private val teamService: TeamService,
|
||||||
|
private val huntService: HuntService,
|
||||||
private val s3StorageService: S3StorageService,
|
private val s3StorageService: S3StorageService,
|
||||||
private val fileProbeService: FileProbeService
|
private val fileProbeService: FileProbeService
|
||||||
) {
|
) {
|
||||||
fun submitPhoto(huntId: HuntId, itemId: ItemId, email: String, file: MultipartFile) {
|
fun submitPhoto(huntId: HuntId, itemId: ItemId, email: String, file: MultipartFile) {
|
||||||
|
val hunter = hunterService.getHunterByEmail(email)
|
||||||
|
val hunt = huntService.getHunt(huntId)
|
||||||
|
if (!hunter.isAdmin && !hunt.isOngoing) throw ForbiddenException()
|
||||||
|
|
||||||
val originalBytes = file.bytes
|
val originalBytes = file.bytes
|
||||||
val fileType = fileProbeService.getFileType(originalBytes)
|
val fileType = fileProbeService.getFileType(originalBytes)
|
||||||
|
|
||||||
@@ -51,8 +56,7 @@ class PhotoService(
|
|||||||
throw BadFileException("Image type is not supported")
|
throw BadFileException("Image type is not supported")
|
||||||
}
|
}
|
||||||
|
|
||||||
val hunter = hunterService.getHunterByEmail(email)
|
val now = OffsetDateTime.now()
|
||||||
val now = LocalDateTime.now()
|
|
||||||
val photo = Photo(
|
val photo = Photo(
|
||||||
itemId = itemId,
|
itemId = itemId,
|
||||||
huntId = huntId,
|
huntId = huntId,
|
||||||
@@ -76,6 +80,8 @@ class PhotoService(
|
|||||||
?: throw NotFoundException(PHOTO_NOT_FOUND)
|
?: throw NotFoundException(PHOTO_NOT_FOUND)
|
||||||
|
|
||||||
if (!requestingHunter.isAdmin) {
|
if (!requestingHunter.isAdmin) {
|
||||||
|
val hunt = huntService.getHunt(huntId)
|
||||||
|
if (!hunt.isOngoing) throw ForbiddenException()
|
||||||
val team = try {
|
val team = try {
|
||||||
teamService.getTeamForHunterInHunt(huntId, email)
|
teamService.getTeamForHunterInHunt(huntId, email)
|
||||||
} catch (_: NotFoundException) {
|
} catch (_: NotFoundException) {
|
||||||
@@ -121,6 +127,8 @@ class PhotoService(
|
|||||||
val requestingHunter = hunterService.getHunterByEmail(email)
|
val requestingHunter = hunterService.getHunterByEmail(email)
|
||||||
|
|
||||||
if (!requestingHunter.isAdmin) {
|
if (!requestingHunter.isAdmin) {
|
||||||
|
val hunt = huntService.getHunt(huntId)
|
||||||
|
if (!hunt.isOngoing) throw ForbiddenException()
|
||||||
val team = try {
|
val team = try {
|
||||||
teamService.getTeamForHunterInHunt(huntId, email)
|
teamService.getTeamForHunterInHunt(huntId, email)
|
||||||
} catch (_: NotFoundException) {
|
} catch (_: NotFoundException) {
|
||||||
@@ -142,25 +150,36 @@ class PhotoService(
|
|||||||
}
|
}
|
||||||
|
|
||||||
fun removePhoto(huntId: HuntId, teamId: TeamId, itemId: ItemId, photoId: PhotoId, email: String) {
|
fun removePhoto(huntId: HuntId, teamId: TeamId, itemId: ItemId, photoId: PhotoId, email: String) {
|
||||||
|
val requestingHunter = hunterService.getHunterByEmail(email)
|
||||||
|
|
||||||
|
if (!requestingHunter.isAdmin) {
|
||||||
|
val hunt = huntService.getHunt(huntId)
|
||||||
|
if (!hunt.isOngoing) throw ForbiddenException()
|
||||||
|
}
|
||||||
|
|
||||||
val photoRecord = photoRepository.findByIdAndItemIdAndHuntId(photoId, itemId, huntId)
|
val photoRecord = photoRepository.findByIdAndItemIdAndHuntId(photoId, itemId, huntId)
|
||||||
?: throw NotFoundException(PHOTO_NOT_FOUND)
|
?: throw NotFoundException(PHOTO_NOT_FOUND)
|
||||||
|
|
||||||
val team = try {
|
if (!requestingHunter.isAdmin) {
|
||||||
teamService.getTeamForHunterInHunt(huntId, email)
|
val team = try {
|
||||||
} catch (_: NotFoundException) {
|
teamService.getTeamForHunterInHunt(huntId, email)
|
||||||
throw ForbiddenException()
|
} catch (_: NotFoundException) {
|
||||||
|
throw ForbiddenException()
|
||||||
|
}
|
||||||
|
if (team.id != teamId) throw ForbiddenException()
|
||||||
}
|
}
|
||||||
if (team.id != teamId) throw ForbiddenException()
|
|
||||||
|
|
||||||
if (photoRecord.status == PhotoStatus.APPROVED) throw ConflictException("Cannot remove an approved photo")
|
if (photoRecord.status == PhotoStatus.APPROVED) throw ConflictException("Cannot remove an approved photo")
|
||||||
|
|
||||||
photoRepository.save(photoRecord.copy(status = PhotoStatus.REMOVED, statusChangeDateTime = LocalDateTime.now()))
|
photoRepository.save(photoRecord.copy(status = PhotoStatus.REMOVED, statusChangeDateTime = OffsetDateTime.now()))
|
||||||
}
|
}
|
||||||
|
|
||||||
fun getItemPhotos(huntId: HuntId, teamId: TeamId, itemId: ItemId, email: String): List<PhotoResponse> {
|
fun getItemPhotos(huntId: HuntId, teamId: TeamId, itemId: ItemId, email: String): List<PhotoResponse> {
|
||||||
val requestingHunter = hunterService.getHunterByEmail(email)
|
val requestingHunter = hunterService.getHunterByEmail(email)
|
||||||
|
|
||||||
if (!requestingHunter.isAdmin) {
|
if (!requestingHunter.isAdmin) {
|
||||||
|
val hunt = huntService.getHunt(huntId)
|
||||||
|
if (!hunt.isOngoing) throw ForbiddenException()
|
||||||
val team = try {
|
val team = try {
|
||||||
teamService.getTeamForHunterInHunt(huntId, email)
|
teamService.getTeamForHunterInHunt(huntId, email)
|
||||||
} catch (_: NotFoundException) {
|
} catch (_: NotFoundException) {
|
||||||
@@ -178,7 +197,7 @@ class PhotoService(
|
|||||||
fun updatePhotoStatus(photoId: PhotoId, status: PhotoStatus) {
|
fun updatePhotoStatus(photoId: PhotoId, status: PhotoStatus) {
|
||||||
val record = photoRepository.findByIdOrNull(photoId)
|
val record = photoRepository.findByIdOrNull(photoId)
|
||||||
?: throw NotFoundException(PHOTO_NOT_FOUND)
|
?: throw NotFoundException(PHOTO_NOT_FOUND)
|
||||||
photoRepository.save(record.copy(status = status, statusChangeDateTime = LocalDateTime.now()))
|
photoRepository.save(record.copy(status = status, statusChangeDateTime = OffsetDateTime.now()))
|
||||||
}
|
}
|
||||||
|
|
||||||
private fun toJpeg(bytes: ByteArray): ByteArray {
|
private fun toJpeg(bytes: ByteArray): ByteArray {
|
||||||
|
|||||||
@@ -5,15 +5,16 @@ import net.halfbinary.scavengerhuntapi.error.exception.ExpiredRefreshTokenExcept
|
|||||||
import net.halfbinary.scavengerhuntapi.error.exception.InvalidRefreshTokenException
|
import net.halfbinary.scavengerhuntapi.error.exception.InvalidRefreshTokenException
|
||||||
import net.halfbinary.scavengerhuntapi.model.RefreshId
|
import net.halfbinary.scavengerhuntapi.model.RefreshId
|
||||||
import net.halfbinary.scavengerhuntapi.model.record.RefreshTokenRecord
|
import net.halfbinary.scavengerhuntapi.model.record.RefreshTokenRecord
|
||||||
|
import net.halfbinary.scavengerhuntapi.repository.HunterRepository
|
||||||
import net.halfbinary.scavengerhuntapi.repository.RefreshTokenRepository
|
import net.halfbinary.scavengerhuntapi.repository.RefreshTokenRepository
|
||||||
import org.slf4j.LoggerFactory
|
import org.slf4j.LoggerFactory
|
||||||
import org.springframework.data.repository.findByIdOrNull
|
import org.springframework.data.repository.findByIdOrNull
|
||||||
import org.springframework.stereotype.Service
|
import org.springframework.stereotype.Service
|
||||||
import java.time.LocalDateTime
|
import java.time.OffsetDateTime
|
||||||
import java.time.temporal.ChronoUnit
|
import java.time.temporal.ChronoUnit
|
||||||
|
|
||||||
@Service
|
@Service
|
||||||
class RefreshTokenService(private val refreshTokenRepository: RefreshTokenRepository, private val jwtUtil: JwtUtil) {
|
class RefreshTokenService(private val refreshTokenRepository: RefreshTokenRepository, private val jwtUtil: JwtUtil, private val hunterRepository: HunterRepository) {
|
||||||
|
|
||||||
companion object {
|
companion object {
|
||||||
private val log = LoggerFactory.getLogger(RefreshTokenService::class.java)
|
private val log = LoggerFactory.getLogger(RefreshTokenService::class.java)
|
||||||
@@ -25,17 +26,18 @@ class RefreshTokenService(private val refreshTokenRepository: RefreshTokenReposi
|
|||||||
removeToken(tokenId)
|
removeToken(tokenId)
|
||||||
throw ExpiredRefreshTokenException(tokenId)
|
throw ExpiredRefreshTokenException(tokenId)
|
||||||
} else {
|
} else {
|
||||||
jwtUtil.generateToken(refreshToken.email)
|
val isAdmin = hunterRepository.findByEmail(refreshToken.email)?.isAdmin ?: false
|
||||||
|
jwtUtil.generateToken(refreshToken.email, isAdmin)
|
||||||
}
|
}
|
||||||
}?: throw InvalidRefreshTokenException(tokenId)
|
}?: throw InvalidRefreshTokenException(tokenId)
|
||||||
}
|
}
|
||||||
|
|
||||||
fun generateRefreshToken(email: String): RefreshId {
|
fun generateRefreshToken(email: String): RefreshId {
|
||||||
return refreshTokenRepository.save(RefreshTokenRecord(RefreshId.randomUUID(), email, LocalDateTime.now().plus(1, ChronoUnit.MONTHS))).token
|
return refreshTokenRepository.save(RefreshTokenRecord(RefreshId.randomUUID(), email, OffsetDateTime.now().plus(1, ChronoUnit.MONTHS))).token
|
||||||
}
|
}
|
||||||
|
|
||||||
fun isTokenExpired(token: RefreshTokenRecord): Boolean {
|
fun isTokenExpired(token: RefreshTokenRecord): Boolean {
|
||||||
return token.expiryDateTime.isBefore(LocalDateTime.now())
|
return token.expiryDateTime.isBefore(OffsetDateTime.now())
|
||||||
}
|
}
|
||||||
|
|
||||||
fun getToken(token: RefreshId): RefreshTokenRecord? {
|
fun getToken(token: RefreshId): RefreshTokenRecord? {
|
||||||
|
|||||||
@@ -6,6 +6,7 @@ import net.halfbinary.scavengerhuntapi.model.HunterId
|
|||||||
import net.halfbinary.scavengerhuntapi.model.TeamId
|
import net.halfbinary.scavengerhuntapi.model.TeamId
|
||||||
import net.halfbinary.scavengerhuntapi.model.converter.toDomain
|
import net.halfbinary.scavengerhuntapi.model.converter.toDomain
|
||||||
import net.halfbinary.scavengerhuntapi.model.converter.toRecord
|
import net.halfbinary.scavengerhuntapi.model.converter.toRecord
|
||||||
|
import net.halfbinary.scavengerhuntapi.model.domain.Hunter
|
||||||
import net.halfbinary.scavengerhuntapi.model.domain.Team
|
import net.halfbinary.scavengerhuntapi.model.domain.Team
|
||||||
import net.halfbinary.scavengerhuntapi.model.domain.TeamHunt
|
import net.halfbinary.scavengerhuntapi.model.domain.TeamHunt
|
||||||
import net.halfbinary.scavengerhuntapi.model.record.HunterTeamRecord
|
import net.halfbinary.scavengerhuntapi.model.record.HunterTeamRecord
|
||||||
@@ -54,6 +55,12 @@ class TeamService(
|
|||||||
return hunterTeamRepository.findByTeamId(teamId).map { it.hunterId }.toSet()
|
return hunterTeamRepository.findByTeamId(teamId).map { it.hunterId }.toSet()
|
||||||
}
|
}
|
||||||
|
|
||||||
|
fun getHuntersForTeam(huntId: HuntId, teamId: TeamId): List<Hunter> {
|
||||||
|
getTeamFromHunt(huntId, teamId)
|
||||||
|
val hunterIds = getHunterIdsForTeam(teamId)
|
||||||
|
return hunterRepository.findAllById(hunterIds).map { it.toDomain() }
|
||||||
|
}
|
||||||
|
|
||||||
fun joinTeam(teamId: TeamId, email: String) {
|
fun joinTeam(teamId: TeamId, email: String) {
|
||||||
val hunter = hunterRepository.findByEmail(email) ?: throw NotFoundException("No hunter with email $email found")
|
val hunter = hunterRepository.findByEmail(email) ?: throw NotFoundException("No hunter with email $email found")
|
||||||
hunterTeamRepository.save(HunterTeamRecord(UUID.randomUUID(), hunter.id, teamId))
|
hunterTeamRepository.save(HunterTeamRecord(UUID.randomUUID(), hunter.id, teamId))
|
||||||
|
|||||||
Reference in New Issue
Block a user