From 0f8f6f837da49af1f24ee61630d82a9b16fc6a0b Mon Sep 17 00:00:00 2001
From: mianbin <mianbin@706.com>
Date: Fri, 9 May 2025 19:28:02 +0800
Subject: [PATCH] =?UTF-8?q?=E4=B8=8D=E5=BD=B1=E5=93=8D=E7=BC=96=E8=AF=91?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .idea/CopilotChatHistory.xml                  | 12 +++
 .../java/cd/casic/plugin/PluginConstants.java | 17 ++--
 .../java/cd/casic/plugin/VersionUtils.java    | 36 +++++++
 .../plugin/core/SpringPluginManager.java      | 24 +++++
 .../plugin/extension/ExtensionClient.java     | 11 +++
 .../plugin/extension/ExtensionMatcher.java    | 13 +++
 .../cd/casic/plugin/function/Controller.java  | 17 ++++
 .../plugin/function/PluginsRootGetter.java    | 13 +++
 .../cd/casic/plugin/function/Reconciler.java  | 29 ++++++
 .../function/SystemVersionSupplier.java       | 14 +++
 .../cd/casic/plugin/function/Watcher.java     | 97 +++++++++++++++++++
 system-framework/pom.xml                      |  3 -
 12 files changed, 276 insertions(+), 10 deletions(-)
 create mode 100644 framework/spring-boot-starter-plugin/src/main/java/cd/casic/plugin/VersionUtils.java
 create mode 100644 framework/spring-boot-starter-plugin/src/main/java/cd/casic/plugin/core/SpringPluginManager.java
 create mode 100644 framework/spring-boot-starter-plugin/src/main/java/cd/casic/plugin/extension/ExtensionClient.java
 create mode 100644 framework/spring-boot-starter-plugin/src/main/java/cd/casic/plugin/extension/ExtensionMatcher.java
 create mode 100644 framework/spring-boot-starter-plugin/src/main/java/cd/casic/plugin/function/Controller.java
 create mode 100644 framework/spring-boot-starter-plugin/src/main/java/cd/casic/plugin/function/PluginsRootGetter.java
 create mode 100644 framework/spring-boot-starter-plugin/src/main/java/cd/casic/plugin/function/Reconciler.java
 create mode 100644 framework/spring-boot-starter-plugin/src/main/java/cd/casic/plugin/function/SystemVersionSupplier.java
 create mode 100644 framework/spring-boot-starter-plugin/src/main/java/cd/casic/plugin/function/Watcher.java

diff --git a/.idea/CopilotChatHistory.xml b/.idea/CopilotChatHistory.xml
index f9e2de9..121bea5 100644
--- a/.idea/CopilotChatHistory.xml
+++ b/.idea/CopilotChatHistory.xml
@@ -3,6 +3,18 @@
   <component name="CopilotChatHistory">
     <option name="conversations">
       <list>
+        <Conversation>
+          <option name="createTime" value="1746752716983" />
+          <option name="id" value="0196b29340b7776ea658e40b4d205868" />
+          <option name="title" value="新对话 2025年5月09日 09:05:16" />
+          <option name="updateTime" value="1746752716983" />
+        </Conversation>
+        <Conversation>
+          <option name="createTime" value="1746752688291" />
+          <option name="id" value="0196b292d0a37ce19aaa9610c3120cbe" />
+          <option name="title" value="新对话 2025年5月09日 09:04:48" />
+          <option name="updateTime" value="1746752688291" />
+        </Conversation>
         <Conversation>
           <option name="createTime" value="1746706460096" />
           <option name="id" value="0196afd16dc0787d9f1e1f1b29555e6c" />
diff --git a/framework/spring-boot-starter-plugin/src/main/java/cd/casic/plugin/PluginConstants.java b/framework/spring-boot-starter-plugin/src/main/java/cd/casic/plugin/PluginConstants.java
index ef64097..1491ee6 100644
--- a/framework/spring-boot-starter-plugin/src/main/java/cd/casic/plugin/PluginConstants.java
+++ b/framework/spring-boot-starter-plugin/src/main/java/cd/casic/plugin/PluginConstants.java
@@ -1,28 +1,31 @@
 package cd.casic.plugin;
 
+import lombok.experimental.UtilityClass;
+
 /**
  * @Classname PluginConstants
  * @Description 常量
  * @Date 2025/5/8 14:51
  * @Created by mianbin
  */
