-
Notifications
You must be signed in to change notification settings - Fork 16
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge branch 'develop' of https://github.com/credebl/platform into qa
- Loading branch information
Showing
6 changed files
with
323 additions
and
13 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
259 changes: 259 additions & 0 deletions
259
apps/agent-provisioning/AFJ/scripts/docker_start_agent.sh
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,259 @@ | ||
| #!/bin/sh | ||
|
|
||
| START_TIME=$(date +%s) | ||
|
|
||
| AGENCY=$1 | ||
| EXTERNAL_IP=$2 | ||
| WALLET_NAME=$3 | ||
| WALLET_PASSWORD=$4 | ||
| RANDOM_SEED=$5 | ||
| WEBHOOK_HOST=$6 | ||
| WALLET_STORAGE_HOST=$7 | ||
| WALLET_STORAGE_PORT=$8 | ||
| WALLET_STORAGE_USER=$9 | ||
| WALLET_STORAGE_PASSWORD=${10} | ||
| CONTAINER_NAME=${11} | ||
| PROTOCOL=${12} | ||
| TENANT=${13} | ||
| AFJ_VERSION=${14} | ||
| INDY_LEDGER=${15} | ||
|
|
||
| echo "AGENCY: $AGENCY" | ||
| echo "EXTERNAL_IP: $EXTERNAL_IP" | ||
| echo "WALLET_NAME: $WALLET_NAME" | ||
| echo "WALLET_PASSWORD: $WALLET_PASSWORD" | ||
| echo "RANDOM_SEED: $RANDOM_SEED" | ||
| echo "WEBHOOK_HOST: $WEBHOOK_HOST" | ||
| echo "WALLET_STORAGE_HOST: $WALLET_STORAGE_HOST" | ||
| echo "WALLET_STORAGE_PORT: $WALLET_STORAGE_PORT" | ||
| echo "WALLET_STORAGE_USER: $WALLET_STORAGE_USER" | ||
| echo "WALLET_STORAGE_PASSWORD: $WALLET_STORAGE_PASSWORD" | ||
| echo "CONTAINER_NAME: $CONTAINER_NAME" | ||
| echo "PROTOCOL: $PROTOCOL" | ||
| echo "TENANT: $TENANT" | ||
| echo "AFJ_VERSION: $AFJ_VERSION" | ||
| echo "INDY_LEDGER: $INDY_LEDGER" | ||
|
|
||
| ADMIN_PORT_FILE="$PWD/agent-provisioning/AFJ/port-file/last-admin-port.txt" | ||
| INBOUND_PORT_FILE="$PWD/agent-provisioning/AFJ/port-file/last-inbound-port.txt" | ||
| ADMIN_PORT=8001 | ||
| INBOUND_PORT=9001 | ||
|
|
||
| increment_port() { | ||
| local port="$1" | ||
| local lower_limit="$2" | ||
|
|
||
| while [ "$port" -le "$lower_limit" ]; do | ||
| port=$((port + 1)) # Increment the port using arithmetic expansion | ||
| done | ||
|
|
||
| echo "$port" | ||
| } | ||
|
|
||
| # Check if admin port file exists and if not, create and initialize it | ||
| if [ ! -e "$ADMIN_PORT_FILE" ]; then | ||
| echo "$ADMIN_PORT" > "$ADMIN_PORT_FILE" | ||
| fi | ||
|
|
||
| # Read the last used admin port number from the file | ||
| last_used_admin_port=$(cat "$ADMIN_PORT_FILE") | ||
| echo "Last used admin port: $last_used_admin_port" | ||
|
|
||
| # Increment the admin port number starting from the last used port | ||
| last_used_admin_port=$(increment_port "$last_used_admin_port" "$last_used_admin_port") | ||
|
|
||
| # Save the updated admin port number back to the file and update the global variable | ||
| echo "$last_used_admin_port" > "$ADMIN_PORT_FILE" | ||
| ADMIN_PORT="$last_used_admin_port" | ||
|
|
||
| # Check if inbound port file exists and if not, create and initialize it | ||
| if [ ! -e "$INBOUND_PORT_FILE" ]; then | ||
| echo "$INBOUND_PORT" > "$INBOUND_PORT_FILE" | ||
| fi | ||
|
|
||
| # Read the last used inbound port number from the file | ||
| last_used_inbound_port=$(cat "$INBOUND_PORT_FILE") | ||
| echo "Last used inbound port: $last_used_inbound_port" | ||
|
|
||
| # Increment the inbound port number starting from the last used port | ||
| last_used_inbound_port=$(increment_port "$last_used_inbound_port" "$last_used_inbound_port") | ||
|
|
||
| # Save the updated inbound port number back to the file and update the global variable | ||
| echo "$last_used_inbound_port" > "$INBOUND_PORT_FILE" | ||
| INBOUND_PORT="$last_used_inbound_port" | ||
|
|
||
| echo "Last used admin port: $ADMIN_PORT" | ||
| echo "Last used inbound port: $INBOUND_PORT" | ||
|
|
||
| echo "AGENT SPIN-UP STARTED" | ||
|
|
||
| if [ -d "${PWD}/agent-provisioning/AFJ/endpoints" ]; then | ||
| echo "Endpoints directory exists." | ||
| else | ||
| echo "Error: Endpoints directory does not exists." | ||
| mkdir ${PWD}/agent-provisioning/AFJ/endpoints | ||
| fi | ||
|
|
||
| if [ -d "${PWD}/agent-provisioning/AFJ/agent-config" ]; then | ||
| echo "Endpoints directory exists." | ||
| else | ||
| echo "Error: Endpoints directory does not exists." | ||
| mkdir ${PWD}/agent-provisioning/AFJ/agent-config | ||
| fi | ||
|
|
||
| AGENT_ENDPOINT="${PROTOCOL}://${EXTERNAL_IP}:${INBOUND_PORT}" | ||
|
|
||
| echo "-----$AGENT_ENDPOINT----" | ||
| CONFIG_FILE="${PWD}/agent-provisioning/AFJ/agent-config/${AGENCY}_${CONTAINER_NAME}.json" | ||
|
|
||
| # Check if the file exists | ||
| if [ -f "$CONFIG_FILE" ]; then | ||
| # If it exists, remove the file | ||
| rm "$CONFIG_FILE" | ||
| fi | ||
|
|
||
|
|
||
| cat <<EOF >${CONFIG_FILE} | ||
| { | ||
| "label": "${AGENCY}_${CONTAINER_NAME}", | ||
| "walletId": "$WALLET_NAME", | ||
| "walletKey": "$WALLET_PASSWORD", | ||
| "walletType": "postgres", | ||
| "walletUrl": "$WALLET_STORAGE_HOST:$WALLET_STORAGE_PORT", | ||
| "walletAccount": "$WALLET_STORAGE_USER", | ||
| "walletPassword": "$WALLET_STORAGE_PASSWORD", | ||
| "walletAdminAccount": "$WALLET_STORAGE_USER", | ||
| "walletAdminPassword": "$WALLET_STORAGE_PASSWORD", | ||
| "walletScheme": "DatabasePerWallet", | ||
| "indyLedger": $INDY_LEDGER, | ||
| "endpoint": [ | ||
| "$AGENT_ENDPOINT" | ||
| ], | ||
| "autoAcceptConnections": true, | ||
| "autoAcceptCredentials": "contentApproved", | ||
| "autoAcceptProofs": "contentApproved", | ||
| "logLevel": 5, | ||
| "inboundTransport": [ | ||
| { | ||
| "transport": "$PROTOCOL", | ||
| "port": "$INBOUND_PORT" | ||
| } | ||
| ], | ||
| "outboundTransport": [ | ||
| "$PROTOCOL" | ||
| ], | ||
| "webhookUrl": "$WEBHOOK_HOST/wh/$AGENCY", | ||
| "adminPort": "$ADMIN_PORT", | ||
| "tenancy": $TENANT | ||
| } | ||
| EOF | ||
|
|
||
| FILE_NAME="docker-compose_${AGENCY}_${CONTAINER_NAME}.yaml" | ||
|
|
||
| DOCKER_COMPOSE="${PWD}/agent-provisioning/AFJ/${FILE_NAME}" | ||
|
|
||
| # Check if the file exists | ||
| if [ -f "$DOCKER_COMPOSE" ]; then | ||
| # If it exists, remove the file | ||
| rm "$DOCKER_COMPOSE" | ||
| fi | ||
| echo ${PWD} | ||
| cat <<EOF >${DOCKER_COMPOSE} | ||
| version: '3' | ||
| services: | ||
| agent: | ||
| image: $AFJ_VERSION | ||
| container_name: ${AGENCY}_${CONTAINER_NAME} | ||
| restart: always | ||
| environment: | ||
| AFJ_REST_LOG_LEVEL: 1 | ||
| ROOT_PATH: ${ROOT_PATH} | ||
| ports: | ||
| - ${INBOUND_PORT}:${INBOUND_PORT} | ||
| - ${ADMIN_PORT}:${ADMIN_PORT} | ||
| volumes: | ||
| - ${ROOT_PATH}:/agent-config | ||
| command: --auto-accept-connections --config /agent-config/${AGENCY}_${CONTAINER_NAME}.json | ||
| volumes: | ||
| pgdata: | ||
| agent-indy_client: | ||
| agent-tmp: | ||
| EOF | ||
|
|
||
| if [ $? -eq 0 ]; then | ||
| cd agent-provisioning/AFJ | ||
| echo "docker-compose generated successfully!" | ||
| echo "=================" | ||
| echo "spinning up the container" | ||
| echo "=================" | ||
| echo "container-name::::::${CONTAINER_NAME}" | ||
| echo "file-name::::::$FILE_NAME" | ||
|
|
||
| docker compose -f $FILE_NAME up -d | ||
| if [ $? -eq 0 ]; then | ||
|
|
||
| n=0 | ||
| until [ "$n" -ge 6 ]; do | ||
| if netstat -tln | grep ${ADMIN_PORT} >/dev/null; then | ||
|
|
||
| AGENTURL="http://${EXTERNAL_IP}:${ADMIN_PORT}/agent" | ||
| agentResponse=$(curl -s -o /dev/null -w "%{http_code}" $AGENTURL) | ||
|
|
||
| if [ "$agentResponse" = "200" ]; then | ||
| echo "Agent is running" && break | ||
| else | ||
| echo "Agent is not running" | ||
| n=$((n + 1)) | ||
| sleep 10 | ||
| fi | ||
| else | ||
| echo "No response from agent" | ||
| n=$((n + 1)) | ||
| sleep 10 | ||
| fi | ||
| done | ||
|
|
||
| echo "Creating agent config" | ||
| # Capture the logs from the container | ||
| container_logs=$(docker logs $(docker ps -q --filter "name=${AGENCY}_${CONTAINER_NAME}")) | ||
|
|
||
| # Extract the token from the logs using sed | ||
| token=$(echo "$container_logs" | sed -nE 's/.*API Toekn: ([^ ]+).*/\1/p') | ||
|
|
||
| # Print the extracted token | ||
| echo "Token: $token" | ||
|
|
||
| ENDPOINT="${PWD}/endpoints/${AGENCY}_${CONTAINER_NAME}.json" | ||
|
|
||
| # Check if the file exists | ||
| if [ -f "$ENDPOINT" ]; then | ||
| # If it exists, remove the file | ||
| rm "$ENDPOINT" | ||
| fi | ||
| cat <<EOF >${ENDPOINT} | ||
| { | ||
| "CONTROLLER_ENDPOINT":"${EXTERNAL_IP}:${ADMIN_PORT}" | ||
| } | ||
| EOF | ||
|
|
||
| cat <<EOF >${PWD}/token/${AGENCY}_${CONTAINER_NAME}.json | ||
| { | ||
| "token" : "$token" | ||
| } | ||
| EOF | ||
| echo "Agent config created" | ||
| else | ||
| echo "===============" | ||
| echo "ERROR : Failed to spin up the agent!" | ||
| echo "===============" && exit 125 | ||
| fi | ||
| else | ||
| echo "ERROR : Failed to execute!" && exit 125 | ||
| fi | ||
|
|
||
| echo "Total time elapsed: $(date -ud "@$(($(date +%s) - $START_TIME))" +%T) (HH:MM:SS)" |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1,4 +1,4 @@ | ||
| #!/bin/bash | ||
| #!/bin/sh | ||
|
|
||
| START_TIME=$(date +%s) | ||
|
|
||
|
|
||
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.