| #!/bin/bash |
| |
| # ============LICENSE_START=============================================== |
| # Copyright (C) 2020 Nordix Foundation. All rights reserved. |
| # ======================================================================== |
| # Licensed under the Apache License, Version 2.0 (the "License"); |
| # you may not use this file except in compliance with the License. |
| # You may obtain a copy of the License at |
| # |
| # http://www.apache.org/licenses/LICENSE-2.0 |
| # |
| # Unless required by applicable law or agreed to in writing, software |
| # distributed under the License is distributed on an "AS IS" BASIS, |
| # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| # See the License for the specific language governing permissions and |
| # limitations under the License. |
| # ============LICENSE_END================================================= |
| # |
| |
| # Automated test script for producer stub container |
| |
| if [ $# -ne 1 ]; then |
| echo "Usage: ./basic_test.sh nonsecure|secure" |
| exit 1 |
| fi |
| if [ "$1" != "nonsecure" ] && [ "$1" != "secure" ]; then |
| echo "Usage: ./basic_test.sh nonsecure|secure" |
| exit 1 |
| fi |
| |
| if [ $1 == "nonsecure" ]; then |
| #Default http port for the simulator |
| PORT=8992 |
| # Set http protocol |
| HTTPX="http" |
| else |
| #Default https port for the simulator |
| PORT=8993 |
| # Set https protocol |
| HTTPX="https" |
| fi |
| |
| # source function to do curl and check result |
| . ../common/do_curl_function.sh |
| |
| echo "=== hello world ===" |
| RESULT="OK" |
| do_curl GET / 200 |
| |
| echo "=== reset ===" |
| RESULT="" |
| do_curl GET /reset 200 |
| |
| echo "=== status ===" |
| RESULT="json:{}" |
| do_curl GET /status 200 |
| |
| # Basic admin |
| |
| echo "=== check supervision counter ===" |
| RESULT="-1" |
| do_curl GET /counter/supervision/prod-x 200 |
| |
| echo "=== check create counter ===" |
| RESULT="-1" |
| do_curl GET /counter/create/prod-x/job-x 200 |
| |
| echo "=== check delete counter ===" |
| RESULT="-1" |
| do_curl GET /counter/delete/prod-x/job-x 200 |
| |
| ## Create/update a producer |
| |
| echo "=== create producer ===" |
| RESULT="Unknown query parameter(s)" |
| do_curl PUT /arm/supervision/prod-x?test=201 400 |
| |
| echo "=== create producer ===" |
| RESULT="" |
| do_curl PUT /arm/supervision/prod-x?response=201 200 |
| |
| echo "=== update producer ===" |
| RESULT="" |
| do_curl PUT /arm/supervision/prod-x?response=400 200 |
| |
| echo "=== update producer ===" |
| RESULT="" |
| do_curl PUT /arm/supervision/prod-x 200 |
| |
| ## Add types to a producere |
| |
| echo "=== add type 10 ===" |
| RESULT="" |
| do_curl PUT /arm/type/prod-x/10 200 |
| |
| echo "=== add type 15 ===" |
| RESULT="" |
| do_curl PUT /arm/type/prod-x/15 200 |
| |
| ## check the db |
| |
| echo "=== status ===" |
| RESULT="json:{\"prod-x\": {\"supervision_response\": 200, \"supervision_counter\": 0, \"types\": [\"10\", \"15\"]}}" |
| do_curl GET /status 200 |
| |
| ## Add type |
| echo "=== add type 20 ===" |
| RESULT="" |
| do_curl PUT /arm/type/prod-x/20 200 |
| |
| echo "=== status ===" |
| RESULT="json:{\"prod-x\": {\"supervision_response\": 200, \"supervision_counter\": 0, \"types\": [\"10\", \"15\", \"20\"]}}" |
| do_curl GET /status 200 |
| |
| ## remove type |
| echo "=== remove type 20 ===" |
| RESULT="" |
| do_curl DELETE /arm/type/prod-x/20 200 |
| |
| echo "=== status ===" |
| RESULT="json:{\"prod-x\": {\"supervision_response\": 200, \"supervision_counter\": 0, \"types\": [\"10\", \"15\"]}}" |
| do_curl GET /status 200 |
| |
| ## producer supervision |
| echo "=== check supervision counter ===" |
| RESULT="0" |
| do_curl GET /counter/supervision/prod-x 200 |
| |
| echo "=== supervision producer ===" |
| RESULT="" |
| do_curl GET /callbacks/supervision/prod-x 200 |
| |
| echo "=== update producer ===" |
| RESULT="" |
| do_curl PUT /arm/supervision/prod-x?response=400 200 |
| |
| echo "=== callback supervision producer ===" |
| RESULT="returning configured response code" |
| do_curl GET /callbacks/supervision/prod-x 400 |
| |
| ## check the db |
| |
| echo "=== status ===" |
| RESULT="json:{\"prod-x\": {\"supervision_response\": 400, \"supervision_counter\": 2, \"types\": [\"10\", \"15\"]}}" |
| do_curl GET /status 200 |
| |
| ## create/update job |
| |
| echo "=== add job ===" |
| RESULT="" |
| do_curl PUT /arm/create/prod-x/job-y 200 |
| |
| echo "=== update job ===" |
| RESULT="" |
| do_curl PUT /arm/create/prod-x/job-y?response=405 200 |
| |
| ## check the db |
| |
| echo "=== status ===" |
| RESULT="json:{\"prod-x\": {\"supervision_response\": 400, \"supervision_counter\": 2, \"types\": [\"10\", \"15\"], \"job-y\": {\"create_response\": 405, \"delete_response\": 404, \"json\": null, \"create_counter\": 0, \"delete_counter\": 0, \"delivering\": \"stopped\", \"delivery_attempts\": 0}}}" |
| do_curl GET /status 200 |
| |
| ## add delete response for job |
| |
| echo "=== update job ===" |
| RESULT="" |
| do_curl PUT /arm/delete/prod-x/job-y?response=407 200 |
| |
| ## check the db |
| |
| echo "=== status ===" |
| RESULT="json:{\"prod-x\": {\"supervision_response\": 400, \"supervision_counter\": 2, \"types\": [\"10\", \"15\"], \"job-y\": {\"create_response\": 405, \"delete_response\": 407, \"json\": null, \"create_counter\": 0, \"delete_counter\": 0, \"delivering\": \"stopped\", \"delivery_attempts\": 0}}}" |
| do_curl GET /status 200 |
| |
| ## Get jobdata |
| echo "=== job data ===" |
| RESULT="" |
| do_curl GET /jobdata/prod-x/job-y 204 |
| |
| ## callback create |
| |
| echo "=== add job ===" |
| RESULT="" |
| do_curl PUT /arm/create/prod-x/job-1 200 |
| RESULT="" |
| do_curl PUT /arm/delete/prod-x/job-1 200 |
| |
| echo "=== callback create job ===" |
| RESULT="" |
| echo "{\"ei_job_identity\": \"job-1\", \"ei_job_data\": {}, \"target_uri\": \"http://localhost:80\",\"ei_type_identity\": \"10\"}" > .p.json |
| do_curl POST /callbacks/job/prod-x 201 .p.json |
| |
| echo "=== callback create job -update ===" |
| RESULT="" |
| echo "{\"ei_job_identity\": \"job-1\", \"ei_job_data\": {}, \"target_uri\": \"http://localhost:80\",\"ei_type_identity\": \"10\"}" > .p.json |
| do_curl POST /callbacks/job/prod-x 200 .p.json |
| |
| ## Get jobdata |
| echo "=== job data ===" |
| RESULT="json:{\"ei_job_identity\": \"job-1\", \"ei_job_data\": {}, \"target_uri\": \"http://localhost:80\", \"ei_type_identity\": \"10\"}" |
| do_curl GET /jobdata/prod-x/job-1 200 |
| |
| ## check the db |
| |
| echo "=== status ===" |
| RESULT="json:{\"prod-x\": {\"supervision_response\": 400, \"supervision_counter\": 2, \"types\": [\"10\", \"15\"], \"job-y\": {\"create_response\": 405, \"delete_response\": 407, \"json\": null, \"create_counter\": 0, \"delete_counter\": 0, \"delivering\": \"stopped\", \"delivery_attempts\": 0}, \"job-1\": {\"create_response\": 200, \"delete_response\": 204, \"json\": {\"ei_job_identity\": \"job-1\", \"ei_job_data\": {}, \"target_uri\": \"http://localhost:80\", \"ei_type_identity\": \"10\"}, \"create_counter\": 2, \"delete_counter\": 0, \"delivering\": \"delivering\", \"delivery_attempts\": 0}}}" |
| do_curl GET /status 200 |
| |
| # create and delete job tests |
| echo "=== set job create response ===" |
| RESULT="" |
| do_curl PUT /arm/create/prod-x/job-1?response=404 200 |
| |
| echo "=== callback create job -update ===" |
| RESULT="returning configured response code" |
| echo "{\"ei_job_identity\": \"job-1\", \"ei_job_data\": {}, \"target_uri\": \"http://localhost:80\",\"ei_type_identity\": \"10\"}" > .p.json |
| do_curl POST /callbacks/job/prod-x 404 .p.json |
| |
| echo "=== set job delete response ===" |
| RESULT="" |
| do_curl PUT /arm/delete/prod-x/job-1?response=404 200 |
| |
| echo "=== callback delete job===" |
| RESULT="returning configured response code" |
| echo "{\"ei_job_identity\": \"job-1\", \"ei_job_data\": {}, \"target_uri\": \"http://localhost:80\",\"ei_type_identity\": \"10\"}" > .p.json |
| do_curl DELETE /callbacks/job/prod-x/job-1 404 .p.json |
| |
| echo "=== set job delete response ===" |
| RESULT="" |
| do_curl PUT /arm/delete/prod-x/job-1 200 |
| |
| echo "=== callback delete job===" |
| RESULT="" |
| echo "{\"ei_job_identity\": \"job-1\", \"ei_job_data\": {}, \"target_uri\": \"http://localhost:80\",\"ei_type_identity\": \"10\"}" > .p.json |
| do_curl DELETE /callbacks/job/prod-x/job-1 204 .p.json |
| |
| ## check the db |
| |
| echo "=== status ===" |
| RESULT="json:{\"prod-x\": {\"supervision_response\": 400, \"supervision_counter\": 2, \"types\": [\"10\", \"15\"], \"job-y\": {\"create_response\": 405, \"delete_response\": 407, \"json\": null, \"create_counter\": 0, \"delete_counter\": 0, \"delivering\": \"stopped\", \"delivery_attempts\": 0}, \"job-1\": {\"create_response\": 404, \"delete_response\": 404, \"json\": null, \"create_counter\": 3, \"delete_counter\": 2, \"delivering\": \"stopped\", \"delivery_attempts\": 0}}}" |
| do_curl GET /status 200 |
| |
| |
| ## data delivery |
| |
| echo "=== update producer ===" |
| RESULT="" |
| do_curl PUT /arm/create/prod-x/job-1 200 |
| |
| echo "=== callback create job ===" |
| RESULT="" |
| echo "{\"ei_job_identity\": \"job-1\", \"ei_job_data\": {}, \"target_uri\": \"http://localhost:80\",\"ei_type_identity\": \"10\"}" > .p.json |
| do_curl POST /callbacks/job/prod-x 201 .p.json |
| |
| echo "=== data delivery start ===" |
| RESULT="job not found" |
| do_curl POST /jobdata/prod-x/job-x?action=START 404 |
| |
| echo "=== data delivery start ===" |
| RESULT="" |
| do_curl POST /jobdata/prod-x/job-1?action=START 200 |
| |
| echo "sleep 5" |
| sleep 5 |
| |
| echo "=== data delivery stop ===" |
| RESULT="" |
| do_curl POST /jobdata/prod-x/job-1?action=STOP 200 |
| |
| echo "********************" |
| echo "*** All tests ok ***" |
| echo "********************" |