Transaction pinning: #1599

src/main/java/com/iota/iri/Iota.java

@@ -1,5 +1,13 @@
 package com.iota.iri;
 
+import java.util.List;
+import java.util.Map;
+
+import com.iota.iri.storage.rocksDB.RocksDBPPPImpl;
+import org.apache.commons.lang3.NotImplementedException;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
 import com.iota.iri.conf.IotaConfig;
 import com.iota.iri.controllers.TipsViewModel;
 import com.iota.iri.controllers.TransactionViewModel;
@@ -272,6 +280,24 @@ private void initializeTangle() {
         if (configuration.isZmqEnabled()) {
             tangle.addMessageQueueProvider(new ZmqMessageQueueProvider(configuration));
         }
+
+        if(configuration.isSelectivePermaEnabled()){
+            switch (configuration.getPermaMainDb()) {
+                case "rocksdb": {
+                    RocksDBPPPImpl ppp = new RocksDBPPPImpl(
+                            configuration.getPermaDbPath(),
+                            configuration.getPermaDbLogPath(),
+                            configuration.getPermaDbCacheSize());
+
+                    tangle.addPersistenceProvider(ppp);
+                    tangle.addPermanentPersistenceProvider(ppp);
+                    break;
+                }
+                default: {
+                    throw new NotImplementedException("No such database type.");
+                }
+            }
+        }
     }
 
     /**

src/main/java/com/iota/iri/conf/BaseIotaConfig.java

@@ -68,6 +68,15 @@ public abstract class BaseIotaConfig implements IotaConfig {
     protected boolean revalidate = Defaults.REVALIDATE;
     protected boolean rescanDb = Defaults.RESCAN_DB;
 
+    //PERMADB
+    protected boolean permaDbEnabled = Defaults.PERMADB_ENABLED;
+    protected String permaDbPath = Defaults.PERMADB_PATH;
+    protected String permaDbLogPath = Defaults.PERMADB_LOG_PATH;
+    protected int permaDbCacheSize = Defaults.PERMADB_CACHE_SIZE; //KB
+    protected String permaMainDb = Defaults.PERMAMAIN_DB;
+    protected boolean permaRevalidate = Defaults.PERMAREVALIDATE;
+    protected boolean permaRescanDb = Defaults.PERMARESCAN_DB;
+
     //Protocol
     protected double pSendMilestone = Defaults.P_SEND_MILESTONE;
 
@@ -384,6 +393,83 @@ protected void setIxiDir(String ixiDir) {
         this.ixiDir = ixiDir;
     }
 
+    //------- PERMADB -------------
+    @Override
+    public boolean isSelectivePermaEnabled() { return this.permaDbEnabled;}
+
+    @JsonProperty
+    @Parameter(names = {"--permadb-enabled"}, description = PermaDBConfig.Descriptions.PERMADB_ENABLED)
+    protected void setPermaDbEnabled(boolean enabled) {
+        this.permaDbEnabled = enabled;
+    }
+
+    @Override
+    public String getPermaDbPath() {
+        return permaDbPath;
+    }
+
+    @JsonProperty
+    @Parameter(names = {"--perma-db-path"}, description = PermaDBConfig.Descriptions.PERMADB_PATH)
+    protected void setPermaDbPath(String permaDbPath) {
+        this.permaDbPath = permaDbPath;
+    }
+
+    @Override
+    public String getPermaDbLogPath() {
+        return dbLogPath;
+    }
+
+    @JsonProperty
+    @Parameter(names = {"--perma-db-log-path"}, description = PermaDBConfig.Descriptions.PERMADB_LOG_PATH)
+    protected void setPermaDbLogPath(String permaDbLogPath) {
+        this.permaDbLogPath = permaDbLogPath;
+    }
+
+    @Override
+    public int getPermaDbCacheSize() {
+        return permaDbCacheSize;
+    }
+
+    @JsonProperty
+    @Parameter(names = {"--perma-db-cache-size"}, description = PermaDBConfig.Descriptions.PERMADB_CACHE_SIZE)
+    protected void setPermaDbCacheSize(int permaDbCacheSize) {
+        this.permaDbCacheSize = permaDbCacheSize;
+    }
+
+    @Override
+    public String getPermaMainDb() {
+        return permaMainDb;
+    }
+
+    @JsonProperty
+    @Parameter(names = {"--perma-db"}, description = PermaDBConfig.Descriptions.PERMAMAIN_DB)
+    protected void setPermaMainDb(String permaMainDb) {
+        this.permaMainDb = permaMainDb;
+    }
+
+    @Override
+    public boolean permaIsRevalidate() {
+        return permaRevalidate;
+    }
+
+    @JsonProperty
+    @Parameter(names = {"--perma-revalidate"}, description = PermaDBConfig.Descriptions.PERMAREVALIDATE)
+    protected void setPermaRevalidate(boolean permaRevalidate) {
+        this.permaRevalidate = permaRevalidate;
+    }
+
+    @Override
+    public boolean permaIsRescanDb() {
+        return this.permaRescanDb;
+    }
+
+    @JsonProperty
+    @Parameter(names = {"--perma-rescan"}, description = PermaDBConfig.Descriptions.PERMARESCAN_DB)
+    protected void setPermaRescanDb(boolean permaRescanDb) {
+        this.permaRescanDb = permaRescanDb;
+    }
+    //-----------------------------
+
     @Override
     public String getDbPath() {
         return dbPath;
@@ -869,6 +955,15 @@ public interface Defaults {
         boolean REVALIDATE = false;
         boolean RESCAN_DB = false;
 
+        //PERMADB
+        boolean PERMADB_ENABLED = true;
+        String PERMADB_PATH = "mainnetpermadb";
+        String PERMADB_LOG_PATH = "mainnetpermadb.log";
+        int PERMADB_CACHE_SIZE = 100_000;
+        String PERMAMAIN_DB = "rocksdb";
+        boolean PERMAREVALIDATE = false;
+        boolean PERMARESCAN_DB = false;
+
         //Protocol
         double P_SEND_MILESTONE = 0.02d;
         int MWM = 14;

src/main/java/com/iota/iri/conf/IotaConfig.java

@@ -10,7 +10,8 @@
  *  In charge of how we parse the configuration from given inputs.
  */
 public interface IotaConfig extends APIConfig, NodeConfig,
