Compare commits
2
Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
f4e5ea2976 | ||
|
|
bf4d1ca450 |
@@ -16,8 +16,7 @@ public class HandlerConfig {
|
|||||||
LoginRequestHandler login,
|
LoginRequestHandler login,
|
||||||
FileUploadHandler upload,
|
FileUploadHandler upload,
|
||||||
FileEntityHandler file,
|
FileEntityHandler file,
|
||||||
LogoutRequestHandler logoutHandler,
|
LogoutRequestHandler logoutHandler
|
||||||
AuthRequestHandler authRequestHandler
|
|
||||||
) {
|
) {
|
||||||
Map<Integer, RequestHandler> map = new HashMap<>();
|
Map<Integer, RequestHandler> map = new HashMap<>();
|
||||||
map.put(20001, login);
|
map.put(20001, login);
|
||||||
@@ -25,7 +24,6 @@ public class HandlerConfig {
|
|||||||
map.put(20004, upload);
|
map.put(20004, upload);
|
||||||
map.put(20005, file);
|
map.put(20005, file);
|
||||||
map.put(20006, logoutHandler);
|
map.put(20006, logoutHandler);
|
||||||
map.put(20008, authRequestHandler);
|
|
||||||
|
|
||||||
return map;
|
return map;
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -19,11 +19,12 @@ import ru.soune.nocopy.dto.file.ChunkUploadResponse;
|
|||||||
import ru.soune.nocopy.dto.file.CompleteUploadResponse;
|
import ru.soune.nocopy.dto.file.CompleteUploadResponse;
|
||||||
import ru.soune.nocopy.dto.file.FileEntityResponse;
|
import ru.soune.nocopy.dto.file.FileEntityResponse;
|
||||||
import ru.soune.nocopy.dto.file.UploadProgress;
|
import ru.soune.nocopy.dto.file.UploadProgress;
|
||||||
|
import ru.soune.nocopy.entity.auth.AuthToken;
|
||||||
import ru.soune.nocopy.entity.file.FileStatus;
|
import ru.soune.nocopy.entity.file.FileStatus;
|
||||||
import ru.soune.nocopy.entity.file.UploadStatus;
|
import ru.soune.nocopy.entity.file.UploadStatus;
|
||||||
import ru.soune.nocopy.exception.*;
|
import ru.soune.nocopy.exception.*;
|
||||||
import ru.soune.nocopy.handler.*;
|
import ru.soune.nocopy.handler.*;
|
||||||
import ru.soune.nocopy.service.auth.AuthService;
|
import ru.soune.nocopy.repository.AuthTokenRepository;
|
||||||
import ru.soune.nocopy.service.file.FileEntityService;
|
import ru.soune.nocopy.service.file.FileEntityService;
|
||||||
import ru.soune.nocopy.service.file.FileUploadService;
|
import ru.soune.nocopy.service.file.FileUploadService;
|
||||||
|
|
||||||
@@ -47,7 +48,7 @@ public class ApiController {
|
|||||||
|
|
||||||
private final FileEntityService fileEntityService;
|
private final FileEntityService fileEntityService;
|
||||||
|
|
||||||
private final AuthService authService;
|
private final AuthTokenRepository authTokenRepository;
|
||||||
|
|
||||||
@PostMapping("/v{version}/data")
|
@PostMapping("/v{version}/data")
|
||||||
public ResponseEntity<?> handlePostRequest(@RequestBody BaseRequest request,
|
public ResponseEntity<?> handlePostRequest(@RequestBody BaseRequest request,
|
||||||
@@ -70,9 +71,6 @@ public class ApiController {
|
|||||||
return ResponseEntity.ok().body(response);
|
return ResponseEntity.ok().body(response);
|
||||||
} catch (ValidationException e) {
|
} catch (ValidationException e) {
|
||||||
return createValidationErrorResponse(e.getBindingResult(), e.getMsgId());
|
return createValidationErrorResponse(e.getBindingResult(), e.getMsgId());
|
||||||
} catch (NotFoundAuthToken e) {
|
|
||||||
return ResponseEntity.ok().body(new BaseResponse(msgId, MessageCode.AUTH_TOKEN_NOT_FOUND.getCode(),
|
|
||||||
MessageCode.AUTH_TOKEN_NOT_FOUND.getDescription(), new HashMap<>()));
|
|
||||||
} catch (NotValidFieldException e) {
|
} catch (NotValidFieldException e) {
|
||||||
throw e;
|
throw e;
|
||||||
} catch (Exception e) {
|
} catch (Exception e) {
|
||||||
@@ -259,7 +257,7 @@ public class ApiController {
|
|||||||
errorData));
|
errorData));
|
||||||
}
|
}
|
||||||
|
|
||||||
Long userId = authService.useUserAuthToken(tokenHeader);
|
Long userId = getUserIdFromToken(tokenHeader);
|
||||||
FileEntityResponse entityResponse = fileEntityService.getById(fileId, version);
|
FileEntityResponse entityResponse = fileEntityService.getById(fileId, version);
|
||||||
|
|
||||||
if (!entityResponse.getUserId().equals(userId)) {
|
if (!entityResponse.getUserId().equals(userId)) {
|
||||||
@@ -381,4 +379,11 @@ public class ApiController {
|
|||||||
mimeType.startsWith("video") ||
|
mimeType.startsWith("video") ||
|
||||||
mimeType.startsWith("audio");
|
mimeType.startsWith("audio");
|
||||||
}
|
}
|
||||||
|
|
||||||
|
private Long getUserIdFromToken(String tokenHeader) {
|
||||||
|
String token = tokenHeader.replace("Bearer ", "");
|
||||||
|
AuthToken authToken = authTokenRepository.findByToken(token)
|
||||||
|
.orElseThrow(() -> new NotFoundAuthToken("Token not found"));
|
||||||
|
return authToken.getUser().getId();
|
||||||
|
}
|
||||||
}
|
}
|
||||||
@@ -6,7 +6,7 @@ import org.springframework.web.bind.annotation.*;
|
|||||||
import ru.soune.nocopy.dto.ChangePasswordRequest;
|
import ru.soune.nocopy.dto.ChangePasswordRequest;
|
||||||
import ru.soune.nocopy.dto.UserDTO;
|
import ru.soune.nocopy.dto.UserDTO;
|
||||||
import ru.soune.nocopy.dto.UserRequest;
|
import ru.soune.nocopy.dto.UserRequest;
|
||||||
import ru.soune.nocopy.entity.AuthToken;
|
import ru.soune.nocopy.entity.auth.AuthToken;
|
||||||
import ru.soune.nocopy.entity.User;
|
import ru.soune.nocopy.entity.User;
|
||||||
import ru.soune.nocopy.exception.InvalidUserEmail;
|
import ru.soune.nocopy.exception.InvalidUserEmail;
|
||||||
import ru.soune.nocopy.exception.NotFoundAuthToken;
|
import ru.soune.nocopy.exception.NotFoundAuthToken;
|
||||||
|
|||||||
@@ -0,0 +1,93 @@
|
|||||||
|
package ru.soune.nocopy.controller;
|
||||||
|
|
||||||
|
import com.fasterxml.jackson.databind.ObjectMapper;
|
||||||
|
import lombok.RequiredArgsConstructor;
|
||||||
|
import lombok.extern.slf4j.Slf4j;
|
||||||
|
import org.springframework.http.HttpStatus;
|
||||||
|
import org.springframework.http.ResponseEntity;
|
||||||
|
import org.springframework.web.bind.annotation.*;
|
||||||
|
import ru.soune.nocopy.dto.BaseResponse;
|
||||||
|
import ru.soune.nocopy.dto.LoginAnswer;
|
||||||
|
import ru.soune.nocopy.dto.MessageCode;
|
||||||
|
import ru.soune.nocopy.entity.User;
|
||||||
|
import ru.soune.nocopy.entity.auth.AuthToken;
|
||||||
|
import ru.soune.nocopy.service.AuthService;
|
||||||
|
import ru.soune.nocopy.service.VkOAuthService;
|
||||||
|
import ru.soune.nocopy.service.auth.ExternalAuthUserService;
|
||||||
|
|
||||||
|
import java.util.ArrayList;
|
||||||
|
import java.util.HashMap;
|
||||||
|
import java.util.List;
|
||||||
|
import java.util.Map;
|
||||||
|
|
||||||
|
@RestController
|
||||||
|
@RequestMapping("/api")
|
||||||
|
@RequiredArgsConstructor
|
||||||
|
@Slf4j
|
||||||
|
public class VkAuthController {
|
||||||
|
|
||||||
|
private final VkOAuthService vkOAuthService;
|
||||||
|
|
||||||
|
private final AuthService authService;
|
||||||
|
|
||||||
|
private final ExternalAuthUserService externalAuthUserService;
|
||||||
|
|
||||||
|
@GetMapping("/v{version}/vk/authorization/{code}/{state}/{codeVerifier}/{deviceId}")
|
||||||
|
public BaseResponse vkAuth(@PathVariable("code") String code,
|
||||||
|
@PathVariable("state") String state,
|
||||||
|
@PathVariable("codeVerifier") String codeVerifier,
|
||||||
|
@PathVariable("deviceId") String deviceId) {
|
||||||
|
try {
|
||||||
|
Map<String, Object> authMap = vkOAuthService.authTokenMap(code, state, codeVerifier, deviceId);
|
||||||
|
ObjectMapper mapper = new ObjectMapper();
|
||||||
|
|
||||||
|
String bodyJson = (String) authMap.get("body");
|
||||||
|
Map<String, Object> body = mapper.readValue(bodyJson, Map.class);
|
||||||
|
|
||||||
|
String accessToken = (String) body.get("access_token");
|
||||||
|
long vkUserId = ((Number) body.get("user_id")).longValue();
|
||||||
|
Integer expiresIn = (Integer) body.get("expires_in");
|
||||||
|
String refreshToken = (String) body.get("refresh_token");
|
||||||
|
|
||||||
|
Map<String, Object> vkUserInfo = vkOAuthService.userVkInfo(accessToken);
|
||||||
|
log.info("vkUserInfo {}", vkUserInfo);
|
||||||
|
|
||||||
|
String userInfoBodyJson = (String) vkUserInfo.get("body");
|
||||||
|
Map<String, Object> userInfoBody = mapper.readValue(userInfoBodyJson, Map.class);
|
||||||
|
Map<String, Object> user = (Map<String, Object>) userInfoBody.get("user");
|
||||||
|
|
||||||
|
String firstName = (String) user.get("first_name");
|
||||||
|
String lastName = (String) user.get("last_name");
|
||||||
|
String fullName = firstName + " " + lastName;
|
||||||
|
|
||||||
|
User userEntity = externalAuthUserService.findOrCreateUserFromVK(Long.toString(vkUserId), fullName,
|
||||||
|
null, accessToken, refreshToken, expiresIn);
|
||||||
|
|
||||||
|
AuthToken ourToken = authService.createTokenForUser(userEntity);
|
||||||
|
|
||||||
|
LoginAnswer loginAnswer = new LoginAnswer();
|
||||||
|
loginAnswer.setToken(ourToken.getToken());
|
||||||
|
loginAnswer.setFieldErrors(new ArrayList<>());
|
||||||
|
|
||||||
|
return new BaseResponse(20009, MessageCode.SUCCESS.getCode(),
|
||||||
|
MessageCode.SUCCESS.getDescription(), loginAnswer);
|
||||||
|
} catch (Exception e) {
|
||||||
|
log.error("VK auth error: ", e);
|
||||||
|
|
||||||
|
LoginAnswer loginAnswer = new LoginAnswer();
|
||||||
|
loginAnswer.setToken(null);
|
||||||
|
|
||||||
|
List<Map<String, String>> errors = new ArrayList<>();
|
||||||
|
Map<String, String> error = new HashMap<>();
|
||||||
|
error.put("field", "vk_auth");
|
||||||
|
error.put("message", e.getMessage());
|
||||||
|
errors.add(error);
|
||||||
|
|
||||||
|
loginAnswer.setFieldErrors(errors);
|
||||||
|
|
||||||
|
return new BaseResponse(20009, MessageCode.SUCCESS.getCode(),
|
||||||
|
MessageCode.SUCCESS.getDescription(), loginAnswer);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
@@ -1,10 +0,0 @@
|
|||||||
package ru.soune.nocopy.dto;
|
|
||||||
|
|
||||||
import java.time.LocalDateTime;
|
|
||||||
|
|
||||||
public record AuthResponse (
|
|
||||||
boolean success,
|
|
||||||
String message,
|
|
||||||
String token,
|
|
||||||
LocalDateTime expiresAt
|
|
||||||
) {}
|
|
||||||
@@ -18,7 +18,6 @@ public enum MessageCode {
|
|||||||
AUTH_EMAIL_NOT_FOUND(4, "Email not found"),
|
AUTH_EMAIL_NOT_FOUND(4, "Email not found"),
|
||||||
AUTH_EMAIL_OR_TOKEN_NOT_FOUND(4, "Email or Token not found "),
|
AUTH_EMAIL_OR_TOKEN_NOT_FOUND(4, "Email or Token not found "),
|
||||||
AUTH_TOKEN_MISMATCH(4, "Token mismatch"),
|
AUTH_TOKEN_MISMATCH(4, "Token mismatch"),
|
||||||
AUTH_TOKEN_NOT_FOUND(4, "Token not found"),
|
|
||||||
FILE_NOT_FOUND(4, "File not found"),
|
FILE_NOT_FOUND(4, "File not found"),
|
||||||
AUTH_PASSWORD_NOT_MATCHES(2, "Password does not match");
|
AUTH_PASSWORD_NOT_MATCHES(2, "Password does not match");
|
||||||
|
|
||||||
|
|||||||
@@ -1,11 +0,0 @@
|
|||||||
package ru.soune.nocopy.dto;
|
|
||||||
|
|
||||||
import com.fasterxml.jackson.annotation.JsonProperty;
|
|
||||||
import lombok.Data;
|
|
||||||
|
|
||||||
@Data
|
|
||||||
public class TokenProcessRequest {
|
|
||||||
|
|
||||||
@JsonProperty("token")
|
|
||||||
private String token;
|
|
||||||
}
|
|
||||||
@@ -0,0 +1,61 @@
|
|||||||
|
package ru.soune.nocopy.dto.file;
|
||||||
|
|
||||||
|
import com.fasterxml.jackson.annotation.JsonProperty;
|
||||||
|
import lombok.AllArgsConstructor;
|
||||||
|
import lombok.Builder;
|
||||||
|
import lombok.Data;
|
||||||
|
import lombok.NoArgsConstructor;
|
||||||
|
|
||||||
|
@Data
|
||||||
|
@Builder
|
||||||
|
@NoArgsConstructor
|
||||||
|
@AllArgsConstructor
|
||||||
|
public class FileInfoUserResponse {
|
||||||
|
@JsonProperty("all_files_size")
|
||||||
|
private Long allFileSize;
|
||||||
|
|
||||||
|
@JsonProperty("all_files_quantity")
|
||||||
|
private Integer fileCount;
|
||||||
|
|
||||||
|
@JsonProperty("all_files_check")
|
||||||
|
private Integer filesCheck;
|
||||||
|
|
||||||
|
@JsonProperty("all_files_violation")
|
||||||
|
private Integer filesViolation;
|
||||||
|
|
||||||
|
@JsonProperty("images_size")
|
||||||
|
private Long imagesSize;
|
||||||
|
|
||||||
|
@JsonProperty("images_quantity")
|
||||||
|
private Integer imagesCount;
|
||||||
|
|
||||||
|
@JsonProperty("images_check")
|
||||||
|
private Integer imagesCheck;
|
||||||
|
|
||||||
|
@JsonProperty("images_violations")
|
||||||
|
private Integer imagesViolations;
|
||||||
|
|
||||||
|
@JsonProperty("videos_size")
|
||||||
|
private Long videosSize;
|
||||||
|
|
||||||
|
@JsonProperty("videos_quantity")
|
||||||
|
private Integer videosCount;
|
||||||
|
|
||||||
|
@JsonProperty("videos_check")
|
||||||
|
private Integer videosCheck;
|
||||||
|
|
||||||
|
@JsonProperty("videos_violations")
|
||||||
|
private Integer videosViolations;
|
||||||
|
|
||||||
|
@JsonProperty("audios_size")
|
||||||
|
private Long audiosSize;
|
||||||
|
|
||||||
|
@JsonProperty("audios_quantity")
|
||||||
|
private Integer audiosCount;
|
||||||
|
|
||||||
|
@JsonProperty("audios_check")
|
||||||
|
private Integer audiosCheck;
|
||||||
|
|
||||||
|
@JsonProperty("audios_violations")
|
||||||
|
private Integer audiosViolations;
|
||||||
|
}
|
||||||
@@ -6,11 +6,14 @@ import jakarta.validation.constraints.Size;
|
|||||||
import lombok.*;
|
import lombok.*;
|
||||||
import org.springframework.data.annotation.CreatedDate;
|
import org.springframework.data.annotation.CreatedDate;
|
||||||
import org.springframework.data.jpa.domain.support.AuditingEntityListener;
|
import org.springframework.data.jpa.domain.support.AuditingEntityListener;
|
||||||
|
import ru.soune.nocopy.entity.auth.AuthToken;
|
||||||
|
import ru.soune.nocopy.entity.auth.ExternalAuthProvider;
|
||||||
|
|
||||||
import java.time.LocalDate;
|
import java.time.LocalDate;
|
||||||
import java.time.LocalDateTime;
|
import java.time.LocalDateTime;
|
||||||
import java.util.ArrayList;
|
import java.util.ArrayList;
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
|
import java.util.Optional;
|
||||||
|
|
||||||
@Entity
|
@Entity
|
||||||
@Table(name = "users")
|
@Table(name = "users")
|
||||||
@@ -19,18 +22,19 @@ import java.util.List;
|
|||||||
@NoArgsConstructor
|
@NoArgsConstructor
|
||||||
@AllArgsConstructor
|
@AllArgsConstructor
|
||||||
@ToString
|
@ToString
|
||||||
|
@Builder
|
||||||
@EntityListeners(AuditingEntityListener.class)
|
@EntityListeners(AuditingEntityListener.class)
|
||||||
public class User {
|
public class User {
|
||||||
|
|
||||||
@Id
|
@Id
|
||||||
@GeneratedValue(strategy = GenerationType.IDENTITY)
|
@GeneratedValue(strategy = GenerationType.IDENTITY)
|
||||||
private Long Id;
|
private Long id;
|
||||||
|
|
||||||
@Column(name = "full_name", nullable = false)
|
@Column(name = "full_name", nullable = false)
|
||||||
private String fullName;
|
private String fullName;
|
||||||
|
|
||||||
@Size(max = 1024)
|
@Size(max = 255)
|
||||||
@Column(name = "email", nullable = false, length = 1024, unique = true)
|
@Column(name = "email", nullable = false, length = 255, unique = true)
|
||||||
private String email;
|
private String email;
|
||||||
|
|
||||||
@Column(name = "company")
|
@Column(name = "company")
|
||||||
@@ -90,4 +94,14 @@ public class User {
|
|||||||
@JsonIgnore
|
@JsonIgnore
|
||||||
@ToString.Exclude
|
@ToString.Exclude
|
||||||
private List<ImageProtection> imageProtections = new ArrayList<>();
|
private List<ImageProtection> imageProtections = new ArrayList<>();
|
||||||
|
|
||||||
|
@OneToMany(mappedBy = "user", cascade = CascadeType.ALL, fetch = FetchType.LAZY)
|
||||||
|
@ToString.Exclude
|
||||||
|
private List<ExternalAuthProvider> externalAuthProviders = new ArrayList<>();
|
||||||
|
|
||||||
|
public Optional<ExternalAuthProvider> getProvider(ExternalAuthProvider.ProviderType providerType) {
|
||||||
|
return externalAuthProviders.stream()
|
||||||
|
.filter(p -> p.getProviderType() == providerType)
|
||||||
|
.findFirst();
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
+6
-1
@@ -1,9 +1,10 @@
|
|||||||
package ru.soune.nocopy.entity;
|
package ru.soune.nocopy.entity.auth;
|
||||||
|
|
||||||
import jakarta.persistence.*;
|
import jakarta.persistence.*;
|
||||||
import lombok.*;
|
import lombok.*;
|
||||||
import org.springframework.data.annotation.CreatedDate;
|
import org.springframework.data.annotation.CreatedDate;
|
||||||
import org.springframework.data.jpa.domain.support.AuditingEntityListener;
|
import org.springframework.data.jpa.domain.support.AuditingEntityListener;
|
||||||
|
import ru.soune.nocopy.entity.User;
|
||||||
|
|
||||||
import java.time.LocalDateTime;
|
import java.time.LocalDateTime;
|
||||||
|
|
||||||
@@ -41,4 +42,8 @@ public class AuthToken {
|
|||||||
|
|
||||||
@Column(name = "is_active")
|
@Column(name = "is_active")
|
||||||
private Boolean isActive = true;
|
private Boolean isActive = true;
|
||||||
|
|
||||||
|
public boolean isValid() {
|
||||||
|
return Boolean.TRUE.equals(isActive) && expiresAt.isAfter(LocalDateTime.now());
|
||||||
|
}
|
||||||
}
|
}
|
||||||
@@ -0,0 +1,89 @@
|
|||||||
|
package ru.soune.nocopy.entity.auth;
|
||||||
|
|
||||||
|
import jakarta.persistence.*;
|
||||||
|
import lombok.*;
|
||||||
|
import org.springframework.data.annotation.CreatedDate;
|
||||||
|
import org.springframework.data.jpa.domain.support.AuditingEntityListener;
|
||||||
|
import ru.soune.nocopy.entity.User;
|
||||||
|
|
||||||
|
import java.time.LocalDateTime;
|
||||||
|
|
||||||
|
@Entity
|
||||||
|
@Table(name = "external_auth_providers",
|
||||||
|
uniqueConstraints = @UniqueConstraint(
|
||||||
|
columnNames = {"provider_type", "provider_user_id"}
|
||||||
|
),
|
||||||
|
indexes = {
|
||||||
|
@Index(name = "idx_provider_type_user_id",
|
||||||
|
columnList = "provider_type, provider_user_id"),
|
||||||
|
@Index(name = "idx_user_id_provider_type",
|
||||||
|
columnList = "user_id, provider_type")
|
||||||
|
})
|
||||||
|
@Getter @Setter
|
||||||
|
@NoArgsConstructor
|
||||||
|
@AllArgsConstructor
|
||||||
|
@Builder
|
||||||
|
@EntityListeners(AuditingEntityListener.class)
|
||||||
|
public class ExternalAuthProvider {
|
||||||
|
|
||||||
|
public enum ProviderType {
|
||||||
|
VK, YANDEX
|
||||||
|
}
|
||||||
|
|
||||||
|
@Id
|
||||||
|
@GeneratedValue(strategy = GenerationType.IDENTITY)
|
||||||
|
private Long id;
|
||||||
|
|
||||||
|
@ManyToOne(fetch = FetchType.LAZY)
|
||||||
|
@JoinColumn(name = "user_id", nullable = false, foreignKey = @ForeignKey(name = "fk_extauth_user"))
|
||||||
|
@ToString.Exclude
|
||||||
|
private User user;
|
||||||
|
|
||||||
|
@Enumerated(EnumType.STRING)
|
||||||
|
@Column(name = "provider_type", nullable = false, length = 20)
|
||||||
|
private ProviderType providerType;
|
||||||
|
|
||||||
|
@Column(name = "provider_user_id", nullable = false, length = 255)
|
||||||
|
private String providerUserId;
|
||||||
|
|
||||||
|
@Column(name = "access_token", length = 2048)
|
||||||
|
private String accessToken;
|
||||||
|
|
||||||
|
@Column(name = "refresh_token", length = 2048)
|
||||||
|
private String refreshToken;
|
||||||
|
|
||||||
|
@Column(name = "token_expires_at")
|
||||||
|
private LocalDateTime tokenExpiresAt;
|
||||||
|
|
||||||
|
@Column(name = "email", length = 255)
|
||||||
|
private String email;
|
||||||
|
|
||||||
|
@Column(name = "phone", length = 20)
|
||||||
|
private String phoneNumber;
|
||||||
|
|
||||||
|
@CreatedDate
|
||||||
|
@Column(name = "linked_at", updatable = false)
|
||||||
|
private LocalDateTime linkedAt;
|
||||||
|
|
||||||
|
@Column(name = "last_used_at")
|
||||||
|
private LocalDateTime lastUsedAt;
|
||||||
|
|
||||||
|
@Column(name = "is_active")
|
||||||
|
@Builder.Default
|
||||||
|
private Boolean isActive = true;
|
||||||
|
|
||||||
|
@PrePersist
|
||||||
|
public void prePersist() {
|
||||||
|
if (this.linkedAt == null) {
|
||||||
|
this.linkedAt = LocalDateTime.now();
|
||||||
|
}
|
||||||
|
if (this.lastUsedAt == null) {
|
||||||
|
this.lastUsedAt = LocalDateTime.now();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
@PreUpdate
|
||||||
|
public void preUpdate() {
|
||||||
|
this.lastUsedAt = LocalDateTime.now();
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -4,5 +4,7 @@ public enum FileStatus {
|
|||||||
ACTIVE,
|
ACTIVE,
|
||||||
DELETED,
|
DELETED,
|
||||||
PROCESSING,
|
PROCESSING,
|
||||||
|
VIOLATION,
|
||||||
|
CHECKED,
|
||||||
ERROR
|
ERROR
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -1,37 +0,0 @@
|
|||||||
package ru.soune.nocopy.handler;
|
|
||||||
|
|
||||||
import com.fasterxml.jackson.databind.ObjectMapper;
|
|
||||||
import lombok.RequiredArgsConstructor;
|
|
||||||
import lombok.extern.slf4j.Slf4j;
|
|
||||||
import org.springframework.stereotype.Component;
|
|
||||||
import ru.soune.nocopy.dto.BaseRequest;
|
|
||||||
import ru.soune.nocopy.dto.BaseResponse;
|
|
||||||
import ru.soune.nocopy.dto.MessageCode;
|
|
||||||
import ru.soune.nocopy.dto.TokenProcessRequest;
|
|
||||||
import ru.soune.nocopy.exception.NotFoundAuthToken;
|
|
||||||
import ru.soune.nocopy.service.auth.AuthService;
|
|
||||||
|
|
||||||
import java.util.Map;
|
|
||||||
|
|
||||||
@Slf4j
|
|
||||||
@Component
|
|
||||||
@RequiredArgsConstructor
|
|
||||||
public class AuthRequestHandler implements RequestHandler {
|
|
||||||
|
|
||||||
private final ObjectMapper objectMapper;
|
|
||||||
|
|
||||||
private final AuthService authService;
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public BaseResponse handle(BaseRequest request) throws NotFoundAuthToken {
|
|
||||||
TokenProcessRequest tokenProcessRequest = objectMapper.convertValue(request.getMessageBody(),
|
|
||||||
TokenProcessRequest.class);
|
|
||||||
|
|
||||||
authService.useUserAuthToken(tokenProcessRequest.getToken());
|
|
||||||
|
|
||||||
return new BaseResponse(request.getMsgId(),
|
|
||||||
MessageCode.SUCCESS.getCode(),
|
|
||||||
"Token processed successfully",
|
|
||||||
Map.of("token", tokenProcessRequest.getToken()));
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@@ -6,14 +6,15 @@ import lombok.extern.slf4j.Slf4j;
|
|||||||
import org.springframework.stereotype.Component;
|
import org.springframework.stereotype.Component;
|
||||||
import ru.soune.nocopy.dto.*;
|
import ru.soune.nocopy.dto.*;
|
||||||
import ru.soune.nocopy.dto.file.*;
|
import ru.soune.nocopy.dto.file.*;
|
||||||
|
import ru.soune.nocopy.entity.auth.AuthToken;
|
||||||
import ru.soune.nocopy.entity.file.FileEntity;
|
import ru.soune.nocopy.entity.file.FileEntity;
|
||||||
import ru.soune.nocopy.entity.file.FileStatus;
|
import ru.soune.nocopy.entity.file.FileStatus;
|
||||||
import ru.soune.nocopy.exception.FileEntityNotFoundException;
|
import ru.soune.nocopy.exception.FileEntityNotFoundException;
|
||||||
import ru.soune.nocopy.exception.NotFoundAuthToken;
|
import ru.soune.nocopy.exception.NotFoundAuthToken;
|
||||||
import ru.soune.nocopy.repository.AuthTokenRepository;
|
import ru.soune.nocopy.repository.AuthTokenRepository;
|
||||||
import ru.soune.nocopy.repository.FileEntityRepository;
|
import ru.soune.nocopy.repository.FileEntityRepository;
|
||||||
import ru.soune.nocopy.service.auth.AuthService;
|
|
||||||
import ru.soune.nocopy.service.file.FileEntityService;
|
import ru.soune.nocopy.service.file.FileEntityService;
|
||||||
|
import ru.soune.nocopy.service.file.FileStatsService;
|
||||||
|
|
||||||
import java.util.Arrays;
|
import java.util.Arrays;
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
@@ -22,9 +23,10 @@ import java.util.List;
|
|||||||
@Component
|
@Component
|
||||||
@RequiredArgsConstructor
|
@RequiredArgsConstructor
|
||||||
public class FileEntityHandler implements RequestHandler {
|
public class FileEntityHandler implements RequestHandler {
|
||||||
|
|
||||||
private final FileEntityService fileEntityService;
|
private final FileEntityService fileEntityService;
|
||||||
|
|
||||||
private final AuthService authService;
|
private final FileStatsService fileStatsService;
|
||||||
|
|
||||||
private final AuthTokenRepository authTokenRepository;
|
private final AuthTokenRepository authTokenRepository;
|
||||||
|
|
||||||
@@ -43,6 +45,8 @@ public class FileEntityHandler implements RequestHandler {
|
|||||||
switch (action) {
|
switch (action) {
|
||||||
case "file_info":
|
case "file_info":
|
||||||
return handleGetFileInfo(request, fileRequest);
|
return handleGetFileInfo(request, fileRequest);
|
||||||
|
case "user_files_info":
|
||||||
|
return handleGetFilesUserInfo(request, fileRequest);
|
||||||
case "file_by_session":
|
case "file_by_session":
|
||||||
return handleGetFileBySession(request, fileRequest);
|
return handleGetFileBySession(request, fileRequest);
|
||||||
case "user_files":
|
case "user_files":
|
||||||
@@ -75,9 +79,19 @@ public class FileEntityHandler implements RequestHandler {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
private BaseResponse handleGetFilesUserInfo(BaseRequest request, FileEntityRequest fileRequest) {
|
||||||
|
Long userId = getUserIdFromToken(fileRequest.getToken());
|
||||||
|
FileInfoUserResponse userFileStats = fileStatsService.getUserFileStats(userId);
|
||||||
|
|
||||||
|
return new BaseResponse(request.getMsgId(),
|
||||||
|
MessageCode.SUCCESS.getCode(),
|
||||||
|
MessageCode.SUCCESS.getDescription(),
|
||||||
|
userFileStats);
|
||||||
|
}
|
||||||
|
|
||||||
private BaseResponse handleGetFileInfo(BaseRequest request, FileEntityRequest fileRequest) {
|
private BaseResponse handleGetFileInfo(BaseRequest request, FileEntityRequest fileRequest) {
|
||||||
try {
|
try {
|
||||||
Long userId = authService.useUserAuthToken(fileRequest.getToken());
|
Long userId = getUserIdFromToken(fileRequest.getToken());
|
||||||
FileEntityResponse fileInfo = fileEntityService.getById(fileRequest.getFileId(), request.getVersion());
|
FileEntityResponse fileInfo = fileEntityService.getById(fileRequest.getFileId(), request.getVersion());
|
||||||
|
|
||||||
if (!fileInfo.getUserId().equals(userId)) {
|
if (!fileInfo.getUserId().equals(userId)) {
|
||||||
@@ -108,7 +122,7 @@ public class FileEntityHandler implements RequestHandler {
|
|||||||
|
|
||||||
private BaseResponse handleGetFileBySession(BaseRequest request, FileEntityRequest fileRequest) {
|
private BaseResponse handleGetFileBySession(BaseRequest request, FileEntityRequest fileRequest) {
|
||||||
try {
|
try {
|
||||||
Long userId = authService.useUserAuthToken(fileRequest.getToken());
|
Long userId = getUserIdFromToken(fileRequest.getToken());
|
||||||
FileEntityResponse fileInfo = fileEntityService.getByUploadSessionId(fileRequest.getUploadSessionId(),
|
FileEntityResponse fileInfo = fileEntityService.getByUploadSessionId(fileRequest.getUploadSessionId(),
|
||||||
request.getVersion());
|
request.getVersion());
|
||||||
|
|
||||||
@@ -140,7 +154,7 @@ public class FileEntityHandler implements RequestHandler {
|
|||||||
|
|
||||||
private BaseResponse handleGetUserFiles(BaseRequest request, FileEntityRequest fileRequest) {
|
private BaseResponse handleGetUserFiles(BaseRequest request, FileEntityRequest fileRequest) {
|
||||||
try {
|
try {
|
||||||
Long userId = authService.useUserAuthToken(fileRequest.getToken());
|
Long userId = getUserIdFromToken(fileRequest.getToken());
|
||||||
int page = fileRequest.getPage() != null ? fileRequest.getPage() : 1;
|
int page = fileRequest.getPage() != null ? fileRequest.getPage() : 1;
|
||||||
int pageSize = fileRequest.getPageSize() != null ? fileRequest.getPageSize() : 20;
|
int pageSize = fileRequest.getPageSize() != null ? fileRequest.getPageSize() : 20;
|
||||||
|
|
||||||
@@ -167,7 +181,7 @@ public class FileEntityHandler implements RequestHandler {
|
|||||||
|
|
||||||
private BaseResponse handleSearchFiles(BaseRequest request, FileEntityRequest fileRequest) {
|
private BaseResponse handleSearchFiles(BaseRequest request, FileEntityRequest fileRequest) {
|
||||||
try {
|
try {
|
||||||
Long userId = authService.useUserAuthToken(fileRequest.getToken());
|
Long userId = getUserIdFromToken(fileRequest.getToken());
|
||||||
int page = fileRequest.getPage() != null ? fileRequest.getPage() : 1;
|
int page = fileRequest.getPage() != null ? fileRequest.getPage() : 1;
|
||||||
int pageSize = fileRequest.getPageSize() != null ? fileRequest.getPageSize() : 20;
|
int pageSize = fileRequest.getPageSize() != null ? fileRequest.getPageSize() : 20;
|
||||||
|
|
||||||
@@ -214,7 +228,7 @@ public class FileEntityHandler implements RequestHandler {
|
|||||||
|
|
||||||
private BaseResponse handleGetStorageUsage(BaseRequest request, FileEntityRequest fileRequest) {
|
private BaseResponse handleGetStorageUsage(BaseRequest request, FileEntityRequest fileRequest) {
|
||||||
try {
|
try {
|
||||||
Long userId = authService.useUserAuthToken(fileRequest.getToken());
|
Long userId = getUserIdFromToken(fileRequest.getToken());
|
||||||
long usage = fileEntityService.getUserStorageUsed(userId);
|
long usage = fileEntityService.getUserStorageUsed(userId);
|
||||||
|
|
||||||
StorageUsageResponse response = StorageUsageResponse.builder()
|
StorageUsageResponse response = StorageUsageResponse.builder()
|
||||||
@@ -244,7 +258,7 @@ public class FileEntityHandler implements RequestHandler {
|
|||||||
|
|
||||||
private BaseResponse handleDeleteFile(BaseRequest request, FileEntityRequest fileRequest) {
|
private BaseResponse handleDeleteFile(BaseRequest request, FileEntityRequest fileRequest) {
|
||||||
try {
|
try {
|
||||||
Long userId = authService.useUserAuthToken(fileRequest.getToken());
|
Long userId = getUserIdFromToken(fileRequest.getToken());
|
||||||
String fileId = fileRequest.getFileId();
|
String fileId = fileRequest.getFileId();
|
||||||
FileEntityResponse fileInfo = fileEntityService.getById(fileId, request.getVersion());
|
FileEntityResponse fileInfo = fileEntityService.getById(fileId, request.getVersion());
|
||||||
DeleteFileResponse response;
|
DeleteFileResponse response;
|
||||||
@@ -291,6 +305,20 @@ public class FileEntityHandler implements RequestHandler {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
private Long getUserIdFromToken(String token) {
|
||||||
|
if (token == null || token.isBlank()) {
|
||||||
|
throw new NotFoundAuthToken("Token is required");
|
||||||
|
}
|
||||||
|
|
||||||
|
if (token.startsWith("Bearer ")) {
|
||||||
|
token = token.replace("Bearer ", "");
|
||||||
|
}
|
||||||
|
|
||||||
|
AuthToken authToken = authTokenRepository.findByToken(token)
|
||||||
|
.orElseThrow(() -> new NotFoundAuthToken("Token not found"));
|
||||||
|
return authToken.getUser().getId();
|
||||||
|
}
|
||||||
|
|
||||||
private String formatFileSize(long size) {
|
private String formatFileSize(long size) {
|
||||||
if (size < 1024) return size + " B";
|
if (size < 1024) return size + " B";
|
||||||
int exp = (int) (Math.log(size) / Math.log(1024));
|
int exp = (int) (Math.log(size) / Math.log(1024));
|
||||||
|
|||||||
@@ -10,14 +10,13 @@ import org.springframework.validation.BindingResult;
|
|||||||
import org.springframework.validation.FieldError;
|
import org.springframework.validation.FieldError;
|
||||||
import ru.soune.nocopy.dto.*;
|
import ru.soune.nocopy.dto.*;
|
||||||
import ru.soune.nocopy.dto.file.*;
|
import ru.soune.nocopy.dto.file.*;
|
||||||
import ru.soune.nocopy.entity.AuthToken;
|
import ru.soune.nocopy.entity.auth.AuthToken;
|
||||||
import ru.soune.nocopy.entity.file.FileType;
|
import ru.soune.nocopy.entity.file.FileType;
|
||||||
import ru.soune.nocopy.entity.file.FileUploadSession;
|
import ru.soune.nocopy.entity.file.FileUploadSession;
|
||||||
import ru.soune.nocopy.exception.*;
|
import ru.soune.nocopy.exception.*;
|
||||||
import ru.soune.nocopy.handler.validator.FileUploadRequestValidator;
|
import ru.soune.nocopy.handler.validator.FileUploadRequestValidator;
|
||||||
import ru.soune.nocopy.repository.AuthTokenRepository;
|
import ru.soune.nocopy.repository.AuthTokenRepository;
|
||||||
import ru.soune.nocopy.repository.FileUploadSessionRepository;
|
import ru.soune.nocopy.repository.FileUploadSessionRepository;
|
||||||
import ru.soune.nocopy.service.auth.AuthService;
|
|
||||||
import ru.soune.nocopy.service.file.FileUploadService;
|
import ru.soune.nocopy.service.file.FileUploadService;
|
||||||
|
|
||||||
import java.util.*;
|
import java.util.*;
|
||||||
@@ -29,8 +28,6 @@ import java.util.stream.Collectors;
|
|||||||
public class FileUploadHandler implements RequestHandler {
|
public class FileUploadHandler implements RequestHandler {
|
||||||
private final FileUploadService fileUploadService;
|
private final FileUploadService fileUploadService;
|
||||||
|
|
||||||
private final AuthService authService;
|
|
||||||
|
|
||||||
private final AuthTokenRepository authTokenRepository;
|
private final AuthTokenRepository authTokenRepository;
|
||||||
|
|
||||||
private final FileUploadSessionRepository fileUploadSessionRepository;
|
private final FileUploadSessionRepository fileUploadSessionRepository;
|
||||||
@@ -89,7 +86,8 @@ public class FileUploadHandler implements RequestHandler {
|
|||||||
MessageCode.INVALID_TOKEN.getDescription(), Map.of("token", token));
|
MessageCode.INVALID_TOKEN.getDescription(), Map.of("token", token));
|
||||||
}
|
}
|
||||||
|
|
||||||
Long userId = authService.useUserAuthToken(token);
|
AuthToken authToken = tokenOptional.orElseThrow(() -> new NotFoundAuthToken("Token not found"));
|
||||||
|
|
||||||
BindingResult bindingResult = new BeanPropertyBindingResult(fileRequest, "fileRequest");
|
BindingResult bindingResult = new BeanPropertyBindingResult(fileRequest, "fileRequest");
|
||||||
fileUploadRequestValidator.validate(fileRequest, bindingResult);
|
fileUploadRequestValidator.validate(fileRequest, bindingResult);
|
||||||
|
|
||||||
@@ -107,7 +105,7 @@ public class FileUploadHandler implements RequestHandler {
|
|||||||
}
|
}
|
||||||
|
|
||||||
FileUploadSession session = fileUploadService.initUpload(
|
FileUploadSession session = fileUploadService.initUpload(
|
||||||
userId,
|
authToken.getUser().getId(),
|
||||||
fileRequest.getFileName(),
|
fileRequest.getFileName(),
|
||||||
fileRequest.getFileType(),
|
fileRequest.getFileType(),
|
||||||
fileRequest.getExtension(),
|
fileRequest.getExtension(),
|
||||||
|
|||||||
@@ -4,10 +4,10 @@ import com.fasterxml.jackson.databind.ObjectMapper;
|
|||||||
import lombok.RequiredArgsConstructor;
|
import lombok.RequiredArgsConstructor;
|
||||||
import org.springframework.stereotype.Component;
|
import org.springframework.stereotype.Component;
|
||||||
import ru.soune.nocopy.dto.*;
|
import ru.soune.nocopy.dto.*;
|
||||||
import ru.soune.nocopy.entity.AuthToken;
|
import ru.soune.nocopy.entity.auth.AuthToken;
|
||||||
import ru.soune.nocopy.exception.NotValidFieldException;
|
import ru.soune.nocopy.exception.NotValidFieldException;
|
||||||
import ru.soune.nocopy.repository.UserRepository;
|
import ru.soune.nocopy.repository.UserRepository;
|
||||||
import ru.soune.nocopy.service.auth.AuthService;
|
import ru.soune.nocopy.service.AuthService;
|
||||||
|
|
||||||
import java.util.Arrays;
|
import java.util.Arrays;
|
||||||
import java.util.Map;
|
import java.util.Map;
|
||||||
@@ -17,9 +17,7 @@ import java.util.Map;
|
|||||||
public class LoginRequestHandler implements RequestHandler {
|
public class LoginRequestHandler implements RequestHandler {
|
||||||
|
|
||||||
private final UserRepository userRepository;
|
private final UserRepository userRepository;
|
||||||
|
|
||||||
private final AuthService authService;
|
private final AuthService authService;
|
||||||
|
|
||||||
private final ObjectMapper objectMapper;
|
private final ObjectMapper objectMapper;
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
@@ -36,12 +34,9 @@ public class LoginRequestHandler implements RequestHandler {
|
|||||||
}
|
}
|
||||||
|
|
||||||
AuthToken authToken = authService.login(loginRequest);
|
AuthToken authToken = authService.login(loginRequest);
|
||||||
String token = authToken.getToken();
|
|
||||||
|
|
||||||
LoginAnswer loginAnswer = new LoginAnswer();
|
LoginAnswer loginAnswer = new LoginAnswer();
|
||||||
loginAnswer.setToken(token);
|
loginAnswer.setToken(authToken.getToken());
|
||||||
|
|
||||||
authService.useUserAuthToken(token);
|
|
||||||
|
|
||||||
return new BaseResponse(request.getMsgId(), MessageCode.SUCCESS.getCode(),
|
return new BaseResponse(request.getMsgId(), MessageCode.SUCCESS.getCode(),
|
||||||
MessageCode.SUCCESS.getDescription(), loginAnswer);
|
MessageCode.SUCCESS.getDescription(), loginAnswer);
|
||||||
|
|||||||
@@ -4,12 +4,12 @@ import com.fasterxml.jackson.databind.ObjectMapper;
|
|||||||
import lombok.RequiredArgsConstructor;
|
import lombok.RequiredArgsConstructor;
|
||||||
import org.springframework.stereotype.Component;
|
import org.springframework.stereotype.Component;
|
||||||
import ru.soune.nocopy.dto.*;
|
import ru.soune.nocopy.dto.*;
|
||||||
import ru.soune.nocopy.entity.AuthToken;
|
import ru.soune.nocopy.entity.auth.AuthToken;
|
||||||
import ru.soune.nocopy.entity.User;
|
import ru.soune.nocopy.entity.User;
|
||||||
import ru.soune.nocopy.exception.NotValidFieldException;
|
import ru.soune.nocopy.exception.NotValidFieldException;
|
||||||
import ru.soune.nocopy.repository.AuthTokenRepository;
|
import ru.soune.nocopy.repository.AuthTokenRepository;
|
||||||
import ru.soune.nocopy.repository.UserRepository;
|
import ru.soune.nocopy.repository.UserRepository;
|
||||||
import ru.soune.nocopy.service.auth.AuthService;
|
import ru.soune.nocopy.service.AuthService;
|
||||||
|
|
||||||
import java.util.Objects;
|
import java.util.Objects;
|
||||||
import java.util.Optional;
|
import java.util.Optional;
|
||||||
|
|||||||
@@ -7,12 +7,12 @@ import org.springframework.stereotype.Component;
|
|||||||
import org.springframework.validation.BeanPropertyBindingResult;
|
import org.springframework.validation.BeanPropertyBindingResult;
|
||||||
import org.springframework.validation.BindingResult;
|
import org.springframework.validation.BindingResult;
|
||||||
import ru.soune.nocopy.dto.*;
|
import ru.soune.nocopy.dto.*;
|
||||||
import ru.soune.nocopy.entity.AuthToken;
|
import ru.soune.nocopy.entity.auth.AuthToken;
|
||||||
import ru.soune.nocopy.exception.NotValidFieldException;
|
import ru.soune.nocopy.exception.NotValidFieldException;
|
||||||
import ru.soune.nocopy.exception.ValidationException;
|
import ru.soune.nocopy.exception.ValidationException;
|
||||||
import ru.soune.nocopy.handler.validator.RegRequestValidator;
|
import ru.soune.nocopy.handler.validator.RegRequestValidator;
|
||||||
import ru.soune.nocopy.repository.UserRepository;
|
import ru.soune.nocopy.repository.UserRepository;
|
||||||
import ru.soune.nocopy.service.auth.AuthService;
|
import ru.soune.nocopy.service.AuthService;
|
||||||
|
|
||||||
import java.util.Arrays;
|
import java.util.Arrays;
|
||||||
import java.util.Map;
|
import java.util.Map;
|
||||||
@@ -52,11 +52,9 @@ public class RegRequestHandler implements RequestHandler {
|
|||||||
}
|
}
|
||||||
|
|
||||||
AuthToken authToken = authService.register(regRequest);
|
AuthToken authToken = authService.register(regRequest);
|
||||||
String token = authToken.getToken();
|
|
||||||
authService.useUserAuthToken(token);
|
|
||||||
|
|
||||||
RegAnswer regAnswer = new RegAnswer();
|
RegAnswer regAnswer = new RegAnswer();
|
||||||
regAnswer.setToken(token);
|
regAnswer.setToken(authToken.getToken());
|
||||||
|
|
||||||
return new BaseResponse(request.getMsgId(), MessageCode.SUCCESS.getCode(),
|
return new BaseResponse(request.getMsgId(), MessageCode.SUCCESS.getCode(),
|
||||||
MessageCode.SUCCESS.getDescription(), regAnswer);
|
MessageCode.SUCCESS.getDescription(), regAnswer);
|
||||||
|
|||||||
@@ -2,14 +2,13 @@ package ru.soune.nocopy.repository;
|
|||||||
|
|
||||||
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 ru.soune.nocopy.entity.AuthToken;
|
import ru.soune.nocopy.entity.auth.AuthToken;
|
||||||
|
|
||||||
import java.time.LocalDateTime;
|
import java.time.LocalDate;
|
||||||
import java.util.Optional;
|
import java.util.Optional;
|
||||||
|
|
||||||
@Repository
|
@Repository
|
||||||
public interface AuthTokenRepository extends JpaRepository<AuthToken, Long> {
|
public interface AuthTokenRepository extends JpaRepository<AuthToken, Long> {
|
||||||
Optional<AuthToken> findByLastUsedAtAndExpiresAtBefore(LocalDateTime lastUsedAt, LocalDateTime expiresAtBefore);
|
Optional<AuthToken> findByTokenAndExpiresAtAfter(String token, LocalDate expiresAtAfter);
|
||||||
Optional<AuthToken> findByLastUsedAtBefore(LocalDateTime lastUsedAt);
|
|
||||||
Optional<AuthToken> findByToken(String token);
|
Optional<AuthToken> findByToken(String token);
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -0,0 +1,25 @@
|
|||||||
|
package ru.soune.nocopy.repository;
|
||||||
|
|
||||||
|
import org.springframework.data.jpa.repository.JpaRepository;
|
||||||
|
import org.springframework.stereotype.Repository;
|
||||||
|
import ru.soune.nocopy.entity.User;
|
||||||
|
import ru.soune.nocopy.entity.auth.ExternalAuthProvider;
|
||||||
|
|
||||||
|
import java.util.List;
|
||||||
|
import java.util.Optional;
|
||||||
|
|
||||||
|
@Repository
|
||||||
|
public interface ExternalAuthProviderRepository extends JpaRepository<ExternalAuthProvider, Long> {
|
||||||
|
|
||||||
|
Optional<ExternalAuthProvider> findByProviderTypeAndProviderUserId(
|
||||||
|
ExternalAuthProvider.ProviderType providerType,
|
||||||
|
String providerUserId
|
||||||
|
);
|
||||||
|
|
||||||
|
List<ExternalAuthProvider> findByUser(User user);
|
||||||
|
|
||||||
|
boolean existsByProviderTypeAndProviderUserId(
|
||||||
|
ExternalAuthProvider.ProviderType providerType,
|
||||||
|
String providerUserId
|
||||||
|
);
|
||||||
|
}
|
||||||
@@ -2,7 +2,10 @@ package ru.soune.nocopy.repository;
|
|||||||
|
|
||||||
import jakarta.validation.constraints.Size;
|
import jakarta.validation.constraints.Size;
|
||||||
import org.springframework.data.jpa.repository.JpaRepository;
|
import org.springframework.data.jpa.repository.JpaRepository;
|
||||||
|
import org.springframework.data.jpa.repository.Query;
|
||||||
|
import org.springframework.data.repository.query.Param;
|
||||||
import ru.soune.nocopy.entity.User;
|
import ru.soune.nocopy.entity.User;
|
||||||
|
import ru.soune.nocopy.entity.auth.ExternalAuthProvider;
|
||||||
|
|
||||||
import java.util.Optional;
|
import java.util.Optional;
|
||||||
|
|
||||||
@@ -10,4 +13,10 @@ public interface UserRepository extends JpaRepository<User, Long> {
|
|||||||
Optional<User> findByEmail(String email);
|
Optional<User> findByEmail(String email);
|
||||||
boolean existsByEmail(String email);
|
boolean existsByEmail(String email);
|
||||||
boolean existsByPhone(@Size(min = 11, max = 14) String phone);
|
boolean existsByPhone(@Size(min = 11, max = 14) String phone);
|
||||||
|
@Query("SELECT u FROM User u JOIN u.externalAuthProviders p " +
|
||||||
|
"WHERE p.providerType = :providerType AND p.providerUserId = :providerUserId")
|
||||||
|
Optional<User> findByExternalProvider(
|
||||||
|
@Param("providerType") ExternalAuthProvider.ProviderType providerType,
|
||||||
|
@Param("providerUserId") String providerUserId
|
||||||
|
);
|
||||||
}
|
}
|
||||||
|
|||||||
+19
-22
@@ -1,13 +1,13 @@
|
|||||||
package ru.soune.nocopy.service.auth;
|
package ru.soune.nocopy.service;
|
||||||
|
|
||||||
import lombok.RequiredArgsConstructor;
|
import lombok.RequiredArgsConstructor;
|
||||||
|
import org.springframework.context.MessageSource;
|
||||||
import org.springframework.security.crypto.password.PasswordEncoder;
|
import org.springframework.security.crypto.password.PasswordEncoder;
|
||||||
import org.springframework.stereotype.Service;
|
import org.springframework.stereotype.Service;
|
||||||
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.transaction.annotation.Transactional;
|
||||||
import ru.soune.nocopy.dto.*;
|
import ru.soune.nocopy.dto.*;
|
||||||
import ru.soune.nocopy.entity.AuthToken;
|
import ru.soune.nocopy.entity.auth.AuthToken;
|
||||||
import ru.soune.nocopy.entity.User;
|
import ru.soune.nocopy.entity.User;
|
||||||
import ru.soune.nocopy.exception.NotFoundAuthToken;
|
|
||||||
import ru.soune.nocopy.exception.NotValidFieldException;
|
import ru.soune.nocopy.exception.NotValidFieldException;
|
||||||
import ru.soune.nocopy.repository.AuthTokenRepository;
|
import ru.soune.nocopy.repository.AuthTokenRepository;
|
||||||
import ru.soune.nocopy.repository.UserRepository;
|
import ru.soune.nocopy.repository.UserRepository;
|
||||||
@@ -29,6 +29,8 @@ public class AuthService {
|
|||||||
|
|
||||||
private final PasswordEncoder passwordEncoder;
|
private final PasswordEncoder passwordEncoder;
|
||||||
|
|
||||||
|
private final MessageSource messageSource;
|
||||||
|
|
||||||
private final SecureRandom secureRandom = new SecureRandom();
|
private final SecureRandom secureRandom = new SecureRandom();
|
||||||
|
|
||||||
@Transactional
|
@Transactional
|
||||||
@@ -79,31 +81,26 @@ public class AuthService {
|
|||||||
return authTokenRepository.save(authToken);
|
return authTokenRepository.save(authToken);
|
||||||
}
|
}
|
||||||
|
|
||||||
@Transactional
|
|
||||||
public Long useUserAuthToken(String token) {
|
|
||||||
if (token == null || token.isBlank()) {
|
|
||||||
throw new NotFoundAuthToken("Token is required");
|
|
||||||
}
|
|
||||||
|
|
||||||
if (token.startsWith("Bearer ")) {
|
|
||||||
token = token.replace("Bearer ", "");
|
|
||||||
}
|
|
||||||
|
|
||||||
AuthToken authToken = authTokenRepository.findByToken(token)
|
|
||||||
.orElseThrow(() -> new NotFoundAuthToken("Token not found"));
|
|
||||||
authToken.setLastUsedAt(LocalDateTime.now());
|
|
||||||
|
|
||||||
authTokenRepository.save(authToken);
|
|
||||||
|
|
||||||
return authToken.getUser().getId();
|
|
||||||
}
|
|
||||||
|
|
||||||
@Transactional
|
@Transactional
|
||||||
public void logout(String token) {
|
public void logout(String token) {
|
||||||
authTokenRepository.findByToken(token)
|
authTokenRepository.findByToken(token)
|
||||||
.ifPresent(authTokenRepository::delete);
|
.ifPresent(authTokenRepository::delete);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Transactional
|
||||||
|
public AuthToken createTokenForUser(User user) {
|
||||||
|
AuthToken authToken = new AuthToken();
|
||||||
|
authToken.setToken(generateAuthToken());
|
||||||
|
authToken.setUser(user);
|
||||||
|
authToken.setExpiresAt(LocalDateTime.now().plusHours(1));
|
||||||
|
authToken.setIsActive(true);
|
||||||
|
|
||||||
|
user.setLastLoginAt(LocalDateTime.now());
|
||||||
|
userRepository.save(user);
|
||||||
|
|
||||||
|
return authTokenRepository.save(authToken);
|
||||||
|
}
|
||||||
|
|
||||||
private String generateAuthToken() {
|
private String generateAuthToken() {
|
||||||
byte[] bytes = new byte[32];
|
byte[] bytes = new byte[32];
|
||||||
secureRandom.nextBytes(bytes);
|
secureRandom.nextBytes(bytes);
|
||||||
@@ -0,0 +1,69 @@
|
|||||||
|
package ru.soune.nocopy.service;
|
||||||
|
|
||||||
|
import org.springframework.beans.factory.annotation.Value;
|
||||||
|
import org.springframework.http.*;
|
||||||
|
import org.springframework.stereotype.Service;
|
||||||
|
import org.springframework.util.LinkedMultiValueMap;
|
||||||
|
import org.springframework.util.MultiValueMap;
|
||||||
|
import org.springframework.web.client.RestTemplate;
|
||||||
|
|
||||||
|
import java.util.HashMap;
|
||||||
|
import java.util.Map;
|
||||||
|
|
||||||
|
@Service
|
||||||
|
public class VkOAuthService {
|
||||||
|
@Value("${auth.vk.oauth2}")
|
||||||
|
String oauthVkPath;
|
||||||
|
|
||||||
|
@Value("${auth.vk.user_info}")
|
||||||
|
String vkUserInfo;
|
||||||
|
|
||||||
|
@Value("${auth.vk.client_id}")
|
||||||
|
String clientId;
|
||||||
|
|
||||||
|
@Value("${auth.vk.redirect_uri}")
|
||||||
|
String redirectUri;
|
||||||
|
|
||||||
|
public Map<String, Object> authTokenMap(String code, String state, String codeVerifier, String deviceId) {
|
||||||
|
MultiValueMap<String, String> params = new LinkedMultiValueMap<>();
|
||||||
|
params.add("grant_type", "authorization_code");
|
||||||
|
params.add("code_verifier", codeVerifier);
|
||||||
|
params.add("redirect_uri", redirectUri);
|
||||||
|
params.add("code", code);
|
||||||
|
params.add("client_id", clientId);
|
||||||
|
params.add("device_id", deviceId);
|
||||||
|
params.add("state", state);
|
||||||
|
params.add("scope", "email,phone");
|
||||||
|
|
||||||
|
HttpHeaders headers = new HttpHeaders();
|
||||||
|
headers.setContentType(MediaType.APPLICATION_FORM_URLENCODED);
|
||||||
|
|
||||||
|
return sendRequest(params, headers,oauthVkPath);
|
||||||
|
}
|
||||||
|
|
||||||
|
public Map<String, Object> userVkInfo(String accessToken) {
|
||||||
|
MultiValueMap<String, String> params = new LinkedMultiValueMap<>();
|
||||||
|
params.add("access_token", accessToken);
|
||||||
|
params.add("client_id", clientId);
|
||||||
|
|
||||||
|
HttpHeaders headers = new HttpHeaders();
|
||||||
|
headers.setContentType(MediaType.APPLICATION_FORM_URLENCODED);
|
||||||
|
|
||||||
|
|
||||||
|
return sendRequest(params, headers, vkUserInfo);
|
||||||
|
}
|
||||||
|
|
||||||
|
private Map<String, Object> sendRequest(MultiValueMap<String, String> params, HttpHeaders headers, String url) {
|
||||||
|
Map<String, Object> info = new HashMap<>();
|
||||||
|
RestTemplate restTemplate = new RestTemplate();
|
||||||
|
ResponseEntity<String> response = restTemplate.exchange(url, HttpMethod.POST,
|
||||||
|
new HttpEntity<>(params, headers), String.class);
|
||||||
|
|
||||||
|
info.put("status", response.getStatusCodeValue());
|
||||||
|
info.put("body", response.getBody());
|
||||||
|
info.put("headers", response.getHeaders());
|
||||||
|
info.put("success", response.getStatusCode().is2xxSuccessful());
|
||||||
|
|
||||||
|
return info;
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -1,38 +0,0 @@
|
|||||||
package ru.soune.nocopy.service.auth;
|
|
||||||
|
|
||||||
import lombok.RequiredArgsConstructor;
|
|
||||||
import lombok.extern.slf4j.Slf4j;
|
|
||||||
import org.springframework.beans.factory.annotation.Autowired;
|
|
||||||
import org.springframework.beans.factory.annotation.Value;
|
|
||||||
import org.springframework.scheduling.annotation.Scheduled;
|
|
||||||
import org.springframework.stereotype.Component;
|
|
||||||
import org.springframework.transaction.annotation.Transactional;
|
|
||||||
import ru.soune.nocopy.entity.AuthToken;
|
|
||||||
import ru.soune.nocopy.repository.AuthTokenRepository;
|
|
||||||
|
|
||||||
import java.time.LocalDateTime;
|
|
||||||
import java.util.List;
|
|
||||||
|
|
||||||
@Slf4j
|
|
||||||
@Component
|
|
||||||
@RequiredArgsConstructor
|
|
||||||
public class CleanupTokenSessionsService {
|
|
||||||
@Autowired
|
|
||||||
private AuthTokenRepository authTokenRepository;
|
|
||||||
|
|
||||||
@Value("${file.storage.auth-token-life-hours}")
|
|
||||||
private int authTokenLife;
|
|
||||||
|
|
||||||
@Transactional
|
|
||||||
@Scheduled(fixedDelay = 30000)
|
|
||||||
public void cleanupExpiredFiles() {
|
|
||||||
LocalDateTime hourBefore = LocalDateTime.now().minusHours(authTokenLife);
|
|
||||||
|
|
||||||
List<AuthToken> tokensForDelete = authTokenRepository.findByLastUsedAtBefore(hourBefore).stream().toList();
|
|
||||||
List<AuthToken> tokensDeleteWithNullUpdate = authTokenRepository.findByLastUsedAtAndExpiresAtBefore(
|
|
||||||
null, hourBefore).stream().toList();
|
|
||||||
|
|
||||||
authTokenRepository.deleteAll(tokensForDelete);
|
|
||||||
authTokenRepository.deleteAll(tokensDeleteWithNullUpdate);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@@ -0,0 +1,102 @@
|
|||||||
|
package ru.soune.nocopy.service.auth;
|
||||||
|
|
||||||
|
import lombok.RequiredArgsConstructor;
|
||||||
|
import org.springframework.stereotype.Service;
|
||||||
|
import org.springframework.transaction.annotation.Transactional;
|
||||||
|
import ru.soune.nocopy.entity.User;
|
||||||
|
import ru.soune.nocopy.entity.auth.ExternalAuthProvider;
|
||||||
|
import ru.soune.nocopy.repository.ExternalAuthProviderRepository;
|
||||||
|
import ru.soune.nocopy.repository.UserRepository;
|
||||||
|
|
||||||
|
import java.time.LocalDateTime;
|
||||||
|
import java.util.Optional;
|
||||||
|
|
||||||
|
@Service
|
||||||
|
@RequiredArgsConstructor
|
||||||
|
public class ExternalAuthUserService {
|
||||||
|
private final UserRepository userRepository;
|
||||||
|
|
||||||
|
private final ExternalAuthProviderRepository externalAuthProviderRepository;
|
||||||
|
|
||||||
|
@Transactional
|
||||||
|
public User findOrCreateUserFromVK(String vkUserId, String fullName, String email,
|
||||||
|
String vkAccessToken, String vkRefreshToken, Integer expiresIn) {
|
||||||
|
|
||||||
|
Optional<User> existingByVkId = userRepository.findByExternalProvider(ExternalAuthProvider.ProviderType.VK,
|
||||||
|
vkUserId);
|
||||||
|
|
||||||
|
if (existingByVkId.isPresent()) {
|
||||||
|
User user = existingByVkId.get();
|
||||||
|
updateVKProvider(user, vkAccessToken, vkRefreshToken, expiresIn, email);
|
||||||
|
|
||||||
|
return user;
|
||||||
|
}
|
||||||
|
|
||||||
|
if (email != null && !email.isBlank()) {
|
||||||
|
Optional<User> existingByEmail = userRepository.findByEmail(email);
|
||||||
|
|
||||||
|
if (existingByEmail.isPresent()) {
|
||||||
|
User user = existingByEmail.get();
|
||||||
|
linkVKProvider(user, vkUserId, vkAccessToken, vkRefreshToken, expiresIn, email);
|
||||||
|
|
||||||
|
return user;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
return createNewUserWithVK(vkUserId, fullName, email, vkAccessToken, vkRefreshToken, expiresIn);
|
||||||
|
}
|
||||||
|
|
||||||
|
private User createNewUserWithVK(String vkUserId, String fullName, String email,
|
||||||
|
String vkAccessToken, String vkRefreshToken, Integer expiresIn) {
|
||||||
|
User newUser = User.builder()
|
||||||
|
.fullName(fullName)
|
||||||
|
.email(email)
|
||||||
|
.password("generateRandomPassword()")
|
||||||
|
.isActive(true)
|
||||||
|
.build();
|
||||||
|
|
||||||
|
User savedUser = userRepository.save(newUser);
|
||||||
|
|
||||||
|
linkVKProvider(savedUser, vkUserId, vkAccessToken, vkRefreshToken, expiresIn, email);
|
||||||
|
|
||||||
|
return savedUser;
|
||||||
|
}
|
||||||
|
|
||||||
|
private void linkVKProvider(User user, String vkUserId, String vkAccessToken, String vkRefreshToken,
|
||||||
|
Integer expiresIn, String email) {
|
||||||
|
ExternalAuthProvider provider = ExternalAuthProvider.builder()
|
||||||
|
.user(user)
|
||||||
|
.providerType(ExternalAuthProvider.ProviderType.VK)
|
||||||
|
.providerUserId(vkUserId)
|
||||||
|
.accessToken(vkAccessToken)
|
||||||
|
.refreshToken(vkRefreshToken)
|
||||||
|
.tokenExpiresAt(LocalDateTime.now().plusSeconds(expiresIn))
|
||||||
|
.email(email)
|
||||||
|
.isActive(true)
|
||||||
|
.build();
|
||||||
|
|
||||||
|
externalAuthProviderRepository.save(provider);
|
||||||
|
|
||||||
|
user.getExternalAuthProviders().add(provider);
|
||||||
|
}
|
||||||
|
|
||||||
|
private void updateVKProvider(User user, String vkAccessToken, String vkRefreshToken,
|
||||||
|
Integer expiresIn, String email) {
|
||||||
|
Optional<ExternalAuthProvider> existingProvider = user.getProvider(ExternalAuthProvider.ProviderType.VK);
|
||||||
|
|
||||||
|
if (existingProvider.isPresent()) {
|
||||||
|
ExternalAuthProvider provider = existingProvider.get();
|
||||||
|
provider.setAccessToken(vkAccessToken);
|
||||||
|
provider.setTokenExpiresAt(LocalDateTime.now().plusSeconds(expiresIn));
|
||||||
|
provider.setEmail(email);
|
||||||
|
provider.setRefreshToken(vkRefreshToken);
|
||||||
|
provider.setLastUsedAt(LocalDateTime.now());
|
||||||
|
|
||||||
|
externalAuthProviderRepository.save(provider);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
private String generateRandomPassword() {
|
||||||
|
return java.util.UUID.randomUUID().toString();
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -0,0 +1,93 @@
|
|||||||
|
package ru.soune.nocopy.service.file;
|
||||||
|
|
||||||
|
import lombok.RequiredArgsConstructor;
|
||||||
|
import org.springframework.stereotype.Service;
|
||||||
|
import ru.soune.nocopy.dto.file.FileInfoUserResponse;
|
||||||
|
import ru.soune.nocopy.entity.file.FileEntity;
|
||||||
|
import ru.soune.nocopy.entity.file.FileStatus;
|
||||||
|
import ru.soune.nocopy.entity.file.FileType;
|
||||||
|
import ru.soune.nocopy.repository.FileEntityRepository;
|
||||||
|
|
||||||
|
import java.util.List;
|
||||||
|
|
||||||
|
@Service
|
||||||
|
@RequiredArgsConstructor
|
||||||
|
public class FileStatsService {
|
||||||
|
private final FileEntityRepository fileEntityRepository;
|
||||||
|
|
||||||
|
public FileInfoUserResponse getUserFileStats(Long userId) {
|
||||||
|
List<FileEntity> userFiles = fileEntityRepository.findByUserId(userId);
|
||||||
|
return calculateStats(userFiles);
|
||||||
|
}
|
||||||
|
|
||||||
|
public FileInfoUserResponse calculateStats(List<FileEntity> files) {
|
||||||
|
return FileInfoUserResponse.builder()
|
||||||
|
.allFileSize(calculateTotalSize(files))
|
||||||
|
.fileCount(calculateTotalCount(files))
|
||||||
|
.filesCheck(calculateByStatus(files, FileStatus.CHECKED))
|
||||||
|
.filesViolation(calculateByStatus(files, FileStatus.VIOLATION))
|
||||||
|
|
||||||
|
.imagesSize(calculateMediaSize(files, FileType.IMAGE))
|
||||||
|
.imagesCount(calculateMediaCount(files, FileType.IMAGE))
|
||||||
|
.imagesCheck(calculateMediaByStatus(files, FileType.IMAGE, FileStatus.CHECKED))
|
||||||
|
.imagesViolations(calculateMediaByStatus(files, FileType.IMAGE, FileStatus.VIOLATION))
|
||||||
|
|
||||||
|
.videosSize(calculateMediaSize(files, FileType.VIDEO))
|
||||||
|
.videosCount(calculateMediaCount(files, FileType.VIDEO))
|
||||||
|
.videosCheck(calculateMediaByStatus(files, FileType.VIDEO, FileStatus.CHECKED))
|
||||||
|
.videosViolations(calculateMediaByStatus(files, FileType.VIDEO, FileStatus.VIOLATION))
|
||||||
|
|
||||||
|
.audiosSize(calculateMediaSize(files, FileType.AUDIO))
|
||||||
|
.audiosCount(calculateMediaCount(files, FileType.AUDIO))
|
||||||
|
.audiosCheck(calculateMediaByStatus(files, FileType.AUDIO, FileStatus.CHECKED))
|
||||||
|
.audiosViolations(calculateMediaByStatus(files, FileType.AUDIO, FileStatus.VIOLATION))
|
||||||
|
.build();
|
||||||
|
}
|
||||||
|
private Long calculateTotalSize(List<FileEntity> files) {
|
||||||
|
return files.stream()
|
||||||
|
.filter(file -> file.getStatus() != FileStatus.DELETED)
|
||||||
|
.mapToLong(FileEntity::getFileSize)
|
||||||
|
.sum();
|
||||||
|
}
|
||||||
|
|
||||||
|
private Integer calculateTotalCount(List<FileEntity> files) {
|
||||||
|
return (int) files.stream()
|
||||||
|
.filter(file -> file.getStatus() != FileStatus.DELETED)
|
||||||
|
.count();
|
||||||
|
}
|
||||||
|
|
||||||
|
private Integer calculateByStatus(List<FileEntity> files, FileStatus status) {
|
||||||
|
return (int) files.stream()
|
||||||
|
.filter(file -> file.getStatus() == status)
|
||||||
|
.count();
|
||||||
|
}
|
||||||
|
|
||||||
|
private Long calculateMediaSize(List<FileEntity> files, FileType fileType) {
|
||||||
|
return files.stream()
|
||||||
|
.filter(file -> file.getStatus() != FileStatus.DELETED)
|
||||||
|
.filter(file -> isFileType(file, fileType))
|
||||||
|
.mapToLong(FileEntity::getFileSize)
|
||||||
|
.sum();
|
||||||
|
}
|
||||||
|
|
||||||
|
private Integer calculateMediaCount(List<FileEntity> files, FileType fileType) {
|
||||||
|
return (int) files.stream()
|
||||||
|
.filter(file -> file.getStatus() != FileStatus.DELETED)
|
||||||
|
.filter(file -> isFileType(file, fileType))
|
||||||
|
.count();
|
||||||
|
}
|
||||||
|
|
||||||
|
private Integer calculateMediaByStatus(List<FileEntity> files, FileType fileType, FileStatus status) {
|
||||||
|
return (int) files.stream()
|
||||||
|
.filter(file -> isFileType(file, fileType))
|
||||||
|
.filter(file -> file.getStatus() == status)
|
||||||
|
.count();
|
||||||
|
}
|
||||||
|
|
||||||
|
private boolean isFileType(FileEntity file, FileType fileType) {
|
||||||
|
if (file.getFileExtension() == null) return false;
|
||||||
|
|
||||||
|
String extension = file.getFileExtension().toLowerCase().replace(".", "");
|
||||||
|
return fileType.supportsExtension(extension);
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -30,9 +30,15 @@ file:
|
|||||||
max-retry-attempts: ${MAX_RETRY_ATTEMPTS:3}
|
max-retry-attempts: ${MAX_RETRY_ATTEMPTS:3}
|
||||||
chunk-timeout-ms: ${CHUNK_TIMEOUT_MS:300000} # 5 минут
|
chunk-timeout-ms: ${CHUNK_TIMEOUT_MS:300000} # 5 минут
|
||||||
temp-ttl-hours: ${TEMP_TTL_HOURS:72} # 3 дня
|
temp-ttl-hours: ${TEMP_TTL_HOURS:72} # 3 дня
|
||||||
auth-token-life-hours: ${AUTH_TOKEN_LIFE:1} # 1 час
|
|
||||||
session-expiry-hours: ${SESSION_EXPIRY_HOURS:24}
|
session-expiry-hours: ${SESSION_EXPIRY_HOURS:24}
|
||||||
|
|
||||||
|
auth:
|
||||||
|
vk:
|
||||||
|
oauth2: "https://id.vk.ru/oauth2/auth"
|
||||||
|
user_info: "https://id.vk.ru/oauth2/user_info"
|
||||||
|
client_id: "54389559"
|
||||||
|
redirect_uri: "http://localhost"
|
||||||
|
|
||||||
security:
|
security:
|
||||||
cors:
|
cors:
|
||||||
allowed-origins: "*"
|
allowed-origins: "*"
|
||||||
|
|||||||
@@ -9,13 +9,12 @@ import org.mockito.MockitoAnnotations;
|
|||||||
import org.springframework.context.MessageSource;
|
import org.springframework.context.MessageSource;
|
||||||
import org.springframework.security.crypto.password.PasswordEncoder;
|
import org.springframework.security.crypto.password.PasswordEncoder;
|
||||||
import ru.soune.nocopy.dto.LoginRequest;
|
import ru.soune.nocopy.dto.LoginRequest;
|
||||||
import ru.soune.nocopy.entity.AuthToken;
|
import ru.soune.nocopy.entity.auth.AuthToken;
|
||||||
import ru.soune.nocopy.entity.User;
|
import ru.soune.nocopy.entity.User;
|
||||||
import ru.soune.nocopy.exception.NotValidationPasswordException;
|
import ru.soune.nocopy.exception.NotValidationPasswordException;
|
||||||
import ru.soune.nocopy.exception.UserNotFoundException;
|
import ru.soune.nocopy.exception.UserNotFoundException;
|
||||||
import ru.soune.nocopy.repository.AuthTokenRepository;
|
import ru.soune.nocopy.repository.AuthTokenRepository;
|
||||||
import ru.soune.nocopy.repository.UserRepository;
|
import ru.soune.nocopy.repository.UserRepository;
|
||||||
import ru.soune.nocopy.service.auth.AuthService;
|
|
||||||
|
|
||||||
import java.util.Optional;
|
import java.util.Optional;
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user