tests: add exec runner

Author: tharvik

tests/execs.rs

@@ -0,0 +1,60 @@
+use std::{env, fs, path::PathBuf};
+
+use duct::cmd;
+use nix::sys::stat::{stat, Mode};
+
+const DIR: &str = concat!(env!("CARGO_MANIFEST_DIR"), "/tests");
+
+const CLIENT_BIN: &str = env!("CARGO_BIN_EXE_client");
+const SERVER_BIN: &str = env!("CARGO_BIN_EXE_server");
+
+#[test]
+fn run_execs() {
+    let all_tests_succeed = fs::read_dir(DIR)
+        .expect("read test directory")
+        .filter_map(|readdir| {
+            let entry = readdir.expect("read entry");
+            if Mode::from_bits_truncate(stat(&entry.path()).expect("stat file").st_mode)
+                .intersects(Mode::S_IXUSR | Mode::S_IXGRP | Mode::S_IXOTH)
+            {
+                Some(entry.path())
+            } else {
+                None
+            }
+        })
+        .map(|exec| {
+            print!("test {:?} ... ", exec);
+
+            let path = env::join_paths(
+                env::split_paths(&env::var_os("PATH").unwrap())
+                    .chain([PathBuf::from(DIR)].iter().cloned())
+                    .chain(
+                        [PathBuf::from(CLIENT_BIN), PathBuf::from(SERVER_BIN)]
+                            .iter()
+                            .cloned()
+                            .map(|mut dir| {
+                                dir.pop();
+                                dir
+                            }),
+                    ),
+            )
+            .expect("valid PATH's element");
+
+            cmd!(exec).dir(DIR).env("PATH", path).run()
+        })
+        .map(|ret| match ret {
+            Ok(_) => {
+                println!("ok");
+                true
+            }
+            Err(err) => {
+                println!("{}", err);
+                false
+            }
+        })
+        .all(|is_success| is_success);
+
+    if !all_tests_succeed {
+        panic!("some test failed")
+    }
+}

tests/lib.sh

@@ -0,0 +1,95 @@
+set -eumo pipefail
+
+readonly node_count=3
+readonly host_name=127.0.0.1
+readonly tick=0.1
+
+tmpdir=$(mktemp -d)
+cd "$tmpdir"
+
+trap cleanup EXIT QUIT
+cleanup() {
+	local err=$?
+	local pid
+
+	for pid in $nodes
+	do
+		kill -9 $pid
+	done
+
+	for pid in $nodes
+	do
+		set +e
+		wait $pid 2>/dev/null
+		local ret=$?
+		set -e
+
+		if [ $ret -ne 137 ]
+		then
+			err=$ret
+		fi
+	done
+
+	rm -rf "$tmpdir"
+
+	exit $err
+}
+
+fail() {
+	echo $@
+	exit 1
+}
+
+readonly port_base=$((RANDOM + 1024))
+readonly port_top=$((port_base + 2*node_count - 1))
+nodes=''
+start_network() {
+	[ -n "$nodes" ] && fail 'nodes already started'
+
+	local port configs=()
+
+	for port in $(seq $port_base 2 $port_top)
+	do
+		configs[$((${#configs[@]}+1))]=$(server config new $host_name:{$port,$((port+1))})
+	done
+
+	local i
+	for i in $(seq $node_count)
+	do
+		local j node_config=${configs[i]}
+		for j in $(seq $node_count)
+		do
+			[ $i -eq $j ] && continue
+			node_config+=$'\n'$(echo "${configs[j]}" | server config get-node)
+		done
+
+		echo "$node_config"
+		echo "$node_config" | server run &
+		nodes+=" $!"
+	done
+
+	for port in $(seq $port_base $port_top)
+	do
+		while ! nc -q 0 localhost $port < /dev/null
+		do
+			sleep 0.1
+		done
+	done
+}
+
+get_node_rpc() {
+	[ -z "$nodes" ] && fail 'asking for client to stopped nodes'
+
+	echo http://$host_name:$((port_base+1))
+}
+
+wait_for_sequence() {
+	local config=$1
+	local seq=$2
+
+	until echo "$config" | client get-last-sequence | xargs test "$seq" -eq
+	do
+		echo "$config" | client get-last-sequence
+		sleep $tick
+	done
+}

tests/sent-tx-shows-in-latest-txs

@@ -0,0 +1,20 @@
+#!/usr/bin/env bash
+
+source ./lib.sh
+
+start_network
+
+sender=$(client config new $(get_node_rpc))
+recipient_pubkley=$(client config new $(get_node_rpc) |
+	client config get-public-key)
+
+echo "$sender" |
+	client send-asset 1 "$recipient_pubkley" 10
+wait_for_sequence "$sender" 1
+
+txs=$(client config new $(get_node_rpc) | client get-latest-transactions)
+
+[ "$(echo "$txs" | wc -l)" -eq 1 ] 
+echo "$txs" | grep -q "$(echo "$sender" | client config get-public-key)"
+echo "$txs" | grep -q "$recipient_pubkley"
+echo "$txs" | grep -q 10