Final push for project
Change-Id: I9103078156eca93df2482b9fe3854d9301bb98b3
diff --git a/Tree.txt b/Tree.txt
new file mode 100644
index 0000000..6eab78e
--- /dev/null
+++ b/Tree.txt
@@ -0,0 +1,129 @@
+.
+├── Tree.txt
+├── backend
+│ └── demo
+│ ├── Dockerfile
+│ ├── HELP.md
+│ ├── compose.yaml
+│ ├── db
+│ │ └── SQLScript.sql
+│ ├── dependency_tree.txt
+│ ├── mvnw
+│ ├── mvnw.cmd
+│ ├── pom.xml
+│ ├── src
+│ │ ├── main
+│ │ │ ├── java
+│ │ │ │ └── com
+│ │ │ │ └── example
+│ │ │ │ └── demo
+│ │ │ │ ├── DemoApplication.java
+│ │ │ │ ├── config
+│ │ │ │ │ ├── JWTProperties.java
+│ │ │ │ │ ├── SecurityConfig.java
+│ │ │ │ │ └── WebConfig.java
+│ │ │ │ ├── controller
+│ │ │ │ │ ├── AuthController.java
+│ │ │ │ │ └── TorrentController.java
+│ │ │ │ ├── dto
+│ │ │ │ │ ├── LoginRequestDTO.java
+│ │ │ │ │ ├── LoginResponseDTO.java
+│ │ │ │ │ └── TorrentInfoDTO.java
+│ │ │ │ ├── entity
+│ │ │ │ │ ├── TorrentInfo.java
+│ │ │ │ │ └── User.java
+│ │ │ │ ├── exception
+│ │ │ │ │ ├── AuthException.java
+│ │ │ │ │ └── GlobalExceptionHandler.java
+│ │ │ │ ├── mapper
+│ │ │ │ │ ├── TorrentInfoMapper.java
+│ │ │ │ │ └── UserMapper.java
+│ │ │ │ ├── result.txt
+│ │ │ │ ├── security
+│ │ │ │ │ ├── JwtAuthenticationFilter.java
+│ │ │ │ │ └── JwtTokenUtil.java
+│ │ │ │ ├── service
+│ │ │ │ │ ├── TorrentService.java
+│ │ │ │ │ ├── UserService.java
+│ │ │ │ │ └── impl
+│ │ │ │ │ ├── TorrentServiceImpl.java
+│ │ │ │ │ └── UserServiceImpl.java
+│ │ │ │ ├── sh.py
+│ │ │ │ └── util
+│ │ │ │ └── TorrentUtils.java
+│ │ │ └── resources
+│ │ │ ├── META-INF
+│ │ │ │ └── additional-spring-configuration-metadata.json
+│ │ │ ├── application.properties
+│ │ │ ├── static
+│ │ │ └── templates
+│ │ └── test
+│ │ └── java
+│ │ └── com
+│ │ └── example
+│ │ └── demo
+│ │ ├── DemoApplicationTests.java
+│ │ ├── controller
+│ │ │ ├── AuthControllerMockTest.java
+│ │ │ └── TorrentControllerTest.java
+│ │ ├── security
+│ │ │ └── JwtTokenUtilTest.java
+│ │ ├── service
+│ │ │ └── impl
+│ │ │ └── TorrentServiceImplTest.java
+│ │ └── util
+│ │ └── TorrentByteReader.java
+│ └── test_temp_upload_dir
+└── frontend
+ └── my-app
+ ├── README.md
+ ├── index.html
+ ├── package-lock.json
+ ├── package.json
+ ├── public
+ │ └── vite.svg
+ ├── src
+ │ ├── App.css
+ │ ├── App.jsx
+ │ ├── assets
+ │ │ ├── fonts
+ │ │ ├── icons
+ │ │ ├── images
+ │ │ └── react.svg
+ │ ├── components
+ │ │ ├── Button
+ │ │ ├── Card
+ │ │ ├── Modal
+ │ │ └── SearchBar
+ │ ├── contexts
+ │ │ └── UserContext.jsx
+ │ ├── hooks
+ │ ├── index.css
+ │ ├── main.jsx
+ │ ├── mocks
+ │ │ ├── handlers.js
+ │ │ └── server.js
+ │ ├── pages
+ │ │ ├── Home.jsx
+ │ │ ├── UploadTorrent.jsx
+ │ │ └── UserProfile.jsx
+ │ ├── services
+ │ │ └── torrentService.js
+ │ ├── setUpTests.js
+ │ ├── store
+ │ │ ├── actions
+ │ │ └── reducers
+ │ ├── styles
+ │ │ ├── base
+ │ │ │ └── base.css
+ │ │ ├── components
+ │ │ ├── pages
+ │ │ └── theme
+ │ │ └── theme.js
+ │ └── utils
+ │ ├── dateUtils
+ │ ├── storage
+ │ └── validation
+ └── vite.config.jsx
+
+64 directories, 62 files
diff --git a/backend/demo/Dockerfile b/backend/demo/Dockerfile
index 3b73f3c..8c3fa5b 100644
--- a/backend/demo/Dockerfile
+++ b/backend/demo/Dockerfile
@@ -1,4 +1,4 @@
-# 阶段 1: builder - 构建应用 JAR 包 (跳过测试)
+# 阶段 1: builder - 构建应用 JAR 包并准备分层结构
# 使用包含 Maven 和 JDK 的基础镜像
FROM maven:3.9.9-eclipse-temurin-24-alpine AS builder
@@ -6,61 +6,28 @@
WORKDIR /app
# 复制 pom.xml 文件，以便 Maven 可以下载依赖
+# 这一步利用 Docker 缓存，如果 pom.xml 没有变化，则不会重新下载依赖
COPY pom.xml .
-# 复制项目源代码，包括 main 和 test
-# 这一步是为了让 Maven 在构建和下载依赖时能够解析所有模块
+# 复制项目源代码
COPY src ./src
-# 执行 Maven clean 和 dependency:go-offline
-# clean: 清理 target 目录
-# dependency:go-offline: 下载所有项目依赖到本地 Maven 仓库，供后续阶段使用
-# -B: 非交互模式
-# 这一步不执行实际的编译和测试，主要用于缓存依赖
-RUN mvn clean dependency:go-offline -B
-
-# 执行 Maven package 构建项目，生成 JAR 包
-# -DskipTests: 跳过单元和集成测试
+# 执行 Maven package 构建项目
+# spring-boot-maven-plugin 会生成一个可执行 JAR (例如 demo-0.0.1-SNAPSHOT.jar)，
+# 并且在 target 目录下也会有 BOOT-INF/lib (所有依赖) 和 BOOT-INF/classes (您的应用代码) 等分层结构
RUN mvn package -DskipTests
-# 阶段 2: tester - 专用于运行和调试测试的运行时环境
-# 基于与 builder 阶段相同的 Maven/JDK 基础镜像，确保测试所需的环境一致
-FROM maven:3.9.9-eclipse-temurin-24-alpine AS tester
-
-# 设置工作目录
-WORKDIR /app
-
-# 复制 pom.xml 和完整的 src 目录 (包含测试代码)
-COPY pom.xml .
-COPY src ./src
-
-# 从 builder 阶段复制已缓存的 Maven 本地仓库
-# 这样在 tester 阶段运行 Maven 时无需重新下载依赖
-COPY --from=builder /root/.m2 /root/.m2
-
-# 暴露调试端口 (可选，如果您需要远程调试测试过程)
-# 您可以在 docker compose 中映射这个端口到主机
-EXPOSE 5005
-
-# 设置默认命令，使容器启动后保持运行
-# 这样您可以方便地使用 docker exec 进入容器手动执行测试和调试命令
-# 如果您希望容器启动后自动运行测试，可以修改此命令为 ["mvn", "test"]
-CMD ["tail", "-f", "/dev/null"]
-
-
-# 阶段 3: runner - 运行最终应用 JAR 包的精简运行时环境
-# 使用轻量级的 OpenJDK JRE 镜像
+# 阶段 2: runner - 运行最终应用 JAR 包的精简运行时环境
+# 使用轻量级的 OpenJDK JRE 镜像，只包含运行时环境，减小镜像大小
FROM openjdk:17-jdk-slim-buster AS runner
-
-# 设置工作目录
WORKDIR /app
-# 从 builder 阶段复制构建好的应用 JAR 包
+# 复制可执行 jar 包
COPY --from=builder /app/target/demo-0.0.1-SNAPSHOT.jar app.jar
-# 暴露 Spring Boot 应用的默认端口
+# 暴露端口
EXPOSE 8080
-# 启动 Spring Boot 应用
-CMD ["java", "-jar", "app.jar"]
+# 直接运行 Spring Boot JAR（推荐方式）
+ENTRYPOINT ["java", "-jar", "app.jar"]
diff --git a/backend/demo/compose.yaml b/backend/demo/compose.yaml
index 4d288a2..1737a5a 100644
--- a/backend/demo/compose.yaml
+++ b/backend/demo/compose.yaml
@@ -40,33 +40,8 @@
mysql:
condition: service_healthy # 确保数据库服务处于健康状态才启动应用
- # 测试服务（使用 Dockerfile 的 tester 阶段）
- # 这个服务用于运行和调试需要连接数据库的测试
- tester:
- build:
- context: . # Dockerfile 所在的上下文路径
- dockerfile: Dockerfile # Dockerfile 文件名
- target: tester # 指定构建 Dockerfile 中的 tester 阶段
- container_name: tester
- # 暴露调试端口，映射到主机端口，用于远程调试测试过程
- ports:
- - "5005:5005"
- # 依赖于数据库服务，并等待其健康检查通过
- depends_on:
- mysql:
- condition: service_healthy # 确保数据库服务处于健康状态才启动测试容器
- environment:
- # 测试环境连接数据库的配置，使用数据库服务的名称作为主机名
- # 这些环境变量会覆盖 application-test.properties 中的相同配置
- SPRING_DATASOURCE_URL: jdbc:mysql://mysql:3306/mydatabase?serverTimezone=Asia/Shanghai&createDatabaseIfNotExist=TRUE&useSSL=FALSE
- SPRING_DATASOURCE_USERNAME: myuser
- SPRING_DATASOURCE_PASSWORD: secret
- # 设置 Maven 运行时的额外 JVM 参数，用于开启远程调试
- MAVEN_OPTS: "-agentlib:jdwp=transport=dt_socket,server=y,suspend=n,address=*:5005"
- # 默认命令：保持容器运行，方便手动进入容器执行测试和调试
- # 如果您希望容器启动后自动运行测试，可以修改此命令为 ["mvn", "test"]
- command: tail -f /dev/null
+
# 定义数据卷用于持久化数据库数据
volumes:
diff --git a/backend/demo/pom.xml b/backend/demo/pom.xml
index 6eccaf5..2e50a85 100644
--- a/backend/demo/pom.xml
+++ b/backend/demo/pom.xml
@@ -12,6 +12,16 @@
<version>3.4.4</version>
<relativePath/>
</parent>
+<repositories>
+ <repository>
+ <id>local-ttorrent</id>
+ <name>Local TTorrent Bundle</name>
+ <url>file://${project.basedir}/src/main/resources/lib</url>
+ <releases><enabled>true</enabled></releases>
+ <snapshots><enabled>false</enabled></snapshots>
+ </repository>
+ </repositories>
+
<groupId>com.example</groupId>
<artifactId>demo</artifactId>
@@ -28,7 +38,9 @@
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
-
+
+
+
<!-- 数据库驱动：MySQL、H2 -->
<dependency>
@@ -97,39 +109,42 @@
<version>0.11.5</version>
<scope>runtime</scope>
</dependency>
+<dependency>
+ <groupId>commons-codec</groupId>
+ <artifactId>commons-codec</artifactId>
+ </dependency>
+ <dependency>
+ <groupId>javax.annotation</groupId>
+ <artifactId>javax.annotation-api</artifactId>
+ <version>1.3.2</version>
+</dependency>
+
<dependency>
<groupId>com.turn</groupId>
<artifactId>ttorrent-bencoding</artifactId>
- <version>1.3.0-SNAPSHOT</version>
- </dependency>
-
- <!-- 通用工具模块（info_hash、文件结构等） -->
- <dependency>
- <groupId>com.turn</groupId>
- <artifactId>ttorrent-common</artifactId>
- <version>1.3.0-SNAPSHOT</version>
- </dependency>
-
- <!-- 网络通信支持（用于 Scrape/Tracker 通信） -->
- <dependency>
- <groupId>com.turn</groupId>
- <artifactId>ttorrent-network</artifactId>
- <version>1.0</version>
- </dependency>
-
- <!-- Tracker 服务（你自己部署的 announce 接口服务） -->
- <dependency>
- <groupId>com.turn</groupId>
- <artifactId>ttorrent-tracker</artifactId>
- <version>1.3.0-SNAPSHOT</version>
- </dependency>
-
- <!-- 客户端支持（如果你需要服务器自动发种、做种） -->
- <dependency>
+ <version>1.3.0-SNAPSHOT</version> <!-- Changed to match your file -->
+</dependency>
+<dependency>
<groupId>com.turn</groupId>
<artifactId>ttorrent-client</artifactId>
- <version>1.3.0-SNAPSHOT</version>
- </dependency>
+ <version>1.3.0-SNAPSHOT</version> <!-- Changed to match your file -->
+</dependency>
+<dependency>
+ <groupId>com.turn</groupId>
+ <artifactId>ttorrent-common</artifactId>
+ <version>1.3.0-SNAPSHOT</version> <!-- Changed to match your file -->
+</dependency>
+<dependency>
+ <groupId>com.turn</groupId>
+ <artifactId>ttorrent-network</artifactId>
+ <version>1.0</version> <!-- Changed to match your file (1.0) -->
+</dependency>
+<dependency>
+ <groupId>com.turn</groupId>
+ <artifactId>ttorrent-tracker</artifactId>
+ <version>1.3.0-SNAPSHOT</version> <!-- Changed to match your file -->
+</dependency>
+
</dependencies>
<build>
diff --git a/backend/demo/src/main/java/com/example/demo/config/SecurityConfig.java b/backend/demo/src/main/java/com/example/demo/config/SecurityConfig.java
index b3e7f91..0c3672b 100644
--- a/backend/demo/src/main/java/com/example/demo/config/SecurityConfig.java
+++ b/backend/demo/src/main/java/com/example/demo/config/SecurityConfig.java
@@ -12,6 +12,9 @@
import org.springframework.security.crypto.password.PasswordEncoder;
import org.springframework.security.web.SecurityFilterChain;
import org.springframework.security.web.authentication.UsernamePasswordAuthenticationFilter;
+import org.springframework.web.cors.CorsConfiguration; // 导入 CorsConfiguration
+import org.springframework.web.cors.UrlBasedCorsConfigurationSource; // 导入 UrlBasedCorsConfigurationSource
+import org.springframework.web.filter.CorsFilter; // 导入 CorsFilter
import com.example.demo.security.JwtAuthenticationFilter;
@@ -41,6 +44,22 @@
}
/**
+ * 配置 CORS 过滤器。
+ * 允许前端应用 (http://localhost:5173) 访问后端 API。
+ */
+ @Bean
+ public CorsFilter corsFilter() {
+ UrlBasedCorsConfigurationSource source = new UrlBasedCorsConfigurationSource();
+ CorsConfiguration config = new CorsConfiguration();
+ config.setAllowCredentials(true); // 允许发送 Cookie
+ config.addAllowedOrigin("http://localhost:5173"); // 允许的前端源
+ config.addAllowedHeader("*"); // 允许所有请求头
+ config.addAllowedMethod("*"); // 允许所有 HTTP 方法 (GET, POST, PUT, DELETE等)
+ source.registerCorsConfiguration("/**", config); // 对所有路径应用 CORS 配置
+ return new CorsFilter(source);
+ }
+
+ /**
* 核心安全策略配置。
* 配置内容包括：禁用 CSRF、禁用 Session 管理（使用 JWT 无状态）、
* 配置请求的授权规则，并将自定义的 JWT 认证过滤器添加到过滤器链中。
@@ -55,6 +74,15 @@
JwtAuthenticationFilter jwtFilter // 直接注入 JwtAuthenticationFilter Bean
) throws Exception {
http
+ // 添加 CORS 过滤器到 Spring Security 过滤器链的开头
+ .cors(cors -> cors.configurationSource(request -> {
+ CorsConfiguration config = new CorsConfiguration();
+ config.setAllowCredentials(true);
+ config.addAllowedOrigin("http://localhost:5173");
+ config.addAllowedHeader("*");
+ config.addAllowedMethod("*");
+ return config;
+ }))
// 禁用 CSRF (跨站请求伪造) 保护，因为 JWT 是无状态的，不需要 CSRF 保护
.csrf(AbstractHttpConfigurer::disable)
// 配置 Session 管理策略为无状态，不使用 Session
@@ -62,7 +90,7 @@
// 配置请求的授权规则
.authorizeHttpRequests(auth -> auth
// 允许对 /auth/** 路径下的所有请求进行匿名访问 (例如登录、注册接口)
- .requestMatchers("/auth/**").permitAll()
+ .requestMatchers("/api/auth/**").permitAll() // 确保这里的路径与您的 AuthController 匹配
// 其他所有请求都需要进行身份认证
.anyRequest().authenticated()
)
diff --git a/backend/demo/src/main/java/com/example/demo/config/WebConfig.java b/backend/demo/src/main/java/com/example/demo/config/WebConfig.java
new file mode 100644
index 0000000..839dce2
--- /dev/null
+++ b/backend/demo/src/main/java/com/example/demo/config/WebConfig.java
@@ -0,0 +1,19 @@
+package com.example.demo.config;
+
+import org.springframework.context.annotation.Configuration;
+import org.springframework.web.servlet.config.annotation.CorsRegistry;
+import org.springframework.web.servlet.config.annotation.WebMvcConfigurer;
+
+@Configuration
+public class WebConfig implements WebMvcConfigurer {
+
+ // @Override
+ public void addCorsMappings(CorsRegistry registry) {
+ registry.addMapping("/api/**") // Apply to your API path
+ .allowedOrigins("http://localhost:5173") // URL of your React app
+ .allowedMethods("GET", "POST", "PUT", "DELETE", "OPTIONS")
+ .allowedHeaders("*")
+ .allowCredentials(true);
+ }
+
+}
\ No newline at end of file
diff --git a/backend/demo/src/main/java/com/example/demo/controller/AuthController.java b/backend/demo/src/main/java/com/example/demo/controller/AuthController.java
index d7dfe50..18f3105 100644
--- a/backend/demo/src/main/java/com/example/demo/controller/AuthController.java
+++ b/backend/demo/src/main/java/com/example/demo/controller/AuthController.java
@@ -1,17 +1,13 @@
package com.example.demo.controller;
-import java.time.Instant;
-import java.util.List;
-import java.util.Map;
-
import org.springframework.http.ResponseEntity;
-import org.springframework.security.authentication.AuthenticationManager; // 导入 AuthenticationManager
-import org.springframework.security.authentication.UsernamePasswordAuthenticationToken; // 导入 UsernamePasswordAuthenticationToken
-import org.springframework.security.core.Authentication; // 导入 Authentication
-import org.springframework.security.core.context.SecurityContextHolder; // 导入 SecurityContextHolder
-import org.springframework.security.crypto.password.PasswordEncoder;
-import org.springframework.validation.BindingResult;
-import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.security.authentication.AuthenticationManager;
+import org.springframework.security.authentication.UsernamePasswordAuthenticationToken;
+import org.springframework.security.core.Authentication;
+import org.springframework.security.core.context.SecurityContextHolder; // 导入 AuthenticationManager
+import org.springframework.security.crypto.password.PasswordEncoder; // 导入 UsernamePasswordAuthenticationToken
+import org.springframework.validation.BindingResult; // 导入 Authentication
+import org.springframework.web.bind.annotation.PostMapping; // 导入 SecurityContextHolder
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
@@ -45,64 +41,45 @@
}
@PostMapping("/login")
- public ResponseEntity<?> login(
- @Valid @RequestBody LoginRequestDTO loginRequest,
- BindingResult bindingResult) {
+public ResponseEntity<?> login(
+ @Valid @RequestBody LoginRequestDTO loginRequest,
+ BindingResult bindingResult) {
- if (bindingResult.hasErrors()) {
- String errMsg = bindingResult.getFieldErrors().stream()
- .map(fe -> fe.getField() + ": " + fe.getDefaultMessage())
- .reduce((a, b) -> a + "; " + b)
- .orElse("Invalid parameters");
- return ResponseEntity.badRequest().body(Map.of("error", errMsg));
- }
+ if (bindingResult.hasErrors()) {
+ // … 参数校验错误的处理，这里不会走到
+ }
- try {
- // 使用 AuthenticationManager 进行认证
- // 这会触发 UserServiceImpl 中的 loadUserByUsername 方法的调用，并比较密码
- Authentication authentication = authenticationManager.authenticate(
- new UsernamePasswordAuthenticationToken(
- loginRequest.getUsername(),
- loginRequest.getPassword()
- )
- );
- // 将认证信息设置到 Spring Security 的上下文中
- SecurityContextHolder.getContext().setAuthentication(authentication);
+ try {
+ System.out.println("login(): 开始调用 authenticationManager.authenticate");
+ Authentication authentication = authenticationManager.authenticate(
+ new UsernamePasswordAuthenticationToken(
+ loginRequest.getUsername(),
+ loginRequest.getPassword()
+ )
+ );
+ System.out.println("login(): authenticate 成功，principal = "
+ + authentication.getPrincipal());
- // 获取认证后的用户详情（假设 User 实体实现了 UserDetails 接口）
- User userDetails = (User) authentication.getPrincipal();
+ // 设置到上下文
+ SecurityContextHolder.getContext().setAuthentication(authentication);
+ System.out.println("login(): SecurityContext 设置完成");
- // 调用 UserService 方法生成登录响应（包括 JWT Token）
- LoginResponseDTO response = userService.generateLoginResponse(userDetails);
+ // 强转 principal 为 用户实体
+ User userDetails = (User) authentication.getPrincipal();
+ System.out.println("login(): 拿到 userDetails，username = " + userDetails.getUsername());
- return ResponseEntity.ok(response);
-
- } catch (Exception e) {
- // 认证失败（用户名不存在或密码错误），抛出自定义认证异常
- // GlobalExceptionHandler 会捕获 AuthException 并返回 401
- throw new AuthException("用户名或密码错误", e);
- }
-
- // 移除原有的手动查找用户和密码比对逻辑
- /*
- User user = userService.lambdaQuery()
- .eq(User::getUsername, loginRequest.getUsername())
- .one();
-
- if (user == null || !passwordEncoder.matches(loginRequest.getPassword(), user.getPassword())) {
- throw new AuthException("用户名或密码错误");
- }
-
- String token = jwtTokenUtil.generateToken(user.getId(), user.getUsername(), user.getRole());
-
- LoginResponseDTO response = new LoginResponseDTO();
- response.setToken(token);
- response.setExpiresAt(Instant.now().plusMillis(jwtTokenUtil.getExpiration()));
- response.setUserId(user.getId());
- response.setUsername(user.getUsername());
- response.setRoles(List.of(user.getRole()));
+ // 调用生成 JWT 的方法
+ System.out.println("login(): 调用 userService.generateLoginResponse");
+ LoginResponseDTO response = userService.generateLoginResponse(userDetails);
+ System.out.println("login(): generateLoginResponse 返回 token = " + response.getToken());
return ResponseEntity.ok(response);
- */
+
+ } catch (Exception e) {
+ System.out.println("login(): 捕获到异常: " + e.getClass().getSimpleName() + " - " + e.getMessage());
+ e.printStackTrace();
+ throw new AuthException("用户名或密码错误", e);
}
+}
+
}
\ No newline at end of file
diff --git a/backend/demo/src/main/java/com/example/demo/controller/TorrentController.java b/backend/demo/src/main/java/com/example/demo/controller/TorrentController.java
index 0bd501a..6a91d27 100644
--- a/backend/demo/src/main/java/com/example/demo/controller/TorrentController.java
+++ b/backend/demo/src/main/java/com/example/demo/controller/TorrentController.java
@@ -1,16 +1,17 @@
// src/main/java/com/example/demo/controller/TorrentController.java
package com.example.demo.controller;
-import java.io.IOException; // 导入 DTO
-import java.nio.file.Path; // 导入服务接口
-import java.nio.file.Paths; // 导入 ttorrent 的异常
+import java.io.IOException;
+import java.net.MalformedURLException;
+import java.nio.file.Path;
+import java.nio.file.Paths;
-import org.springframework.beans.factory.annotation.Value; // 导入 @Value 用于读取配置
-import org.springframework.core.io.Resource; // 导入 Resource
-import org.springframework.core.io.UrlResource; // 导入 UrlResource
-import org.springframework.http.HttpHeaders; // 导入 HttpHeaders
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.core.io.Resource;
+import org.springframework.core.io.UrlResource;
+import org.springframework.http.HttpHeaders;
import org.springframework.http.HttpStatus;
-import org.springframework.http.MediaType; // 导入 MediaType
+import org.springframework.http.MediaType;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
@@ -27,38 +28,37 @@
/**
* 处理 .torrent 文件上传和下载的 RESTful 控制器。
*/
-@RestController // 组合了 @Controller 和 @ResponseBody，表示这是一个 RESTful 控制器
-@RequestMapping("/api") // 定义所有处理方法的根路径
+@RestController
+@RequestMapping("/api")
public class TorrentController {
private final TorrentService torrentService;
- @Value("${file.upload-dir}") // 从 application.properties 中注入文件上传目录
+ @Value("${file.upload-dir}")
private String uploadDir;
- // 通过构造函数注入 TorrentService
public TorrentController(TorrentService torrentService) {
this.torrentService = torrentService;
}
/**
- * 处理 .torrent 文件的上传请求。
+ * 上传 .torrent 文件并处理其元信息。
*
- * @param file 上传的 MultipartFile 对象，通过 @RequestParam("file") 绑定。
- * @return 包含 TorrentInfoDTO 的 ResponseEntity，表示操作结果。
+ * @param file 上传的 .torrent 文件
+ * @param title 用户指定的标题
+ * @return 处理结果
*/
- @PostMapping("/torrents") // 映射到 /api/torrents 的 POST 请求
- public ResponseEntity<TorrentInfoDTO> uploadTorrent(@RequestParam("file") MultipartFile file) {
- // 1. 接收 HTTP 请求 (通过 @PostMapping 和 @RequestParam)
+ @PostMapping("/torrents/upload")
+ public ResponseEntity<TorrentInfoDTO> uploadTorrent(
+ @RequestParam("file") MultipartFile file,
+ @RequestParam("title") String title) {
- // 2. 校验参数
if (file.isEmpty()) {
TorrentInfoDTO errorDto = new TorrentInfoDTO();
errorDto.setMessage("上传文件不能为空。");
return new ResponseEntity<>(errorDto, HttpStatus.BAD_REQUEST);
}
- // 校验文件类型 (可选，但推荐)
if (!file.getOriginalFilename().toLowerCase().endsWith(".torrent")) {
TorrentInfoDTO errorDto = new TorrentInfoDTO();
errorDto.setMessage("只允许上传 .torrent 文件。");
@@ -66,65 +66,66 @@
}
try {
- // 3. 调用 Service 层处理业务逻辑
- TorrentInfoDTO result = torrentService.handleUpload(file);
-
- // 4. 返回 TorrentInfoDTO 给前端
+ TorrentInfoDTO result = torrentService.handleUpload(file, title);
return new ResponseEntity<>(result, HttpStatus.OK);
} catch (InvalidBEncodingException e) {
- // 捕获 .torrent 文件解析错误
TorrentInfoDTO errorDto = new TorrentInfoDTO();
errorDto.setMessage("文件解析失败，请确保它是有效的 .torrent 文件: " + e.getMessage());
return new ResponseEntity<>(errorDto, HttpStatus.BAD_REQUEST);
} catch (IllegalArgumentException e) {
- // 捕获服务层抛出的非法参数异常 (如文件为空)
TorrentInfoDTO errorDto = new TorrentInfoDTO();
errorDto.setMessage("处理文件时发生错误: " + e.getMessage());
return new ResponseEntity<>(errorDto, HttpStatus.BAD_REQUEST);
} catch (IOException e) {
- // 捕获文件读写或保存失败的异常
TorrentInfoDTO errorDto = new TorrentInfoDTO();
errorDto.setMessage("文件上传或保存失败: " + e.getMessage());
return new ResponseEntity<>(errorDto, HttpStatus.INTERNAL_SERVER_ERROR);
} catch (Exception e) {
- // 捕获其他未知异常
TorrentInfoDTO errorDto = new TorrentInfoDTO();
errorDto.setMessage("文件上传过程中发生未知错误: " + e.getMessage());
- e.printStackTrace(); // 打印堆栈跟踪以便调试
+ e.printStackTrace();
return new ResponseEntity<>(errorDto, HttpStatus.INTERNAL_SERVER_ERROR);
}
}
/**
- * 实现 .torrent 文件的下载功能。
- * 根据 infoHash 找到对应的 .torrent 文件并提供下载。
+ * 下载已上传的 .torrent 文件。
*
- * @param infoHash 洪流的 info hash，用于查找服务器上的文件。
- * @param fileName 原始文件名 (用于设置下载时的文件名，实际查找文件仍依赖 infoHash)。
- * @return 包含 .torrent 文件内容的 ResponseEntity。
+ * @param infoHash 该文件的 info hash，用于定位文件
+ * @param fileName 用户下载时看到的文件名
+ * @return ResponseEntity 包含下载资源
*/
- // 修正后的 downloadTorrent 方法片段
-@GetMapping("/downloads/{infoHash}/{fileName}")
-public ResponseEntity<Resource> downloadTorrent(@PathVariable String infoHash, @PathVariable String fileName) {
- try {
- Path fileStorageLocation = Paths.get(uploadDir).toAbsolutePath().normalize();
- Path filePath = fileStorageLocation.resolve(infoHash + ".torrent").normalize();
- Resource resource = new UrlResource(filePath.toUri()); // 这一行不会抛出 MalformedURLException
-
- if (resource.exists() && resource.isReadable()) {
- String contentType = "application/x-bittorrent";
- String headerValue = "attachment; filename=\"" + fileName + "\"";
-
- return ResponseEntity.ok()
- .contentType(MediaType.parseMediaType(contentType))
- .header(HttpHeaders.CONTENT_DISPOSITION, headerValue)
- .body(resource);
- } else {
- return new ResponseEntity<>(HttpStatus.NOT_FOUND);
+ // —— 2. 启动下载 —— //
+ @PostMapping("/download")
+ public ResponseEntity<Void> download(@RequestParam("infoHash") String infoHash) {
+ try {
+ torrentService.startDownload(infoHash);
+ return ResponseEntity.accepted().build();
+ } catch (Exception e) {
+ return ResponseEntity.status(HttpStatus.INTERNAL_SERVER_ERROR).build();
}
- } catch (IOException e) { // 只保留 IOException
- return new ResponseEntity<>(HttpStatus.INTERNAL_SERVER_ERROR);
}
- // MalformedURLException 相关的 catch 块已移除
+
+ // —— 3. 查询下载进度 —— //
+ @GetMapping("/download/status/{infoHash}")
+ public ResponseEntity<Float> status(@PathVariable String infoHash) {
+ float progress = torrentService.getDownloadProgress(infoHash);
+ return ResponseEntity.ok(progress);
+ }
+
+ // —— 4. 获取下载后的文件路径 —— //
+ // 如果你想让浏览器直接触发下载，也可以重定向或返回文件流
+ @GetMapping("/download/file/{infoHash}")
+ public ResponseEntity<Resource> file(@PathVariable String infoHash) throws MalformedURLException {
+ String path = torrentService.getDownloadedFilePath(infoHash);
+ if (path == null) {
+ return ResponseEntity.notFound().build();
+ }
+ UrlResource resource = new UrlResource("file:" + path);
+ return ResponseEntity.ok()
+ .header(HttpHeaders.CONTENT_DISPOSITION,
+ "attachment; filename=\"" + Paths.get(path).getFileName() + "\"")
+ .body(resource);
+ }
+
}
-}
\ No newline at end of file
diff --git a/backend/demo/src/main/java/com/example/demo/result.txt b/backend/demo/src/main/java/com/example/demo/result.txt
index bd1dd30..d7cdef4 100644
--- a/backend/demo/src/main/java/com/example/demo/result.txt
+++ b/backend/demo/src/main/java/com/example/demo/result.txt
@@ -110,6 +110,9 @@
import org.springframework.security.crypto.password.PasswordEncoder;
import org.springframework.security.web.SecurityFilterChain;
import org.springframework.security.web.authentication.UsernamePasswordAuthenticationFilter;
+import org.springframework.web.cors.CorsConfiguration; // 导入 CorsConfiguration
+import org.springframework.web.cors.UrlBasedCorsConfigurationSource; // 导入 UrlBasedCorsConfigurationSource
+import org.springframework.web.filter.CorsFilter; // 导入 CorsFilter
import com.example.demo.security.JwtAuthenticationFilter;
@@ -139,6 +142,22 @@
}
/**
+ * 配置 CORS 过滤器。
+ * 允许前端应用 (http://localhost:5173) 访问后端 API。
+ */
+ @Bean
+ public CorsFilter corsFilter() {
+ UrlBasedCorsConfigurationSource source = new UrlBasedCorsConfigurationSource();
+ CorsConfiguration config = new CorsConfiguration();
+ config.setAllowCredentials(true); // 允许发送 Cookie
+ config.addAllowedOrigin("http://localhost:5173"); // 允许的前端源
+ config.addAllowedHeader("*"); // 允许所有请求头
+ config.addAllowedMethod("*"); // 允许所有 HTTP 方法 (GET, POST, PUT, DELETE等)
+ source.registerCorsConfiguration("/**", config); // 对所有路径应用 CORS 配置
+ return new CorsFilter(source);
+ }
+
+ /**
* 核心安全策略配置。
* 配置内容包括：禁用 CSRF、禁用 Session 管理（使用 JWT 无状态）、
* 配置请求的授权规则，并将自定义的 JWT 认证过滤器添加到过滤器链中。
@@ -153,6 +172,15 @@
JwtAuthenticationFilter jwtFilter // 直接注入 JwtAuthenticationFilter Bean
) throws Exception {
http
+ // 添加 CORS 过滤器到 Spring Security 过滤器链的开头
+ .cors(cors -> cors.configurationSource(request -> {
+ CorsConfiguration config = new CorsConfiguration();
+ config.setAllowCredentials(true);
+ config.addAllowedOrigin("http://localhost:5173");
+ config.addAllowedHeader("*");
+ config.addAllowedMethod("*");
+ return config;
+ }))
// 禁用 CSRF (跨站请求伪造) 保护，因为 JWT 是无状态的，不需要 CSRF 保护
.csrf(AbstractHttpConfigurer::disable)
// 配置 Session 管理策略为无状态，不使用 Session
@@ -160,7 +188,7 @@
// 配置请求的授权规则
.authorizeHttpRequests(auth -> auth
// 允许对 /auth/** 路径下的所有请求进行匿名访问 (例如登录、注册接口)
- .requestMatchers("/auth/**").permitAll()
+ .requestMatchers("/api/auth/**").permitAll() // 确保这里的路径与您的 AuthController 匹配
// 其他所有请求都需要进行身份认证
.anyRequest().authenticated()
)
@@ -185,18 +213,14 @@
--- Content of: ./controller/AuthController.java ---
package com.example.demo.controller;
-import java.time.Instant;
-import java.util.List;
-import java.util.Map;
-
import org.springframework.http.ResponseEntity;
-import org.springframework.security.authentication.AuthenticationManager; // 导入 AuthenticationManager
-import org.springframework.security.authentication.UsernamePasswordAuthenticationToken; // 导入 UsernamePasswordAuthenticationToken
-import org.springframework.security.core.Authentication; // 导入 Authentication
-import org.springframework.security.core.context.SecurityContextHolder; // 导入 SecurityContextHolder
-import org.springframework.security.crypto.password.PasswordEncoder;
-import org.springframework.validation.BindingResult;
-import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.security.authentication.AuthenticationManager;
+import org.springframework.security.authentication.UsernamePasswordAuthenticationToken;
+import org.springframework.security.core.Authentication;
+import org.springframework.security.core.context.SecurityContextHolder; // 导入 AuthenticationManager
+import org.springframework.security.crypto.password.PasswordEncoder; // 导入 UsernamePasswordAuthenticationToken
+import org.springframework.validation.BindingResult; // 导入 Authentication
+import org.springframework.web.bind.annotation.PostMapping; // 导入 SecurityContextHolder
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
@@ -230,68 +254,175 @@
}
@PostMapping("/login")
- public ResponseEntity<?> login(
- @Valid @RequestBody LoginRequestDTO loginRequest,
- BindingResult bindingResult) {
+public ResponseEntity<?> login(
+ @Valid @RequestBody LoginRequestDTO loginRequest,
+ BindingResult bindingResult) {
- if (bindingResult.hasErrors()) {
- String errMsg = bindingResult.getFieldErrors().stream()
- .map(fe -> fe.getField() + ": " + fe.getDefaultMessage())
- .reduce((a, b) -> a + "; " + b)
- .orElse("Invalid parameters");
- return ResponseEntity.badRequest().body(Map.of("error", errMsg));
+ if (bindingResult.hasErrors()) {
+ // … 参数校验错误的处理，这里不会走到
+ }
+
+ try {
+ System.out.println("login(): 开始调用 authenticationManager.authenticate");
+ Authentication authentication = authenticationManager.authenticate(
+ new UsernamePasswordAuthenticationToken(
+ loginRequest.getUsername(),
+ loginRequest.getPassword()
+ )
+ );
+ System.out.println("login(): authenticate 成功，principal = "
+ + authentication.getPrincipal());
+
+ // 设置到上下文
+ SecurityContextHolder.getContext().setAuthentication(authentication);
+ System.out.println("login(): SecurityContext 设置完成");
+
+ // 强转 principal 为 用户实体
+ User userDetails = (User) authentication.getPrincipal();
+ System.out.println("login(): 拿到 userDetails，username = " + userDetails.getUsername());
+
+ // 调用生成 JWT 的方法
+ System.out.println("login(): 调用 userService.generateLoginResponse");
+ LoginResponseDTO response = userService.generateLoginResponse(userDetails);
+ System.out.println("login(): generateLoginResponse 返回 token = " + response.getToken());
+
+ return ResponseEntity.ok(response);
+
+ } catch (Exception e) {
+ System.out.println("login(): 捕获到异常: " + e.getClass().getSimpleName() + " - " + e.getMessage());
+ e.printStackTrace();
+ throw new AuthException("用户名或密码错误", e);
+ }
+}
+
+}
+--- End of: ./controller/AuthController.java ---
+
+--- Content of: ./controller/TorrentController.java ---
+// src/main/java/com/example/demo/controller/TorrentController.java
+package com.example.demo.controller;
+
+import java.io.IOException;
+import java.nio.file.Path;
+import java.nio.file.Paths;
+
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.core.io.Resource;
+import org.springframework.core.io.UrlResource;
+import org.springframework.http.HttpHeaders;
+import org.springframework.http.HttpStatus;
+import org.springframework.http.MediaType;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.PostMapping;
+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.multipart.MultipartFile;
+
+import com.example.demo.dto.TorrentInfoDTO;
+import com.example.demo.service.TorrentService;
+import com.turn.ttorrent.bcodec.InvalidBEncodingException;
+
+/**
+ * 处理 .torrent 文件上传和下载的 RESTful 控制器。
+ */
+@RestController
+@RequestMapping("/api")
+public class TorrentController {
+
+ private final TorrentService torrentService;
+
+ @Value("${file.upload-dir}")
+ private String uploadDir;
+
+ public TorrentController(TorrentService torrentService) {
+ this.torrentService = torrentService;
+ }
+
+ /**
+ * 上传 .torrent 文件并处理其元信息。
+ *
+ * @param file 上传的 .torrent 文件
+ * @param title 用户指定的标题
+ * @return 处理结果
+ */
+ @PostMapping("/torrents/upload")
+ public ResponseEntity<TorrentInfoDTO> uploadTorrent(
+ @RequestParam("file") MultipartFile file,
+ @RequestParam("title") String title) {
+
+ if (file.isEmpty()) {
+ TorrentInfoDTO errorDto = new TorrentInfoDTO();
+ errorDto.setMessage("上传文件不能为空。");
+ return new ResponseEntity<>(errorDto, HttpStatus.BAD_REQUEST);
+ }
+
+ if (!file.getOriginalFilename().toLowerCase().endsWith(".torrent")) {
+ TorrentInfoDTO errorDto = new TorrentInfoDTO();
+ errorDto.setMessage("只允许上传 .torrent 文件。");
+ return new ResponseEntity<>(errorDto, HttpStatus.UNSUPPORTED_MEDIA_TYPE);
}
try {
- // 使用 AuthenticationManager 进行认证
- // 这会触发 UserServiceImpl 中的 loadUserByUsername 方法的调用，并比较密码
- Authentication authentication = authenticationManager.authenticate(
- new UsernamePasswordAuthenticationToken(
- loginRequest.getUsername(),
- loginRequest.getPassword()
- )
- );
- // 将认证信息设置到 Spring Security 的上下文中
- SecurityContextHolder.getContext().setAuthentication(authentication);
-
- // 获取认证后的用户详情（假设 User 实体实现了 UserDetails 接口）
- User userDetails = (User) authentication.getPrincipal();
-
- // 调用 UserService 方法生成登录响应（包括 JWT Token）
- LoginResponseDTO response = userService.generateLoginResponse(userDetails);
-
- return ResponseEntity.ok(response);
-
+ TorrentInfoDTO result = torrentService.handleUpload(file, title);
+ return new ResponseEntity<>(result, HttpStatus.OK);
+ } catch (InvalidBEncodingException e) {
+ TorrentInfoDTO errorDto = new TorrentInfoDTO();
+ errorDto.setMessage("文件解析失败，请确保它是有效的 .torrent 文件: " + e.getMessage());
+ return new ResponseEntity<>(errorDto, HttpStatus.BAD_REQUEST);
+ } catch (IllegalArgumentException e) {
+ TorrentInfoDTO errorDto = new TorrentInfoDTO();
+ errorDto.setMessage("处理文件时发生错误: " + e.getMessage());
+ return new ResponseEntity<>(errorDto, HttpStatus.BAD_REQUEST);
+ } catch (IOException e) {
+ TorrentInfoDTO errorDto = new TorrentInfoDTO();
+ errorDto.setMessage("文件上传或保存失败: " + e.getMessage());
+ return new ResponseEntity<>(errorDto, HttpStatus.INTERNAL_SERVER_ERROR);
} catch (Exception e) {
- // 认证失败（用户名不存在或密码错误），抛出自定义认证异常
- // GlobalExceptionHandler 会捕获 AuthException 并返回 401
- throw new AuthException("用户名或密码错误", e);
+ TorrentInfoDTO errorDto = new TorrentInfoDTO();
+ errorDto.setMessage("文件上传过程中发生未知错误: " + e.getMessage());
+ e.printStackTrace();
+ return new ResponseEntity<>(errorDto, HttpStatus.INTERNAL_SERVER_ERROR);
}
+ }
- // 移除原有的手动查找用户和密码比对逻辑
- /*
- User user = userService.lambdaQuery()
- .eq(User::getUsername, loginRequest.getUsername())
- .one();
+ /**
+ * 下载已上传的 .torrent 文件。
+ *
+ * @param infoHash 该文件的 info hash，用于定位文件
+ * @param fileName 用户下载时看到的文件名
+ * @return ResponseEntity 包含下载资源
+ */
+ @GetMapping("/downloads/{infoHash}/{fileName}")
+ public ResponseEntity<Resource> downloadTorrent(
+ @PathVariable String infoHash,
+ @PathVariable String fileName) {
- if (user == null || !passwordEncoder.matches(loginRequest.getPassword(), user.getPassword())) {
- throw new AuthException("用户名或密码错误");
+ try {
+ Path fileStorageLocation = Paths.get(uploadDir).toAbsolutePath().normalize();
+ Path filePath = fileStorageLocation.resolve(infoHash + ".torrent").normalize();
+ Resource resource = new UrlResource(filePath.toUri());
+
+ if (resource.exists() && resource.isReadable()) {
+ String contentType = "application/x-bittorrent";
+ String headerValue = "attachment; filename=\"" + fileName + "\"";
+
+ return ResponseEntity.ok()
+ .contentType(MediaType.parseMediaType(contentType))
+ .header(HttpHeaders.CONTENT_DISPOSITION, headerValue)
+ .body(resource);
+ } else {
+ return new ResponseEntity<>(HttpStatus.NOT_FOUND);
+ }
+ } catch (IOException e) {
+ return new ResponseEntity<>(HttpStatus.INTERNAL_SERVER_ERROR);
}
-
- String token = jwtTokenUtil.generateToken(user.getId(), user.getUsername(), user.getRole());
-
- LoginResponseDTO response = new LoginResponseDTO();
- response.setToken(token);
- response.setExpiresAt(Instant.now().plusMillis(jwtTokenUtil.getExpiration()));
- response.setUserId(user.getId());
- response.setUsername(user.getUsername());
- response.setRoles(List.of(user.getRole()));
-
- return ResponseEntity.ok(response);
- */
}
}
---- End of: ./controller/AuthController.java ---
+
+--- End of: ./controller/TorrentController.java ---
--- Content of: ./DemoApplication.java ---
package com.example.demo;
@@ -414,6 +545,96 @@
--- End of: ./dto/LoginResponseDTO.java ---
+--- Content of: ./dto/TorrentInfoDTO.java ---
+// src/main/java/com/example/demo/dto/TorrentInfoDTO.java
+package com.example.demo.dto;
+
+import java.io.Serializable;
+
+public class TorrentInfoDTO implements Serializable {
+ private String fileName;
+ private long fileSize;
+ private String infoHash;
+ private String magnetUri;
+ private String downloadUrl;
+ private String message; // For success or error messages
+
+ // Constructors
+ public TorrentInfoDTO() {
+ }
+
+ public TorrentInfoDTO(String fileName, long fileSize, String infoHash, String magnetUri, String downloadUrl, String message) {
+ this.fileName = fileName;
+ this.fileSize = fileSize;
+ this.infoHash = infoHash;
+ this.magnetUri = magnetUri;
+ this.downloadUrl = downloadUrl;
+ this.message = message;
+ }
+
+ // Getters and Setters
+ public String getFileName() {
+ return fileName;
+ }
+
+ public void setFileName(String fileName) {
+ this.fileName = fileName;
+ }
+
+ public long getFileSize() {
+ return fileSize;
+ }
+
+ public void setFileSize(long fileSize) {
+ this.fileSize = fileSize;
+ }
+
+ public String getInfoHash() {
+ return infoHash;
+ }
+
+ public void setInfoHash(String infoHash) {
+ this.infoHash = infoHash;
+ }
+
+ public String getMagnetUri() {
+ return magnetUri;
+ }
+
+ public void setMagnetUri(String magnetUri) {
+ this.magnetUri = magnetUri;
+ }
+
+ public String getDownloadUrl() {
+ return downloadUrl;
+ }
+
+ public void setDownloadUrl(String downloadUrl) {
+ this.downloadUrl = downloadUrl;
+ }
+
+ public String getMessage() {
+ return message;
+ }
+
+ public void setMessage(String message) {
+ this.message = message;
+ }
+
+ @Override
+ public String toString() {
+ return "TorrentInfoDTO{" +
+ "fileName='" + fileName + '\'' +
+ ", fileSize=" + fileSize +
+ ", infoHash='" + infoHash + '\'' +
+ ", magnetUri='" + magnetUri + '\'' +
+ ", downloadUrl='" + downloadUrl + '\'' +
+ ", message='" + message + '\'' +
+ '}';
+ }
+}
+--- End of: ./dto/TorrentInfoDTO.java ---
+
--- Content of: ./entity/User.java ---
package com.example.demo.entity;
@@ -579,6 +800,127 @@
--- End of: ./entity/User.java ---
+--- Content of: ./entity/TorrentInfo.java ---
+// src/main/java/com/example/demo/entity/TorrentInfo.java
+package com.example.demo.entity;
+
+import java.time.LocalDateTime;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+
+@TableName("torrent_info") // 映射到数据库中的 torrent_info 表
+public class TorrentInfo {
+
+ @TableId(value = "id", type = IdType.AUTO) // 标记为主键，并设置为数据库自增
+ private Long id;
+
+ @TableField("info_hash") // 映射到数据库中的 info_hash 列
+ private String infoHash; // 洪流的唯一标识符（信息哈希）
+
+ @TableField("file_name") // 映射到数据库中的 file_name 列
+ private String fileName; // 原始文件名
+
+ @TableField("file_size") // 映射到数据库中的 file_size 列
+ private Long fileSize; // 文件大小（字节）
+
+ @TableField("magnet_uri") // 映射到数据库中的 magnet_uri 列
+ private String magnetUri; // 生成的磁力链接
+
+ @TableField("download_url") // 映射到数据库中的 download_url 列
+ private String downloadUrl; // .torrent 文件的下载 URL
+
+ @TableField("upload_time") // 映射到数据库中的 upload_time 列
+ private LocalDateTime uploadTime; // 上传时间
+
+ // 默认构造函数，MyBatis-Plus 需要
+ public TorrentInfo() {
+ }
+
+ // 带有所有字段的构造函数（不包含 ID 和 uploadTime，因为它们是自动生成的）
+ public TorrentInfo(String infoHash, String fileName, Long fileSize, String magnetUri, String downloadUrl) {
+ this.infoHash = infoHash;
+ this.fileName = fileName;
+ this.fileSize = fileSize;
+ this.magnetUri = magnetUri;
+ this.downloadUrl = downloadUrl;
+ this.uploadTime = LocalDateTime.now(); // 设置当前上传时间
+ }
+
+ // Getters and Setters
+ public Long getId() {
+ return id;
+ }
+
+ public void setId(Long id) {
+ this.id = id;
+ }
+
+ public String getInfoHash() {
+ return infoHash;
+ }
+
+ public void setInfoHash(String infoHash) {
+ this.infoHash = infoHash;
+ }
+
+ public String getFileName() {
+ return fileName;
+ }
+
+ public void setFileName(String fileName) {
+ this.fileName = fileName;
+ }
+
+ public Long getFileSize() {
+ return fileSize;
+ }
+
+ public void setFileSize(Long fileSize) {
+ this.fileSize = fileSize;
+ }
+
+ public String getMagnetUri() {
+ return magnetUri;
+ }
+
+ public void setMagnetUri(String magnetUri) {
+ this.magnetUri = magnetUri;
+ }
+
+ public String getDownloadUrl() {
+ return downloadUrl;
+ }
+
+ public void setDownloadUrl(String downloadUrl) {
+ this.downloadUrl = downloadUrl;
+ }
+
+ public LocalDateTime getUploadTime() {
+ return uploadTime;
+ }
+
+ public void setUploadTime(LocalDateTime uploadTime) {
+ this.uploadTime = uploadTime;
+ }
+
+ @Override
+ public String toString() {
+ return "TorrentInfo{" +
+ "id=" + id +
+ ", infoHash='" + infoHash + '\'' +
+ ", fileName='" + fileName + '\'' +
+ ", fileSize=" + fileSize +
+ ", magnetUri='" + magnetUri + '\'' +
+ ", downloadUrl='" + downloadUrl + '\'' +
+ ", uploadTime=" + uploadTime +
+ '}';
+ }
+}
+--- End of: ./entity/TorrentInfo.java ---
+
--- Content of: ./exception/AuthException.java ---
package com.example.demo.exception;
@@ -666,15 +1008,31 @@
--- End of: ./mapper/UserMapper.java ---
+--- Content of: ./mapper/TorrentInfoMapper.java ---
+// src/main/java/com/example/demo/mapper/TorrentInfoMapper.java
+package com.example.demo.mapper;
+
+import org.apache.ibatis.annotations.Mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.example.demo.entity.TorrentInfo; // MyBatis 的 Mapper 注解
+
+@Mapper // 标记这是一个 MyBatis Mapper 接口
+public interface TorrentInfoMapper extends BaseMapper<TorrentInfo> {
+ // BaseMapper 提供了基本的 CRUD 操作，例如 insert(), selectById(), selectList(), deleteById() 等。
+ // 无需编写任何实现代码。
+}
+--- End of: ./mapper/TorrentInfoMapper.java ---
+
--- Content of: ./security/JwtAuthenticationFilter.java ---
package com.example.demo.security;
import java.io.IOException;
-import java.util.List;
import org.springframework.security.authentication.UsernamePasswordAuthenticationToken;
-import org.springframework.security.core.authority.SimpleGrantedAuthority;
import org.springframework.security.core.context.SecurityContextHolder;
+import org.springframework.security.core.userdetails.UserDetails;
+import org.springframework.security.core.userdetails.UserDetailsService;
import org.springframework.stereotype.Component;
import org.springframework.util.StringUtils;
import org.springframework.web.filter.OncePerRequestFilter;
@@ -682,20 +1040,23 @@
import com.example.demo.config.JWTProperties;
import com.example.demo.exception.AuthException;
-import io.jsonwebtoken.Claims;
import jakarta.servlet.FilterChain;
import jakarta.servlet.ServletException;
import jakarta.servlet.http.HttpServletRequest;
import jakarta.servlet.http.HttpServletResponse;
-@Component
+@Component
public class JwtAuthenticationFilter extends OncePerRequestFilter {
private final JwtTokenUtil tokenUtil;
private final JWTProperties props;
+ private final UserDetailsService userDetailsService; // ✅ 注入接口
- public JwtAuthenticationFilter(JwtTokenUtil tokenUtil, JWTProperties props) {
+ public JwtAuthenticationFilter(JwtTokenUtil tokenUtil,
+ JWTProperties props,
+ UserDetailsService userDetailsService) {
this.tokenUtil = tokenUtil;
this.props = props;
+ this.userDetailsService = userDetailsService;
}
@Override
@@ -715,16 +1076,16 @@
throw new AuthException("Invalid or expired JWT token");
}
- Claims claims = tokenUtil.parseClaims(token);
- String username =tokenUtil.getUsername(token);
- Long userId = tokenUtil.getUserId(token);
- String role = tokenUtil.getRole(token);
+ String username = tokenUtil.getUsername(token);
+
+ // ✅ 使用 UserServiceImpl 加载完整的用户对象（包括权限信息）
+ UserDetails userDetails = userDetailsService.loadUserByUsername(username);
UsernamePasswordAuthenticationToken auth =
new UsernamePasswordAuthenticationToken(
- userId,
- null,
- List.of(new SimpleGrantedAuthority(role))
+ userDetails, // ✅ 设置完整的用户对象
+ null,
+ userDetails.getAuthorities()
);
SecurityContextHolder.getContext().setAuthentication(auth);
@@ -875,26 +1236,15 @@
import com.example.demo.service.UserService;
-/**
- * 用户业务逻辑服务实现类
- * 继承了MyBatis-Plus的ServiceImpl，并实现了UserService接口和Spring Security的UserDetailsService接口。
- * 利用ServiceImpl提供的通用CRUD方法，并实现自定义的用户业务操作和加载用户详情。
- * 用户登录认证逻辑已移至 Controller 层，以解决循环依赖问题。
- */
+
@Service
-// 继承ServiceImpl，指定Mapper和实体类型。
-// 这样就自动拥有了IService中大部分通用方法的实现。
+
public class UserServiceImpl extends ServiceImpl<UserMapper, User> implements UserService, UserDetailsService {
- // 当继承ServiceImpl后，ServiceImpl内部已经注入了BaseMapper，
- // 通常不需要在这里再次声明UserMapper，除非您需要调用UserMapper中自定义的非BaseMapper方法。
- // private final UserMapper userMapper; // 如果继承ServiceImpl，这行通常可以移除
- // 注入密码编码器，用于密码加密和校验
+
private final PasswordEncoder passwordEncoder;
- // 移除 AuthenticationManager 注入，认证逻辑已移至 Controller
- // private final AuthenticationManager authenticationManager;
- // 注入JWT工具类，用于生成和解析Token
+
private final JwtTokenUtil jwtTokenUtil;
@@ -902,12 +1252,12 @@
* 构造函数注入非BaseMapper的依赖
* ServiceImpl会自动注入BaseMapper
* @param passwordEncoder 密码编码器
- * // 移除 authenticationManager 参数
+ *
* @param jwtTokenUtil JWT工具类
*/
- // @Autowired // 当只有一个构造函数时，@Autowired 可选
+
public UserServiceImpl(PasswordEncoder passwordEncoder,
- // AuthenticationManager authenticationManager, // 移除此参数
+ // 移除此参数
JwtTokenUtil jwtTokenUtil) {
// 当继承ServiceImpl时，不需要在构造函数中注入并初始化BaseMapper
// this.userMapper = userMapper; // 移除这行
@@ -1008,22 +1358,6 @@
return response;
}
-
-
- // 当继承ServiceImpl后，IService中的通用方法（如 save, updateById, list, page 等）
- // 已经由ServiceImpl提供默认实现，无需在此重复编写。
- // 如果您需要对IService中的某个通用方法进行定制（例如在保存前进行额外处理），
- // 可以在这里@Override该方法并添加您的逻辑，然后调用super.方法名(...)来执行ServiceImpl的默认逻辑。
- /*
- @Override
- public boolean saveBatch(Collection<User> entityList, int batchSize) {
- // 在调用ServiceImpl的批量保存前/后添加自定义逻辑
- // ...
- return super.saveBatch(entityList, batchSize); // 调用ServiceImpl的默认实现
- }
-
- // ... 其他IService中的方法实现
- */
}
--- End of: ./service/impl/UserServiceImpl.java ---
diff --git a/backend/demo/src/main/java/com/example/demo/security/JwtAuthenticationFilter.java b/backend/demo/src/main/java/com/example/demo/security/JwtAuthenticationFilter.java
index 520908c..d69361f 100644
--- a/backend/demo/src/main/java/com/example/demo/security/JwtAuthenticationFilter.java
+++ b/backend/demo/src/main/java/com/example/demo/security/JwtAuthenticationFilter.java
@@ -1,11 +1,11 @@
package com.example.demo.security;
import java.io.IOException;
-import java.util.List;
import org.springframework.security.authentication.UsernamePasswordAuthenticationToken;
-import org.springframework.security.core.authority.SimpleGrantedAuthority;
import org.springframework.security.core.context.SecurityContextHolder;
+import org.springframework.security.core.userdetails.UserDetails;
+import org.springframework.security.core.userdetails.UserDetailsService;
import org.springframework.stereotype.Component;
import org.springframework.util.StringUtils;
import org.springframework.web.filter.OncePerRequestFilter;
@@ -13,20 +13,23 @@
import com.example.demo.config.JWTProperties;
import com.example.demo.exception.AuthException;
-import io.jsonwebtoken.Claims;
import jakarta.servlet.FilterChain;
import jakarta.servlet.ServletException;
import jakarta.servlet.http.HttpServletRequest;
import jakarta.servlet.http.HttpServletResponse;
-@Component
+@Component
public class JwtAuthenticationFilter extends OncePerRequestFilter {
private final JwtTokenUtil tokenUtil;
private final JWTProperties props;
+ private final UserDetailsService userDetailsService; // ✅ 注入接口
- public JwtAuthenticationFilter(JwtTokenUtil tokenUtil, JWTProperties props) {
+ public JwtAuthenticationFilter(JwtTokenUtil tokenUtil,
+ JWTProperties props,
+ UserDetailsService userDetailsService) {
this.tokenUtil = tokenUtil;
this.props = props;
+ this.userDetailsService = userDetailsService;
}
@Override
@@ -46,16 +49,16 @@
throw new AuthException("Invalid or expired JWT token");
}
- Claims claims = tokenUtil.parseClaims(token);
- String username =tokenUtil.getUsername(token);
- Long userId = tokenUtil.getUserId(token);
- String role = tokenUtil.getRole(token);
+ String username = tokenUtil.getUsername(token);
+
+ // ✅ 使用 UserServiceImpl 加载完整的用户对象（包括权限信息）
+ UserDetails userDetails = userDetailsService.loadUserByUsername(username);
UsernamePasswordAuthenticationToken auth =
new UsernamePasswordAuthenticationToken(
- userId,
- null,
- List.of(new SimpleGrantedAuthority(role))
+ userDetails, // ✅ 设置完整的用户对象
+ null,
+ userDetails.getAuthorities()
);
SecurityContextHolder.getContext().setAuthentication(auth);
diff --git a/backend/demo/src/main/java/com/example/demo/service/TorrentService.java b/backend/demo/src/main/java/com/example/demo/service/TorrentService.java
index b863798..2be7aad 100644
--- a/backend/demo/src/main/java/com/example/demo/service/TorrentService.java
+++ b/backend/demo/src/main/java/com/example/demo/service/TorrentService.java
@@ -1,4 +1,3 @@
-// src/main/java/com/example/demo/service/TorrentService.java
package com.example.demo.service;
import java.io.IOException;
@@ -17,10 +16,35 @@
* 处理上传的 .torrent 文件，解析其内容，保存到数据库，并生成相关链接。
*
* @param file 上传的 MultipartFile 对象
+ * @param title 洪流的标题
* @return 包含解析信息、磁力链接和下载 URL 的 TorrentInfoDTO
* @throws IOException 如果文件读取或保存失败
* @throws InvalidBEncodingException 如果 .torrent 文件内容不符合 B 编码规范
* @throws IllegalArgumentException 如果文件为空或解析后的元数据不完整
*/
- TorrentInfoDTO handleUpload(MultipartFile file) throws IOException, InvalidBEncodingException, IllegalArgumentException;
+ TorrentInfoDTO handleUpload(MultipartFile file, String title) throws IOException, InvalidBEncodingException, IllegalArgumentException;
+
+ /**
+ * 根据 infoHash 启动与 Tracker 联动的下载任务（异步执行）。
+ *
+ * @param infoHash 种子的 infoHash（十六进制字符串）
+ * @throws Exception 启动任务失败时抛出
+ */
+void startDownload(String infoHash) throws Exception;
+
+/**
+ * 查询指定 infoHash 的当前下载进度，返回值范围 0.0 到 1.0。
+ *
+ * @param infoHash 种子的 infoHash
+ * @return 下载完成比例（0.0–1.0）
+ */
+float getDownloadProgress(String infoHash);
+
+/**
+ * 下载完成后，获取本地保存的文件路径；若未完成或未启动下载，则返回 null。
+ *
+ * @param infoHash 种子的 infoHash
+ * @return 已下载文件的绝对路径或 null
+ */
+String getDownloadedFilePath(String infoHash);
}
\ No newline at end of file
diff --git a/backend/demo/src/main/java/com/example/demo/service/impl/TorrentServiceImpl.java b/backend/demo/src/main/java/com/example/demo/service/impl/TorrentServiceImpl.java
index eb00160..eedad56 100644
--- a/backend/demo/src/main/java/com/example/demo/service/impl/TorrentServiceImpl.java
+++ b/backend/demo/src/main/java/com/example/demo/service/impl/TorrentServiceImpl.java
@@ -2,9 +2,15 @@
package com.example.demo.service.impl;
import java.io.IOException;
+import java.net.InetAddress;
import java.nio.file.Files; // 导入 DTO
import java.nio.file.Path; // 导入实体类
import java.nio.file.Paths; // 导入 Mapper
+import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+import java.util.concurrent.TimeUnit;
import org.springframework.beans.factory.annotation.Value; // 导入服务接口
import org.springframework.stereotype.Service; // 导入工具类
@@ -18,6 +24,14 @@
import com.example.demo.service.TorrentService; // 用于文件操作
import com.example.demo.util.TorrentUtils; // 用于文件路径
import com.turn.ttorrent.bcodec.InvalidBEncodingException; // 用于文件路径
+import com.turn.ttorrent.client.CommunicationManager;
+import com.turn.ttorrent.client.PeerInformation;
+import com.turn.ttorrent.client.PieceInformation;
+import com.turn.ttorrent.client.SharedTorrent;
+import com.turn.ttorrent.client.TorrentListener;
+import com.turn.ttorrent.client.TorrentManager;
+
+import jakarta.annotation.PostConstruct;
/**
* TorrentService 接口的实现类，负责处理 .torrent 文件的上传、解析、持久化及链接生成。
@@ -27,8 +41,11 @@
private final TorrentInfoMapper torrentInfoMapper;
- @Value("${file.upload-dir}") // 从 application.properties 中注入文件上传目录
- private String uploadDir;
+ @Value("${file.upload-dir}")
+ private String uploadDir;
+
+ @Value("${file.download-dir}")
+ private String downloadDir;
// 通过构造函数注入 Mapper
public TorrentServiceImpl(TorrentInfoMapper torrentInfoMapper) {
@@ -37,7 +54,7 @@
@Override
@Transactional // 确保文件保存和数据库操作的原子性
- public TorrentInfoDTO handleUpload(MultipartFile file) throws IOException, InvalidBEncodingException, IllegalArgumentException {
+ public TorrentInfoDTO handleUpload(MultipartFile file,String title) throws IOException, InvalidBEncodingException, IllegalArgumentException {
if (file.isEmpty()) {
throw new IllegalArgumentException("上传文件不能为空。");
}
@@ -123,4 +140,82 @@
return dto;
}
+
+ private CommunicationManager commManager;
+ private final Map<String, TorrentManager> managers = new ConcurrentHashMap<>();
+ private final ExecutorService executor = Executors.newFixedThreadPool(4);
+
+ @PostConstruct
+ public void init() throws Exception {
+ // 1. 初始化 CommunicationManager
+ ExecutorService netPool = Executors.newFixedThreadPool(4);
+ ExecutorService ioPool = Executors.newFixedThreadPool(2);
+ this.commManager = new CommunicationManager(netPool, ioPool);
+ this.commManager.start(InetAddress.getLocalHost());
+ }
+
+ @Override
+ public void startDownload(String infoHash) throws Exception {
+ // 2.1 .torrent 文件路径 & 本地输出目录
+ String torrentPath = uploadDir + "/" + infoHash + ".torrent";
+ String outDir = downloadDir + "/" + infoHash;
+ TorrentManager tm = commManager.addTorrent(torrentPath, outDir);
+
+ // 2.2 注册进度监听
+ tm.addListener(new TorrentListener() {
+ @Override
+ public void pieceDownloaded(PieceInformation pi, PeerInformation peer) {
+ // no-op
+ }
+ @Override public void downloadComplete() {
+ System.out.println("[" + infoHash + "] 下载完成");
+ }
+ @Override public void validationComplete(int valid, int total) {}
+ @Override public void peerConnected(PeerInformation peer) {}
+ @Override public void peerDisconnected(PeerInformation peer) {}
+ @Override public void pieceReceived(PieceInformation pi, PeerInformation peer) {}
+ @Override public void downloadFailed(Throwable cause) {
+ cause.printStackTrace();
+ }
+ });
+
+ // 2.3 异步等待完成
+ executor.submit(() -> {
+ try {
+ tm.awaitDownloadComplete(Integer.MAX_VALUE, TimeUnit.SECONDS);
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ });
+
+ managers.put(infoHash, tm);
+ }
+
+ @Override
+public float getDownloadProgress(String infoHash) {
+ for (SharedTorrent t : commManager.getTorrents()) {
+ if (t.getHexInfoHash().equalsIgnoreCase(infoHash)) {
+ long downloaded = t.getDownloaded(); // 已下载字节数
+ long left = t.getLeft(); // 剩余字节数
+ long total = downloaded + left; // 总字节数
+ return total > 0
+ ? (float) downloaded / total
+ : 0f;
+ }
+ }
+ return 0f;
+}
+
+
+ @Override
+ public String getDownloadedFilePath(String infoHash) {
+ for (SharedTorrent t : commManager.getTorrents()) {
+ if (t.getHexInfoHash().equalsIgnoreCase(infoHash) && t.isComplete()) {
+ // 拿到第一个文件的相对路径，再拼上下载目录
+ String rel = t.getFiles().get(0).getRelativePathAsString();
+ return downloadDir + "/" + infoHash + "/" + rel;
+ }
+ }
+ return null;
+ }
}
\ No newline at end of file
diff --git a/backend/demo/src/main/java/com/example/demo/service/impl/UserServiceImpl.java b/backend/demo/src/main/java/com/example/demo/service/impl/UserServiceImpl.java
index 1fc434c..1b72d0f 100644
--- a/backend/demo/src/main/java/com/example/demo/service/impl/UserServiceImpl.java
+++ b/backend/demo/src/main/java/com/example/demo/service/impl/UserServiceImpl.java
@@ -19,26 +19,15 @@
import com.example.demo.service.UserService;
-/**
- * 用户业务逻辑服务实现类
- * 继承了MyBatis-Plus的ServiceImpl，并实现了UserService接口和Spring Security的UserDetailsService接口。
- * 利用ServiceImpl提供的通用CRUD方法，并实现自定义的用户业务操作和加载用户详情。
- * 用户登录认证逻辑已移至 Controller 层，以解决循环依赖问题。
- */
+
@Service
-// 继承ServiceImpl，指定Mapper和实体类型。
-// 这样就自动拥有了IService中大部分通用方法的实现。
+
public class UserServiceImpl extends ServiceImpl<UserMapper, User> implements UserService, UserDetailsService {
- // 当继承ServiceImpl后，ServiceImpl内部已经注入了BaseMapper，
- // 通常不需要在这里再次声明UserMapper，除非您需要调用UserMapper中自定义的非BaseMapper方法。
- // private final UserMapper userMapper; // 如果继承ServiceImpl，这行通常可以移除
- // 注入密码编码器，用于密码加密和校验
+
private final PasswordEncoder passwordEncoder;
- // 移除 AuthenticationManager 注入，认证逻辑已移至 Controller
- // private final AuthenticationManager authenticationManager;
- // 注入JWT工具类，用于生成和解析Token
+
private final JwtTokenUtil jwtTokenUtil;
@@ -46,12 +35,12 @@
* 构造函数注入非BaseMapper的依赖
* ServiceImpl会自动注入BaseMapper
* @param passwordEncoder 密码编码器
- * // 移除 authenticationManager 参数
+ *
* @param jwtTokenUtil JWT工具类
*/
- // @Autowired // 当只有一个构造函数时，@Autowired 可选
+
public UserServiceImpl(PasswordEncoder passwordEncoder,
- // AuthenticationManager authenticationManager, // 移除此参数
+ // 移除此参数
JwtTokenUtil jwtTokenUtil) {
// 当继承ServiceImpl时，不需要在构造函数中注入并初始化BaseMapper
// this.userMapper = userMapper; // 移除这行
@@ -152,20 +141,4 @@
return response;
}
-
-
- // 当继承ServiceImpl后，IService中的通用方法（如 save, updateById, list, page 等）
- // 已经由ServiceImpl提供默认实现，无需在此重复编写。
- // 如果您需要对IService中的某个通用方法进行定制（例如在保存前进行额外处理），
- // 可以在这里@Override该方法并添加您的逻辑，然后调用super.方法名(...)来执行ServiceImpl的默认逻辑。
- /*
- @Override
- public boolean saveBatch(Collection<User> entityList, int batchSize) {
- // 在调用ServiceImpl的批量保存前/后添加自定义逻辑
- // ...
- return super.saveBatch(entityList, batchSize); // 调用ServiceImpl的默认实现
- }
-
- // ... 其他IService中的方法实现
- */
}
diff --git a/backend/demo/src/main/java/com/example/demo/sh.py b/backend/demo/src/main/java/com/example/demo/sh.py
index 3be143b..7b30510 100644
--- a/backend/demo/src/main/java/com/example/demo/sh.py
+++ b/backend/demo/src/main/java/com/example/demo/sh.py
@@ -53,13 +53,17 @@
'./config/JWTProperties.java',
'./config/SecurityConfig.java',
'./controller/AuthController.java',
+ './controller/TorrentController.java',
'./DemoApplication.java',
'./dto/LoginRequestDTO.java',
'./dto/LoginResponseDTO.java',
+ './dto/TorrentInfoDTO.java',
'./entity/User.java',
+ './entity/TorrentInfo.java',
'./exception/AuthException.java',
'./exception/GlobalExceptionHandler.java',
'./mapper/UserMapper.java',
+ './mapper/TorrentInfoMapper.java',
'./security/JwtAuthenticationFilter.java',
'./security/JwtTokenUtil.java',
'./service/UserService.java',
diff --git a/backend/demo/src/main/resources/META-INF/additional-spring-configuration-metadata.json b/backend/demo/src/main/resources/META-INF/additional-spring-configuration-metadata.json
index cf06b61..3da4c86 100644
--- a/backend/demo/src/main/resources/META-INF/additional-spring-configuration-metadata.json
+++ b/backend/demo/src/main/resources/META-INF/additional-spring-configuration-metadata.json
@@ -1,5 +1,12 @@
-{"properties": [{
- "name": "file.upload-dir",
- "type": "java.lang.String",
- "description": "Torrent dir for uploading'"
-}]}
\ No newline at end of file
+{"properties": [
+ {
+ "name": "file.upload-dir",
+ "type": "java.lang.String",
+ "description": "Torrent dir for uploading'"
+ },
+ {
+ "name": "app.torrent.download-dir",
+ "type": "java.lang.String",
+ "description": "A description for 'app.torrent.download-dir'"
+ }
+]}
\ No newline at end of file
diff --git a/backend/demo/src/main/resources/application.properties b/backend/demo/src/main/resources/application.properties
index 9bbb45b..720d673 100644
--- a/backend/demo/src/main/resources/application.properties
+++ b/backend/demo/src/main/resources/application.properties
@@ -1,15 +1,21 @@
# ========== 数据源 ==========
-spring.datasource.url=jdbc:mysql://mysql:3306/mydatabase?serverTimezone=Asia/Shanghai&createDatabaseIfNotExist=TRUE&useSSL=FALSE&allowPublicKeyRetrieval=TRUE
+spring.datasource.url=jdbc:mysql://localhost:3306/mydatabase?serverTimezone=Asia/Shanghai&useSSL=false&allowPublicKeyRetrieval=true
spring.datasource.username=myuser
spring.datasource.password=secret
spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
# ========== JWT 配置 ==========
-jwt.secret=YourJWTSecretKeyHere1234567890
+jwt.secret=YWFhYWFhYWFhYWFhYWFhYWFhYWFhYWFhYWFhYWFhYWE=
jwt.expirationMs=3600000
# ========== 日志输出（可选） ==========
logging.level.org.springframework.security=DEBUG
+logging.level.root=INFO
+logging.level.org.springframework.web=DEBUG
+logging.level.org.springframework.web.servlet=DEBUG
+logging.level.com.example=DEBUG
file.upload-dir=./torrents
-
+app.torrent.download-dir=downloads
+spring.docker.compose.enabled=false
+spring.web.resources.static-locations=file:downloads/
\ No newline at end of file
diff --git a/backend/demo/src/main/resources/lib b/backend/demo/src/main/resources/lib
new file mode 160000
index 0000000..ed28512
--- /dev/null
+++ b/backend/demo/src/main/resources/lib
@@ -0,0 +1 @@
+Subproject commit ed28512530673c7363ae21f6fa09543955963de8
diff --git a/backend/demo/src/test/java/com/example/demo/controller/TorrentControllerTest.java b/backend/demo/src/test/java/com/example/demo/controller/TorrentControllerTest.java
index e0f2c8d..2ff389d 100644
--- a/backend/demo/src/test/java/com/example/demo/controller/TorrentControllerTest.java
+++ b/backend/demo/src/test/java/com/example/demo/controller/TorrentControllerTest.java
@@ -74,7 +74,7 @@
// 当 torrentService.handleUpload 被调用时，返回预期的 DTO
// When torrentService.handleUpload is called, return the expected DTO
- when(torrentService.handleUpload(any(MultipartFile.class))).thenReturn(expectedDto);
+ when(torrentService.handleUpload(any(MultipartFile.class), null)).thenReturn(expectedDto);
// 2. 执行请求并验证结果 (Execute the request and verify the results)
mockMvc.perform(multipart("/api/torrents") // 发送 POST 请求到 /api/torrents (Send POST request to /api/torrents)
@@ -141,7 +141,7 @@
// 配置 torrentService.handleUpload 在被调用时抛出 InvalidBEncodingException
// Configure torrentService.handleUpload to throw InvalidBEncodingException when called
- when(torrentService.handleUpload(any(MultipartFile.class)))
+ when(torrentService.handleUpload(any(MultipartFile.class), null))
.thenThrow(new InvalidBEncodingException("Mocked BEncoding error"));
mockMvc.perform(multipart("/api/torrents")
@@ -166,7 +166,7 @@
// 配置 torrentService.handleUpload 在被调用时抛出 IOException
// Configure torrentService.handleUpload to throw IOException when called
- when(torrentService.handleUpload(any(MultipartFile.class)))
+ when(torrentService.handleUpload(any(MultipartFile.class), null))
.thenThrow(new IOException("Mocked IO error"));
mockMvc.perform(multipart("/api/torrents")
@@ -191,7 +191,7 @@
// 配置 torrentService.handleUpload 在被调用时抛出 RuntimeException
// Configure torrentService.handleUpload to throw RuntimeException when called
- when(torrentService.handleUpload(any(MultipartFile.class)))
+ when(torrentService.handleUpload(any(MultipartFile.class), null))
.thenThrow(new RuntimeException("Mocked generic error"));
mockMvc.perform(multipart("/api/torrents")
@@ -216,7 +216,7 @@
// 配置 torrentService.handleUpload 在被调用时抛出 IllegalArgumentException
// Configure torrentService.handleUpload to throw IllegalArgumentException when called
- when(torrentService.handleUpload(any(MultipartFile.class)))
+ when(torrentService.handleUpload(any(MultipartFile.class), null))
.thenThrow(new IllegalArgumentException("Mocked illegal argument from service"));
mockMvc.perform(multipart("/api/torrents")
diff --git a/backend/demo/src/test/java/com/example/demo/service/impl/TorrentServiceImplTest.java b/backend/demo/src/test/java/com/example/demo/service/impl/TorrentServiceImplTest.java
index 69eb5ba..a9da766 100644
--- a/backend/demo/src/test/java/com/example/demo/service/impl/TorrentServiceImplTest.java
+++ b/backend/demo/src/test/java/com/example/demo/service/impl/TorrentServiceImplTest.java
@@ -138,7 +138,7 @@
when(torrentInfoMapper.insert(any(TorrentInfo.class))).thenReturn(1);
// 4. Call the service method under test
- TorrentInfoDTO result = torrentService.handleUpload(mockFile);
+ TorrentInfoDTO result = torrentService.handleUpload(mockFile, testFileName);
// 5. Assertions: Verify the returned DTO and side effects
@@ -218,7 +218,7 @@
when(torrentInfoMapper.selectOne(any(QueryWrapper.class))).thenReturn(existingTorrentInDb);
// 5. Call the service method
- TorrentInfoDTO result = torrentService.handleUpload(mockFile);
+ TorrentInfoDTO result = torrentService.handleUpload(mockFile, existingFileName);
// 6. Assertions
assertNotNull(result, "Returned DTO should not be null");
@@ -262,7 +262,7 @@
// Assert that calling handleUpload with an empty file throws IllegalArgumentException.
IllegalArgumentException thrown = assertThrows(IllegalArgumentException.class, () -> {
- torrentService.handleUpload(emptyFile);
+ torrentService.handleUpload(emptyFile, uploadDir);
}, "Should throw IllegalArgumentException for empty file");
// Verify the error message.
@@ -296,7 +296,7 @@
// Assert that calling handleUpload throws IllegalArgumentException.
IllegalArgumentException thrown = assertThrows(IllegalArgumentException.class, () -> {
- torrentService.handleUpload(mockFile);
+ torrentService.handleUpload(mockFile, uploadDir);
}, "Should throw IllegalArgumentException for invalid B-encoding");
// Verify the error message.
@@ -331,7 +331,7 @@
// Assert that calling handleUpload throws IOException.
IOException thrown = assertThrows(IOException.class, () -> {
- torrentService.handleUpload(mockFile);
+ torrentService.handleUpload(mockFile, uploadDir);
}, "Should throw IOException for parsing IO error");
// Verify the error message.
@@ -388,7 +388,7 @@
// Now, call the service method
IOException thrown = assertThrows(IOException.class, () -> {
- torrentService.handleUpload(mockFile);
+ torrentService.handleUpload(mockFile, testFileName);
}, "Should throw IOException when file saving fails");
assertTrue(thrown.getMessage().contains("无法保存 .torrent 文件到磁盘"), "Error message should indicate file save failure");
@@ -440,7 +440,7 @@
// Assert that calling handleUpload throws RuntimeException.
RuntimeException thrown = assertThrows(RuntimeException.class, () -> {
- torrentService.handleUpload(mockFile);
+ torrentService.handleUpload(mockFile, testFileName);
}, "Should throw RuntimeException when DB insert fails");
// Verify the error message.
diff --git a/backend/demo/torrents/E2BCE3123903796D19EEE0E341E2BB67FA8A66EC.torrent b/backend/demo/torrents/E2BCE3123903796D19EEE0E341E2BB67FA8A66EC.torrent
new file mode 100644
index 0000000..f38517a
--- /dev/null
+++ b/backend/demo/torrents/E2BCE3123903796D19EEE0E341E2BB67FA8A66EC.torrent
Binary files differ
diff --git a/frontend/my-app/package-lock.json b/frontend/my-app/package-lock.json
index 21a1a55..533fd75 100644
--- a/frontend/my-app/package-lock.json
+++ b/frontend/my-app/package-lock.json
@@ -13,6 +13,7 @@
"@mui/icons-material": "^7.0.2",
"@mui/material": "^7.0.2",
"axios": "^1.9.0",
+ "file-saver": "^2.0.5",
"react": "^19.0.0",
"react-dom": "^19.0.0",
"react-router-dom": "^7.5.1"
@@ -4915,6 +4916,12 @@
"node": "^10.12.0 || >=12.0.0"
}
},
+ "node_modules/file-saver": {
+ "version": "2.0.5",
+ "resolved": "https://registry.npmjs.org/file-saver/-/file-saver-2.0.5.tgz",
+ "integrity": "sha512-P9bmyZ3h/PRG+Nzga+rbdI4OEpNDzAVyy74uVO9ATgzLK6VtAsYybF/+TOCvrc0MO793d6+42lLyZTw7/ArVzA==",
+ "license": "MIT"
+ },
"node_modules/fill-range": {
"version": "7.1.1",
"resolved": "https://registry.npmjs.org/fill-range/-/fill-range-7.1.1.tgz",
diff --git a/frontend/my-app/package.json b/frontend/my-app/package.json
index 07b11c9..04db654 100644
--- a/frontend/my-app/package.json
+++ b/frontend/my-app/package.json
@@ -18,6 +18,7 @@
"@mui/icons-material": "^7.0.2",
"@mui/material": "^7.0.2",
"axios": "^1.9.0",
+ "file-saver": "^2.0.5",
"react": "^19.0.0",
"react-dom": "^19.0.0",
"react-router-dom": "^7.5.1"
diff --git a/frontend/my-app/src/App.jsx b/frontend/my-app/src/App.jsx
index 214e127..c83b97d 100644
--- a/frontend/my-app/src/App.jsx
+++ b/frontend/my-app/src/App.jsx
@@ -8,6 +8,7 @@
import UserProfile from './pages/UserProfile';
import UserContextProvider from './contexts/UserContext';
import TorrentUploadPage from './pages/UploadTorrent';
+import LoginPage from './pages/Login';
function App() {
return (
<UserContextProvider>
@@ -18,6 +19,7 @@
<Route path="/" element={<Home />} />
<Route path="/user/:id" element={<UserProfile />} />
<Route path="/Upload" element={<TorrentUploadPage />} />
+ <Route path="/login" element={<LoginPage />} />
</Routes>
</div>
</ThemeProvider>
diff --git a/frontend/my-app/src/components/Button/TorrentDownloadButton.jsx b/frontend/my-app/src/components/Button/TorrentDownloadButton.jsx
new file mode 100644
index 0000000..a8a6177
--- /dev/null
+++ b/frontend/my-app/src/components/Button/TorrentDownloadButton.jsx
@@ -0,0 +1,84 @@
+import React, { useState } from 'react';
+import PropTypes from 'prop-types';
+import axios from 'axios';
+import { saveAs } from 'file-saver';
+import Button from '@mui/material/Button';
+import LinearProgress from '@mui/material/LinearProgress';
+import Box from '@mui/material/Box';
+import Typography from '@mui/material/Typography';
+
+function TorrentDownloadButton({ infoHash, title }) {
+ // 新增状态：下载进度（0~100）
+ const [progress, setProgress] = useState(0);
+ // 新增状态：是否正在下载
+ const [downloading, setDownloading] = useState(false);
+
+ const handleDownload = async () => {
+ try {
+ setDownloading(true);
+ setProgress(0);
+ // 1) 启动下载
+ await axios.post('/api/torrents/download', null, { params: { infoHash } });
+
+ // 2) 轮询进度
+ let p = 0;
+ while (p < 1) {
+ await new Promise(resolve => setTimeout(resolve, 1000));
+ const res = await axios.get(`/api/torrents/download/status/${infoHash}`);
+ p = res.data;
+ setProgress(Math.round(p * 100));
+ }
+
+ // 3) 下载文件流
+ const fileRes = await axios.get(
+ `/api/torrents/download/file/${infoHash}`,
+ { responseType: 'blob' }
+ );
+
+ // 4) 保存文件
+ saveAs(fileRes.data, title);
+ } catch (err) {
+ console.error('下载过程中出错', err);
+ } finally {
+ setDownloading(false);
+ }
+ };
+
+ return (
+ <Box sx={{ width: 200 }}>
+ <Button
+ variant="outlined"
+ color="success"
+ onClick={handleDownload}
+ disabled={downloading}
+ sx={{
+ width: '100%',
+ fontSize: '0.85rem',
+ borderColor: '#4caf50',
+ '&:hover': {
+ backgroundColor: 'rgba(76, 175, 80, 0.15)',
+ borderColor: '#388e3c',
+ },
+ }}
+ >
+ {downloading ? `下载中 ${progress}%` : '下载'}
+ </Button>
+
+ {downloading && (
+ <Box sx={{ mt: 1 }}>
+ <LinearProgress variant="determinate" value={progress} />
+ <Typography variant="caption" display="block" align="center">
+ {progress}%
+ </Typography>
+ </Box>
+ )}
+ </Box>
+ );
+}
+
+TorrentDownloadButton.propTypes = {
+ infoHash: PropTypes.string.isRequired,
+ title: PropTypes.string.isRequired,
+};
+
+export default TorrentDownloadButton;
diff --git a/frontend/my-app/src/pages/Home.jsx b/frontend/my-app/src/pages/Home.jsx
index 6bca4b8..e2f7f8e 100644
--- a/frontend/my-app/src/pages/Home.jsx
+++ b/frontend/my-app/src/pages/Home.jsx
@@ -1,12 +1,10 @@
import React, { useState, useEffect } from 'react';
import {
Box, Container, Typography, Paper,
- List, ListItem, ListItemText, Chip, Stack, CircularProgress, Alert
+ List, ListItem, ListItemText, Chip, Stack, CircularProgress, Alert, Button
} from '@mui/material';
import { Link } from 'react-router-dom'; // 假设你已经配置了 React Router
-// import '../styles/base/base.css'; // ✅ 引入统一样式 - 我们将尝试用 sx prop 替代
-
// 模拟从API获取数据
const fetchTorrents = () => {
return new Promise((resolve) => {
@@ -63,7 +61,7 @@
return (
<Box sx={{ minHeight: '100vh', py: 4, background: 'linear-gradient(135deg, #2c3e50, #4ca1af)', color: 'white' }}>
- <Container maxWidth="md" sx={{ position: 'relative', zIndex: 10 }}> {/* Changed to md for wider content */}
+ <Container maxWidth="md" sx={{ position: 'relative', zIndex: 10 }}>
<Typography variant="h4" sx={{ textAlign: 'center', mb: 3, fontWeight: 'bold' }}>
🌐 首页 · Mini-Tracker
</Typography>
@@ -90,36 +88,41 @@
key={torrent.id}
component={Link} // react-router-dom Link
to={`/detail/${torrent.id}`} // 假设的详情页路由
- sx={{
- color: 'white',
+ sx={{
+ color: 'white',
textDecoration: 'none',
- mb: 1.5, // 增加列表项间距
- p: 1.5, // 增加列表项内边距
+ mb: 1.5,
+ p: 1.5,
borderBottom: '1px solid rgba(255, 255, 255, 0.1)',
'&:last-child': {
- borderBottom: 'none' // 移除最后一个元素的边框
+ borderBottom: 'none'
},
- display: 'flex', // 确保内部元素正确对齐
- flexDirection: { xs: 'column', sm: 'row' }, // 响应式布局
+ display: 'flex',
+ flexDirection: { xs: 'column', sm: 'row' },
alignItems: { xs: 'flex-start', sm: 'center' }
}}
- divider={false} // 使用自定义边框代替
+ divider={false}
>
<ListItemText
primary={torrent.title}
secondary={`大小: ${torrent.size} · 上传者: ${torrent.uploader}`}
- primaryTypographyProps={{ variant: 'h6', component: 'div', sx: { mb: 0.5, color: '#f5f5f5', fontWeight: 500 } }}
+ primaryTypographyProps={{
+ variant: 'h6',
+ component: 'div',
+ sx: { mb: 0.5, color: '#f5f5f5', fontWeight: 500 }
+ }}
secondaryTypographyProps={{ sx: { color: '#bbb', fontSize: '0.85rem' } }}
- sx={{ flexGrow: 1, mb: { xs: 1, sm: 0 }, mr: { sm: 2 } }} // 响应式边距
+ sx={{ flexGrow: 1, mb: { xs: 1, sm: 0 }, mr: { sm: 2 } }}
/>
- <Stack direction="row" spacing={1} sx={{ flexWrap: 'wrap', gap: 0.5 }}> {/* 允许标签换行 */}
+
+ <Stack direction="row" spacing={1} sx={{ flexWrap: 'wrap', gap: 0.5 }}>
{torrent.tags.map(tag => (
<Chip
key={tag}
label={tag}
size="small"
- sx={{
- backgroundColor: 'rgba(255, 255, 255, 0.2)', // upload-chip 样式
+ sx={{
+ backgroundColor: 'rgba(255, 255, 255, 0.2)',
color: 'white',
cursor: 'pointer',
'&:hover': {
@@ -129,6 +132,29 @@
/>
))}
</Stack>
+
+ {/* ——— 在此处添加“下载”按钮 —— */}
+ <Button
+ variant="outlined"
+ component="a"
+ href={`http://localhost:8080/api/downloads/${torrent.id}/${encodeURIComponent(torrent.title)}.torrent`}
+ download={`${torrent.title}.torrent`}
+ sx={{
+ ml: { xs: 0, sm: 2 }, // 小屏幕时居中；大屏幕时与右边距留空
+ mt: { xs: 1, sm: 0 }, // 小屏时在下方，留一点间距
+ color: '#4caf50',
+ borderColor: '#4caf50',
+ fontSize: '0.85rem',
+ '&:hover': {
+ backgroundColor: 'rgba(76, 175, 80, 0.15)',
+ borderColor: '#388e3c'
+ }
+ }}
+ >
+ 下载
+ </Button>
+ {/* ——— 下载按钮结束 ——— */}
+
</ListItem>
))}
</List>
@@ -136,7 +162,7 @@
</Paper>
</Container>
- {/* 背景泡泡动画复用 - 这些类名 (.bubbles, .bubble) 和 @keyframes rise 应该在全局CSS或者下面的 <style> 标签中定义 */}
+ {/* 背景泡泡动画复用 */}
<Box className="bubbles" sx={{
pointerEvents: 'none',
position: 'fixed',
@@ -145,7 +171,7 @@
width: '100%',
height: '100%',
overflow: 'hidden',
- zIndex: 1,
+ zIndex: 1,
}}>
{[...Array(40)].map((_, i) => (
<Box
@@ -153,48 +179,43 @@
className="bubble"
sx={{
position: 'absolute',
- bottom: '-150px', // 确保从屏幕外开始
- background: `hsla(${Math.random() * 360}, 70%, 80%, 0.15)`, // 增加颜色多样性
+ bottom: '-150px',
+ background: `hsla(${Math.random() * 360}, 70%, 80%, 0.15)`,
borderRadius: '50%',
animation: 'rise 20s infinite ease-in',
- width: `${Math.random() * 25 + 10}px`, // 调整大小范围
+ width: `${Math.random() * 25 + 10}px`,
height: `${Math.random() * 25 + 10}px`,
left: `${Math.random() * 100}%`,
- animationDuration: `${15 + Math.random() * 20}s`, // 调整动画时长
- animationDelay: `${Math.random() * 10}s`, // 调整动画延迟
- opacity: 0, // 初始透明
+ animationDuration: `${15 + Math.random() * 20}s`,
+ animationDelay: `${Math.random() * 10}s`,
+ opacity: 0,
}}
/>
))}
</Box>
- {/* 定义动画和其他全局可能需要的样式 */}
<style>
{`
- body { /* 基本重置 */
+ body {
margin: 0;
- font-family: 'Roboto', sans-serif; /* 确保字体一致 */
+ font-family: 'Roboto', sans-serif;
}
@keyframes rise {
0% {
transform: translateY(0) scale(0.8);
- opacity: 0; /* 从透明开始 */
+ opacity: 0;
}
10% {
- opacity: 1; /* 渐显 */
+ opacity: 1;
}
90% {
- opacity: 1; /* 保持可见 */
+ opacity: 1;
}
100% {
- transform: translateY(-130vh) scale(0.3); /* 飘得更高更小 */
- opacity: 0; /* 渐隐 */
+ transform: translateY(-130vh) scale(0.3);
+ opacity: 0;
}
}
-
- /* 如果 .bubbles 和 .bubble 样式没有在 sx 中完全覆盖，可以在这里补充 */
- /* .bubbles { ... } */
- /* .bubble { ... } */
`}
</style>
</Box>
@@ -202,4 +223,3 @@
}
export default Home;
-
diff --git a/frontend/my-app/src/pages/Login.jsx b/frontend/my-app/src/pages/Login.jsx
new file mode 100644
index 0000000..19f13ca
--- /dev/null
+++ b/frontend/my-app/src/pages/Login.jsx
@@ -0,0 +1,214 @@
+import React, { useState } from 'react';
+import {
+ Box, Container, Typography, Paper, TextField, Button, CircularProgress, Alert
+} from '@mui/material';
+// import { useNavigate } from 'react-router-dom'; // 如果需要重定向，请取消注释
+
+function LoginPage() {
+ const [username, setUsername] = useState('');
+ const [password, setPassword] = useState('');
+ const [loading, setLoading] = useState(false);
+ const [message, setMessage] = useState(null); // 用于显示成功或错误消息
+ const [messageSeverity, setMessageSeverity] = useState('info'); // 'success', 'error', 'info'
+
+ // const navigate = useNavigate(); // 如果需要重定向，请取消注释
+
+ const handleSubmit = async (event) => {
+ event.preventDefault(); // 阻止表单默认提交行为
+
+ setMessage(null); // 清除之前的消息
+ setLoading(true); // 显示加载指示器
+
+ try {
+ const response = await fetch('http://localhost:8080/api/auth/login', { // 确保这里的URL与您的后端接口一致
+ method: 'POST',
+ headers: {
+ 'Content-Type': 'application/json'
+ },
+ body: JSON.stringify({ username, password })
+ });
+
+ const data = await response.json();
+
+ if (response.ok) {
+ // 登录成功
+ setMessage('登录成功！欢迎 ' + data.username);
+ setMessageSeverity('success');
+ console.log('登录成功:', data);
+ // 将 JWT Token 保存到 localStorage
+ localStorage.setItem('jwt_token', data.token);
+ // 可选：登录成功后重定向到其他页面
+ // navigate('/dashboard');
+ } else {
+ // 登录失败
+ const errorMessage = data.error || '未知错误';
+ setMessage('登录失败: ' + errorMessage);
+ setMessageSeverity('error');
+ console.error('登录失败:', data);
+ }
+ } catch (error) {
+ // 网络错误或请求发送失败
+ setMessage('网络错误，请稍后再试。');
+ setMessageSeverity('error');
+ console.error('请求发送失败:', error);
+ } finally {
+ setLoading(false); // 隐藏加载指示器
+ }
+ };
+
+ return (
+ <Box sx={{
+ minHeight: '100vh',
+ display: 'flex',
+ justifyContent: 'center',
+ alignItems: 'center',
+ background: 'linear-gradient(135deg, #2c3e50, #4ca1af)', // 与 Home 组件相同的背景
+ color: 'white',
+ py: 4 // 垂直内边距
+ }}>
+ <Container maxWidth="xs" sx={{ position: 'relative', zIndex: 10 }}>
+ <Typography variant="h4" align="center" sx={{ mb: 4, fontWeight: 'bold' }}>
+ 🔐 用户登录
+ </Typography>
+
+ <Paper sx={{
+ p: 4, // 内边距
+ backgroundColor: 'rgba(30, 30, 30, 0.9)', // 半透明深色背景
+ borderRadius: '12px', // 圆角
+ boxShadow: '0 8px 16px rgba(0,0,0,0.3)' // 阴影
+ }}>
+ {message && (
+ <Alert severity={messageSeverity} sx={{ mb: 2, borderRadius: '8px' }}>
+ {message}
+ </Alert>
+ )}
+
+ <form onSubmit={handleSubmit}>
+ <TextField
+ label="用户名"
+ variant="outlined"
+ fullWidth
+ margin="normal"
+ value={username}
+ onChange={(e) => setUsername(e.target.value)}
+ required
+ sx={{
+ mb: 2, // 底部外边距
+ '& .MuiOutlinedInput-root': {
+ borderRadius: '8px',
+ color: 'white', // 输入文字颜色
+ '& fieldset': { borderColor: 'rgba(255, 255, 255, 0.3)' }, // 边框颜色
+ '&:hover fieldset': { borderColor: 'rgba(255, 255, 255, 0.5)' },
+ '&.Mui-focused fieldset': { borderColor: '#8b5cf6' }, // 聚焦时边框颜色
+ },
+ '& .MuiInputLabel-root': { color: '#bbb' }, // 标签颜色
+ '& .MuiInputLabel-root.Mui-focused': { color: '#8b5cf6' }, // 聚焦时标签颜色
+ }}
+ />
+ <TextField
+ label="密码"
+ type="password"
+ variant="outlined"
+ fullWidth
+ margin="normal"
+ value={password}
+ onChange={(e) => setPassword(e.target.value)}
+ required
+ sx={{
+ mb: 3, // 底部外边距
+ '& .MuiOutlinedInput-root': {
+ borderRadius: '8px',
+ color: 'white', // 输入文字颜色
+ '& fieldset': { borderColor: 'rgba(255, 255, 255, 0.3)' },
+ '&:hover fieldset': { borderColor: 'rgba(255, 255, 255, 0.5)' },
+ '&.Mui-focused fieldset': { borderColor: '#8b5cf6' },
+ },
+ '& .MuiInputLabel-root': { color: '#bbb' },
+ '& .MuiInputLabel-root.Mui-focused': { color: '#8b5cf6' },
+ }}
+ />
+ <Button
+ type="submit"
+ variant="contained"
+ fullWidth
+ disabled={loading}
+ sx={{
+ py: '0.75rem', // 垂直内边距
+ backgroundImage: 'linear-gradient(to right, #6366f1, #8b5cf6)', // 渐变背景
+ color: 'white',
+ borderRadius: '0.375rem', // 圆角
+ fontWeight: 600,
+ position: 'relative', // 用于加载指示器定位
+ '&:hover': {
+ backgroundImage: 'linear-gradient(to right, #4f46e5, #7c3aed)',
+ },
+ }}
+ >
+ {loading ? <CircularProgress size={24} color="inherit" sx={{ position: 'absolute' }} /> : '登录'}
+ </Button>
+ </form>
+ </Paper>
+ </Container>
+
+ {/* 背景泡泡动画 - 复用 Home 组件中的样式 */}
+ <Box className="bubbles" sx={{
+ pointerEvents: 'none',
+ position: 'fixed',
+ top: 0,
+ left: 0,
+ width: '100%',
+ height: '100%',
+ overflow: 'hidden',
+ zIndex: 1,
+ }}>
+ {[...Array(40)].map((_, i) => (
+ <Box
+ key={i}
+ className="bubble"
+ sx={{
+ position: 'absolute',
+ bottom: '-150px', // 确保从屏幕外开始
+ background: `hsla(${Math.random() * 360}, 70%, 80%, 0.15)`, // 增加颜色多样性
+ borderRadius: '50%',
+ animation: 'rise 20s infinite ease-in',
+ width: `${Math.random() * 25 + 10}px`, // 调整大小范围
+ height: `${Math.random() * 25 + 10}px`,
+ left: `${Math.random() * 100}%`,
+ animationDuration: `${15 + Math.random() * 20}s`, // 调整动画时长
+ animationDelay: `${Math.random() * 10}s`, // 调整动画延迟
+ opacity: 0, // 初始透明
+ }}
+ />
+ ))}
+ </Box>
+ {/* 定义动画和其他全局可能需要的样式 */}
+ <style>
+ {`
+ body { /* 基本重置 */
+ margin: 0;
+ font-family: 'Roboto', sans-serif; /* 确保字体一致 */
+ }
+
+ @keyframes rise {
+ 0% {
+ transform: translateY(0) scale(0.8);
+ opacity: 0; /* 从透明开始 */
+ }
+ 10% {
+ opacity: 1; /* 渐显 */
+ }
+ 90% {
+ opacity: 1; /* 保持可见 */
+ }
+ 100% {
+ transform: translateY(-130vh) scale(0.3); /* 飘得更高更小 */
+ opacity: 0; /* 渐隐 */
+ }
+ }
+ `}
+ </style>
+ </Box>
+ );
+}
+
+export default LoginPage;
\ No newline at end of file
diff --git a/frontend/my-app/src/pages/UploadTorrent.jsx b/frontend/my-app/src/pages/UploadTorrent.jsx
index 493cdce..465afda 100644
--- a/frontend/my-app/src/pages/UploadTorrent.jsx
+++ b/frontend/my-app/src/pages/UploadTorrent.jsx
@@ -4,43 +4,44 @@
TextField, Button, Stack
} from '@mui/material';
import CloudUploadIcon from '@mui/icons-material/CloudUpload';
-// Assuming your base.css is in a relative path like src/styles/base/base.css
-// If your component is in src/components/Upload.js, this path would be ../styles/base/base.css
-// Adjust if your project structure is different.
-// For this example, I'll assume it's correctly linked.
-// import '../styles/base/base.css';
+
function Upload() {
const [title, setTitle] = useState('');
const [file, setFile] = useState(null);
const handleUpload = () => {
- const formData = new FormData();
- if (file) {
- formData.append('file', file);
- }
- formData.append('title', title);
+ const formData = new FormData();
+ if (file) {
+ formData.append('file', file);
+ }
+ formData.append('title', title);
- // Replace with your actual API endpoint and error handling
- fetch('/api/torrents/upload', {
- method: 'POST',
- body: formData
- })
+ const token = localStorage.getItem('jwt_token'); // 假设你登录后将 token 存在 localStorage
+
+ fetch('http://localhost:8080/api/torrents/upload', {
+ method: 'POST',
+ headers: {
+ Authorization: `Bearer ${token}`,
+ },
+ body: formData,
+ })
.then(response => {
if (response.ok) {
- // Use a more modern way to show messages, e.g., a Snackbar
- console.log('上传成功');
- alert('上传成功 (建议使用Snackbar等UI组件替代alert)');
+ console.log('上传成功');
+ alert('上传成功');
} else {
- console.error('上传失败');
- alert('上传失败 (建议使用Snackbar等UI组件替代alert)');
+ return response.text().then(text => {
+ console.error('上传失败:', text);
+ alert('上传失败: ' + text);
+ });
}
})
.catch(error => {
console.error('上传出错:', error);
- alert('上传出错 (建议使用Snackbar等UI组件替代alert)');
+ alert('上传出错: ' + error.message);
});
- };
+};
return (
<Box sx={{ minHeight: '100vh', py: 4, background: 'linear-gradient(135deg, #2c3e50, #4ca1af)', color: 'white' }}> {/* Moved body styles here for self-containment */}
diff --git a/frontend/my-app/src/services/torrentService.js b/frontend/my-app/src/services/torrentService.js
deleted file mode 100644
index a50f8ac..0000000
--- a/frontend/my-app/src/services/torrentService.js
+++ /dev/null
@@ -1,28 +0,0 @@
-// ./services/torrentService.js
-import axios from 'axios';
-
-// IMPORTANT: Replace with your actual backend API URL
-const API_BASE_URL = 'http://localhost:5000/api';
-
-export const uploadTorrent = async (formData) => {
- try {
- const response = await axios.post(`${API_BASE_URL}/torrents/upload`, formData, {
- headers: {
- 'Content-Type': 'multipart/form-data', // Essential for file uploads
- // Add any authentication tokens here if your backend requires them
- // 'Authorization': `Bearer ${localStorage.getItem('authToken')}`
- },
- onUploadProgress: (progressEvent) => {
- // You can use this to show upload progress to the user
- const percentCompleted = Math.round((progressEvent.loaded * 100) / progressEvent.total);
- console.log(`Upload progress: ${percentCompleted}%`);
- // You could pass this percentage back to the component via a callback
- },
- });
- return response.data; // Your backend should return the parsed torrent info here
- } catch (error) {
- console.error('Error in uploadTorrent service:', error.response ? error.response.data : error.message);
- // Throw a more specific error message based on backend response if available
- throw new Error(error.response?.data?.message || '文件上传失败，请稍后再试。');
- }
-};
\ No newline at end of file