scaproust 0.3.2

Nanomsg scalability protocols implementation in rust. Various messaging patterns over pluggable transports
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50

#!/bin/bash

COMPAT_PATH="$( cd "$(dirname "$0")" ; pwd -P )"
source "$COMPAT_PATH/test_helper.bash"

# TEST CASE 1
# Checks that scaproust can receive a message sent by nanocat
# Arguments : URL
function testcase_pipeline1 {
    URL=$1
    msg="asterohache"
    $EXAMPLE_PATH/pipeline node0 $URL > /tmp/pipeline_tc_1.log & node0=$!
    nanocat --push --connect $URL --data "$msg" > /dev/null & ncat=$!
    sleep 0.3 && kill $ncat $node0
    result=`cat /tmp/pipeline_tc_1.log`
    expected=`cat $COMPAT_PATH/pipeline_tc_1_expected.log`
    if [[ $result == $expected ]]; then
        echo_test_case_succeeded "pipeline test case 1 ${URL:0:3}"
    else
        echo_test_case_failed "pipeline test case 1 ${URL:0:3}"
    fi
}

# TEST CASE 2
# Checks that a message sent by scaproust is received by nanocat
# Arguments : URL
function testcase_pipeline2 {
    URL=$1
    msg="cornofulgur"
    nanocat --pull --bind $URL --ascii > /tmp/pipeline_tc_2.log & ncat=$!
    ./target/debug/examples/pipeline node1 $URL "$msg" > /dev/null & node1=$!
    sleep 0.3 && kill $ncat $node1
    result=`cat /tmp/pipeline_tc_2.log`
    expected=`cat $COMPAT_PATH/pipeline_tc_2_expected.log`
    if [[ $result == $expected ]]; then
        echo_test_case_succeeded "pipeline test case 2 ${URL:0:3}"
    else
        echo_test_case_failed "pipeline test case 2 ${URL:0:3}"
    fi
}

function test_pipeline {
    testcase_pipeline1 $1
    testcase_pipeline2 $1
}

rm -f /tmp/pipeline* > /dev/null

test_pipeline "tcp://127.0.0.1:5454"
test_pipeline "ipc:///tmp/pipeline_test.ipc"