5931 gossip encapsulation (#6607)

Signed-off-by: Cody Littley <cody@swirldslabs.com>
hashgraph · May 22, 2023 · 6057902 · 6057902
1 parent 09d7828
commit 6057902
Show file tree

Hide file tree

Showing 19 changed files with 2,301 additions and 931 deletions.
diff --git a/platform-sdk/sdk/settings.txt b/platform-sdk/sdk/settings.txt
@@ -16,4 +16,6 @@ checkSignedStateFromDisk,         true
 loadKeysFromPfxFiles,             false
 event.preconsensus.enableStorage, false
 enableEventStreaming,             false
-reconnect.active,                 true
+reconnect.active,                 true
+chatter.useChatter,               false
+sync.syncAsProtocolEnabled,       false
diff --git a/...m-sdk/swirlds-jasperdb/src/test/java/com/swirlds/jasperdb/files/DataFileLowLevelTest.java b/...m-sdk/swirlds-jasperdb/src/test/java/com/swirlds/jasperdb/files/DataFileLowLevelTest.java
@@ -228,7 +228,7 @@ void readBackRawData(FilesTestType testType) throws IOException {
                     int repeatCount = getRepeatCountForKey(i);
                     // read size
                     int size = (int) longBuf.get();
-                    // TODO be nice to assert size
+                    // FUTURE WORK: be nice to assert size
                     // read key
                     assertEquals(i, longBuf.get(), "unexpected data value #2");
                     for (int j = 0; j < repeatCount; j++) {

diff --git a/platform-sdk/swirlds-platform-core/src/main/java/com/swirlds/platform/Browser.java b/platform-sdk/swirlds-platform-core/src/main/java/com/swirlds/platform/Browser.java
@@ -516,6 +516,11 @@ public static synchronized void launch(final Set<Integer> localNodesToStart, fin
             }
             logger = LogManager.getLogger(Browser.class);
 
+            if (Thread.getDefaultUncaughtExceptionHandler() == null) {
+                Thread.setDefaultUncaughtExceptionHandler((final Thread t, final Throwable e) ->
+                        logger.error(EXCEPTION.getMarker(), "exception on thread {}", t.getName(), e));
+            }
+
             final LoggerContextFactory factory = LogManager.getFactory();
             if (factory instanceof final Log4jContextFactory contextFactory) {
                 // Do not allow log4j to use its own shutdown hook. Use our own shutdown
@@ -676,13 +681,10 @@ private Collection<SwirldsPlatform> createLocalPlatforms(
                 GuiPlatformAccessor.getInstance().setInstanceNumber(address.getId(), i);
 
                 final SwirldsPlatform platform = new SwirldsPlatform(
-                        // all key pairs and CSPRNG state for this member
+                        platformContext,
                         crypto.get(address.getNodeId()),
-                        // address book index, which is the member ID
-                        nodeId,
-                        // copy of the address book,
                         initialAddressBook,
-                        platformContext,
+                        nodeId,
                         mainClassName,
                         swirldName,
                         appVersion,

diff --git a/...orm-sdk/swirlds-platform-core/src/main/java/com/swirlds/platform/PlatformConstructor.java b/...orm-sdk/swirlds-platform-core/src/main/java/com/swirlds/platform/PlatformConstructor.java
@@ -66,7 +66,7 @@
 /**
  * Used to construct platform components that use DI
  */
-final class PlatformConstructor {
+public final class PlatformConstructor {
 
     /** The maximum size of the queue holding signed states ready to be hashed and signed by others. */
     private static final int STATE_HASH_QUEUE_MAX = 1;
@@ -81,15 +81,15 @@ private PlatformConstructor() {}
      *
      * @param threadManager responsible for managing thread lifecycles
      */
-    static ParallelExecutor parallelExecutor(final ThreadManager threadManager) {
+    public static ParallelExecutor parallelExecutor(final ThreadManager threadManager) {
         return new CachedPoolParallelExecutor(threadManager, "node-sync");
     }
 
-    static SettingsProvider settingsProvider() {
+    public static SettingsProvider settingsProvider() {
         return StaticSettingsProvider.getSingleton();
     }
 
-    static SocketFactory socketFactory(final KeysAndCerts keysAndCerts, final CryptoConfig cryptoConfig) {
+    public static SocketFactory socketFactory(final KeysAndCerts keysAndCerts, final CryptoConfig cryptoConfig) {
         if (!Settings.getInstance().isUseTLS()) {
             return new TcpFactory(PlatformConstructor.settingsProvider());
         }
@@ -105,7 +105,8 @@ static SocketFactory socketFactory(final KeysAndCerts keysAndCerts, final Crypto
         }
     }
 
-    static PlatformSigner platformSigner(final KeysAndCerts keysAndCerts) {
+    public static PlatformSigner platformSigner(@NonNull final KeysAndCerts keysAndCerts) {
+        Objects.requireNonNull(keysAndCerts);
         try {
             return new PlatformSigner(keysAndCerts);
         } catch (final NoSuchAlgorithmException | NoSuchProviderException | InvalidKeyException e) {

diff --git a/platform-sdk/swirlds-platform-core/src/main/java/com/swirlds/platform/SwirldsPlatform.java b/platform-sdk/swirlds-platform-core/src/main/java/com/swirlds/platform/SwirldsPlatform.java