optimize: skip exists attachment save.

Author: li-guohao

console/.gitignore

@@ -22,3 +22,4 @@ dist-ssr
 *.njsproj
 *.sln
 *.sw?
+*.d.ts

console/src/views/AListControl.vue

@@ -1,13 +1,17 @@
 <script setup lang="ts">
+import {  ref } from "vue"
+
+const alistPath = ref("/")
 </script>
 
 <template>
   <div class="ik-plugin-alist-container">
     <h3>AList 插件操作</h3>
     <hr />
     <form name="form" method="post" action="#">
-      <input name="path" placeholder="请输入需要导入的相对路径路径" required>
+      <input name="path" placeholder="请输入需要导入的相对路径路径" required v-model="alistPath">
       <input type="submit" name="submit" value="提交导入">
+      {{alistPath}}
     </form>
   </div>
 </template>

console/vite.config.ts

@@ -1,31 +1,34 @@
-import { defineConfig } from 'vite'
-import { fileURLToPath, URL } from "url";
+import {defineConfig} from 'vite'
+import {fileURLToPath, URL} from "url";
 import Vue from "@vitejs/plugin-vue";
 import VueJsx from "@vitejs/plugin-vue-jsx";
 
 // Current plugin entry name value must eq plugin.yaml name value.
 const pluginEntryName = "PluginAList";
 // https://vitejs.dev/config/
 export default defineConfig({
-  define: {
-    'process.env': {},
-  },
-  plugins: [Vue(), VueJsx()],
-  resolve: {
-    alias: {
-      "@": fileURLToPath(new URL("./src", import.meta.url)),
+    define: {
+        'process.env': {},
     },
-  },
-  build: {
-    outDir: fileURLToPath(
-        new URL("../src/main/resources/console", import.meta.url)
-    ),
-    emptyOutDir: true,
-    lib: {
-      entry: "src/index.ts",
-      name: pluginEntryName,
-      formats: ["iife"],
-      fileName: () => "index.js",
+    plugins: [
+        Vue(),
+        VueJsx(),
+    ],
+    resolve: {
+        alias: {
+            "@": fileURLToPath(new URL("./src", import.meta.url)),
+        },
+    },
+    build: {
+        outDir: fileURLToPath(
+            new URL("../src/main/resources/console", import.meta.url)
+        ),
+        emptyOutDir: true,
+        lib: {
+            entry: "src/index.ts",
+            name: pluginEntryName,
+            formats: ["iife"],
+            fileName: () => "index.js",
+        },
     },
-  },
 })

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

@@ -2,9 +2,7 @@
 
 import lombok.Data;
 
-import java.time.LocalDateTime;
 import java.util.List;
-import java.util.Map;
 
 @Data
 public class AListAttachment {

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

@@ -25,8 +25,6 @@
 import run.ikaros.api.store.enums.AttachmentType;
 import run.ikaros.plugin.alist.AListConst.ConfigMapKey;
 
-import java.net.URLDecoder;
-import java.nio.charset.StandardCharsets;
 import java.time.Duration;
 import java.time.LocalDateTime;
 import java.util.*;
@@ -142,18 +140,22 @@ private Mono<Long> mkdirByLastPath(List<String> paths, Long parentId) {
     }
 
     private Mono<AListAttachment> saveAListAttachment(AListAttachment aListAttachment) {
-        return attachmentOperate.save(
+        AttachmentType type = aListAttachment.getIs_dir() ? AttachmentType.Directory : AttachmentType.File;
+        return attachmentOperate.existsByTypeAndParentIdAndName(type,
+                        aListAttachment.getParentId(), aListAttachment.getName())
+                .filter(exists -> !exists)
+                .flatMap(exists -> attachmentOperate.save(
                         Attachment.builder()
                                 .parentId(aListAttachment.getParentId())
                                 .name(aListAttachment.getName())
                                 .updateTime(LocalDateTime.now())
-                                .type(aListAttachment.getIs_dir() ? AttachmentType.Directory : AttachmentType.File)
+                                .type(type)
                                 .size(aListAttachment.getSize())
                                 .url(aListAttachment.getRaw_url())
                                 .fsPath(getPathByPathArr(aListAttachment.getPaths()))
-                                .build())
-                .flatMap(attachment -> attachmentOperate.findByTypeAndParentIdAndName(
-                        attachment.getType(), attachment.getParentId(), attachment.getName()
+                                .build()))
+                .then(attachmentOperate.findByTypeAndParentIdAndName(
+                        type, aListAttachment.getParentId(), aListAttachment.getName()
                 ))
                 .map(attachment -> {
                     aListAttachment.setParentId(attachment.getParentId());
@@ -179,8 +181,8 @@ public Mono<AListToken> refreshToken() {
     @Retryable
     public Mono<AListToken> refreshToken(boolean refresh) {
         if (StringUtils.isBlank(token.getUrl())
-        || StringUtils.isBlank(token.getUsername())
-            || StringUtils.isBlank(token.getPassword())) {
+                || StringUtils.isBlank(token.getUsername())
+                || StringUtils.isBlank(token.getPassword())) {
             log.warn("token url or username or password is null or empty for token: {}",
                     JsonUtils.obj2Json(token));
             return Mono.empty();
@@ -228,7 +230,7 @@ public Mono<AListToken> refreshToken(boolean refresh) {
 
     private String getPathByPathArr(List<String> paths) {
         StringBuilder path = new StringBuilder("/");
-        for (String p: paths) {
+        for (String p : paths) {
             path.append(p).append("/");
         }
         String pStr = path.toString();
@@ -295,13 +297,13 @@ public AListToken cm2token(ConfigMap cm) {
         token.setPassword(cmd.get(ConfigMapKey.apiPassword));
         token.setEnableAutoTokenRefresh(
                 Boolean.parseBoolean(
-                StringUtils.isNotBlank(cmd.get(ConfigMapKey.enableAutoTokenRefresh))
-                        ? cmd.get(ConfigMapKey.enableAutoTokenRefresh) : "false"
-        ));
+                        StringUtils.isNotBlank(cmd.get(ConfigMapKey.enableAutoTokenRefresh))
+                                ? cmd.get(ConfigMapKey.enableAutoTokenRefresh) : "false"
+                ));
         token.setToken(cmd.get(ConfigMapKey.apiToken));
         token.setExpire(
                 StringUtils.isNotBlank(cmd.get(ConfigMapKey.apiExpire))
-                ? Long.parseLong(cmd.get(ConfigMapKey.apiExpire)) : 0
+                        ? Long.parseLong(cmd.get(ConfigMapKey.apiExpire)) : 0
         );
         // log.debug("token: {}", token);
         return token;
@@ -351,7 +353,7 @@ public Mono<Void> initAListToken() {
     @EventListener(PluginConfigMapUpdateEvent.class)
     public Mono<Void> onConfigMapUpdated(PluginConfigMapUpdateEvent updateEvent) throws Exception {
         // log.debug("afterPropertiesSet PluginConfigMapUpdateEvent for event: {}", new ObjectMapper().writeValueAsString(updateEvent));
-        if(Objects.isNull(updateEvent.getConfigMap()) || !AListPlugin.NAME.equals(updateEvent.getConfigMap().getName())) {
+        if (Objects.isNull(updateEvent.getConfigMap()) || !AListPlugin.NAME.equals(updateEvent.getConfigMap().getName())) {
             return Mono.empty();
         }
         return updateOperateByToken().then();