Merge pull request tronprotocol#5 from tronprotocol/mongodb

Mongodb

Author: DorianRust

api/build.gradle

@@ -4,4 +4,8 @@ dependencies {
     compileOnly (group: 'org.apache.commons', name: 'commons-lang3', version: '3.5')
 
     testCompile group: 'junit', name: 'junit', version: '4.+'
+
+    compileOnly ("org.projectlombok:lombok:1.16.18") {
+        exclude group: "org.slf4j"
+    }
 }

app/src/main/java/org/tron/common/logsfilter/trigger/BlockLogTrigger.java renamed to api/src/main/java/org/tron/common/logsfilter/trigger/BlockLogTrigger.java

@@ -34,7 +34,7 @@ public class PluginLauncher {
     private static final Logger logger = LoggerFactory.getLogger(PluginLauncher.class);
 
     public static void main(String[] args) {
-        String path = "/home/java-tron/plugin-kafka-1.0.0.zip";
+        String path = "/Users/tron/workplace/java-tronSubmit/java-tronUseSubmit/develop_event_subscribe/eventplugin/build/plugins/plugin-mongodb-1.0.0.zip";
 
         File dir = new File(path);
         // create the plugin manager
@@ -57,7 +57,7 @@ protected CompoundPluginDescriptorFinder createPluginDescriptorFinder() {
         if (Objects.isNull(eventListeners)) return;
 
         eventListeners.forEach(listener -> {
-            listener.setServerAddress("127.0.0.1:9092");
+            listener.setServerAddress("127.0.0.1:27017");
         });
 
         eventListeners.forEach(listener -> {

app/src/main/java/org/tron/common/logsfilter/trigger/ContractEventTrigger.java renamed to api/src/main/java/org/tron/common/logsfilter/trigger/ContractEventTrigger.java

@@ -0,0 +1 @@
+build

app/src/main/java/org/tron/common/logsfilter/trigger/ContractLogTrigger.java renamed to api/src/main/java/org/tron/common/logsfilter/trigger/ContractLogTrigger.java

@@ -0,0 +1,30 @@
+dependencies {
+  // compileOnly important!!! We do not want to put the api into the zip file since the main program has it already!
+  compileOnly project(':api')
+  compileOnly(group: 'org.pf4j', name: 'pf4j', version: "${pf4jVersion}") {
+    exclude group: "org.slf4j"
+  }
+  compileOnly group: 'org.apache.commons', name: 'commons-lang3', version: '3.5'
+  testCompile group: 'junit', name: 'junit', version: '4.+'
+
+  compileOnly (group: 'ch.qos.logback', name: 'logback-classic', version: '1.2.3') {
+    exclude group: "org.slf4j"
+  }
+
+  compileOnly ("org.projectlombok:lombok:1.16.18") {
+    exclude group: "org.slf4j"
+  }
+
+  compile ("org.springframework.data:spring-data-mongodb:2.0.0.RELEASE") {
+    exclude group: "org.slf4j"
+  }
+  compile ("org.mongodb:mongo-java-driver:3.6.3"){
+    exclude group: "org.slf4j"
+  }
+
+  compileOnly group: 'com.alibaba', name: 'fastjson', version: '1.2.44'
+
+  compileOnly group: 'com.fasterxml.jackson.core', name: 'jackson-databind', version: '2.8.5'
+  compileOnly group: 'com.fasterxml.jackson.core', name: 'jackson-core', version: '2.8.5'
+
+}

app/src/main/java/org/tron/common/logsfilter/trigger/ContractTrigger.java renamed to api/src/main/java/org/tron/common/logsfilter/trigger/ContractTrigger.java

@@ -0,0 +1,5 @@
+version=1.0.0
+
+pluginId=mongodb
+pluginClass=org.tron.eventplugin.MongodbLogFilterPlugin
+pluginProvider=Tron

app/src/main/java/org/tron/common/logsfilter/trigger/TransactionLogTrigger.java renamed to api/src/main/java/org/tron/common/logsfilter/trigger/TransactionLogTrigger.java

@@ -0,0 +1,15 @@
+package org.tron.eventplugin;
+
+public class Constant {
+    public static final int BLOCK_TRIGGER = 0;
+    public static final int TRANSACTION_TRIGGER = 1;
+    public static final int CONTRACTLOG_TRIGGER = 2;
+    public static final int CONTRACTEVENT_TRIGGER = 3;
+
+    public static final String BLOCK_TRIGGER_NAME = "blockTrigger";
+    public static final String TRANSACTION_TRIGGER_NAME = "transactionTrigger";
+    public static final String CONTRACTLOG_TRIGGER_NAME = "contractLogTrigger";
+    public static final String CONTRACTEVENT_TRIGGER_NAME = "contractEventTrigger";
+
+    private Constant(){}
+}

app/src/main/java/org/tron/common/logsfilter/trigger/Trigger.java renamed to api/src/main/java/org/tron/common/logsfilter/trigger/Trigger.java

@@ -0,0 +1,68 @@
+package org.tron.eventplugin;
+
+import org.pf4j.Extension;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.tron.common.logsfilter.IPluginEventListener;
+import java.util.Objects;
+
+@Extension
+public class MongodbEventListener implements IPluginEventListener {
+
+    private static final Logger log = LoggerFactory.getLogger(MongodbEventListener.class);
+
+    @Override
+    public void setServerAddress(String address) {
+
+        if (Objects.isNull(address) || address.length() == 0){
+            return;
+        }
+
+        MongodbSenderImpl.getInstance().setServerAddress(address);
+
+        // MessageSenderImpl should never init until server address is set
+        MongodbSenderImpl.getInstance().init();
+    }
+
+    @Override
+    public void setTopic(int eventType, String topic) {
+        MongodbSenderImpl.getInstance().setTopic(eventType, topic);
+    }
+
+    @Override
+    public void handleBlockEvent(Object data) {
+
+        if (Objects.isNull(data)){
+            return;
+        }
+
+        MongodbSenderImpl.getInstance().getTriggerQueue().offer((String)data);
+    }
+
+    @Override
+    public void handleTransactionTrigger(Object data) {
+        if (Objects.isNull(data)){
+            return;
+        }
+
+        MongodbSenderImpl.getInstance().getTriggerQueue().offer((String)data);
+    }
+
+    @Override
+    public void handleContractLogTrigger(Object data) {
+        if (Objects.isNull(data)){
+            return;
+        }
+
+        MongodbSenderImpl.getInstance().getTriggerQueue().offer((String)data);
+    }
+
+    @Override
+    public void handleContractEventTrigger(Object data) {
+        if (Objects.isNull(data)){
+            return;
+        }
+
+        MongodbSenderImpl.getInstance().getTriggerQueue().offer((String)data);
+    }
+}

app/src/main/java/org/tron/eventplugin/app/PluginLauncher.java

@@ -0,0 +1,20 @@
+package org.tron.eventplugin;
+
+import org.pf4j.Plugin;
+import org.pf4j.PluginWrapper;
+
+public class MongodbLogFilterPlugin extends Plugin {
+
+    public MongodbLogFilterPlugin(PluginWrapper wrapper) {
+        super(wrapper);
+    }
+
+    @Override
+    public void start() {
+    }
+
+    @Override
+    public void stop() {
+        MongodbSenderImpl.getInstance().close();
+    }
+}