dev.sh

#!/bin/bash
 
 PUBLISH_TOPIC=gateway.publish
 SUBSCRIBE_TOPIC=gateway.subscribe
 SUBSCRIBE_GROUP_ID=gateway
 TIMEOUT=30
 
 DOCKER_IMAGE=s7i/kafka-gateway
 DOCKER_NETWORK=dev-network

main () {

    case $1 in
        run)
            run $2
            ;;
        dr)
            dockerRun $2
            ;;
        db)
            dockerBuild
            ;;
        win)
            buildWindwsBins
            ;;
        test)
            runTest
            ;;
        *)
        badOpt $@
    esac

}

function asYaml() {
    cat <<EOF
app:
  port: 8080
  timeout: ${TIMEOUT}
  jwt-chk: false
  id-gen-type: uuid
  context: /
pub:
  topic: ${PUBLISH_TOPIC}
  properties:
   - "bootstrap.servers=${BROKER}"
sub:
  topic: ${SUBSCRIBE_TOPIC}
  properties:
   - "bootstrap.servers=${BROKER}"
   - "group.id=${SUBSCRIBE_GROUP_ID}"
   - "auto.offset.reset=earliest"

EOF
}

badOpt() {
    echo bad options: $@
}

run() {
    export BROKER=$1
    export PUBLISH_TOPIC=$PUBLISH_TOPIC
    export SUBSCRIBE_TOPIC=$SUBSCRIBE_TOPIC
    export SUBSCRIBE_GROUP_ID=$SUBSCRIBE_GROUP_ID
    export TIMEOUT=$TIMEOUT
    ./kafka-gateway
}

dockerRun() {
    docker run \
     --name kafka-gateway \
     -p 8080:8080 \
     -e BROKER=$1 \
     -e PUBLISH_TOPIC=$PUBLISH_TOPIC \
     -e SUBSCRIBE_TOPIC=$SUBSCRIBE_TOPIC \
     -e SUBSCRIBE_GROUP_ID=$SUBSCRIBE_GROUP_ID \
     -e TIMEOUT=$TIMEOUT \
     --network $DOCKER_NETWORK\
     -it --rm $DOCKER_IMAGE
}

dockerBuild() {
    local VCS_REF=$(git_ref)

    echo "[Docker Build] tag: $DOCKER_IMAGE, git-ref: $VCS_REF"

    docker build -t $DOCKER_IMAGE --build-arg BUILD_DATE="$(date +"%Y-%m-%dT%H:%M:%S%z")" --build-arg VCS="$VCS_REF" .
}

buildWindwsBins() {
    GOOS=windows GOARCH=amd64 go build -o bin/gateway-amd64.exe
}

runTest() {
    go test -v -timeout 30s ./internal/*
}

git_ref() {
    echo "$(git rev-parse --abbrev-ref HEAD) @ $(git rev-parse HEAD)"
}

main $@