#!/bin/bash

tenant=${tenant}
#env=${env}
env="qa"
while [ $# -gt 0 ]; do
  if [[ $1 == *"--"* ]]; then
    param="${1/--/}"
    declare $param="$2"
  fi
  shift
done

if [ -z "$tenant" ]; then
  echo "--tenant is not set"
  exit 2
fi

if [ -z "$env" ]; then
  echo "--env is not set"
  exit 2
fi

containerId="$(docker ps | grep 'kafka_kafka-dev-1_1'  | sed 's/\|/ /'|awk '{print $1}')"
declare -a queues=("sms_message_order_" "sms_message_order_dlq_" "sms_message_order_reply_" "vpn_order_" "vpn_order_dlq_" "vpn_order_reply_" "billing_seller_order_" "billing_seller_order_reply_" "billing_account_order_" "billing_account_order_dlq_" "billing_account_order_reply_" "create_customer_hierarchy_" "create_customer_hierarchy_reply_" "billing_order_create_" "create_plan_" "create_plan_reply_" "create_plan_dlq_" "supplementary_plan_save_" "supplementary_plan_save_reply_" "supplementary_plan_save_dlq_" "ordering_submit_" "ordering_success_" "ordering_dlq_")

for queue in "${queues[@]}"; do
  if [ "$env" == "prod" ]; then
    queue=$queue
  elif [ "$env" == "qa" ]; then
    queue="qa_"$queue
  elif [ "$env" == "staging" ]; then
    queue="staging_"$queue
  else
    queue="development_"$queue
  fi
  queue=$queue$tenant
  echo "preparing to create queue: $queue"
  docker exec $containerId /opt/bitnami/kafka/bin/kafka-topics.sh --create --topic $queue --replication-factor 1 --partitions 1 --bootstrap-server 85.184.249.102:9092
done