add submit_and_wait

Author: vans163

README.md

@@ -11,6 +11,19 @@ podman build --tag erlang_builder -f build.Dockerfile
 ./build.sh
 ```
 
+### Testnet
+```
+#run local testnet with RPC api
+
+TESTNET=true WORKFOLDER=/tmp/testnet HTTP_IPV4=127.0.0.1 HTTP_PORT=8080  ./amadeusd
+
+# inside REPL submit a transfer to self
+
+pk = Application.fetch_env!(:ama, :trainer_pk)
+sk = Application.fetch_env!(:ama, :trainer_sk)
+Testnet.call(sk, "Coin", "transfer", [pk,"1","AMA"])
+```
+
 ### AutoUpdates + Running as a systemd service
 
 ```

ex/lib/api/api_tx.ex

@@ -132,6 +132,44 @@ defmodule API.TX do
         end
     end
 
+    def submit_and_wait(tx_packed, broadcast \\ true) do
+      result = TX.validate(tx_packed)
+      if result[:error] == :ok do
+          txu = TX.unpack(tx_packed)
+          if tx_packed =~ "deploy" do
+              action = hd(txu.tx.actions)
+              if action.contract == "Contract" and action.function == "deploy" do
+                  case BIC.Contract.validate(List.first(action.args)) do
+                      %{error: :ok} ->
+                          if broadcast do TXPool.insert_and_broadcast(tx_packed) else TXPool.insert(tx_packed) end
+                          txres = submit_and_wait_1(result.txu.hash)
+                          %{error: :ok, hash: Base58.encode(result.txu.hash), entry_hash: txres.metadata.entry_hash, result: txres[:result]}
+                      error -> error
+                  end
+              else
+                  if broadcast do TXPool.insert_and_broadcast(tx_packed) else TXPool.insert(tx_packed) end
+                  txres = submit_and_wait_1(result.txu.hash)
+                  %{error: :ok, hash: Base58.encode(result.txu.hash), entry_hash: txres.metadata.entry_hash, result: txres[:result]}
+              end
+          else
+              if broadcast do TXPool.insert_and_broadcast(tx_packed) else TXPool.insert(tx_packed) end
+              txres = submit_and_wait_1(result.txu.hash)
+              %{error: :ok, hash: Base58.encode(result.txu.hash), entry_hash: txres.metadata.entry_hash, result: txres[:result]}
+          end
+      else
+          %{error: result.error}
+      end
+    end
+
+    def submit_and_wait_1(hash, 30) do nil end
+    def submit_and_wait_1(hash, tries \\ 0) do
+      tx = get(hash)
+      if tx do tx else
+        Process.sleep(100)
+        submit_and_wait_1(hash, tries + 1)
+      end
+    end
+
     def format_tx_for_client(nil) do nil end
     def format_tx_for_client(tx) do
         tx = Map.drop(tx, [:tx_encoded])

ex/lib/misc/testnet.ex

@@ -0,0 +1,11 @@
+defmodule Testnet do
+  def call(sk, contract, function, args, attach_symbol \\ nil, attach_amount \\ nil) do
+    packed_tx = TX.build(sk, contract, function, args, nil, attach_symbol, attach_amount)
+    API.TX.submit_and_wait(packed_tx, false)
+  end
+
+  def read(key) do
+    %{db: db, cf: cf} = :persistent_term.get({:rocksdb, Fabric})
+    RocksDB.get(key, %{db: db, cf: cf.contractstate})
+  end
+end