test_2_ring.sh

#!/usr/bin/env bash

go build
cd client
go build
cd ..

RED='\033[0;31m'
GREEN='\033[0;32m'
NC='\033[0m'
DEBUG="true"

outputFiles=()
message_c1_1=Weather_is_clear
message_c2_1=Winter_is_coming
message_c1_2=No_clouds_really
message_c2_2=Let\'s_go_skiing
message_c3=Is_anybody_here?


UIPort=12345
gossipPort=5000
name='A'

# General peerster (gossiper) command
#./Peerster -UIPort=12345 -gossipAddr=127.0.0.1:5001 -name=A -peers=127.0.0.1:5002 > A.out &

for i in `seq 1 10`;
do
	outFileName="$name.out"
	peerPort=$((($gossipPort+1)%10+5000))
	peer="127.0.0.1:$peerPort"
	gossipAddr="127.0.0.1:$gossipPort"
	./Peerster -UIPort=$UIPort -gossipAddr=$gossipAddr -name=$name -peers=$peer > $outFileName &
	outputFiles+=("$outFileName")
	if [[ "$DEBUG" == "true" ]] ; then
		echo "$name running at UIPort $UIPort and gossipPort $gossipPort"
	fi
	UIPort=$(($UIPort+1))
	gossipPort=$(($gossipPort+1))
	name=$(echo "$name" | tr "A-Y" "B-Z")
done

./client/client -UIPort=12349 -msg=$message_c1_1
./client/client -UIPort=12346 -msg=$message_c2_1
sleep 2
./client/client -UIPort=12349 -msg=$message_c1_2
sleep 1
./client/client -UIPort=12346 -msg=$message_c2_2
./client/client -UIPort=12351 -msg=$message_c3

sleep 64
pkill -f Peerster


#testing
failed="F"

echo -e "${RED}###CHECK that client messages arrived${NC}"

if !(grep -q "CLIENT MESSAGE $message_c1_1" "E.out") ; then
  echo "CLIENT MESSAGE $message_c1_1" "E.out"
	failed="T"
fi

if !(grep -q "CLIENT MESSAGE $message_c1_2" "E.out") ; then
  echo "CLIENT MESSAGE $message_c1_2" "E.out"
	failed="T"
fi

if !(grep -q "CLIENT MESSAGE $message_c2_1" "B.out") ; then
    echo "CLIENT MESSAGE $message_c2_1" "B.out"
    failed="T"
fi

if !(grep -q "CLIENT MESSAGE $message_c2_2" "B.out") ; then
    echo "CLIENT MESSAGE $message_c2_2" "B.out"
    failed="T"
fi

if !(grep -q "CLIENT MESSAGE $message_c3" "G.out") ; then
    echo "CLIENT MESSAGE $message_c3" "G.out"
    failed="T"
fi

if [[ "$failed" == "T" ]] ; then
	echo -e "${RED}***FAILED***${NC}"
else
	echo -e "${GREEN}***PASSED***${NC}"
fi

failed="F"
echo -e "${RED}###CHECK rumor messages ${NC}"

gossipPort=5000
for i in `seq 0 9`;
do
	relayPort=$(($gossipPort-1))
	if [[ "$relayPort" == 4999 ]] ; then
		relayPort=5009
	fi
	nextPort=$((($gossipPort+1)%10+5000))
	msgLine1="RUMOR origin E from 127.0.0.1:[0-9]{4} ID 1 contents $message_c1_1"
	msgLine2="RUMOR origin E from 127.0.0.1:[0-9]{4} ID 2 contents $message_c1_2"
	msgLine3="RUMOR origin B from 127.0.0.1:[0-9]{4} ID 1 contents $message_c2_1"
	msgLine4="RUMOR origin B from 127.0.0.1:[0-9]{4} ID 2 contents $message_c2_2"
	msgLine5="RUMOR origin G from 127.0.0.1:[0-9]{4} ID 1 contents $message_c3"

	if [[ "$gossipPort" != 5004 ]] ; then
		if !(grep -Eq "$msgLine1" "${outputFiles[$i]}") ; then
		      echo "$msgLine1" "${outputFiles[$i]}"
        	failed="T"
    	fi
		if !(grep -Eq "$msgLine2" "${outputFiles[$i]}") ; then
		      echo "$msgLine2" "${outputFiles[$i]}"
        	failed="T"
    	fi
	fi

	if [[ "$gossipPort" != 5001 ]] ; then
		if !(grep -Eq "$msgLine3" "${outputFiles[$i]}") ; then
		      echo "$msgLine3" "${outputFiles[$i]}"
        	failed="T"
    	fi
		if !(grep -Eq "$msgLine4" "${outputFiles[$i]}") ; then
		      echo "$msgLine4" "${outputFiles[$i]}"
        	failed="T"
    	fi
	fi
	
	if [[ "$gossipPort" != 5006 ]] ; then
		if !(grep -Eq "$msgLine5" "${outputFiles[$i]}") ; then
		      echo "$msgLine5" "${outputFiles[$i]}"
        	failed="T"
    	fi
	fi
	gossipPort=$(($gossipPort+1))
done

if [[ "$failed" == "T" ]] ; then
    echo -e "${RED}***FAILED***${NC}"
else
    echo -e "${GREEN}***PASSED***${NC}"
fi

