add Trigger

Author: xlorne

pom.xml

@@ -12,7 +12,7 @@
 
     <groupId>com.codingapi.springboot</groupId>
     <artifactId>springboot-parent</artifactId>
-    <version>1.4.10</version>
+    <version>1.4.11.dev</version>
 
     <url>https://github.com/codingapi/springboot-framewrok</url>
     <name>springboot-parent</name>

springboot-starter-data-fast/pom.xml

@@ -5,7 +5,7 @@
     <parent>
         <artifactId>springboot-parent</artifactId>
         <groupId>com.codingapi.springboot</groupId>
-        <version>1.4.10</version>
+        <version>1.4.11.dev</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 

springboot-starter-id-generator/pom.xml

@@ -5,7 +5,7 @@
     <parent>
         <artifactId>springboot-parent</artifactId>
         <groupId>com.codingapi.springboot</groupId>
-        <version>1.4.10</version>
+        <version>1.4.11.dev</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 

springboot-starter-security-jwt/pom.xml

@@ -6,7 +6,7 @@
     <parent>
         <artifactId>springboot-parent</artifactId>
         <groupId>com.codingapi.springboot</groupId>
-        <version>1.4.10</version>
+        <version>1.4.11.dev</version>
     </parent>
 
     <artifactId>springboot-starter-security-jwt</artifactId>

springboot-starter/pom.xml

@@ -5,7 +5,7 @@
     <parent>
         <groupId>com.codingapi.springboot</groupId>
         <artifactId>springboot-parent</artifactId>
-        <version>1.4.10</version>
+        <version>1.4.11.dev</version>
     </parent>
     <artifactId>springboot-starter</artifactId>
 

springboot-starter/src/main/java/com/codingapi/springboot/framework/trigger/Trigger.java

@@ -0,0 +1,4 @@
+package com.codingapi.springboot.framework.trigger;
+
+public interface Trigger {
+}

springboot-starter/src/main/java/com/codingapi/springboot/framework/trigger/TriggerContext.java

@@ -0,0 +1,69 @@
+package com.codingapi.springboot.framework.trigger;
+
+import java.lang.reflect.ParameterizedType;
+import java.util.ArrayList;
+import java.util.Iterator;
+import java.util.List;
+import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
+
+@SuppressWarnings("all")
+public class TriggerContext{
+
+    public static TriggerContext getInstance() {
+        return instance;
+    }
+
+    private final static TriggerContext instance = new TriggerContext();
+
+
+    private final Map<Class<? extends Trigger>,List<TriggerHandler>> triggers;
+
+    private TriggerContext(){
+        this.triggers = new ConcurrentHashMap<>();
+    }
+
+    public void addTrigger(TriggerHandler trigger){
+        Class<? extends Trigger> clazz = getTriggerClass(trigger);
+        List<TriggerHandler> triggerList =  this.triggers.get(clazz);
+        if(triggerList==null){
+            triggerList = new ArrayList<>();
+            this.triggers.put(clazz,triggerList);
+        }
+        triggerList.add(trigger);
+    }
+
+
+    private Class<? extends Trigger> getTriggerClass(TriggerHandler trigger){
+        ParameterizedType parameterizedType = (ParameterizedType) trigger.getClass().getGenericInterfaces()[0];
+        return (Class<? extends Trigger>) parameterizedType.getActualTypeArguments()[0];
+    }
+
+
+    public void trigger(Trigger trigger){
+        Class<? extends Trigger> clazz = trigger.getClass();
+        Iterator<TriggerHandler> iterator = triggers.get(clazz).iterator();
+        while (iterator.hasNext()){
+            TriggerHandler handler = iterator.next();
+            Class<? extends Trigger> triggerClass = getTriggerClass(handler);
+            if(triggerClass.equals(clazz)) {
+                if (handler.preTrigger(trigger)) {
+                    handler.trigger(trigger);
+                    if (handler.remove()) {
+                        iterator.remove();
+                    }
+                }
+            }
+        }
+    }
+
+    public void clear(Class<? extends Trigger> clazz){
+        triggers.get(clazz).clear();
+    }
+
+
+    public boolean isEmpty(Class<? extends Trigger> clazz){
+        return triggers.get(clazz).isEmpty();
+    }
+
+}

springboot-starter/src/main/java/com/codingapi/springboot/framework/trigger/TriggerHandler.java

@@ -0,0 +1,12 @@
+package com.codingapi.springboot.framework.trigger;
+
+
+public interface TriggerHandler<T extends  Trigger> {
+
+    boolean preTrigger(T trigger);
+
+    void trigger(T trigger);
+
+    boolean remove();
+
+}

springboot-starter/src/test/java/com/codingapi/springboot/framework/trigger/TriggerHandlerContextTest.java

@@ -0,0 +1,92 @@
+package com.codingapi.springboot.framework.trigger;
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+import org.junit.jupiter.api.Test;
+
+import static org.junit.jupiter.api.Assertions.assertFalse;
+import static org.junit.jupiter.api.Assertions.assertTrue;
+
+class TriggerHandlerContextTest {
+
+    @Test
+    void addTrigger() {
+        TriggerContext.getInstance().addTrigger(new TriggerHandler<MyTrigger>() {
+            @Override
+            public boolean preTrigger(MyTrigger trigger) {
+                return false;
+            }
+
+            @Override
+            public void trigger(MyTrigger trigger) {
+
+            }
+
+            @Override
+            public boolean remove() {
+                return false;
+            }
+        });
+
+        TriggerContext.getInstance().addTrigger(new TriggerHandler<MyTrigger2>() {
+            @Override
+            public boolean preTrigger(MyTrigger2 trigger) {
+                return false;
+            }
+
+            @Override
+            public void trigger(MyTrigger2 trigger) {
+
+            }
+
+            @Override
+            public boolean remove() {
+                return false;
+            }
+        });
+
+        assertFalse(TriggerContext.getInstance().isEmpty(MyTrigger.class));
+        TriggerContext.getInstance().clear(MyTrigger.class);
+        assertTrue(TriggerContext.getInstance().isEmpty(MyTrigger.class));
+    }
+
+    @Test
+    void trigger() {
+        TriggerContext.getInstance().addTrigger(new TriggerHandler<MyTrigger>() {
+            @Override
+            public boolean preTrigger(MyTrigger trigger) {
+                return true;
+            }
+
+            @Override
+            public void trigger(MyTrigger trigger) {
+                System.out.println(trigger.getName());
+            }
+
+            @Override
+            public boolean remove() {
+                return true;
+            }
+        });
+
+        MyTrigger trigger = new MyTrigger("bob");
+
+        TriggerContext.getInstance().trigger(trigger);
+        assertTrue(TriggerContext.getInstance().isEmpty(MyTrigger.class));
+
+    }
+
+    @AllArgsConstructor
+    private static class MyTrigger implements Trigger{
+        @Getter
+        private final String name;
+    }
+
+    @AllArgsConstructor
+    private static class MyTrigger2 implements Trigger{
+        @Getter
+        private final String name;
+    }
+
+
+}