fix: masternode group will not do header sync

core/src/main/java/org/bitcoinj/coinjoin/utils/MasternodeGroup.java

@@ -147,7 +147,7 @@ public MasternodeGroup(NetworkParameters params, @Nullable AbstractBlockChain ch
      * @param chain
      */
     public MasternodeGroup(Context context, @Nullable AbstractBlockChain chain) {
-        super(context, chain);
+        super(context, chain, false);
         init();
     }
 

core/src/main/java/org/bitcoinj/core/PeerGroup.java

@@ -364,9 +364,14 @@ public PeerGroup(Context context) {
         this(context, null);
     }
 
+    /** See {@link #PeerGroup(Context, AbstractBlockChain)} */
+    public PeerGroup(NetworkParameters params, @Nullable AbstractBlockChain chain, boolean syncBlockchain) {
+        this(Context.getOrCreate(params), chain, null, new NioClientManager(), syncBlockchain);
+    }
+
     /** See {@link #PeerGroup(Context, AbstractBlockChain)} */
     public PeerGroup(NetworkParameters params, @Nullable AbstractBlockChain chain) {
-        this(Context.getOrCreate(params), chain, null, new NioClientManager());
+        this(Context.getOrCreate(params), chain, null, new NioClientManager(), true);
     }
 
     /** See {@link #PeerGroup(Context, AbstractBlockChain)} */
@@ -382,16 +387,32 @@ public PeerGroup(Context context, @Nullable AbstractBlockChain chain) {
         this(context, chain, null, new NioClientManager());
     }
 
+    /**
+     * Creates a PeerGroup for the given context and chain. Blocks will be passed to the chain as they are broadcast
+     * and downloaded. This is probably the constructor you want to use.
+     */
+    public PeerGroup(Context context, @Nullable AbstractBlockChain chain, boolean syncsBlockchain) {
+        this(context, chain, null, new NioClientManager(), syncsBlockchain);
+    }
+
     /** See {@link #PeerGroup(Context, AbstractBlockChain, AbstractBlockChain, ClientConnectionManager)} */
     public PeerGroup(NetworkParameters params, @Nullable AbstractBlockChain chain, ClientConnectionManager connectionManager) {
         this(Context.getOrCreate(params), chain, null, connectionManager);
     }
 
     /**
      * Creates a new PeerGroup allowing you to specify the {@link ClientConnectionManager} which is used to create new
-     * connections and keep track of existing ones.
+     * connections and keep track of existing ones.  This peer group will initialize headerChain if null
      */
     private PeerGroup(Context context, @Nullable AbstractBlockChain chain, @Nullable AbstractBlockChain headerChain, ClientConnectionManager connectionManager) {
+        this(context, chain, headerChain, connectionManager, true);
+    }
+
+        /**
+         * Creates a new PeerGroup allowing you to specify the {@link ClientConnectionManager} which is used to create new
+         * connections and keep track of existing ones.
+         */
+    private PeerGroup(Context context, @Nullable AbstractBlockChain chain, @Nullable AbstractBlockChain headerChain, ClientConnectionManager connectionManager, boolean syncsBlockchain) {
         checkNotNull(context);
         this.context = context;
         this.params = context.getParams();
@@ -438,15 +459,18 @@ public int compare(PeerAddress a, PeerAddress b) {
         vMinRequiredProtocolVersion = params.getProtocolVersionNum(NetworkParameters.ProtocolVersion.MINIMUM);
         runningVoteBroadcasts = Collections.synchronizedSet(new HashSet<GovernanceVoteBroadcast>());
 
-        //DashSpecific
-        if (headerChain == null) {
+        // Dash Specific - if this PeerGroup does not sync the blockchain, then syncsBlockchain should be false
+        // otherwise, if headerChain is null, then copy the last 100 headers over to it
+        if (headerChain == null && syncsBlockchain) {
             if (context.getSyncFlags().contains(MasternodeSync.SYNC_FLAGS.SYNC_HEADERS_MN_LIST_FIRST)) {
                 try {
                     this.headerChain = new BlockChain(params, new MemoryBlockStore(params));
                     StoredBlock cursor = chain.getChainHead();
-                    while (cursor != null && !cursor.getHeader().equals(params.getGenesisBlock())) {
+                    int headers = 0; // limit headers to 100, enough to sync
+                    while (cursor != null && !cursor.getHeader().equals(params.getGenesisBlock()) && headers < 100) {
                         this.headerChain.getBlockStore().put(cursor);
                         cursor = cursor.getPrev(chain.getBlockStore());
+                        headers++;
                     }
                 } catch (BlockStoreException x) {
                     // swallow

core/src/main/java/org/bitcoinj/wallet/Wallet.java

@@ -5946,7 +5946,7 @@ public void addReceivingFromFriendKeyChain(FriendKeyChain chain) {
                 receivingFromFriendsGroup = FriendKeyChainGroup.friendlybuilder(params).build();
             }
             receivingFromFriendsGroup.addAndActivateHDChain(chain);
-            saveNow();
+            saveLater();
         } finally {
             keyChainGroupLock.unlock();
         }
@@ -5966,7 +5966,7 @@ public void addSendingToFriendKeyChain(FriendKeyChain chain) {
                 sendingToFriendsGroup = FriendKeyChainGroup.friendlybuilder(params).build();
             }
             sendingToFriendsGroup.addAndActivateHDChain(chain);
-            saveNow();
+            saveLater();
         } finally {
             keyChainGroupLock.unlock();
         }