failed="F"
echo -e "${RED}###CHECK mongering${NC}"
gossipPort=5000
for i in `seq 0 9`;
do
    relayPort=$(($gossipPort-1))
    if [[ "$relayPort" == 4999 ]] ; then
        relayPort=5009
    fi
    nextPort=$((($gossipPort+1)%10+5000))

    msgLine1="MONGERING with 127.0.0.1:$relayPort"
    msgLine2="MONGERING with 127.0.0.1:$nextPort"

    if !(grep -q "$msgLine1" "${outputFiles[$i]}") && !(grep -q "$msgLine2" "${outputFiles[$i]}") ; then
        echo "$msgLine1" "${outputFiles[$i]}"
        echo "$msgLine2" "${outputFiles[$i]}"
        failed="T"
    fi
    gossipPort=$(($gossipPort+1))
done

if [[ "$failed" == "T" ]] ; then
    echo -e "${RED}***FAILED***${NC}"
else
    echo -e "${GREEN}***PASSED***${NC}"
fi


failed="F"
echo -e "${RED}###CHECK status messages ${NC}"
gossipPort=5000
for i in `seq 0 9`;
do
    relayPort=$(($gossipPort-1))
    if [[ "$relayPort" == 4999 ]] ; then
        relayPort=5009
    fi
    nextPort=$((($gossipPort+1)%10+5000))

	msgLine1="STATUS from 127.0.0.1:$relayPort"
	msgLine2="STATUS from 127.0.0.1:$nextPort"
	msgLine3="peer E nextID 3"
	msgLine4="peer B nextID 3"
	msgLine5="peer G nextID 2"	

	if !(grep -q "$msgLine1" "${outputFiles[$i]}") ; then
	      echo "$msgLine1" "${outputFiles[$i]}"
        failed="T"
    fi
    if !(grep -q "$msgLine2" "${outputFiles[$i]}") ; then
        echo "$msgLine2" "${outputFiles[$i]}"
        failed="T"
    fi
    if !(grep -q "$msgLine3" "${outputFiles[$i]}") ; then
        echo "$msgLine3" "${outputFiles[$i]}"
        failed="T"
    fi
    if !(grep -q "$msgLine4" "${outputFiles[$i]}") ; then
        echo "$msgLine4" "${outputFiles[$i]}"
        failed="T"
    fi
    if !(grep -q "$msgLine5" "${outputFiles[$i]}") ; then
        echo "$msgLine5" "${outputFiles[$i]}"
        failed="T"
    fi
	gossipPort=$(($gossipPort+1))
done

if [[ "$failed" == "T" ]] ; then
    echo -e "${RED}***FAILED***${NC}"
else
    echo -e "${GREEN}***PASSED***${NC}"
fi

failed="F"
echo -e "${RED}###CHECK flipped coin${NC}"
gossipPort=5000
for i in `seq 0 9`;
do
    relayPort=$(($gossipPort-1))
    if [[ "$relayPort" == 4999 ]] ; then
        relayPort=5009
    fi
    nextPort=$((($gossipPort+1)%10+5000))

    msgLine1="FLIPPED COIN sending rumor to 127.0.0.1:$relayPort"
    msgLine2="FLIPPED COIN sending rumor to 127.0.0.1:$nextPort"

    if !(grep -q "$msgLine1" "${outputFiles[$i]}") ; then
        echo "$msgLine1" "${outputFiles[$i]}"
        failed="T"
    fi
    if !(grep -q "$msgLine2" "${outputFiles[$i]}") ; then
        echo "$msgLine2" "${outputFiles[$i]}"
        failed="T"
    fi
	gossipPort=$(($gossipPort+1))

done

if [[ "$failed" == "T" ]] ; then
    echo -e "${RED}***FAILED***${NC}"
else
    echo -e "${GREEN}***PASSED***${NC}"
fi

failed="F"
echo -e "${RED}###CHECK in sync${NC}"
gossipPort=5000
for i in `seq 0 9`;
do
    relayPort=$(($gossipPort-1))
    if [[ "$relayPort" == 4999 ]] ; then
        relayPort=5009
    fi
    nextPort=$((($gossipPort+1)%10+5000))

    msgLine1="IN SYNC WITH 127.0.0.1:$relayPort"
    msgLine2="IN SYNC WITH 127.0.0.1:$nextPort"

    if !(grep -q "$msgLine1" "${outputFiles[$i]}") ; then
        echo "$msgLine1" "${outputFiles[$i]}"
        failed="T"
    fi
    if !(grep -q "$msgLine2" "${outputFiles[$i]}") ; then
        echo "$msgLine2" "${outputFiles[$i]}"
        failed="T"
    fi
	gossipPort=$(($gossipPort+1))
done

if [[ "$failed" == "T" ]] ; then
    echo -e "${RED}***FAILED***${NC}"
else
    echo -e "${GREEN}***PASSED***${NC}"
fi

failed="F"
echo -e "${RED}###CHECK correct peers${NC}"
gossipPort=5000
for i in `seq 0 9`;
do
    relayPort=$(($gossipPort-1))
    if [[ "$relayPort" == 4999 ]] ; then
        relayPort=5009
    fi
    nextPort=$((($gossipPort+1)%10+5000))

	peersLine1="127.0.0.1:$relayPort,127.0.0.1:$nextPort"
	peersLine2="127.0.0.1:$nextPort,127.0.0.1:$relayPort"

    if !(grep -q "$peersLine1" "${outputFiles[$i]}") && !(grep -q "$peersLine2" "${outputFiles[$i]}") ; then
        echo "$peersLine1" "${outputFiles[$i]}"
        echo "$peersLine2" "${outputFiles[$i]}"
        failed="T"
    fi
	gossipPort=$(($gossipPort+1))
done

if [[ "$failed" == "T" ]] ; then
    echo -e "${RED}***FAILED***${NC}"
else
    echo -e "${GREEN}***PASSED***${NC}"
fi