#!/bin/bash

MAXINDEX="--max-index -1"
TRANSPORT="--transport zeromq"
VERBOSE="--verbose INFO"
FAIRTASKNAME="--task-name PndMvdPixelClusterTask"

while [[ $# > 1 ]]
do
key="$1"

case $key in
    -f|--task-name)
    FAIRTASKNAME="--task-name $2"
    shift
    ;;
    -m|--max-index)
    MAXINDEX="--max-index $2"
    shift
    ;;
    -t|--transport)
    TRANSPORT="--transport $2"
    shift
    ;;
    -v|--verbose)
    VERBOSE="--verbose $2"
    shift
    ;;
esac
shift 
done

########################### Define some variables
# JSON file containing the configuration parameters of all FairMQ devices of this example
MQCONFIGFILE="@MVDMQ_FILE_LOCATION@/mvd/MvdMQ/run/options/PixelClusterTask.json"
# ASCII and ROOT parameter files for the processor device
ROOTPARAM="@MVDMQ_FILE_LOCATION@/macro/run/simparams.root"
ASCIIPARAM="@MVDMQ_FILE_LOCATION@/macro/params/all.par"

if [ "$FAIRTASKNAME" == "--task-name PndMvdPixelClusterTask" ] ; then
    # input file and branch for the sampler device
    INPUTFILE="@MVDMQ_FILE_LOCATION@/macro/run/digi_complete.root"
#    INPUTBRANCH="data-out1=MVDPixelDigis data-out2=MVDStripDigis"
    INPUTBRANCH="data-out1=MVDStripDigis"
    
    # output file for sink
    OUTPUTFILE="@MVDMQ_FILE_LOCATION@/macro/run/pixelRecoMQ.root"
    OUTPUTCLASS="--class-name TClonesArray(PndSdsHit) --class-name TClonesArray(PndSdsClusterPixel)"
    OUTPUTBRANCH="--branch-name MVDHitsPixel --branch-name MVDPixelCluster"
#elif [ "$FAIRTASKNAME" == "--task-name PixelFindTracks" ] ; then
#    # input file and branch for the sampler device
#    INPUTFILE="@EXAMPLE9_FILE_LOCATION@/examples/MQ/9-PixelDetector/macros/MQ.pixel_TGeant3.hit.root"
#    INPUTBRANCH="PixelHits"
    
#    # output file for sink
#    OUTPUTFILE="@EXAMPLE9_FILE_LOCATION@/examples/MQ/9-PixelDetector/macros/MQ.pixel_TGeant3.track.root"
#    OUTPUTCLASS="--class-name TClonesArray(PixelTrack)"
#    OUTPUTBRANCH="--branch-name PixelTracks"
else
    echo "TASK $FAIRTASKNAME UNKNOWN!!!"
    exit
fi
###########################



########################### Start the chain of the devices


########################## start Parameter server
SERVER="parmq-server $TRANSPORT"
SERVER+=" --id parmq-server  --mq-config $MQCONFIGFILE"
SERVER+=" --first-input-name $ROOTPARAM --second-input-name $ASCIIPARAM --second-input-type ASCII"
xterm -geometry 80x25+0+350 -e @EXAMPLE9_BIN_LOCATION@/$SERVER & 


########################## start SAMPLER
SAMPLER="PndMQFileSamplerBursts $TRANSPORT"
SAMPLER+=" --id sampler1  --mq-config $MQCONFIGFILE"
SAMPLER+=" --file-name $INPUTFILE --branch-name $INPUTBRANCH $MAXINDEX"
# xterm -sl 10000 -geometry 80x25+0+0 -e @MVDMQ_BIN_LOCATION@/$SAMPLER &


######################### start PROCESSORs
PROCESSOR1="PndMQTaskProcessor $TRANSPORT"
PROCESSOR1+=" $VERBOSE"
PROCESSOR1+=" --id processor1 $FAIRTASKNAME --mq-config $MQCONFIGFILE"
#xterm -geometry 80x25+500+0 -e @MVDMQ_BIN_LOCATION@/$PROCESSOR1 &

PROCESSOR2="PndMQTaskProcessor $TRANSPORT"
PROCESSOR2+=" $VERBOSE"
PROCESSOR2+=" --id processor2 $FAIRTASKNAME --mq-config $MQCONFIGFILE"
#xterm -geometry 80x25+500+350 -e @MVDMQ_BIN_LOCATION@/$PROCESSOR2 &

PROCESSOR3="PndMQTaskProcessor $TRANSPORT"
PROCESSOR3+=" $VERBOSE"
PROCESSOR3+=" --id processor3 $FAIRTASKNAME --mq-config $MQCONFIGFILE"
#xterm -geometry 80x25+500+700 -e @MVDMQ_BIN_LOCATION@/$PROCESSOR3 &

PROCESSOR4="PndMQTaskProcessor $TRANSPORT"
PROCESSOR4+=" $VERBOSE"
PROCESSOR4+=" --id processor4 $FAIRTASKNAME --mq-config $MQCONFIGFILE"
#xterm -geometry 80x25+1000+0 -e @MVDMQ_BIN_LOCATION@/$PROCESSOR4 &

PROCESSOR5="PndMQTaskProcessor $TRANSPORT"
PROCESSOR5+=" $VERBOSE"
PROCESSOR5+=" --id processor5 $FAIRTASKNAME --mq-config $MQCONFIGFILE"
#xterm -geometry 80x25+1000+350 -e @MVDMQ_BIN_LOCATION@/$PROCESSOR5 &


########################## start FILESINK
FILESINK="PndMQFileSinkBursts $TRANSPORT"
FILESINK+=" --id processor1 --mq-config $MQCONFIGFILE"
FILESINK+=" --file-name $OUTPUTFILE $OUTPUTCLASS $OUTPUTBRANCH"
xterm -sl 10000 -geometry 80x25+0+700 -e @MVDMQ_BIN_LOCATION@/$FILESINK & 

########################## start FILESINK
FILESINK="PndMQFileSinkBursts $TRANSPORT"
FILESINK+=" --id processor2 --mq-config $MQCONFIGFILE"
FILESINK+=" --file-name $OUTPUTFILE $OUTPUTCLASS $OUTPUTBRANCH"
xterm -sl 10000 -geometry 80x25+500+0 -e @MVDMQ_BIN_LOCATION@/$FILESINK &

########################## start FILESINK
#FILESINK="PndMQFileSinkBurst $TRANSPORT"
#FILESINK+=" --id sink1 --mq-config $MQCONFIGFILE"
#FILESINK+=" --file-name $OUTPUTFILE $OUTPUTCLASS $OUTPUTBRANCH"
#xterm +aw -geometry 80x25+0+700 -e @MVDMQ_BIN_LOCATION@/$FILESINK &