Changeset 871 for trunk/Monitoring/libIGCM_mock/libIGCM_mock.sh

Timestamp:

06/11/13 09:33:58 (11 years ago)

Author:

jripsl

Message:

Improve "config-card" file handling.
Use explicite function for "repo_io" module initialization

File:

• trunk/Monitoring/libIGCM_mock/libIGCM_mock.sh (modified) (7 diffs)

trunk/Monitoring/libIGCM_mock/libIGCM_mock.sh

@@ -18 +18 @@
 # init
 
-stack_file=$1
 send_msg_cmd="/home/jripsl/snapshot/Monitoring/CNClient/sendAMQPMsg"
-scenario_dir=scenario
+g__stackfile=
+g__scenario_dir=scenario
 g__mode="scenario"
-g__stackfile=
-g__scenario_file=
+g__scenariofile=
+g__dryrun=0
+g__confirm=0
+g__delay=1 # delay between message
 
 # func
@@ -47 +49 @@
 
 OPTIONS:
+   -h              this help
    -f              set stack file
    -l              print scenarios list 
-   -m              set mode (if missing, "scenario" mode is used)
-   -s              set scenario
+   -m              set MODE
+                   MODE may be "scenario", "stackfile" or "purge"
+                   default mode is "scenario"
+   -s              set scenario file
 
 EXAMPLES:
@@ -74 +79 @@
         echo "Scenarios list:"
         echo ""
-        ls -1 $scenario_dir
+        ls -1 $g__scenario_dir
         echo ""
         exit 2
@@ -87 +92 @@
 # parse args
 
-while getopts 'f:hlm:s:' OPTION
+while getopts 'cdf:hlm:s:' OPTION
 do
   case $OPTION in
+  c)    g__confirm="1"
+        ;;
+  d)    g__dryrun="1"
+        ;;
   f)    g__stackfile="$OPTARG"
         ;;
@@ -98 +107 @@
   m)    g__mode="$OPTARG"
         ;;
-  s)    l__scenario_file="$OPTARG"
-
-                if [[ "$l__scenario_file" =~ "*/*" ]]; then
+  s)    l__scenariofile="$OPTARG"
+
+                if [[ "$l__scenariofile" =~ "*/*" ]]; then
                         # full/relative path was given with the filename
 
-                        g__scenario_file="$l__scenario_file"
+                        g__scenariofile="$l__scenariofile"
                 else
                         # only the filename was given
 
-                        g__scenario_file="$scenario_dir/$l__scenario_file"
+                        g__scenariofile="$g__scenario_dir/$l__scenariofile"
                 fi
 
@@ -120 +129 @@
 
         # check
-        if [ ! -f "$g__scenario_file" ]; then
+        if [ ! -f "$g__scenariofile" ]; then
                 msg "LIBIGCM-MOCK-ERR003" "scenario file not found"
                 exit 1
         fi
 
-        N=0
-        while read LINE ; do
-
-                N=$((N+1))
+        while read LINE <&3; do
+
+                # debug
+                #echo $LINE
 
                 l__JSON_msg_buf=
-
-                # process fields (split on " " delimiter)
-                for field in "$LINE"; do
-                        arr=(${LINE//=/ }) # process key/value (split on "=" delimiter)
-                        key=${arr[0]}
-                        val=${arr[1]}
-
-                        # base64 encoding
+                N=1
+                fields_arr=(${LINE// / }) # process fields (split on " " delimiter)
+                for FIELD in "${fields_arr[@]}"; do
+
+                        # debug 
+                        #echo $FIELD
+
+
+                        field_arr=(${FIELD//=/ }) # process key/value (split on "=" delimiter)
+                        key=${field_arr[0]}
+
+
+                        # HACK
+                        if [ "$key" = "file" ]; then
+                                # special processing for "file" key (base64 encoding)
+
+                                l__configcard_file="/home/jripsl/snapshot/Monitoring/sample/${field_arr[1]}"
+
+                                # check
+                                if [ ! -f "$l__configcard_file" ]; then
+                                        msg "LIBIGCM-MOCK-ERR004" "config-card file not found ($l__configcard_file)"
+                                        exit 1
+                                fi
+
+                                val=$( cat $l__configcard_file | base64 -w 0 )
+
+                        else
+                                val=${field_arr[1]}
+                        fi
+
 
                         # append to JSON message buffer
-                        l__JSON_msg_buf=$l__JSON_msg_buf
-
+                        if [ "$N" -gt "1" ]; then
+
+                                l__JSON_msg_buf="$l__JSON_msg_buf,\"$key\":\"$val\""
+                        else
+                                # first field
+
+                                l__JSON_msg_buf="\"$key\":\"$val\""
+                        fi
+
+
+                        N=$((N+1))
                 done
 
+                # enclose
+                l__JSON_msg_buf="{""$l__JSON_msg_buf""}"
+
+                # debug
+                #echo $l__JSON_msg_buf
+
                 # message base64 encoding
-
-
-                #callname=$(echo $line | awk -F" " '{print $4}' )
+                l__JSON_msg_buf_encoded=$( echo $l__JSON_msg_buf | base64 -w 0 )
+
+                # debug
+                #echo $l__JSON_msg_buf_encoded
+                #echo $send_msg_cmd -h localhost -p 5672 -b "$l__JSON_msg_buf_encoded"
 
                 # send AMQP message
-                #$send_msg_cmd localhost 5672 string "$callname"
-                echo
-
-        done < $g__scenario_file
+                if [ "$g__dryrun" = "1" ]; then
+
+                        echo $send_msg_cmd -h localhost -p 5672 -b "$l__JSON_msg_buf"
+
+
+                        # debug
+                        #
+                        # uncomment line below (and comment line above) to output only the encoded message
+                        # 
+                        # it can then be unencoded for debug purpose (message encoding level, not config-card encoding) using command below
+                        # ./libIGCM_mock.sh -s start_simu__stop_simu -d | base64 -d | less
+                        # 
+                        # 
+                        #echo $l__JSON_msg_buf_encoded
+
+                else
+                        $send_msg_cmd -h localhost -p 5672 -b "$l__JSON_msg_buf_encoded"
+                fi
+
+
+
+
+                if [ "$g__confirm" = "1" ]; then
+                        read -p "Press enter for next message" bla
+                else
+                        sleep $g__delay
+                fi
+
+
+
+                # debug
+                #break
+
+        done 3<$g__scenariofile
+
+elif [ "$g__mode" = "purge" ]; then
+
+        :
 
 elif [ "$g__mode" = "stackfile" ]; then
 
         # check
-        if [ ! -f $stack_file ]; then
+        if [ ! -f $g__stackfile ]; then
                 msg "LIBIGCM-MOCK-ERR001" "file not found"
                 exit 1
@@ -165 +247 @@
 
         IFS=$'\n'
-        for line in $(cat $stack_file); do
+        for line in $(cat $g__stackfile); do
                 #echo $line | awk -F" " '{print $4}'
                 callname=$(echo $line | awk -F" " '{print $4}' )