Built a way to test the examples work with each mainnet release and n…

…ew SDK release (#1592) Signed-off-by: Nikita Lebedev <[email protected]>
hashgraph · Oct 18, 2023 · 9ac8a30 · 9ac8a30
1 parent bf54aa5
commit 9ac8a30
Show file tree

Hide file tree

Showing 51 changed files with 394 additions and 190 deletions.
diff --git a/.github/workflows/build.yml b/.github/workflows/build.yml
@@ -89,3 +89,42 @@ jobs:
 
       - name: Stop the local node
         run: npx @hashgraph/hedera-local stop
+
+  examples:
+    runs-on: ubuntu-latest
+
+    steps:
+      - uses: actions/checkout@v2
+        with:
+          fetch-depth: 0  # Shallow clones should be disabled for a better relevancy of analysis
+      - name: Set up JDK 17
+        uses: actions/setup-java@v2
+        with:
+          java-version: '17'
+          distribution: 'adopt'
+      - name: Cache Gradle packages
+        uses: actions/cache@v2
+        with:
+          path: |
+            ~/.gradle/caches
+            ~/.gradle/wrapper
+          key: ${{ runner.os }}-gradle-${{ hashFiles('**/*.gradle*', '**/gradle-wrapper.properties') }}
+          restore-keys: |
+            ${{ runner.os }}-gradle-
+      - name: Compile SDK
+        run: ./gradlew compileJava
+      - name: Compile Examples
+        run: ./gradlew :examples:compileJava
+
+      - name: Start the local node
+        run: npx @hashgraph/[email protected] start -d --network local
+
+      - name: Prepare .env for Examples
+        run: |
+          echo "OPERATOR_KEY=0xa608e2130a0a3cb34f86e757303c862bee353d9ab77ba4387ec084f881d420d4" > examples/.env
+          echo "OPERATOR_ID=0.0.1022" >> examples/.env
+          echo "HEDERA_NETWORK=localhost" >> examples/.env
+
+      - name: Run Examples
+        run: |
+            ./gradlew :examples:runAllExamples
diff --git a/examples/build.gradle b/examples/build.gradle
@@ -8,6 +8,39 @@ dependencies {
     implementation "com.google.errorprone:error_prone_core:2.21.1"
 }
 
+task runAllExamples {
+    def exampleClasses = fileTree('src/main/java')
+        .toList()
+        .stream()
+        .filter { it.name.endsWith('Example.java') }
+        .map { it.name.replaceAll('\\.java$', '') }
+        .filter { !it.equals('ValidateChecksumExample') } // disabled this example, because it needs user input (but it WORKS)
+        .filter { !it.equals('SolidityPrecompileExample') } // doesn't work with hedera-local-node
+        .toList()
+
+    exampleClasses.each { className ->
+        def multilineString = """
+
+        ---EXECUTING $className:
+
+        """
+
+        doLast {
+            javaexec {
+                println multilineString
+
+                classpath = sourceSets.main.runtimeClasspath
+                main = className
+                standardInput(System.in)
+
+                // NOTE: Uncomment to enable trace logs in the SDK during the examples
+                // jvmArgs "-Dorg.slf4j.simpleLogger.log.com.hedera.hashgraph=trace"
+            }
+        }
+    }
+
+}
+
 tasks.addRule("Pattern: run<Example>: Runs an example.") { String taskName ->
     if (taskName.startsWith("run")) {
         task(taskName, type: JavaExec) {

diff --git a/examples/src/main/java/AccountAliasExample.java b/examples/src/main/java/AccountAliasExample.java
@@ -43,8 +43,9 @@ public class AccountAliasExample {
     // HEDERA_NETWORK defaults to testnet if not specified in dotenv
     private static final String HEDERA_NETWORK = Dotenv.load().get("HEDERA_NETWORK", "testnet");
 
-    public static void main(String[] args) throws TimeoutException, PrecheckStatusException, ReceiptStatusException {
-        Client client = Client.forName(HEDERA_NETWORK);
+    public static void main(String[] args)
+        throws TimeoutException, PrecheckStatusException, ReceiptStatusException, InterruptedException {
+        Client client = ClientHelper.forName(HEDERA_NETWORK);
 
         // Defaults the operator account ID and key such that all generated transactions will be paid for
         // by this account and be signed by this key

diff --git a/examples/src/main/java/AccountAllowanceExample.java b/examples/src/main/java/AccountAllowanceExample.java
@@ -57,15 +57,17 @@ public class AccountAllowanceExample {
     private final PrivateKey charlieKey;
     private final AccountId charlieId;
 
-    public static void main(String[] args) throws PrecheckStatusException, TimeoutException, ReceiptStatusException {
+    public static void main(String[] args)
+        throws PrecheckStatusException, TimeoutException, ReceiptStatusException, InterruptedException {
         AccountAllowanceExample example = new AccountAllowanceExample();
         example.demonstrateAllowances();
         example.cleanUp();
         System.out.println("End of example");
     }
 
-    private AccountAllowanceExample() throws PrecheckStatusException, TimeoutException, ReceiptStatusException {
-        client = Client.forName(HEDERA_NETWORK);
+    private AccountAllowanceExample()
+        throws PrecheckStatusException, TimeoutException, ReceiptStatusException, InterruptedException {
+        client = ClientHelper.forName(HEDERA_NETWORK);
 
         // Defaults the operator account ID and key such that all generated transactions will be paid for
         // by this account and be signed by this key

diff --git a/examples/src/main/java/AccountCreateWithHtsExample.java b/examples/src/main/java/AccountCreateWithHtsExample.java
@@ -36,7 +36,7 @@ private AccountCreateWithHtsExample() {
     }
 
     public static void main(String[] args) throws NullPointerException, PrecheckStatusException, ReceiptStatusException, InterruptedException, TimeoutException {
-        Client client = Client.forName(HEDERA_NETWORK);
+        Client client = ClientHelper.forName(HEDERA_NETWORK);
 
         // Defaults the operator account ID and key such that all generated transactions will be paid for
         // by this account and be signed by this key

diff --git a/examples/src/main/java/AutoCreateAccountTransferTransactionExample.java b/examples/src/main/java/AutoCreateAccountTransferTransactionExample.java
@@ -42,7 +42,7 @@ private AutoCreateAccountTransferTransactionExample() {
     - Get the `AccountInfo` for the account and return the public key on the account to show it is a complete account
     */
     public static void main(String[] args) throws PrecheckStatusException, TimeoutException, ReceiptStatusException, InterruptedException, IOException {
-        Client client = Client.forName(HEDERA_NETWORK);
+        Client client = ClientHelper.forName(HEDERA_NETWORK);
 
         // Defaults the operator account ID and key such that all generated transactions will be paid for
         // by this account and be signed by this key

diff --git a/examples/src/main/java/ClientHelper.java b/examples/src/main/java/ClientHelper.java
@@ -0,0 +1,27 @@
+import com.hedera.hashgraph.sdk.AccountId;
+import com.hedera.hashgraph.sdk.Client;
+import java.util.HashMap;
+import java.util.List;
+
+public class ClientHelper {
+    public static final String LOCAL_NETWORK_NAME = "localhost";
+    private static final String DEFAULT_LOCAL_NODE_ADDRESS = "127.0.0.1:50211";
+    private static final String DEFAULT_LOCAL_MIRROR_NODE_ADDRESS = "127.0.0.1:5600";
+
+    public static Client forName(String network) throws InterruptedException {
+        if (network.equals(LOCAL_NETWORK_NAME)) {
+            return forLocalNetwork();
+        } else {
+            return Client.forName(network);
+        }
+    }
+
+    public static Client forLocalNetwork() throws InterruptedException {
+        var network = new HashMap<String, AccountId>();
+        network.put(DEFAULT_LOCAL_NODE_ADDRESS, new AccountId(3));
+
+        return Client
+            .forNetwork(network)
+            .setMirrorNetwork(List.of(DEFAULT_LOCAL_MIRROR_NODE_ADDRESS));
+    }
+}
diff --git a/examples/src/main/java/ConsensusPubSubChunkedExample.java b/examples/src/main/java/ConsensusPubSubChunkedExample.java
@@ -36,6 +36,8 @@
 import java.io.InputStream;
 import java.io.InputStreamReader;
 import java.util.Objects;
+import java.util.concurrent.CountDownLatch;
+import java.util.concurrent.TimeUnit;
 import java.util.concurrent.TimeoutException;
 
 import static java.nio.charset.StandardCharsets.UTF_8;
@@ -46,11 +48,13 @@ public final class ConsensusPubSubChunkedExample {
     // HEDERA_NETWORK defaults to testnet if not specified in dotenv
     private static final String HEDERA_NETWORK = Dotenv.load().get("HEDERA_NETWORK", "testnet");
 
+    private static final CountDownLatch largeMessageLatch = new CountDownLatch(1);
+
     private ConsensusPubSubChunkedExample() {
     }
 
     public static void main(String[] args) throws TimeoutException, PrecheckStatusException, ReceiptStatusException, InterruptedException, InvalidProtocolBufferException {
-        Client client = Client.forName(HEDERA_NETWORK);
+        Client client = ClientHelper.forName(HEDERA_NETWORK);
 
         // Defaults the operator account ID and key such that all generated transactions will be paid for
         // by this account and be signed by this key
@@ -80,6 +84,7 @@ public static void main(String[] args) throws TimeoutException, PrecheckStatusEx
             .setTopicId(newTopicId)
             .subscribe(client, topicMessage -> {
                 System.out.println("at " + topicMessage.consensusTimestamp + " ( seq = " + topicMessage.sequenceNumber + " ) received topic message of " + topicMessage.contents.length + " bytes");
+                largeMessageLatch.countDown();
             });
 
         // get a large file to send
@@ -115,12 +120,9 @@ public static void main(String[] args) throws TimeoutException, PrecheckStatusEx
         // get the receipt to ensure there were no errors
         transaction.execute(client).getReceipt(client);
 
-        // noinspection InfiniteLoopStatement
-        while (true) {
-            System.out.println("waiting ...");
-
-            // noinspection BusyWait
-            Thread.sleep(2500);
+        boolean largeMessageReceived = largeMessageLatch.await(30, TimeUnit.SECONDS);
+        if (!largeMessageReceived) {
+            throw new TimeoutException("Large topic message was not received!");
         }
     }
 

diff --git a/examples/src/main/java/ConsensusPubSubExample.java b/examples/src/main/java/ConsensusPubSubExample.java
@@ -32,6 +32,8 @@
 
 import java.nio.charset.StandardCharsets;
 import java.util.Objects;
+import java.util.concurrent.CountDownLatch;
+import java.util.concurrent.TimeUnit;
 import java.util.concurrent.TimeoutException;
 
 
@@ -41,11 +43,14 @@ class ConsensusPubSubExample {
     // HEDERA_NETWORK defaults to testnet if not specified in dotenv
     private static final String HEDERA_NETWORK = Dotenv.load().get("HEDERA_NETWORK", "testnet");
 
+    private static final int TOTAL_MESSAGES = 5;
+    private static final CountDownLatch messagesLatch = new CountDownLatch(TOTAL_MESSAGES);
+
     private ConsensusPubSubExample() {
     }
 
     public static void main(String[] args) throws TimeoutException, InterruptedException, PrecheckStatusException, ReceiptStatusException {
-        Client client = Client.forName(HEDERA_NETWORK);
+        Client client = ClientHelper.forName(HEDERA_NETWORK);
 
         // Defaults the operator account ID and key such that all generated transactions will be paid for
         // by this account and be signed by this key
@@ -68,11 +73,10 @@ public static void main(String[] args) throws TimeoutException, InterruptedExcep
                 String messageAsString = new String(resp.contents, StandardCharsets.UTF_8);
 
                 System.out.println(resp.consensusTimestamp + " received topic message: " + messageAsString);
+                messagesLatch.countDown();
             });
 
-        // keep the main thread from exiting because the listeners run on daemon threads
-        // noinspection InfiniteLoopStatement
-        for (int i = 0; ; i++) {
+        for (int i = 0; i <= TOTAL_MESSAGES; i++) {
             new TopicMessageSubmitTransaction()
                 .setTopicId(topicId)
                 .setMessage("hello, HCS! " + i)
@@ -81,5 +85,10 @@ public static void main(String[] args) throws TimeoutException, InterruptedExcep
 
             Thread.sleep(2500);
         }
+
+        boolean allMessagesReceived = messagesLatch.await(30, TimeUnit.SECONDS);
+        if (!allMessagesReceived) {
+            throw new TimeoutException("Not all topic messages were received!");
+        }
     }
 }
diff --git a/examples/src/main/java/ConsensusPubSubWithSubmitKeyExample.java b/examples/src/main/java/ConsensusPubSubWithSubmitKeyExample.java
@@ -58,7 +58,8 @@ public class ConsensusPubSubWithSubmitKeyExample {
     private TopicId topicId;
     private PrivateKey submitKey;
 
-    public ConsensusPubSubWithSubmitKeyExample(int messagesToPublish, int millisBetweenMessages) {
+    public ConsensusPubSubWithSubmitKeyExample(int messagesToPublish, int millisBetweenMessages)
+        throws InterruptedException {
         this.messagesToPublish = messagesToPublish;
         this.millisBetweenMessages = millisBetweenMessages;
         setupClient();
@@ -77,8 +78,8 @@ public void execute() throws TimeoutException, InterruptedException, PrecheckSta
         publishMessagesToTopic();
     }
 
-    private void setupClient() {
-        client = Client.forName(HEDERA_NETWORK);
+    private void setupClient() throws InterruptedException {
+        client = ClientHelper.forName(HEDERA_NETWORK);
 
         // Defaults the operator account ID and key such that all generated transactions will be paid for by this
         // account and be signed by this key

diff --git a/examples/src/main/java/ConstructClientExample.java b/examples/src/main/java/ConstructClientExample.java
@@ -33,8 +33,7 @@ public class ConstructClientExample {
     // or set environment variables with the same names
     @Nullable
     private static final String CONFIG_FILE = Dotenv.load().get("CONFIG_FILE");
-    // HEDERA_NETWORK defaults to testnet if not specified in dotenv
-    private static final String HEDERA_NETWORK = Dotenv.load().get("HEDERA_NETWORK", "testnet");
+    private static final String HEDERA_NETWORK = "testnet";
 
     ConstructClientExample() {
     }

diff --git a/examples/src/main/java/ContractNoncesExample.java b/examples/src/main/java/ContractNoncesExample.java
@@ -53,8 +53,9 @@ public final class ContractNoncesExample {
     private ContractNoncesExample() {
     }
 
-    public static void main(String[] args) throws TimeoutException, PrecheckStatusException, ReceiptStatusException {
-        Client client = Client.forName(HEDERA_NETWORK);
+    public static void main(String[] args)
+        throws TimeoutException, PrecheckStatusException, ReceiptStatusException, InterruptedException {
+        Client client = ClientHelper.forName(HEDERA_NETWORK);
 
         // Defaults the operator account ID and key such that all generated transactions will be paid for
         // by this account and be signed by this key

diff --git a/examples/src/main/java/CreateAccountExample.java b/examples/src/main/java/CreateAccountExample.java
@@ -44,8 +44,9 @@ public final class CreateAccountExample {
     private CreateAccountExample() {
     }
 
-    public static void main(String[] args) throws TimeoutException, PrecheckStatusException, ReceiptStatusException {
-        Client client = Client.forName(HEDERA_NETWORK);
+    public static void main(String[] args)
+        throws TimeoutException, PrecheckStatusException, ReceiptStatusException, InterruptedException {
+        Client client = ClientHelper.forName(HEDERA_NETWORK);
 
         // Defaults the operator account ID and key such that all generated transactions will be paid for
         // by this account and be signed by this key

diff --git a/examples/src/main/java/CreateAccountThresholdKeyExample.java b/examples/src/main/java/CreateAccountThresholdKeyExample.java
@@ -48,8 +48,9 @@ public final class CreateAccountThresholdKeyExample {
     private CreateAccountThresholdKeyExample() {
     }
 
-    public static void main(String[] args) throws PrecheckStatusException, TimeoutException, ReceiptStatusException {
-        Client client = Client.forName(HEDERA_NETWORK);
+    public static void main(String[] args)
+        throws PrecheckStatusException, TimeoutException, ReceiptStatusException, InterruptedException {
+        Client client = ClientHelper.forName(HEDERA_NETWORK);
 
         // Defaults the operator account ID and key such that all generated transactions will be paid for
         // by this account and be signed by this key

diff --git a/examples/src/main/java/CreateAccountWithAliasAndReceiverSignatureRequiredExample.java b/examples/src/main/java/CreateAccountWithAliasAndReceiverSignatureRequiredExample.java
@@ -24,8 +24,9 @@ private CreateAccountWithAliasAndReceiverSignatureRequiredExample() {
     - Sign the `AccountCreateTransaction` transaction with both the new private key and the admin key
     - Get the `AccountInfo` and show that the account has contractAccountId
     */
-    public static void main(String[] args) throws PrecheckStatusException, TimeoutException, ReceiptStatusException {
-        Client client = Client.forName(HEDERA_NETWORK);
+    public static void main(String[] args)
+        throws PrecheckStatusException, TimeoutException, ReceiptStatusException, InterruptedException {
+        Client client = ClientHelper.forName(HEDERA_NETWORK);
 
         // Defaults the operator account ID and key such that all generated transactions will be paid for
         // by this account and be signed by this key

diff --git a/examples/src/main/java/CreateAccountWithAliasExample.java b/examples/src/main/java/CreateAccountWithAliasExample.java
@@ -25,7 +25,7 @@ private CreateAccountWithAliasExample() {
     - Get the `AccountInfo` and show that the account has contractAccountId
     */
     public static void main(String[] args) throws PrecheckStatusException, TimeoutException, InterruptedException {
-        Client client = Client.forName(HEDERA_NETWORK);
+        Client client = ClientHelper.forName(HEDERA_NETWORK);
 
         // Defaults the operator account ID and key such that all generated transactions will be paid for
         // by this account and be signed by this key

diff --git a/examples/src/main/java/CreateFileExample.java b/examples/src/main/java/CreateFileExample.java
@@ -44,8 +44,9 @@ public final class CreateFileExample {
     private CreateFileExample() {
     }
 
-    public static void main(String[] args) throws TimeoutException, PrecheckStatusException, ReceiptStatusException {
-        Client client = Client.forName(HEDERA_NETWORK);
+    public static void main(String[] args)
+        throws TimeoutException, PrecheckStatusException, ReceiptStatusException, InterruptedException {
+        Client client = ClientHelper.forName(HEDERA_NETWORK);
 
         // Defaults the operator account ID and key such that all generated transactions will be paid for
         // by this account and be signed by this key

diff --git a/examples/src/main/java/CreateSimpleContractExample.java b/examples/src/main/java/CreateSimpleContractExample.java
@@ -56,11 +56,11 @@ public final class CreateSimpleContractExample {
     private CreateSimpleContractExample() {
     }
 
-    public static void main(String[] args) throws PrecheckStatusException, IOException, TimeoutException, ReceiptStatusException {
+    public static void main(String[] args)
+        throws PrecheckStatusException, IOException, TimeoutException, ReceiptStatusException, InterruptedException {
         String byteCodeHex = ContractHelper.getBytecodeHex("hello_world.json");
 
-
-        Client client = Client.forName(HEDERA_NETWORK);
+        Client client = ClientHelper.forName(HEDERA_NETWORK);
 
         // Defaults the operator account ID and key such that all generated transactions will be paid for
         // by this account and be signed by this key

diff --git a/examples/src/main/java/CreateStatefulContractExample.java b/examples/src/main/java/CreateStatefulContractExample.java
@@ -56,10 +56,11 @@ public final class CreateStatefulContractExample {
     private CreateStatefulContractExample() {
     }
 
-    public static void main(String[] args) throws PrecheckStatusException, TimeoutException, IOException, ReceiptStatusException {
+    public static void main(String[] args)
+        throws PrecheckStatusException, TimeoutException, IOException, ReceiptStatusException, InterruptedException {
         String byteCodeHex = ContractHelper.getBytecodeHex("stateful.json");
 
-        Client client = Client.forName(HEDERA_NETWORK);
+        Client client = ClientHelper.forName(HEDERA_NETWORK);
 
         // Defaults the operator account ID and key such that all generated transactions will be paid for
         // by this account and be signed by this key