mirror of
https://github.com/Kong/go-pluginserver.git
synced 2025-09-27 04:26:20 +08:00
155 lines
3.4 KiB
Bash
Executable File
155 lines
3.4 KiB
Bash
Executable File
#!/bin/bash
|
|
|
|
if [ "$1" == "-v" ]; then
|
|
VERBOSE='true'
|
|
fi
|
|
if [ "$1" == "-vv" ]; then
|
|
VERBOSE='very'
|
|
fi
|
|
|
|
pkill go-pluginserver
|
|
rq --help >/dev/null
|
|
|
|
echo "pwd: $PWD"
|
|
|
|
SOCKET='go_pluginserver.sock'
|
|
|
|
if pgrep go-pluginserver -l; then
|
|
PREVIOUS_SERVER="yes"
|
|
else
|
|
echo "starting server..."
|
|
[ -S "$SOCKET" ] && rm "$SOCKET"
|
|
./go-pluginserver -kong-prefix . &
|
|
pgrep go-pluginserver -l
|
|
sleep 0.1s
|
|
fi
|
|
|
|
msg() {
|
|
query="$1"
|
|
[ -v VERBOSE ] && rq <<< "$query"
|
|
[ "$VERBOSE" == "very" ] && rq <<< "$query" -M | hd
|
|
METHOD="$(rq <<< "$query" -- 'at([2])')"
|
|
response="$(rq <<< "$query" -M | ncat -U "$SOCKET" | rq -m | jq 'select(.[0]==1)' )"
|
|
[ -v VERBOSE ] && rq <<< "$response"
|
|
|
|
ERROR="$(jq <<< "$response" '.[2]')"
|
|
RESULT="$(jq <<< "$response" '.[3]')"
|
|
# echo $RESULT
|
|
}
|
|
|
|
assert_noerr() {
|
|
if [ "$ERROR" != "null" ]; then
|
|
echo "query: $query"
|
|
echo "response: $response"
|
|
echo "$METHOD : $ERROR" > /dev/stderr
|
|
exit 1
|
|
fi
|
|
echo "$METHOD: ok"
|
|
}
|
|
|
|
assert_fld_match() {
|
|
fld="$1"
|
|
pattern="$2"
|
|
|
|
fld_v="$(query_result '.'$fld'')"
|
|
if [[ "$fld_v" =~ "$pattern" ]]; then
|
|
echo "==> $fld_v : ok"
|
|
else
|
|
echo "==> $fld_v : no match '$pattern'"
|
|
exit 1
|
|
fi
|
|
}
|
|
|
|
query_result() {
|
|
jq <<< "$RESULT" "$1"
|
|
}
|
|
|
|
msg '[0, 19, "plugin.SetPluginDir", ["'$PWD'"]]'
|
|
assert_noerr
|
|
|
|
msg '[0, 19, "plugin.GetStatus", []]'
|
|
assert_noerr
|
|
assert_fld_match 'Plugins' '{}'
|
|
|
|
msg '[0, 19, "plugin.GetPluginInfo", ["go-hello-lm"]]'
|
|
assert_noerr
|
|
|
|
msg '[0, 19, "plugin.StartInstance", [{"Name":"go-hello-lm", "Config":"{\"message\":\"howdy\"}"}]]'
|
|
assert_noerr
|
|
helloId=$(query_result '."Id"')
|
|
echo "helloId: $helloId"
|
|
|
|
msg '[0, 19, "plugin.StartInstance", [{"Name":"go-log-lm", "Config":"{\"reopen\":false, \"path\":\"/some/where/else/\"}"}]]'
|
|
assert_noerr
|
|
logId=$(query_result '."Id"')
|
|
echo "logId: $logId"
|
|
|
|
msg '[0, 19, "plugin.HandleEvent", [{"InstanceId": '$helloId', "EventName": "access", "Params": [45, 23]}]]'
|
|
assert_noerr
|
|
helloEventId=$(query_result '."EventId"')
|
|
|
|
assert_fld_match 'Data.Method' 'kong.request.get_header'
|
|
assert_fld_match 'Data.Args' '"host"'
|
|
|
|
msg '[0, 20, "plugin.HandleEvent", [{"InstanceId": '$logId', "EventName": "log", "Params": [45, 23]}]]'
|
|
assert_noerr
|
|
logEventId=$(query_result '."EventId"')
|
|
|
|
assert_noerr
|
|
assert_fld_match 'Data.Method' 'kong.log.serialize'
|
|
|
|
# msg '[0, 19, "plugin.StepError", [{"EventId": '$helloEventId', "Data": "not in the mood for routes"}]]'
|
|
#msg "$(cat <<-EOF
|
|
#[
|
|
# 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", ['$helloId']]'
|
|
assert_noerr
|
|
|
|
msg "[0, 19, \"plugin.CloseInstance\", [$helloId]]"
|
|
assert_noerr
|
|
|
|
msg '[0, 19, "plugin.InstanceStatus", ['$logId']]'
|
|
assert_noerr
|
|
|
|
msg "[0, 19, \"plugin.CloseInstance\", [$logId]]"
|
|
assert_noerr
|
|
|
|
msg '[0, 19, "plugin.GetStatus", []]'
|
|
assert_noerr
|
|
assert_fld_match 'Plugins["go-hello-lm"]' '"Name": "go-hello-lm"'
|
|
assert_fld_match 'Plugins["go-log-lm"]' '"Name": "go-log-lm"'
|
|
|
|
|
|
if [ ! -v PREVIOUS_SERVER ]; then
|
|
pkill go-pluginserver
|
|
rm "$SOCKET"
|
|
fi
|
|
|