apps/go-pluginserver
1
0
Fork 0
mirror of https://github.com/Kong/go-pluginserver.git synced 2025-10-17 13:40:40 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

tests(*) update test to use two plugins and use ncat

Browse Source 
There are several incompatible versions of netcat around.
`ncat` (from nmap) is a more "reliable" tool for scripting.

Extends the test a bit with the latest change in
https://github.com/kong/go-plugins, where the example
plugin was split in two.
This commit is contained in:
Hisham Muhammad
2019-12-16 19:02:46 -03:00
committed by Guilherme Salazar
parent 65e79d9937
commit aeebdd2425
1 changed files with 54 additions and 47 deletions
Download Patch File Download Diff File Expand all files Collapse all files

101
test.sh
View File

@@ -29,11 +29,12 @@ msg() {
[ -v VERBOSE ] && rq <<< "$query" [ -v VERBOSE ] && rq <<< "$query"
[ "$VERBOSE" == "very" ] && rq <<< "$query" -M | hd [ "$VERBOSE" == "very" ] && rq <<< "$query" -M | hd
METHOD="$(rq <<< "$query" -- 'at([2])')" METHOD="$(rq <<< "$query" -- 'at([2])')"
response="$(rq <<< "$query" -M | nc -NU "$SOCKET" | rq -m | jq 'select(.[0]==1)' )" response="$(rq <<< "$query" -M | ncat -U "$SOCKET" | rq -m | jq 'select(.[0]==1)' )"
[ -v VERBOSE ] && rq <<< "$response" [ -v VERBOSE ] && rq <<< "$response"
ERROR="$(jq <<< "$response" '.[2]')" ERROR="$(jq <<< "$response" '.[2]')"
RESULT="$(jq <<< "$response" '.[3]')" RESULT="$(jq <<< "$response" '.[3]')"
# echo $RESULT
} }
assert_noerr() { assert_noerr() {
@@ -50,7 +51,7 @@ assert_fld_match() {
fld="$1" fld="$1"
pattern="$2" pattern="$2"
fld_v="$(query_result '."'$fld'"')" fld_v="$(query_result '.'$fld'')"
if [[ "$fld_v" =~ "$pattern" ]]; then if [[ "$fld_v" =~ "$pattern" ]]; then
echo "==> $fld_v : ok" echo "==> $fld_v : ok"
else else
@@ -60,7 +61,6 @@ assert_fld_match() {
} }
query_result() { query_result() {
# echo "$RESULT"
jq <<< "$RESULT" "$1" jq <<< "$RESULT" "$1"
} }
@@ -71,73 +71,80 @@ msg '[0, 19, "plugin.GetStatus", []]'
assert_noerr assert_noerr
assert_fld_match 'Plugins' '{}' assert_fld_match 'Plugins' '{}'
msg '[0, 19, "plugin.GetPluginInfo", ["go-log"]]' msg '[0, 19, "plugin.GetPluginInfo", ["go-hello"]]'
assert_noerr assert_noerr
msg '[0, 19, "plugin.StartInstance", [{"Name":"go-hello", "Config":"{\"message\":\"howdy\"}"}]]'
assert_noerr
helloId=$(query_result '."Id"')
echo "helloId: $helloId"
msg '[0, 19, "plugin.StartInstance", [{"Name":"go-log", "Config":"{\"reopen\":false, \"path\":\"/some/where/else/\"}"}]]' msg '[0, 19, "plugin.StartInstance", [{"Name":"go-log", "Config":"{\"reopen\":false, \"path\":\"/some/where/else/\"}"}]]'
assert_noerr assert_noerr
instanceID=$(query_result '."Id"') logId=$(query_result '."Id"')
echo "instanceID: $instanceID" echo "logId: $logId"
msg '[0, 19, "plugin.HandleEvent", [{"InstanceId": '$instanceID', "EventName": "access", "Params": [45, 23]}]]' msg '[0, 19, "plugin.HandleEvent", [{"InstanceId": '$helloId', "EventName": "access", "Params": [45, 23]}]]'
assert_noerr assert_noerr
eventId=$(query_result '."EventId"') helloEventId=$(query_result '."EventId"')
assert_fld_match 'Data.Method' 'kong.request.get_header' assert_fld_match 'Data.Method' 'kong.request.get_header'
assert_fld_match 'Data.Args' '"host"' assert_fld_match 'Data.Args' '"host"'
msg '[0, 19, "plugin.GetStatus", []]' msg '[0, 20, "plugin.HandleEvent", [{"InstanceId": '$logId', "EventName": "log", "Params": [45, 23]}]]'
assert_noerr assert_noerr
logEventId=$(query_result '."EventId"')
msg '[0, 19, "plugin.Step", [{"EventId": '$eventId', "Data": "example.com"}]]'
assert_noerr assert_noerr
assert_fld_match 'Data.Method' 'kong.response.set_header' assert_fld_match 'Data.Method' 'kong.log.serialize'
assert_fld_match 'Data.Args[0]' '"x-hello-go"'
assert_fld_match 'Data.Args[1]' '"Go says hello to example.com (/some/where/else/)"'
msg '[0, 19, "plugin.Step", [{"EventId": '$eventId', "Data": "ok"}]]' # msg '[0, 19, "plugin.StepError", [{"EventId": '$helloEventId', "Data": "not in the mood for routes"}]]'
assert_noerr #msg "$(cat <<-EOF
# assert_fld_match 'Data.Method' 'kong.router.get_route' #[
# 0, 19, "plugin.StepRoute",
# [{
# "Data": {
# "created_at": 1574445198,
# "https_redirect_status_code": 426,
# "id": "c0ba987b-99e0-4342-a255-61ff47d54fe6",
# "paths": [ "/" ],
# "preserve_host": false,
# "protocols": [ "http", "https" ],
# "regex_priority": 0,
# "service": {
# "id": "a1a72823-4c75-42b3-92e6-79c865175287"
# },
# "strip_path": true,
# "updated_at": 1574445198
# },
# "EventId": 0
# }]
#]
#EOF
#)"
#assert_noerr
# #
# # msg '[0, 19, "plugin.StepError", [{"EventId": '$eventId', "Data": "not in the mood for routes"}]]' #callBack=$(query_result '."Data"')
# msg "$(cat <<-EOF #
# [ #assert_fld_match 'Data' '"ret"'
# 0, 19, "plugin.StepRoute",
# [{
# "Data": {
# "created_at": 1574445198,
# "https_redirect_status_code": 426,
# "id": "c0ba987b-99e0-4342-a255-61ff47d54fe6",
# "paths": [ "/" ],
# "preserve_host": false,
# "protocols": [ "http", "https" ],
# "regex_priority": 0,
# "service": {
# "id": "a1a72823-4c75-42b3-92e6-79c865175287"
# },
# "strip_path": true,
# "updated_at": 1574445198
# },
# "EventId": 0
# }]
# ]
# EOF
# )"
# assert_noerr
# # callBack=$(query_result '."Data"')
assert_fld_match 'Data' '"ret"'
msg '[0, 19, "plugin.InstanceStatus", ['$instanceID']]' msg '[0, 19, "plugin.InstanceStatus", ['$helloId']]'
assert_noerr assert_noerr
msg "[0, 19, \"plugin.CloseInstance\", [$instanceID]]" msg "[0, 19, \"plugin.CloseInstance\", [$helloId]]"
assert_noerr
msg '[0, 19, "plugin.InstanceStatus", ['$logId']]'
assert_noerr
msg "[0, 19, \"plugin.CloseInstance\", [$logId]]"
assert_noerr assert_noerr
msg '[0, 19, "plugin.GetStatus", []]' msg '[0, 19, "plugin.GetStatus", []]'
assert_noerr assert_noerr
assert_fld_match 'Plugins.go-log' '"Name":"go-log"' assert_fld_match 'Plugins["go-hello"]' '"Name": "go-hello"'
assert_fld_match 'Plugins["go-log"]' '"Name": "go-log"'
if [ ! -v PREVIOUS_SERVER ]; then if [ ! -v PREVIOUS_SERVER ]; then