blob: fc822e186e513964487e5bcd91393ac5dcce4a19 [file] [log] [blame]
#! /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