+@UtilityClass
 public class PluginConstants {
     /**
      * Plugin metadata labels key.
      */
-    static String PLUGIN_NAME_LABEL_NAME = "plugin.ops/plugin-name";
+    String PLUGIN_NAME_LABEL_NAME = "plugin.ops/plugin-name";
 
-    static String SYSTEM_PLUGIN_NAME = "system";
+    String SYSTEM_PLUGIN_NAME = "system";
 
-    static String RELOAD_ANNO = "plugin.ops/reload";
+    String RELOAD_ANNO = "plugin.ops/reload";
 
-    static String REQUEST_TO_UNLOAD_LABEL = "plugin.ops/request-to-unload";
+    String REQUEST_TO_UNLOAD_LABEL = "plugin.ops/request-to-unload";
 
-    static String PLUGIN_PATH = "plugin.ops/plugin-path";
+    String PLUGIN_PATH = "plugin.ops/plugin-path";
     // 模式这边后面要考虑下dev\prod， 目前作为现在的情况，这两种就够了
-    static String RUNTIME_MODE_ANNO = "plugin.ops/runtime-mode";
+    String RUNTIME_MODE_ANNO = "plugin.ops/runtime-mode";
 
-    static String assetsRoutePrefix(String pluginName) {
+    String assetsRoutePrefix(String pluginName) {
         return "/plugins/" + pluginName + "/assets/";
     }
 }
diff --git a/framework/spring-boot-starter-plugin/src/main/java/cd/casic/plugin/VersionUtils.java b/framework/spring-boot-starter-plugin/src/main/java/cd/casic/plugin/VersionUtils.java
new file mode 100644
index 0000000..70d18d6
--- /dev/null
+++ b/framework/spring-boot-starter-plugin/src/main/java/cd/casic/plugin/VersionUtils.java
@@ -0,0 +1,36 @@
+package cd.casic.plugin;
+
+import com.github.zafarkhaja.semver.Version;
+import lombok.experimental.UtilityClass;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.web.server.ServerWebInputException;
+
+/**
+ * @Classname VersionUtils
+ * @Description 版本
+ * @Date 2025/5/9 17:10
+ * @Created by mianbin
+ */
+@UtilityClass
+public class VersionUtils {
+
+    public static boolean satisfiesRequires(String version, String requires) {
+        String requiresVersion = StringUtils.trim(requires);
+        // an exact version x.y.z will implicitly mean the same as >=x.y.z
+        if (requiresVersion.matches("^\\d+\\.\\d+\\.\\d+$")) {
+            // If exact versions are not allowed in requires, rewrite to >= expression
+            requiresVersion = ">=" + requiresVersion;
+        }
+        return version.equals("0.0.0") || checkVersionConstraint(version, requiresVersion);
+    }
+
+    public static boolean checkVersionConstraint(String version, String constraint) {
+        try {
+            return StringUtils.isBlank(constraint)
+                    || "*".equals(constraint)
+                    || Version.parse(version).satisfies(constraint);
+        } catch (Exception e) {
+            throw new ServerWebInputException("Illegal requires version expression.", null, e);
+        }
+    }
+}
diff --git a/framework/spring-boot-starter-plugin/src/main/java/cd/casic/plugin/core/SpringPluginManager.java b/framework/spring-boot-starter-plugin/src/main/java/cd/casic/plugin/core/SpringPluginManager.java
new file mode 100644
index 0000000..b4dbe2a
--- /dev/null
+++ b/framework/spring-boot-starter-plugin/src/main/java/cd/casic/plugin/core/SpringPluginManager.java
@@ -0,0 +1,24 @@
+package cd.casic.plugin.core;
+
+import org.pf4j.PluginManager;
+import org.pf4j.PluginWrapper;
+import org.springframework.context.ApplicationContext;
+
+import java.util.List;
+
+/**
+ * @Classname SpringPluginManager
+ * @Description 增强插件管理器，增加spring上下文管理
+ * @Date 2025/5/9 14:38
+ * @Created by mianbin
+ */
+public interface SpringPluginManager extends PluginManager {
+    ApplicationContext getRootContext();
+
+    ApplicationContext getSharedContext();
+
+    /**
+     * 递归获取所有依赖
+     */
+    List<PluginWrapper> getDependents(String pluginId);
+}
diff --git a/framework/spring-boot-starter-plugin/src/main/java/cd/casic/plugin/extension/ExtensionClient.java b/framework/spring-boot-starter-plugin/src/main/java/cd/casic/plugin/extension/ExtensionClient.java
new file mode 100644
index 0000000..de23378
--- /dev/null
+++ b/framework/spring-boot-starter-plugin/src/main/java/cd/casic/plugin/extension/ExtensionClient.java
@@ -0,0 +1,11 @@
+package cd.casic.plugin.extension;
+
+/**
+ * @Classname ExtensionClient
+ * @Description 接口
+ * @Date 2025/5/9 15:43
+ * @Created by mianbin
+ */
+public interface ExtensionClient {
+
+}
diff --git a/framework/spring-boot-starter-plugin/src/main/java/cd/casic/plugin/extension/ExtensionMatcher.java b/framework/spring-boot-starter-plugin/src/main/java/cd/casic/plugin/extension/ExtensionMatcher.java
new file mode 100644
index 0000000..9eeea9f
--- /dev/null
+++ b/framework/spring-boot-starter-plugin/src/main/java/cd/casic/plugin/extension/ExtensionMatcher.java
@@ -0,0 +1,13 @@
+package cd.casic.plugin.extension;
+
+/**
+ * @Classname ExtensionMatcher
+ * @Description TODO
+ * @Date 2025/5/9 17:03
+ * @Created by mianbin
+ */
+public interface ExtensionMatcher {
+
+    boolean match(Extension extension);
+
+}
diff --git a/framework/spring-boot-starter-plugin/src/main/java/cd/casic/plugin/function/Controller.java b/framework/spring-boot-starter-plugin/src/main/java/cd/casic/plugin/function/Controller.java
new file mode 100644
index 0000000..d1ca0c4
--- /dev/null
+++ b/framework/spring-boot-starter-plugin/src/main/java/cd/casic/plugin/function/Controller.java
@@ -0,0 +1,17 @@
+package cd.casic.plugin.function;
+
+import reactor.core.Disposable;
+
+/**
+ * @Classname Controller
+ * @Description TODO
+ * @Date 2025/5/9 15:55
+ * @Created by mianbin
+ */
+public interface Controller extends Disposable {
+
+    String getName();
+
+    void start();
+
+}
diff --git a/framework/spring-boot-starter-plugin/src/main/java/cd/casic/plugin/function/PluginsRootGetter.java b/framework/spring-boot-starter-plugin/src/main/java/cd/casic/plugin/function/PluginsRootGetter.java
new file mode 100644
index 0000000..1c72ecb
--- /dev/null
+++ b/framework/spring-boot-starter-plugin/src/main/java/cd/casic/plugin/function/PluginsRootGetter.java
@@ -0,0 +1,13 @@
+package cd.casic.plugin.function;
+
+import java.nio.file.Path;
+import java.util.function.Supplier;
+
+/**
+ * @Classname PluginsRootGetter
+ * @Description 获取插件根路径
+ * @Date 2025/5/9 14:34
+ * @Created by mianbin
+ */
+public interface PluginsRootGetter extends Supplier<Path> {
+}
diff --git a/framework/spring-boot-starter-plugin/src/main/java/cd/casic/plugin/function/Reconciler.java b/framework/spring-boot-starter-plugin/src/main/java/cd/casic/plugin/function/Reconciler.java
new file mode 100644
index 0000000..84b1525
--- /dev/null
+++ b/framework/spring-boot-starter-plugin/src/main/java/cd/casic/plugin/function/Reconciler.java
@@ -0,0 +1,29 @@
+package cd.casic.plugin.function;
+
+import java.time.Duration;
+
+/**
+ * @Classname Reconciler
+ * @Description TODO
+ * @Date 2025/5/9 15:54
+ * @Created by mianbin
+ */
+public interface Reconciler<R> {
+
+    Result reconcile(R request);
+
+    record Request(String name) {
+    }
+
+    record Result(boolean reEnqueue, Duration retryAfter) {
+
+        public static Result doNotRetry() {
+            return new Result(false, null);
+        }
+
+        public static Result requeue(Duration retryAfter) {
+            return new Result(true, retryAfter);
+        }
+    }
+}
+
diff --git a/framework/spring-boot-starter-plugin/src/main/java/cd/casic/plugin/function/SystemVersionSupplier.java b/framework/spring-boot-starter-plugin/src/main/java/cd/casic/plugin/function/SystemVersionSupplier.java
new file mode 100644
index 0000000..5a79d93
--- /dev/null
+++ b/framework/spring-boot-starter-plugin/src/main/java/cd/casic/plugin/function/SystemVersionSupplier.java
@@ -0,0 +1,14 @@
+package cd.casic.plugin.function;
+
+import com.github.zafarkhaja.semver.Version;
+
+import java.util.function.Supplier;
+
+/**
+ * @Classname SystemVersionSupplier
+ * @Description TODO
+ * @Date 2025/5/9 15:43
+ * @Created by mianbin
+ */
+public interface SystemVersionSupplier extends Supplier<Version> {
+}
diff --git a/framework/spring-boot-starter-plugin/src/main/java/cd/casic/plugin/function/Watcher.java b/framework/spring-boot-starter-plugin/src/main/java/cd/casic/plugin/function/Watcher.java
new file mode 100644
index 0000000..67982e5
--- /dev/null
+++ b/framework/spring-boot-starter-plugin/src/main/java/cd/casic/plugin/function/Watcher.java
@@ -0,0 +1,97 @@
+package cd.casic.plugin.function;
+
+import cd.casic.plugin.extension.Extension;
+import reactor.core.Disposable;
+
+import java.util.List;
+import java.util.concurrent.CopyOnWriteArrayList;
+
+/**
+ * @Classname Watcher
+ * @Description TODO
+ * @Date 2025/5/9 15:54
+ * @Created by mianbin
+ */
+public interface Watcher extends Disposable {
+
+    default void onAdd(Reconciler.Request request) {
+        // Do nothing here, just for sync all on start.
+    }
+
+    default void onAdd(Extension extension) {
+        // Do nothing here
+    }
+
+    default void onUpdate(Extension oldExtension, Extension newExtension) {
+        // Do nothing here
+    }
+
+    default void onDelete(Extension extension) {
+        // Do nothing here
+    }
+
+    default void registerDisposeHook(Runnable dispose) {
+    }
+
+    class WatcherComposite implements Watcher {
+
+        private final List<Watcher> watchers;
+
+        private volatile boolean disposed = false;
+
+        private Runnable disposeHook;
+
+        public WatcherComposite() {
+            watchers = new CopyOnWriteArrayList<>();
+        }
+
+        @Override
+        public void onAdd(Extension extension) {
+            // TODO Deep copy extension and execute onAdd asynchronously
+            watchers.forEach(watcher -> watcher.onAdd(extension));
+        }
+
+        @Override
+        public void onUpdate(Extension oldExtension, Extension newExtension) {
+            // TODO Deep copy extension and execute onUpdate asynchronously
+            watchers.forEach(watcher -> watcher.onUpdate(oldExtension, newExtension));
+        }
+
+        @Override
+        public void onDelete(Extension extension) {
+            // TODO Deep copy extension and execute onDelete asynchronously
+            watchers.forEach(watcher -> watcher.onDelete(extension));
+        }
+
+        public void addWatcher(Watcher watcher) {
+            if (!watcher.isDisposed() && !watchers.contains(watcher)) {
+                watchers.add(watcher);
+                watcher.registerDisposeHook(() -> removeWatcher(watcher));
+            }
+        }
+
+        public void removeWatcher(Watcher watcher) {
+            watchers.remove(watcher);
+        }
+
+        @Override
+        public void registerDisposeHook(Runnable dispose) {
+            this.disposeHook = dispose;
+        }
+
+        @Override
+        public void dispose() {
+            this.disposed = true;
+            this.watchers.clear();
+            if (this.disposeHook != null) {
+                this.disposeHook.run();
+            }
+        }
+
+        @Override
+        public boolean isDisposed() {
+            return this.disposed;
+        }
+    }
+}
+
diff --git a/system-framework/pom.xml b/system-framework/pom.xml
index ca2d3eb..a5d9175 100644
--- a/system-framework/pom.xml
+++ b/system-framework/pom.xml
@@ -22,8 +22,5 @@
         3. 业务相关
     </description>
 
-    <modules>
-        <module>system-plugin-example-web</module>
-    </modules>
 
 </project>