[PRIV] Fix private transaction acceptance test (PegaSysEng#1134)

raullaprida · Mar 19, 2019 · aa3bf1f · aa3bf1f
1 parent 884274f
commit aa3bf1f
Show file tree

Hide file tree

Showing 31 changed files with 458 additions and 219 deletions.
diff --git a/...nce-tests/src/test/java/tech/pegasys/pantheon/tests/acceptance/dsl/node/PantheonNode.java b/...nce-tests/src/test/java/tech/pegasys/pantheon/tests/acceptance/dsl/node/PantheonNode.java
@@ -13,6 +13,7 @@
 package tech.pegasys.pantheon.tests.acceptance.dsl.node;
 
 import static java.util.Collections.unmodifiableList;
+import static net.consensys.cava.io.file.Files.copyResource;
 import static org.apache.logging.log4j.LogManager.getLogger;
 
 import tech.pegasys.pantheon.controller.KeyPairUtil;
@@ -104,6 +105,7 @@ public PantheonNode(
       final WebSocketConfiguration webSocketConfiguration,
       final MetricsConfiguration metricsConfiguration,
       final Optional<PermissioningConfiguration> permissioningConfiguration,
+      final Optional<String> keyfilePath,
       final boolean devMode,
       final GenesisConfigProvider genesisConfigProvider,
       final boolean p2pEnabled,
@@ -112,10 +114,19 @@ public PantheonNode(
       throws IOException {
     this.bootnodeEligible = bootnodeEligible;
     this.homeDirectory = Files.createTempDirectory("acctest");
+    keyfilePath.ifPresent(
+        path -> {
+          try {
+            copyResource(path, homeDirectory.resolve("key"));
+          } catch (IOException e) {
+            LOG.error("Could not find key file \"{}\" in resources", path);
+          }
+        });
     this.keyPair = KeyPairUtil.loadKeyPair(homeDirectory);
     this.name = name;
     this.miningParameters = miningParameters;
     this.privacyParameters = privacyParameters;
+    this.privacyParameters.setSigningKeyPair(keyPair);
     this.jsonRpcConfiguration = jsonRpcConfiguration;
     this.webSocketConfiguration = webSocketConfiguration;
     this.metricsConfiguration = metricsConfiguration;

diff --git a/.../test/java/tech/pegasys/pantheon/tests/acceptance/dsl/node/ProcessPantheonNodeRunner.java b/.../test/java/tech/pegasys/pantheon/tests/acceptance/dsl/node/ProcessPantheonNodeRunner.java
@@ -87,7 +87,7 @@ public void startNode(final PantheonNode node) {
       params.add("--privacy-url");
       params.add(node.getPrivacyParameters().getUrl());
       params.add("--privacy-public-key-file");
-      params.add(node.getPrivacyParameters().getPublicKeyFile().getAbsolutePath());
+      params.add(node.getPrivacyParameters().getEnclavePublicKeyFile().getAbsolutePath());
       params.add("--privacy-precompiled-address");
       params.add(String.valueOf(node.getPrivacyParameters().getPrivacyAddress()));
     }

diff --git a/...c/test/java/tech/pegasys/pantheon/tests/acceptance/dsl/node/ThreadPantheonNodeRunner.java b/...c/test/java/tech/pegasys/pantheon/tests/acceptance/dsl/node/ThreadPantheonNodeRunner.java
@@ -20,6 +20,7 @@
 import tech.pegasys.pantheon.cli.PantheonControllerBuilder;
 import tech.pegasys.pantheon.controller.KeyPairUtil;
 import tech.pegasys.pantheon.controller.PantheonController;
+import tech.pegasys.pantheon.ethereum.core.PendingTransactions;
 import tech.pegasys.pantheon.ethereum.eth.sync.SynchronizerConfiguration;
 import tech.pegasys.pantheon.metrics.MetricsSystem;
 import tech.pegasys.pantheon.metrics.noop.NoOpMetricsSystem;
@@ -69,6 +70,7 @@ public void startNode(final PantheonNode node) {
               .devMode(node.isDevMode())
               .nodePrivateKeyFile(KeyPairUtil.getDefaultKeyFile(node.homeDirectory()))
               .metricsSystem(noOpMetricsSystem)
+              .maxPendingTransactions(PendingTransactions.MAX_PENDING_TRANSACTIONS)
               .build();
     } catch (final IOException e) {
       throw new RuntimeException("Error building PantheonController", e);

diff --git a/...tech/pegasys/pantheon/tests/acceptance/dsl/node/factory/PantheonFactoryConfiguration.java b/...tech/pegasys/pantheon/tests/acceptance/dsl/node/factory/PantheonFactoryConfiguration.java
@@ -31,6 +31,7 @@ class PantheonFactoryConfiguration {
   private final WebSocketConfiguration webSocketConfiguration;
   private final MetricsConfiguration metricsConfiguration;
   private final Optional<PermissioningConfiguration> permissioningConfiguration;
+  private final Optional<String> keyFilePath;
   private final boolean devMode;
   private final GenesisConfigProvider genesisConfigProvider;
   private final boolean p2pEnabled;
@@ -45,6 +46,7 @@ class PantheonFactoryConfiguration {
       final WebSocketConfiguration webSocketConfiguration,
       final MetricsConfiguration metricsConfiguration,
       final Optional<PermissioningConfiguration> permissioningConfiguration,
+      final Optional<String> keyFilePath,
       final boolean devMode,
       final GenesisConfigProvider genesisConfigProvider,
       final boolean p2pEnabled,
@@ -57,6 +59,7 @@ class PantheonFactoryConfiguration {
     this.webSocketConfiguration = webSocketConfiguration;
     this.metricsConfiguration = metricsConfiguration;
     this.permissioningConfiguration = permissioningConfiguration;
+    this.keyFilePath = keyFilePath;
     this.devMode = devMode;
     this.genesisConfigProvider = genesisConfigProvider;
     this.p2pEnabled = p2pEnabled;
@@ -92,6 +95,10 @@ public Optional<PermissioningConfiguration> getPermissioningConfiguration() {
     return permissioningConfiguration;
   }
 
+  public Optional<String> getKeyFilePath() {
+    return keyFilePath;
+  }
+
   public boolean isDevMode() {
     return devMode;
   }

diff --git a/...gasys/pantheon/tests/acceptance/dsl/node/factory/PantheonFactoryConfigurationBuilder.java b/...gasys/pantheon/tests/acceptance/dsl/node/factory/PantheonFactoryConfigurationBuilder.java
@@ -39,6 +39,7 @@ public class PantheonFactoryConfigurationBuilder {
   private WebSocketConfiguration webSocketConfiguration = WebSocketConfiguration.createDefault();
   private MetricsConfiguration metricsConfiguration = MetricsConfiguration.createDefault();
   private Optional<PermissioningConfiguration> permissioningConfiguration = Optional.empty();
+  private Optional<String> keyFilePath = Optional.empty();
   private boolean devMode = true;
   private GenesisConfigProvider genesisConfigProvider = ignore -> Optional.empty();
   private Boolean p2pEnabled = true;
@@ -142,6 +143,11 @@ public PantheonFactoryConfigurationBuilder setPermissioningConfiguration(
     return this;
   }
 
+  public PantheonFactoryConfigurationBuilder setKeyFilePath(final String keyFilePath) {
+    this.keyFilePath = Optional.of(keyFilePath);
+    return this;
+  }
+
   public PantheonFactoryConfigurationBuilder setDevMode(final boolean devMode) {
     this.devMode = devMode;
     return this;
@@ -172,6 +178,7 @@ public PantheonFactoryConfiguration build() {
         webSocketConfiguration,
         metricsConfiguration,
         permissioningConfiguration,
+        keyFilePath,
         devMode,
         genesisConfigProvider,
         p2pEnabled,

diff --git a/...est/java/tech/pegasys/pantheon/tests/acceptance/dsl/node/factory/PantheonNodeFactory.java b/...est/java/tech/pegasys/pantheon/tests/acceptance/dsl/node/factory/PantheonNodeFactory.java
@@ -61,6 +61,7 @@ private PantheonNode create(final PantheonFactoryConfiguration config) throws IO
         config.getWebSocketConfiguration(),
         config.getMetricsConfiguration(),
         config.getPermissioningConfiguration(),
+        config.getKeyFilePath(),
         config.isDevMode(),
         config.getGenesisConfigProvider(),
         config.isP2pEnabled(),
@@ -79,12 +80,14 @@ public PantheonNode createMinerNode(final String name) throws IOException {
   }
 
   public PantheonNode createPrivateTransactionEnabledMinerNode(
-      final String name, final PrivacyParameters privacyParameters) throws IOException {
+      final String name, final PrivacyParameters privacyParameters, final String keyFilePath)
+      throws IOException {
     return create(
         new PantheonFactoryConfigurationBuilder()
             .setName(name)
             .miningEnabled()
             .jsonRpcEnabled()
+            .setKeyFilePath(keyFilePath)
             .enablePrivateTransactions(privacyParameters)
             .webSocketEnabled()
             .build());

diff --git a/...asys/pantheon/tests/acceptance/dsl/privacy/ExpectValidPrivateContractDeployedReceipt.java b/...asys/pantheon/tests/acceptance/dsl/privacy/ExpectValidPrivateContractDeployedReceipt.java
@@ -19,8 +19,7 @@
 import tech.pegasys.pantheon.tests.acceptance.dsl.transaction.ResponseTypes;
 import tech.pegasys.pantheon.tests.acceptance.dsl.transaction.Transactions;
 
-public class ExpectValidPrivateContractDeployedReceipt
-    extends ExpectValidPrivateTransactionReceipt {
+public class ExpectValidPrivateContractDeployedReceipt extends GetValidPrivateTransactionReceipt {
 
   private final String contractAddress;
 

diff --git a/...egasys/pantheon/tests/acceptance/dsl/privacy/ExpectValidPrivateContractEventsEmitted.java b/...egasys/pantheon/tests/acceptance/dsl/privacy/ExpectValidPrivateContractEventsEmitted.java
@@ -23,7 +23,7 @@
 
 import org.web3j.utils.Numeric;
 
-public class ExpectValidPrivateContractEventsEmitted extends ExpectValidPrivateTransactionReceipt {
+public class ExpectValidPrivateContractEventsEmitted extends GetValidPrivateTransactionReceipt {
   private final String eventValue;
 
   public ExpectValidPrivateContractEventsEmitted(
@@ -33,12 +33,12 @@ public ExpectValidPrivateContractEventsEmitted(
   }
 
   public void verify(
-      final PantheonNode node, final String transactionHash, final String PUBLIC_KEY) {
+      final PantheonNode node, final String transactionHash, final String publicKey) {
     ResponseTypes.PrivateTransactionReceipt privateTxReceipt =
-        getPrivateTransactionReceipt(node, transactionHash, PUBLIC_KEY);
+        getPrivateTransactionReceipt(node, transactionHash, publicKey);
 
     String event = privateTxReceipt.getLogs().get(0).getData().substring(66, 130);
     assertEquals(
-        Numeric.decodeQuantity(Numeric.prependHexPrefix(event)), new BigInteger(eventValue));
+        new BigInteger(eventValue), Numeric.decodeQuantity(Numeric.prependHexPrefix(event)));
   }
 }
diff --git a/...gasys/pantheon/tests/acceptance/dsl/privacy/ExpectValidPrivateContractValuesReturned.java b/...gasys/pantheon/tests/acceptance/dsl/privacy/ExpectValidPrivateContractValuesReturned.java
@@ -24,7 +24,7 @@
 
 import org.web3j.utils.Numeric;
 
-public class ExpectValidPrivateContractValuesReturned extends ExpectValidPrivateTransactionReceipt {
+public class ExpectValidPrivateContractValuesReturned extends GetValidPrivateTransactionReceipt {
   private final String returnValue;
 
   public ExpectValidPrivateContractValuesReturned(
@@ -34,11 +34,11 @@ public ExpectValidPrivateContractValuesReturned(
   }
 
   public void verify(
-      final PantheonNode node, final String transactionHash, final String PUBLIC_KEY) {
+      final PantheonNode node, final String transactionHash, final String publicKey) {
     ResponseTypes.PrivateTransactionReceipt privateTxReceipt =
-        getPrivateTransactionReceipt(node, transactionHash, PUBLIC_KEY);
+        getPrivateTransactionReceipt(node, transactionHash, publicKey);
 
     BytesValue output = BytesValue.fromHexString(privateTxReceipt.getOutput());
-    assertEquals(Numeric.decodeQuantity(output.toString()), new BigInteger(returnValue));
+    assertEquals(new BigInteger(returnValue), Numeric.decodeQuantity(output.toString()));
   }
 }
diff --git a/...h/pegasys/pantheon/tests/acceptance/dsl/privacy/ExpectValidPrivateTransactionReceipt.java b/...h/pegasys/pantheon/tests/acceptance/dsl/privacy/ExpectValidPrivateTransactionReceipt.java
@@ -12,29 +12,25 @@
  */
 package tech.pegasys.pantheon.tests.acceptance.dsl.privacy;
 
-import static tech.pegasys.pantheon.tests.acceptance.dsl.WaitUtils.waitFor;
+import static org.assertj.core.api.Assertions.assertThat;
+import static org.junit.Assert.assertNotNull;
 
 import tech.pegasys.pantheon.tests.acceptance.dsl.jsonrpc.Eea;
 import tech.pegasys.pantheon.tests.acceptance.dsl.node.PantheonNode;
 import tech.pegasys.pantheon.tests.acceptance.dsl.transaction.ResponseTypes;
 import tech.pegasys.pantheon.tests.acceptance.dsl.transaction.Transactions;
 
-public abstract class ExpectValidPrivateTransactionReceipt {
+public class ExpectValidPrivateTransactionReceipt extends GetValidPrivateTransactionReceipt {
 
-  private Eea eea;
-  private Transactions transactions;
-
-  ExpectValidPrivateTransactionReceipt(final Eea eea, final Transactions transactions) {
-    this.eea = eea;
-    this.transactions = transactions;
+  public ExpectValidPrivateTransactionReceipt(final Eea eea, final Transactions transactions) {
+    super(eea, transactions);
   }
 
-  ResponseTypes.PrivateTransactionReceipt getPrivateTransactionReceipt(
+  public void verify(
       final PantheonNode node, final String transactionHash, final String publicKey) {
-
-    waitFor(() -> node.verify(eea.expectSuccessfulTransactionReceipt(transactionHash, publicKey)));
     ResponseTypes.PrivateTransactionReceipt privateTxReceipt =
-        node.execute(transactions.getPrivateTransactionReceipt(transactionHash, publicKey));
-    return privateTxReceipt;
+        getPrivateTransactionReceipt(node, transactionHash, publicKey);
+    assertNotNull(privateTxReceipt);
+    assertThat(privateTxReceipt.getFrom()).isNotBlank();
   }
 }
diff --git a/...tech/pegasys/pantheon/tests/acceptance/dsl/privacy/GetValidPrivateTransactionReceipt.java b/...tech/pegasys/pantheon/tests/acceptance/dsl/privacy/GetValidPrivateTransactionReceipt.java
@@ -0,0 +1,40 @@
+/*
+ * Copyright 2019 ConsenSys AG.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on
+ * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations under the License.
+ */
+package tech.pegasys.pantheon.tests.acceptance.dsl.privacy;
+
+import static tech.pegasys.pantheon.tests.acceptance.dsl.WaitUtils.waitFor;
+
+import tech.pegasys.pantheon.tests.acceptance.dsl.jsonrpc.Eea;
+import tech.pegasys.pantheon.tests.acceptance.dsl.node.PantheonNode;
+import tech.pegasys.pantheon.tests.acceptance.dsl.transaction.ResponseTypes;
+import tech.pegasys.pantheon.tests.acceptance.dsl.transaction.Transactions;
+
+public abstract class GetValidPrivateTransactionReceipt {
+
+  private Eea eea;
+  private Transactions transactions;
+
+  GetValidPrivateTransactionReceipt(final Eea eea, final Transactions transactions) {
+    this.eea = eea;
+    this.transactions = transactions;
+  }
+
+  ResponseTypes.PrivateTransactionReceipt getPrivateTransactionReceipt(
+      final PantheonNode node, final String transactionHash, final String publicKey) {
+
+    waitFor(() -> node.verify(eea.expectSuccessfulTransactionReceipt(transactionHash, publicKey)));
+    ResponseTypes.PrivateTransactionReceipt privateTxReceipt =
+        node.execute(transactions.getPrivateTransactionReceipt(transactionHash, publicKey));
+    return privateTxReceipt;
+  }
+}
diff --git a/.../dsl/privacy/PrivateContractVerifier.java → ...l/privacy/PrivateTransactionVerifier.java b/.../dsl/privacy/PrivateContractVerifier.java → ...l/privacy/PrivateTransactionVerifier.java
@@ -15,28 +15,30 @@
 import tech.pegasys.pantheon.tests.acceptance.dsl.jsonrpc.Eea;
 import tech.pegasys.pantheon.tests.acceptance.dsl.transaction.Transactions;
 
-public class PrivateContractVerifier {
+public class PrivateTransactionVerifier {
 
   private final Transactions transactions;
   private final Eea eea;
 
-  public PrivateContractVerifier(final Eea eea, final Transactions transactions) {
+  public PrivateTransactionVerifier(final Eea eea, final Transactions transactions) {
     this.eea = eea;
     this.transactions = transactions;
   }
 
-  public ExpectValidPrivateContractDeployedReceipt validPrivateTransactionReceipt(
+  public ExpectValidPrivateTransactionReceipt validPrivateTransactionReceipt() {
+    return new ExpectValidPrivateTransactionReceipt(eea, transactions);
+  }
+
+  public ExpectValidPrivateContractDeployedReceipt validPrivateContractDeployed(
       final String contractAddress) {
     return new ExpectValidPrivateContractDeployedReceipt(contractAddress, eea, transactions);
   }
 
-  public ExpectValidPrivateContractEventsEmitted validPrivateTransactionReceiptReturnsEvents(
-      final String eventValue) {
+  public ExpectValidPrivateContractEventsEmitted validEventReturned(final String eventValue) {
     return new ExpectValidPrivateContractEventsEmitted(eventValue, eea, transactions);
   }
 
-  public ExpectValidPrivateContractValuesReturned validPrivateTransactionReceiptReturnsValues(
-      final String returnValue) {
+  public ExpectValidPrivateContractValuesReturned validOutputReturned(final String returnValue) {
     return new ExpectValidPrivateContractValuesReturned(returnValue, eea, transactions);
   }
 }