Add preview, submit tx and tx stream APIs in Rust

.github/workflows/ci.yml

@@ -55,7 +55,7 @@ jobs:
           SONAR_TOKEN: ${{ secrets.SONAR_TOKEN }}
         run: ./gradlew sonarqube
   local-dev-sm-docker-build:
-    name: Test state-manager docker build for local development
+    name: Test core-rust docker build for local development
     runs-on: ubuntu-latest
     steps:
       - uses: actions/checkout@v2
@@ -76,8 +76,8 @@ jobs:
           path: ~/.gradle/caches
           key: ${{ runner.os }}-gradle-${{ hashFiles('**/*.gradle') }}
           restore-keys: ${{ runner.os }}-gradle
-      - name: Run local state-manager docker build
-        run: ./gradlew :state-manager:buildRustForDocker
+      - name: Run local core-rust docker build
+        run: ./gradlew :core-rust:buildRustForDocker
   steadystate-integration:
     name: Steady state integration tests
     runs-on: babylon-runner

build.gradle

@@ -182,12 +182,12 @@ allprojects {
     tasks.withType(Test) {
         systemProperty "file.encoding", "UTF-8"
         jvmArgs("--enable-preview")
-        systemProperty "java.library.path", "${project(':state-manager').projectDir}/target/debug"
+        systemProperty "java.library.path", "${project(':core-rust').projectDir}/target/debug"
     }
 }
 
 subprojects {
-    if (project.name == "state-manager") {
+    if (project.name == "core-rust") {
         // The below is suitable for a java project, not for a rust project
         return
     }

cli-tools/build.gradle

@@ -144,7 +144,7 @@ task getClassPathForRadixShell {
 
 task getNativeLibPathForRadixShell {
     doLast {
-        print "${project(':state-manager').projectDir}/target/debug/"
+        print "${project(':core-rust').projectDir}/target/debug/"
     }
 }
 
@@ -249,7 +249,7 @@ task runAllIntegrationTests(type: Test) {
 
 task runP2pTests(type: JavaExec) {
     classpath = sourceSets.p2pTest.runtimeClasspath
-    systemProperty "java.library.path", "${project(':state-manager').projectDir}/target/debug/"
+    systemProperty "java.library.path", "${project(':core-rust').projectDir}/target/debug/"
     main = "com.radixdlt.p2ptest.LargeMessageTest"
 
 }

state-manager-bridge/build.gradle → core-rust-bridge/build.gradle

@@ -79,11 +79,11 @@ compileJava {
     // This prevents it being output by the jobs EG generateDevUniverse run in quiet mode. Hence, lifecycle.
     // Side note: The method of using stdout for generateDevUniverse and friends should really be changed.
     if (System.getenv("SKIP_NATIVE_RUST_BUILD") == "TRUE") {
-        logger.lifecycle("As SKIP_NATIVE_RUST_BUILD=TRUE, the native state-manager rust build is being skipped at this point.")
+        logger.lifecycle("As SKIP_NATIVE_RUST_BUILD=TRUE, the native core-rust build is being skipped at this point.")
     } else {
         logger.lifecycle("A native debug rust build required for the node to run natively will be run.")
         logger.lifecycle("This can be skipped with SKIP_NATIVE_RUST_BUILD=TRUE, if the rust is being built separately.")
-        dependsOn(":state-manager:buildRustDebug")
+        dependsOn(":core-rust:buildRustDebug")
     }
 }
 

state-manager-bridge/src/main/java/com/radixdlt/rev2/NetworkDefinition.java → core-rust-bridge/src/main/java/com/radixdlt/rev2/NetworkDefinition.java

@@ -88,4 +88,5 @@ public static NetworkDefinition from(Network network) {
 
   public static NetworkDefinition LOCAL_SIMULATOR = NetworkDefinition.from(Network.LOCALSIMULATOR);
   public static NetworkDefinition INT_TEST_NET = NetworkDefinition.from(Network.INTEGRATIONTESTNET);
+  public static NetworkDefinition LOCALNET = NetworkDefinition.from(Network.LOCALNET);
 }

state-manager-bridge/src/main/java/com/radixdlt/sbor/StateManagerSbor.java → core-rust-bridge/src/main/java/com/radixdlt/sbor/StateManagerSbor.java

@@ -77,11 +77,6 @@
 import com.radixdlt.sbor.codec.CodecMap;
 import com.radixdlt.sbor.codec.StructCodec;
 import com.radixdlt.statecomputer.commit.CommitRequest;
-import com.radixdlt.statecomputer.preview.FeeSummary;
-import com.radixdlt.statecomputer.preview.PreviewError;
-import com.radixdlt.statecomputer.preview.PreviewFlags;
-import com.radixdlt.statecomputer.preview.PreviewRequest;
-import com.radixdlt.statecomputer.preview.PreviewResult;
 import com.radixdlt.statemanager.CoreApiServerConfig;
 import com.radixdlt.statemanager.REv2DatabaseConfig;
 import com.radixdlt.statemanager.StateManagerConfig;
@@ -124,17 +119,12 @@ public static void registerCodecsWithCodecMap(CodecMap codecMap) {
     NetworkDefinition.registerCodec(codecMap);
     StateManagerConfig.registerCodec(codecMap);
     RawTransaction.registerCodec(codecMap);
-    PreviewFlags.registerCodec(codecMap);
-    PreviewRequest.registerCodec(codecMap);
-    PreviewResult.registerCodec(codecMap);
-    PreviewError.registerCodec(codecMap);
     TransactionStatus.registerCodec(codecMap);
     Decimal.registerCodec(codecMap);
     LogLevel.registerCodec(codecMap);
     ComponentAddress.registerCodec(codecMap);
     PackageAddress.registerCodec(codecMap);
     ResourceAddress.registerCodec(codecMap);
-    FeeSummary.registerCodec(codecMap);
     TID.registerCodec(codecMap);
     StateManagerRuntimeError.registerCodec(codecMap);
     MempoolError.registerCodec(codecMap);

state-manager-bridge/src/main/java/com/radixdlt/statecomputer/RustStateComputer.java → core-rust-bridge/src/main/java/com/radixdlt/statecomputer/RustStateComputer.java

@@ -72,9 +72,6 @@
 import com.radixdlt.rev2.Decimal;
 import com.radixdlt.sbor.NativeCalls;
 import com.radixdlt.statecomputer.commit.CommitRequest;
-import com.radixdlt.statecomputer.preview.PreviewError;
-import com.radixdlt.statecomputer.preview.PreviewRequest;
-import com.radixdlt.statecomputer.preview.PreviewResult;
 import com.radixdlt.statemanager.StateManager;
 import com.radixdlt.transaction.REv2TransactionAndProofStore;
 import com.radixdlt.transactions.RawTransaction;
@@ -93,9 +90,6 @@ public RustStateComputer(StateManager stateManager) {
     verifyFunc =
         NativeCalls.Func1.with(
             stateManager, new TypeToken<>() {}, new TypeToken<>() {}, RustStateComputer::verify);
-    previewFunc =
-        NativeCalls.Func1.with(
-            stateManager, new TypeToken<>() {}, new TypeToken<>() {}, RustStateComputer::preview);
     commitFunc =
         NativeCalls.Func1.with(
             stateManager, new TypeToken<>() {}, new TypeToken<>() {}, RustStateComputer::commit);
@@ -136,19 +130,10 @@ public Result<Unit, String> verify(RawTransaction transaction) {
     return verifyFunc.call(transaction);
   }
 
-  public Result<PreviewResult, PreviewError> preview(PreviewRequest previewRequest) {
-    return previewFunc.call(previewRequest);
-  }
-
   private final NativeCalls.Func1<StateManager, RawTransaction, Result<Unit, String>> verifyFunc;
 
   private static native byte[] verify(StateManager stateManager, byte[] payload);
 
-  private final NativeCalls.Func1<StateManager, PreviewRequest, Result<PreviewResult, PreviewError>>
-      previewFunc;
-
-  private static native byte[] preview(StateManager stateManager, byte[] payload);
-
   private final NativeCalls.Func1<StateManager, CommitRequest, Unit> commitFunc;
 
   private static native byte[] commit(StateManager stateManager, byte[] payload);

state-manager/build.gradle → core-rust/build.gradle

@@ -113,7 +113,7 @@ task buildRustForDocker(type: Exec) {
     ignoreExitValue true
     if (project.hasProperty('ci')){
         workingDir rootProject.projectDir
-        def outputDir="state-manager/target/$target"
+        def outputDir="core-rust/target/$target"
         def rustBuilderRepo = "eu.gcr.io/dev-container-repo/rust-builder-base"
         def rustCacheRepo = "eu.gcr.io/dev-container-repo/rust-cache-packages"
         def cacheTag = project.properties['cacheBranch'] ?: "latest"
@@ -135,7 +135,7 @@ task buildRustForDocker(type: Exec) {
              docker build -f docker/rust-builder/Dockerfile \\
                --target=artifact --build-arg TARGET=$target --build-arg BUILDKIT_INLINE_CACHE=1 \\
                --cache-from=$rustBuilderRepo:$cacheTag --cache-from=$rustCacheRepo:$cacheTag  \\
-               --output type=local,dest=state-manager/target/$target/${project.property("rustBinaryBuildType")}/ .
+               --output type=local,dest=core-rust/target/$target/${project.property("rustBinaryBuildType")}/ .
              docker push $rustBuilderRepo:$cacheTag || true
              docker push $rustCacheRepo:$cacheTag || true
              [ -f $outputDir/${project.property("rustBinaryBuildType")}/libcorerust.so ]

state-manager/core-api-server/Cargo.toml → core-rust/core-api-server/Cargo.toml

@@ -42,3 +42,4 @@ serde_ignored = "0.1.1"
 url = "2.1"
 lazy_static = "1.4"
 regex = "1.3"
+hex = { version = "0.4.3", default-features = false }