add remove contract

Author: wubin1

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

@@ -24,6 +24,7 @@
 import org.pf4j.PluginManager;
 import org.tron.common.logsfilter.IPluginEventListener;
 import org.tron.common.logsfilter.trigger.BlockLogTrigger;
+import org.tron.common.logsfilter.trigger.ContractEventTrigger;
 import org.tron.common.logsfilter.trigger.Trigger;
 
 import java.io.File;
@@ -34,7 +35,7 @@ public class PluginLauncher {
     private static final Logger logger = LoggerFactory.getLogger(PluginLauncher.class);
 
     public static void main(String[] args) {
-        String path = "/Users/tron/sourcecode/eventplugin/build/plugins/plugin-mongodb-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"; // absolute path of plugin
 
         File dir = new File(path);
         // create the plugin manager
@@ -57,7 +58,7 @@ protected CompoundPluginDescriptorFinder createPluginDescriptorFinder() {
         if (Objects.isNull(eventListeners)) return;
 
         eventListeners.forEach(listener -> {
-            listener.setServerAddress("127.0.0.1:27017");
+            listener.setServerAddress("47.90.245.68:27017");
         });
 
         eventListeners.forEach(listener -> {
@@ -77,15 +78,12 @@ protected CompoundPluginDescriptorFinder createPluginDescriptorFinder() {
 
         ObjectMapper objectMapper = new ObjectMapper();
         for (int index = 0; index < 1000; ++index){
-            BlockLogTrigger trigger = new BlockLogTrigger();
-            trigger.setBlockNumber(index);
-            trigger.setBlockHash("000000000002f5834df6036318999576bfa23ff1a57e0538fa87d5a90319659e");
-            trigger.setTimeStamp(System.currentTimeMillis());
-            trigger.setTransactionSize(100);
-
+            ContractEventTrigger trigger = new ContractEventTrigger();
+            trigger.setRemoved(true);
+            trigger.setTriggerName();
             eventListeners.forEach(listener -> {
                 try {
-                    listener.handleBlockEvent(objectMapper.writeValueAsString(trigger));
+                    listener.handleContractEventTrigger(objectMapper.writeValueAsString(trigger));
                 } catch (com.fasterxml.jackson.core.JsonProcessingException e) {
                     e.printStackTrace();
                 }

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

@@ -1,4 +1,5 @@
 package org.tron.eventplugin;
+import com.alibaba.fastjson.JSONObject;
 import org.pf4j.util.StringUtils;
 
 import java.io.IOException;
@@ -238,8 +239,6 @@ public void handleTransactionTrigger(Object data) {
             return;
         }
 
-        System.out.println(data);
-
         MongoTemplate template = mongoTemplateMap.get(transactionTopic);
         if (Objects.nonNull(template)) {
             service.execute(new Runnable() {
@@ -277,7 +276,20 @@ public void handleContractEventTrigger(Object data) {
             service.execute(new Runnable() {
                 @Override
                 public void run() {
-                    template.addEntity((String)data);
+                    String dataStr = (String)data;
+                    if (dataStr.contains("\"removed\":true")) {
+                        try {
+                            JSONObject jsStr = JSONObject.parseObject(dataStr);
+                            String uniqueId = jsStr.getString("uniqueId");
+                            if (uniqueId != null) {
+                                template.delete("uniqueId", uniqueId);
+                            }
+                        } catch (Exception ex) {
+                            log.error("unknown exception happened in parse object ", ex);
+                        }
+                    } else {
+                        template.addEntity(dataStr);
+                    }
                 }
             });
         }

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

@@ -70,9 +70,9 @@ public UpdateResult updateMany(Bson filter, Bson update) {
         return result;
     }
 
-    public long delete(String whereColumn, Object whereValue) {
+    public long delete(String whereColumn, String whereValue) {
         MongoCollection<Document> collection = getCollection();
-        DeleteResult result = collection.deleteMany(Filters.eq(whereColumn, whereValue));
+        DeleteResult result = collection.deleteOne(Filters.eq(whereColumn, whereValue));
         return result.getDeletedCount();
     }