mirror of
https://github.com/rsyslog/rsyslog.git
synced 2025-12-19 12:40:42 +01:00
5a7d6009c7
- DEAD_PORT now uses unassigned IANA port unlike to be used on the system (dynamic port querying is racy and we had at least once an issue, so we can remove ambiguity here easily) - replace some diag.sh commands by bash functions
132 lines
3.1 KiB
Bash
Executable File
132 lines
3.1 KiB
Bash
Executable File
#!/bin/bash
|
|
# This file is part of the rsyslog project, released under ASL 2.0
|
|
. $srcdir/diag.sh download-elasticsearch
|
|
. $srcdir/diag.sh stop-elasticsearch
|
|
. $srcdir/diag.sh prepare-elasticsearch
|
|
. $srcdir/diag.sh start-elasticsearch
|
|
|
|
# Starting actual testbench
|
|
. $srcdir/diag.sh init
|
|
generate_conf
|
|
add_conf '
|
|
template(name="tpl" type="string"
|
|
string="{\"msgnum\":\"%msg:F,58:2%\"}")
|
|
|
|
module(load="../plugins/omelasticsearch/.libs/omelasticsearch")
|
|
|
|
if $msg contains "msgnum:" then
|
|
action(type="omelasticsearch"
|
|
server="127.0.0.1"
|
|
serverport="19200"
|
|
template="tpl"
|
|
writeoperation="create"
|
|
searchIndex="rsyslog_testbench")
|
|
|
|
action(type="omfile" file=`echo $RSYSLOG_OUT_LOG`)
|
|
'
|
|
|
|
# . $srcdir/diag.sh es-init
|
|
startup
|
|
injectmsg 0 1
|
|
shutdown_when_empty
|
|
wait_shutdown
|
|
if grep -q "omelasticsearch: writeoperation '1' requires bulkid" $RSYSLOG_OUT_LOG ; then
|
|
echo found correct error message
|
|
else
|
|
echo Error: did not complain about incorrect writeoperation
|
|
cat $RSYSLOG_OUT_LOG
|
|
error_exit 1
|
|
fi
|
|
|
|
. $srcdir/diag.sh init
|
|
generate_conf
|
|
add_conf '
|
|
template(name="tpl" type="string"
|
|
string="{\"msgnum\":\"%msg:F,58:2%\"}")
|
|
|
|
module(load="../plugins/omelasticsearch/.libs/omelasticsearch")
|
|
|
|
if $msg contains "msgnum:" then
|
|
action(type="omelasticsearch"
|
|
server="127.0.0.1"
|
|
serverport="19200"
|
|
template="tpl"
|
|
writeoperation="unknown"
|
|
searchIndex="rsyslog_testbench")
|
|
|
|
action(type="omfile" file=`echo $RSYSLOG_OUT_LOG`)
|
|
'
|
|
|
|
# . $srcdir/diag.sh es-init
|
|
startup
|
|
injectmsg 0 1
|
|
shutdown_when_empty
|
|
wait_shutdown
|
|
if grep -q "omelasticsearch: invalid value 'unknown' for writeoperation" $RSYSLOG_OUT_LOG ; then
|
|
echo found correct error message
|
|
else
|
|
echo Error: did not complain about incorrect writeoperation
|
|
cat $RSYSLOG_OUT_LOG
|
|
error_exit 1
|
|
fi
|
|
|
|
. $srcdir/diag.sh init
|
|
generate_conf
|
|
add_conf '
|
|
template(name="tpl" type="string"
|
|
string="{\"msgnum\":\"%msg:F,58:2%\"}")
|
|
|
|
module(load="../plugins/omelasticsearch/.libs/omelasticsearch")
|
|
|
|
template(name="id-template" type="list") { constant(value="123456789") }
|
|
|
|
if $msg contains "msgnum:" then
|
|
action(type="omelasticsearch"
|
|
server="127.0.0.1"
|
|
serverport="19200"
|
|
template="tpl"
|
|
writeoperation="create"
|
|
bulkid="id-template"
|
|
dynbulkid="on"
|
|
bulkmode="on"
|
|
searchIndex="rsyslog_testbench")
|
|
|
|
action(type="omfile" file=`echo $RSYSLOG_OUT_LOG`)
|
|
'
|
|
|
|
export ES_PORT=19200
|
|
. $srcdir/diag.sh es-init
|
|
#export RSYSLOG_DEBUG="debug nostdout noprintmutexaction"
|
|
#export RSYSLOG_DEBUGLOG="debug.log"
|
|
startup
|
|
injectmsg 0 1
|
|
shutdown_when_empty
|
|
wait_shutdown
|
|
. $srcdir/diag.sh es-getdata 1 $ES_PORT
|
|
|
|
cat work | \
|
|
python -c '
|
|
import sys,json
|
|
hsh = json.load(sys.stdin)
|
|
try:
|
|
if hsh["hits"]["hits"][0]["_id"] == "123456789":
|
|
print "good - found expected value"
|
|
sys.exit(0)
|
|
print "Error: _id not expected value 123456789:", hsh["hits"]["hits"][0]["_id"]
|
|
sys.exit(1)
|
|
except ValueError:
|
|
print "Error: output is not valid:", json.dumps(hsh,indent=2)
|
|
sys.exit(1)
|
|
'
|
|
|
|
if [ $? -eq 0 ] ; then
|
|
echo found correct response
|
|
else
|
|
cat $RSYSLOG_OUT_LOG
|
|
error_exit 1
|
|
fi
|
|
|
|
. $srcdir/diag.sh stop-elasticsearch
|
|
. $srcdir/diag.sh cleanup-elasticsearch
|
|
exit_test
|