优化导入效率

Author: chivehao

CHANGELOG.MD

@@ -2,7 +2,9 @@
 
 更新日志文档，版本顺序从新到旧，最新版本在最前(上)面。
 
-# 15.2.1
+# 17.1.0
+
+- 优化导入效率
 
 # 15.2.0
 

build.gradle

@@ -14,7 +14,7 @@ ext {
     springContext = '6.0.3'
     pf4j = '3.8.0'
     lombok = '1.18.24'
-    libFile = 'lib/api-0.15.11.jar'
+    libFile = 'lib/api-0.17.5.jar'
 }
 
 tasks.withType(JavaCompile) {

gradle.properties

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

lib/api-0.15.11-sources.jar lib/api-0.17.5-sources.jarlib/api-0.15.11-sources.jar renamed to lib/api-0.17.5-sources.jar

@@ -21,6 +21,7 @@
 import run.ikaros.api.core.attachment.Attachment;
 import run.ikaros.api.core.attachment.AttachmentConst;
 import run.ikaros.api.core.attachment.AttachmentOperate;
+import run.ikaros.api.core.meta.MetaOperate;
 import run.ikaros.api.core.setting.ConfigMap;
 import run.ikaros.api.custom.ReactiveCustomClient;
 import run.ikaros.api.infra.utils.StringUtils;
@@ -43,10 +44,13 @@ public class AListClient implements InitializingBean, DisposableBean {
 
     private final ReactiveCustomClient customClient;
     private final AttachmentOperate attachmentOperate;
+    private final MetaOperate metaOperate;
 
-    public AListClient(ReactiveCustomClient customClient, AttachmentOperate attachmentOperate) {
+    public AListClient(ReactiveCustomClient customClient, AttachmentOperate attachmentOperate,
+                       MetaOperate metaOperate) {
         this.customClient = customClient;
         this.attachmentOperate = attachmentOperate;
+        this.metaOperate = metaOperate;
     }
 
     public Mono<Void> doImportFilesFromAListPath(List<String> paths) {
@@ -81,6 +85,7 @@ private Mono<Void> createAttachmentRecursively(List<String> paths, Long parentId
 
         AListAttachment[] attachments = fetchAttachments(paths);
         return Flux.fromStream(Arrays.stream(attachments))
+                .parallel()
                 .map(aListAttachment -> {
                     List<String> newPaths = new ArrayList<>(paths);
                     newPaths.add(aListAttachment.getName());

lib/api-0.15.11.jar lib/api-0.17.5.jarlib/api-0.15.11.jar renamed to lib/api-0.17.5.jar

@@ -4,8 +4,8 @@ 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: 15.2.1
-requires: ">=0.15.11"
+version: 17.1.0
+requires: ">=0.17.5"
 author:
   name: Ikaros OSS Team
   website: https://github.com/ikaros-dev