- 修正刷新token的api的基础域名

- 取消定时刷新token任务

Author: chivehao

CHANGELOG.MD

@@ -2,6 +2,11 @@
 
 更新日志文档，版本顺序从新到旧，最新版本在最前(上)面。
 
+# 1.0.3
+
+- 修正刷新token的api的基础域名
+- 取消定时刷新token任务
+
 # 1.0.2
 
 - 修复github的ci

build.gradle

@@ -28,6 +28,7 @@ dependencies {
     compileOnly "org.springdoc:springdoc-openapi-starter-webflux-api:2.0.2"
 
     compileOnly files(libFile)
+    testCompileOnly files(libFile)
     testRuntimeOnly files(libFile)
 
     testRuntimeOnly "org.springframework:spring-context:$springContext"

gradle.properties

@@ -1,3 +1,3 @@
 group=run.ikaros.plugin
 description=A pan115 plugin for ikaros.
-version=1.0.2
+version=1.0.3

src/main/java/run/ikaros/plugin/pan115/Pan115AttachmentDriverFetcher.java

@@ -95,8 +95,6 @@ public Flux<Attachment> getChildren(Long driverId, Long pid, String remotePath)
 
                     return Flux.fromStream(pan115Attachments.stream());
                 })
-                .parallel(5)
-                .runOn(Schedulers.boundedElastic())
                 .map(att -> {
                     final String fid = att.getFid();
                     Pan115Folder pan115Folder = pan115Repository.openFolderGetInfo(fid);
@@ -129,8 +127,7 @@ public Flux<Attachment> getChildren(Long driverId, Long pid, String remotePath)
                     attachment.setUrl(url);
                     attachment.setPath(path);
                     return attachment;
-                })
-                .sequential();
+                });
     }
 
     @Override

src/main/java/run/ikaros/plugin/pan115/Pan115Plugin.java

@@ -30,7 +30,7 @@ public Pan115Plugin(PluginWrapper wrapper, Pan115AttachmentDriverFetcher driverF
 
     @Override
     public void start() {
-        startRefreshTokenTask = startRefreshTokenTask();
+        // startRefreshTokenTask = startRefreshTokenTask();
         log.info("plugin [Pan115Plugin] start success");
     }
 

src/main/java/run/ikaros/plugin/pan115/repository/DefaultPan115Repository.java

@@ -136,7 +136,7 @@ public void refreshToken(AttachmentDriver driver) {
         final String refreshToken = driver.getRefreshToken();
         refreshHttpHeaders(driver.getAccessToken());
         Assert.hasText(refreshToken, "'refreshToken' must has text.");
-        final String url = API_BASE + "/open/refreshToken";
+        final String url = "https://passportapi.115.com/open/refreshToken";
         try {
             MultiValueMap<String, Object> body = new LinkedMultiValueMap<>();
             body.put("refresh_token", List.of(refreshToken));

src/test/java/run/ikaros/plugin/pan115/repository/Pan115RepositoryTest.java

@@ -0,0 +1,18 @@
+package run.ikaros.plugin.pan115.repository;
+
+import org.junit.jupiter.api.Test;
+import run.ikaros.api.core.attachment.AttachmentDriver;
+
+import static org.junit.jupiter.api.Assertions.*;
+
+class Pan115RepositoryTest {
+
+    //@Test
+    void refreshToken() {
+        Pan115Repository pan115Repository = new DefaultPan115Repository();
+        pan115Repository.refreshHttpHeaders("");
+        pan115Repository.refreshToken(AttachmentDriver.builder()
+                        .accessToken("").refreshToken(System.getenv("REFRESH_TOKEN"))
+                .build());
+    }
+}