store revoked transaction and contract event.

Author: jiangyy0824

plugins/kafkaplugin/src/main/java/org/tron/eventplugin/KafkaEventListener.java

@@ -4,6 +4,7 @@
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.tron.common.logsfilter.IPluginEventListener;
+
 import java.util.Objects;
 
 @Extension

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

@@ -4,6 +4,7 @@
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.tron.common.logsfilter.IPluginEventListener;
+
 import java.util.Objects;
 
 @Extension

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

@@ -29,7 +29,8 @@ public class MongodbSenderImpl{
     private String contractEventTopic = "";
     private String contractLogTopic = "";
 
-    private String revokingItems = "";
+    private String revokedTransaction = "revokedtransaction";
+    private String revokedEvent = "revokedevent";
 
     private Thread triggerProcessThread;
     private boolean isRunTriggerProcessThread = true;
@@ -135,8 +136,11 @@ private void createCollections(){
         mongoManager.createCollection(contractEventTopic);
         createMongoTemplate(contractEventTopic);
 
-        mongoManager.createCollection(revokingItems);
-        createMongoTemplate(revokingItems);
+        mongoManager.createCollection(revokedEvent);
+        createMongoTemplate(revokedEvent);
+
+        mongoManager.createCollection(revokedTransaction);
+        createMongoTemplate(revokedTransaction);
     }
 
     private void loadMongoConfig(){
@@ -248,7 +252,26 @@ public void handleTransactionTrigger(Object data) {
             service.execute(new Runnable() {
                 @Override
                 public void run() {
-                    template.addEntity((String)data);
+                  String dataStr = (String)data;
+                  // Block revoking events:
+                  if (dataStr.contains("\"removed\":true")) {
+                    try {
+                      JSONObject jsStr = JSONObject.parseObject(dataStr);
+                      String uniqueId = jsStr.getString("uniqueId");
+                      if (uniqueId != null) {
+                        template.delete("uniqueId", uniqueId);
+                      }
+
+                      MongoTemplate revokingTemplate = mongoTemplateMap.get(revokedTransaction);
+                      if (Objects.nonNull(revokingTemplate)){
+                        revokingTemplate.addEntity(dataStr);
+                      }
+                    } catch (Exception ex) {
+                      log.error("unknown exception happened in parse object ", ex);
+                    }
+                  } else {
+                    template.addEntity(dataStr);
+                  }
                 }
             });
         }
@@ -290,7 +313,7 @@ public void run() {
                                 template.delete("uniqueId", uniqueId);
                             }
 
-                            MongoTemplate revokingTemplate = mongoTemplateMap.get(revokingItems);
+                            MongoTemplate revokingTemplate = mongoTemplateMap.get(revokedEvent);
                             if (Objects.nonNull(revokingTemplate)){
                                 revokingTemplate.addEntity(dataStr);
                             }

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

@@ -6,6 +6,7 @@
 import com.mongodb.ServerAddress;
 import com.mongodb.client.MongoDatabase;
 import org.pf4j.util.StringUtils;
+
 import java.util.ArrayList;
 import java.util.List;
 import java.util.Objects;

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

@@ -1,21 +1,21 @@
 package org.tron.mongodb;
 
-import java.util.ArrayList;
-import java.util.List;
-import java.util.Objects;
-
-import org.bson.Document;
-import org.bson.conversions.Bson;
 import com.mongodb.BasicDBObject;
 import com.mongodb.client.FindIterable;
 import com.mongodb.client.MongoCollection;
 import com.mongodb.client.MongoCursor;
 import com.mongodb.client.model.Filters;
 import com.mongodb.client.result.DeleteResult;
 import com.mongodb.client.result.UpdateResult;
+import org.bson.Document;
+import org.bson.conversions.Bson;
 import org.tron.mongodb.util.Converter;
 import org.tron.mongodb.util.Pager;
 
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Objects;
+
 public abstract class MongoTemplate {
 
     private MongoManager manager;

plugins/mongodbplugin/src/main/java/org/tron/mongodb/util/Converter.java

@@ -1,10 +1,9 @@
 package org.tron.mongodb.util;
 
-import java.io.Serializable;
-
+import com.alibaba.fastjson.JSON;
 import org.bson.Document;
 
-import com.alibaba.fastjson.JSON;
+import java.io.Serializable;
 
 public class Converter {