| #! /bin/bash |
| |
| # ============LICENSE_START======================================================= |
| # ONAP |
| # ================================================================================ |
| # Copyright (C) 2017-2020 AT&T Intellectual Property. 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========================================================= |
| |
| source ${POLICY_HOME}/etc/profile.d/env.sh |
| |
| function usage() { |
| echo -n "Usage: $(basename $0) " |
| echo -n "[(-d|--debug)] " |
| echo -n "(-h|--host) <bus-host> " |
| echo -n "[(-p|--port) <bus-port>] " |
| echo -n "[(-k|--key) <api-key>] " |
| echo -n "[(-s|--secret) <api-secret>] " |
| echo -n "[(-r|--request-id) <request-id>] " |
| echo -n "(-c|--controller-name) <controller-name> " |
| echo -n "(-o|--operation) <create|update|lock|unlock> " |
| echo -n "[(-g|--group-id) <group-id> " |
| echo -n "(-a|--artifact-id) <artifact-id> " |
| echo -n "(-v|--version) <version>] " |
| echo -n "[(-t|--topic) <topic>] " |
| echo "" |
| } |
| |
| BUS_PORT=3904 |
| ENTITY=controller |
| REQUEST_ID="7f5474ca-16a9-42ac-abc0-d86f62296fbc" |
| TOPIC="PDPD-CONFIGURATION" |
| |
| # command line options parsing |
| until [[ -z "$1" ]]; do |
| case $1 in |
| -d|--debug) set -x |
| ;; |
| -h|--host) shift |
| BUS_HOST=$1 |
| ;; |
| -p|--port) shift |
| BUS_PORT=$1 |
| ;; |
| -r|--request-id) shift |
| REQUEST_ID=$1 |
| ;; |
| -k|--key) shift |
| API_KEY=$1 |
| ;; |
| -s|--secret) shift |
| API_SECRET=$1 |
| ;; |
| -c|--controller-name) shift |
| CONTROLLER_NAME=$1 |
| ;; |
| -o|--operation) shift |
| OPERATION=$1 |
| ;; |
| -g|--group-id) shift |
| GROUP_ID=$1 |
| ;; |
| -a|--artifact-id) shift |
| ARTIFACT_ID=$1 |
| ;; |
| -v|--version) shift |
| VERSION=$1 |
| ;; |
| -t|--topic) shift |
| TOPIC=$1 |
| ;; |
| *) usage |
| exit 1 |
| ;; |
| esac |
| shift |
| done |
| |
| if [[ -z ${BUS_HOST} ]]; then |
| echo "An UEB/DMAAP server must be provided." |
| echo |
| usage |
| exit 1 |
| fi |
| |
| if [[ -z ${CONTROLLER_NAME} ]]; then |
| echo "The controller-name must be provided." |
| usage |
| exit 2 |
| fi |
| |
| if [[ -z ${OPERATION} ]]; then |
| echo "The operation must be provided: create|update|lock|unlock" |
| usage |
| exit 3 |
| fi |
| |
| if [[ ${OPERATION} == "create" ]] || [[ ${OPERATION} == "update" ]]; then |
| if [[ -z ${GROUP_ID} ]]; then |
| echo "The maven group id must be provided when operation is create|update" |
| usage |
| exit 4 |
| fi |
| |
| if [[ -z ${ARTIFACT_ID} ]]; then |
| echo "The maven artifact id must be provided when operation is create|update" |
| usage |
| exit 5 |
| fi |
| |
| if [[ -z ${VERSION} ]]; then |
| echo "The maven version must be provided when operation is create|update" |
| usage |
| exit 6 |
| fi |
| fi |
| |
| UPDATE_BODY=$(< <(cat <<EOF |
| { |
| "requestID": "${REQUEST_ID}", |
| "entity": "controller", |
| "controllers": [{ |
| "name": "${CONTROLLER_NAME}", |
| "drools": { |
| "groupId": "${GROUP_ID}", |
| "artifactId": "${ARTIFACT_ID}", |
| "version": "${VERSION}" |
| }, |
| "operation": "${OPERATION}" |
| }] |
| } |
| |
| EOF |
| )) |
| |
| LOCK_BODY=$(< <(cat <<EOF |
| { |
| "requestID": "${REQUEST_ID}", |
| "entity": "controller", |
| "controllers": [{ |
| "name": "${CONTROLLER_NAME}", |
| "operation": "${OPERATION}" |
| }] |
| } |
| |
| EOF |
| )) |
| |
| unset http_proxy |
| |
| if [[ ${OPERATION} == "lock" ]] || [[ ${OPERATION} == "unlock" ]]; then |
| if [[ -n ${API_KEY} ]]; then |
| DATE=$(date) |
| DATE_HASH=$(echo -n "${DATE}" | openssl sha1 -hmac "${API_SECRET}" -binary | openssl base64) |
| curl --silent -X POST \ |
| --header "Accept:" \ |
| --header "X-CambriaDate: ${DATE}" \ |
| --header "X-CambriaAuth: ${API_KEY}:${DATE_HASH}" \ |
| --header "Content-Type: application/json" \ |
| --data "${LOCK_BODY}" \ |
| http://${BUS_HOST}:${BUS_PORT}/events/${TOPIC} |
| else |
| curl --silent -X POST \ |
| --header "Accept:" \ |
| --header "Content-Type: application/json" \ |
| --data "${LOCK_BODY}" \ |
| http://${BUS_HOST}:${BUS_PORT}/events/${TOPIC} |
| fi |
| fi |
| |
| if [[ ${OPERATION} == "create" ]] || [[ ${OPERATION} == "update" ]]; then |
| if [[ -n ${API_KEY} ]]; then |
| DATE=$(date) |
| DATE_HASH=$(echo -n "${DATE}" | openssl sha1 -hmac "${API_SECRET}" -binary | openssl base64) |
| curl --silent -X POST \ |
| --header "Accept:" \ |
| --header "X-CambriaDate: ${DATE}" \ |
| --header "X-CambriaAuth: ${API_KEY}:${DATE_HASH}" \ |
| --header "Content-Type: application/json" \ |
| --data "${UPDATE_BODY}" \ |
| http://${BUS_HOST}:${BUS_PORT}/events/${TOPIC} |
| else |
| curl --silent -X POST \ |
| --header "Accept:" \ |
| --header "Content-Type: application/json" \ |
| --data "${UPDATE_BODY}" \ |
| http://${BUS_HOST}:${BUS_PORT}/events/${TOPIC} |
| fi |
| fi |