Expose start and stop synchronization to plugin aPI (#7940)

Signed-off-by: Gabriel-Trintinalia <[email protected]>

besu/src/main/java/org/hyperledger/besu/cli/BesuCommand.java

@@ -1278,6 +1278,7 @@ private void startPlugins(final Runner runner) {
     besuPluginContext.addService(
         SynchronizationService.class,
         new SynchronizationServiceImpl(
+            besuController.getSynchronizer(),
             besuController.getProtocolContext(),
             besuController.getProtocolSchedule(),
             besuController.getSyncState(),

besu/src/main/java/org/hyperledger/besu/services/SynchronizationServiceImpl.java

@@ -20,6 +20,7 @@
 import org.hyperledger.besu.ethereum.chain.MutableBlockchain;
 import org.hyperledger.besu.ethereum.core.Block;
 import org.hyperledger.besu.ethereum.core.BlockImporter;
+import org.hyperledger.besu.ethereum.core.Synchronizer;
 import org.hyperledger.besu.ethereum.eth.sync.state.SyncState;
 import org.hyperledger.besu.ethereum.mainnet.HeaderValidationMode;
 import org.hyperledger.besu.ethereum.mainnet.ProtocolSchedule;
@@ -45,23 +46,27 @@ public class SynchronizationServiceImpl implements SynchronizationService {
 
   private final ProtocolContext protocolContext;
   private final ProtocolSchedule protocolSchedule;
+  private final Synchronizer synchronizer;
 
   private final SyncState syncState;
   private final Optional<DiffBasedWorldStateProvider> worldStateArchive;
 
   /**
    * Constructor for SynchronizationServiceImpl.
    *
+   * @param synchronizer synchronizer
    * @param protocolContext protocol context
    * @param protocolSchedule protocol schedule
    * @param syncState sync state
    * @param worldStateArchive world state archive
    */
   public SynchronizationServiceImpl(
+      final Synchronizer synchronizer,
       final ProtocolContext protocolContext,
       final ProtocolSchedule protocolSchedule,
       final SyncState syncState,
       final WorldStateArchive worldStateArchive) {
+    this.synchronizer = synchronizer;
     this.protocolContext = protocolContext;
     this.protocolSchedule = protocolSchedule;
     this.syncState = syncState;
@@ -157,4 +162,14 @@ public void disableWorldStateTrie() {
           }
         });
   }
+
+  @Override
+  public void stop() {
+    synchronizer.stop();
+  }
+
+  @Override
+  public void start() {
+    synchronizer.start();
+  }
 }

plugin-api/build.gradle

@@ -71,7 +71,7 @@ Calculated : ${currentHash}
 tasks.register('checkAPIChanges', FileStateChecker) {
   description = "Checks that the API for the Plugin-API project does not change without deliberate thought"
   files = sourceSets.main.allJava.files
-  knownHash = 'KuKoCZT1A+gOlJlry5GQMCRKVWWAlO3lGAqt9MDv0r4='
+  knownHash = 'PKvPlngg7BfdZ4Jinh0IUsyFOLvNaQU72VD4BHia/WM='
 }
 check.dependsOn('checkAPIChanges')
 

plugin-api/src/main/java/org/hyperledger/besu/plugin/services/sync/SynchronizationService.java

@@ -59,4 +59,10 @@ public interface SynchronizationService extends BesuService {
 
   /** Disables the worldstate trie for update. */
   void disableWorldStateTrie();
+
+  /** Stops the synchronizer. */
+  void stop();
+
+  /** Starts the synchronizer. */
+  void start();
 }