-        IXIConfig, DbConfig, ConsensusConfig, ZMQConfig, TipSelConfig, PearlDiverConfig, SolidificationConfig {
+        IXIConfig, DbConfig, PermaDBConfig,
+        ConsensusConfig, ZMQConfig, TipSelConfig, PearlDiverConfig, SolidificationConfig {
     File CONFIG_FILE = new File("iota.ini");
 
     /**

src/main/java/com/iota/iri/conf/PermaDBConfig.java

@@ -0,0 +1,72 @@
+package com.iota.iri.conf;
+
+/**
+ * Configurations for tangle database.
+ */
+public interface PermaDBConfig extends Config {
+
+
+    /**
+     * Default Value: {@value BaseIotaConfig.Defaults#PERMADB_ENABLED}
+     *
+     * @return {@value PermaDBConfig.Descriptions#PERMADB_ENABLED}
+     */
+    boolean isSelectivePermaEnabled();
+
+    /**
+     * Default Value: {@value BaseIotaConfig.Defaults#PERMADB_PATH}
+     *
+     * @return {@value PermaDBConfig.Descriptions#PERMADB_PATH}
+     */
+    String getPermaDbPath();
+
+    /**
+     * Default Value: {@value BaseIotaConfig.Defaults#PERMADB_LOG_PATH}
+     *
+     * @return {@value PermaDBConfig.Descriptions#PERMADB_LOG_PATH}
+     */
+    String getPermaDbLogPath();
+
+    /**
+     * Default Value: {@value BaseIotaConfig.Defaults#PERMADB_CACHE_SIZE}
+     *
+     * @return {@value PermaDBConfig.Descriptions#PERMADB_CACHE_SIZE}
+     */
+    int getPermaDbCacheSize();
+
+    /**
+     * Default Value: {@value BaseIotaConfig.Defaults#PERMAMAIN_DB}
+     *
+     * @return {@value PermaDBConfig.Descriptions#PERMAMAIN_DB}
+     */
+    String getPermaMainDb();
+
+    /**
+     * Default Value: {@value BaseIotaConfig.Defaults#PERMAREVALIDATE}
+     *
+     * @return {@value PermaDBConfig.Descriptions#PERMAREVALIDATE}
+     */
+    boolean permaIsRevalidate();
+
+    /**
+     * Default Value: {@value BaseIotaConfig.Defaults#PERMARESCAN_DB}
+     *
+     * @return {@value PermaDBConfig.Descriptions#PERMARESCAN_DB}
+     */
+    boolean permaIsRescanDb();
+
+    /**
+     * Field descriptions
+     */
+    interface Descriptions {
+
+        String PERMADB_PATH = "The folder where the DB saves its data.";
+        String PERMADB_LOG_PATH = "The folder where the DB logs info";
+        String PERMADB_CACHE_SIZE = "The size of the DB cache in KB";
+        String PERMAMAIN_DB = "The DB engine used to store the transactions. Currently only RocksDB is supported.";
+        String PERMAREVALIDATE = "Reload from the db data about confirmed transaction (milestones), state of the ledger, " +
+                "and transaction metadata.";
+        String PERMARESCAN_DB = "Rescan all transaction metadata (Approvees, Bundles, and Tags)";
+        String PERMADB_ENABLED = "Enables secondary permanent storage";
+    }
+}

src/main/java/com/iota/iri/model/persistables/Hashes.java

@@ -62,7 +62,6 @@ public void readMetadata(byte[] bytes) {
 
     }
 
-
     @Override
     public boolean canMerge() {
         return true;

src/main/java/com/iota/iri/model/persistables/Milestone.java

@@ -55,7 +55,6 @@ public void readMetadata(byte[] bytes) {
 
     }
 
-
     @Override
     public boolean canMerge() {
         return false;

src/main/java/com/iota/iri/model/persistables/SpentAddress.java

@@ -31,15 +31,14 @@ public boolean canMerge() {
         return false;
     }
 
-
     @Override
     public Persistable mergeInto(Persistable source)  throws OperationNotSupportedException {
         throw new OperationNotSupportedException("This object is not mergeable");
     }
 
-
     @Override
     public boolean exists() {
         return exists;
     }
+
 }

src/main/java/com/iota/iri/model/persistables/Transaction.java

@@ -217,8 +217,6 @@ public void readMetadata(byte[] bytes) {
         parsed = true;
     }
 
-
-
     @Override
     public boolean canMerge() {
         return false;