debug with java-tron, fix bugs

Author: jiangyy0824

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

@@ -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 -> {

plugins/mongodbplugin/src/main/java/org/tron/eventplugin/MongodbSenderImpl.java

@@ -1,4 +1,5 @@
 package org.tron.eventplugin;
+import org.pf4j.util.StringUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import java.util.*;
@@ -45,8 +46,8 @@ public static MongodbSenderImpl getInstance(){
         return instance;
     }
 
-    public void setServerAddress(String address){
-        this.serverAddress = address;
+    public void setServerAddress(final String address){
+        initMongoConfig(address);
     }
 
     public void init(){
@@ -57,24 +58,46 @@ public void init(){
 
         triggerProcessThread = new Thread(triggerProcessLoop);
         triggerProcessThread.start();
-        loaded = true;
 
-        initMongoConfig();
+        mongoTemplateMap = new HashMap<>();
 
+        loaded = true;
     }
 
-    private void initMongoConfig(){
-        mongoManager = new MongoManager();
-        mongoTemplateMap = new HashMap<>();
+    private void initMongoConfig(String serverAddress){
+        if (StringUtils.isNullOrEmpty(serverAddress)){
+            return;
+        }
+
+        String[] params = serverAddress.split(":");
+        if (params.length != 2){
+            return;
+        }
+
+        String hostName = "";
+        int port = -1;
+
+        try{
+            hostName = params[0];
+            port = Integer.valueOf(params[1]);
+        }
+        catch (Exception e){
+            e.printStackTrace();
+            return;
+        }
 
         MongoConfig config = new MongoConfig();
         config.setDbName("eventlog");
-        config.setHost("127.0.0.1");
-        config.setPort(27017);
+        config.setHost(hostName);
+        config.setPort(port);
+
         config.setUsername("tron");
         config.setPassword("123456");
 
-        mongoManager.initConfig(config);
+        if (Objects.isNull(mongoManager)){
+            mongoManager = new MongoManager();
+            mongoManager.initConfig(config);
+        }
     }
 
     private MongoTemplate createMongoTemplate(final String collectionName){
@@ -138,6 +161,7 @@ public void handleBlockEvent(Object data) {
         MongoTemplate template = mongoTemplateMap.get(blockTopic);
         if (Objects.nonNull(template)){
             template.addEntity((String)data);
+            System.out.println("handleBlockEvent " + data);
         }
     }
 

plugins/mongodbplugin/src/main/java/org/tron/mongodb/MongoManager.java

@@ -6,9 +6,6 @@
 import com.mongodb.ServerAddress;
 import com.mongodb.client.MongoDatabase;
 import org.pf4j.util.StringUtils;
-import org.tron.common.logsfilter.trigger.BlockLogTrigger;
-import org.tron.eventplugin.Constant;
-
 import java.util.ArrayList;
 import java.util.List;
 import java.util.Objects;

plugins/mongodbplugin/src/main/java/org/tron/mongodb/MongoTemplate.java

@@ -37,7 +37,9 @@ public void add(Document document) {
 
     public void addEntity(String entity) {
         MongoCollection<Document> collection = getCollection();
-        collection.insertOne(Converter.jsonStringToDocument(entity));
+        if (Objects.nonNull(collection)){
+            collection.insertOne(Converter.jsonStringToDocument(entity));
+        }
     }
 
     public void addList(List<Document> documents) {
@@ -167,7 +169,7 @@ private <T> List<T> getEntityList(FindIterable<Document> findIterable) {
     }
 
     private MongoCollection<Document> getCollection() {
-        if (Objects.isNull(manager)){
+        if (Objects.isNull(manager) || Objects.isNull(manager.getDb())){
             return null;
         }