optimize: 启动时自动加载alist的token

Author: li-guohao

CHANGELOG.MD

@@ -2,6 +2,12 @@
 
 更新日志文档，版本顺序从新到旧，最新版本在最前(上)面。
 
+# 0.12.7
+
+## 优化
+
+- 启动时自动加载alist的token
+
 # 0.12.6
 
 ## 优化

gradle.properties

@@ -1,3 +1,3 @@
 group=run.ikaros.plugin.alist
 description=A ikaros plugin for alist.
-version=0.12.6
+version=0.12.7

src/main/java/run/ikaros/plugin/alist/AListClient.java

@@ -2,6 +2,8 @@
 
 import com.fasterxml.jackson.core.type.TypeReference;
 import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.DisposableBean;
+import org.springframework.beans.factory.InitializingBean;
 import org.springframework.boot.context.event.ApplicationReadyEvent;
 import org.springframework.context.event.EventListener;
 import org.springframework.http.HttpEntity;
@@ -31,7 +33,7 @@
 
 @Slf4j
 @Component
-public class AListClient {
+public class AListClient implements InitializingBean, DisposableBean {
     private final RestTemplate restTemplate = new RestTemplate();
     private HttpHeaders httpHeaders = new HttpHeaders();
     private AListToken token;
@@ -92,7 +94,8 @@ private Mono<Void> createAttachmentRecursively(List<String> paths, Long parentId
                 .flatMap(aListAttachment -> {
                     if (aListAttachment.getIs_dir()) {
                         List<String> paths1 = aListAttachment.getPaths();
-                        return createAttachmentRecursively(paths1, aListAttachment.getId());
+                        return createAttachmentRecursively(paths1, aListAttachment.getId())
+                                .subscribeOn(Schedulers.boundedElastic());
                     } else {
                         return Mono.empty();
                     }
@@ -205,6 +208,7 @@ public Mono<AListToken> refreshToken(boolean refresh) {
                 Object token1 = apiResult.getData().get("token");
                 httpHeaders.set("Authorization", String.valueOf(token1));
                 token.setToken(String.valueOf(token1));
+                log.info("refresh alist token success");
                 return customClient.update(token2cm(token))
                         .then(Mono.just(token));
             } else {
@@ -340,14 +344,20 @@ public Mono<AListToken> updateOperateByToken() {
         return getToken().flatMap(aListToken -> refreshToken(true));
     }
 
-    @EventListener(ApplicationReadyEvent.class)
-    public Mono<Void> initAListToken() {
-        log.debug("init alist token.");
-        if (Objects.isNull(token)) {
+    @Override
+    public void destroy() throws Exception {
+        if (Objects.nonNull(refreshTokenTaskDisposable) && !refreshTokenTaskDisposable.isDisposed()) {
+            refreshTokenTaskDisposable.dispose();
+        }
+    }
+
+    @Override
+    public void afterPropertiesSet() throws Exception {
+        log.debug("init alist token afterPropertiesSet.");
+        if (Objects.isNull(token) || StringUtils.isBlank(token.getToken())) {
             // token is null, get config from db.
-            return updateOperateByToken().then();
+            updateOperateByToken().subscribe();
         }
-        return Mono.empty();
     }
 
 

src/main/resources/plugin.yaml

@@ -4,7 +4,7 @@ name: PluginAList
 # plugin entry class that extends BasePlugin
 clazz: run.ikaros.plugin.alist.AListPlugin
 # plugin 'version' is a valid semantic version string (see semver.org).
-version: 0.12.6
+version: 0.12.7
 requires: ">=0.12.1"
 author:
   name: Ikaros OSS Team