analis-wineservice/updateToTargetVersionJenkinsfile

def ENAMES = [ 'prod-open', 'prod' ]
//def def ENAMES = [ 'dev-open', 'dev' ]
def CLUSTERS = ['prod': 'iru-swarm.infoclinica.lan',
                'prod-open': 'iru-swarm1-open.infoclinica.ru',
                'dev': 'dev-iru-swarm.infoclinica.lan',
                'dev-open': 'dev-iru-swarm1-open.infoclinica.lan']
def REGISTRIES = ['prod': 'registry.infoclinica.ru:5000',
                  'prod-open': 'registry.infoclinica.ru:5000',
                  'dev': 'dev-registry.infoclinica.ru:5000',
                  'dev-open': 'dev-registry.infoclinica.ru:5000']
def DHOST = ['prod': 'tcp://iru-swarm.infoclinica.lan:2376',
             'prod-open': 'tcp://iru-swarm1-open.infoclinica.ru:2376',
             'dev': 'tcp://dev-iru-swarm.infoclinica.lan:2376',
             'dev-open': 'tcp://dev-iru-swarm1-open.infoclinica.lan:2376']

def LIST_SERVICE = [:]
def TO_ROLLBACK = [:]
def ERROR_JOB
def VERSION_TO_UPDATE
pipeline {
  agent {
    label "swarm"
  }
  environment {
    SWARM_GIT_URL='ssh://git@git.sdsys.ru:8022/labportal/stack-deploy.git'
    SWARM_GIT_NAME='stack-deploy'
    JENKINS_MAIL='jenkins.dev@sdsys.ru'
    DOCKER_CERT_PATH='/run/secrets/swarm'
    DOCKER_IMAGE='analis-wineservice'
    SERVICE_LABEL='analis-std'
    STACK_LABEL='analis-wineservice'
  }
  parameters {
    string(
      name: "mailto",
      defaultValue: "admin.v@sdsys.ru",
      description: "Email which has to be notified."
    )
    string(
      name: "toVersion",
      defaultValue: "",
      description: "What version to update?"
    )
  }
  stages {
    stage("Git Pull. Define Version to Update") {
      steps {
        script {
          withCredentials([sshUserPrivateKey(credentialsId: 'provision', keyFileVariable: 'GIT_SSH_KEY', passphraseVariable: '', usernameVariable: 'GIT_SSH_USERNAME')]) {
            sh """set +x && GIT_SSH_COMMAND='ssh -i ${GIT_SSH_KEY} -o UserKnownHostsFile=/dev/null -o StrictHostKeyChecking=no' \
                    git clone ${SWARM_GIT_URL}
               """
            sh "set +x && echo \"Update version of Apps to $toVersion\" > commit.txt"
          }
        }
      }
    }
    stage("Get Names Of Running Services") {
      steps {
        script {
          ENAMES.each { item ->
            echo "Viewing: ${item} services, on ${CLUSTERS.get((item))}"
            LIST_SERVICE[item] = sh (script: "set +x && DOCKER_HOST=${DHOST.get((item))} DOCKER_TLS_VERIFY=1 docker service ls -f \
              label=com.docker.stack.namespace=$STACK_LABEL -f \
              label=ru.infoclinica.service=$SERVICE_LABEL --format '{{.Name}}'" , returnStdout: true).split('\n')
            echo "These services will be updated ${LIST_SERVICE.get(item)} to version $toVersion"
          }
        }
      }
    }
    stage("Update Services") {
      steps {
        script {
          ENAMES.each { item ->
            TO_ROLLBACK[item] = []
            try {
              for (name in LIST_SERVICE.get(item)) {
                TO_ROLLBACK[item].add(name)
                echo "Update service $name"
                sh "set +x && DOCKER_HOST=${DHOST.get((item))} DOCKER_TLS_VERIFY=1 docker service update \
                    $name --image ${REGISTRIES.get((item))}/lab/$DOCKER_IMAGE:$toVersion"
              }
            }
            catch (err) {
              def STABLE_VERSION = sh (script: "set +x && cat $SWARM_GIT_NAME/tags/lab/analis-wineservice.stable-version" , returnStdout: true).trim()
              TO_ROLLBACK.each { target, value ->
                for (service_name in value) {
                  echo "Recoverig $service_name running in $target to $STABLE_VERSION"
                  sh "set +x && DOCKER_HOST=${DHOST.get((item))} DOCKER_TLS_VERIFY=1 docker service rollback $service_name"
                }
              }
              ERROR_JOB = TO_ROLLBACK[item][-1]
              currentBuild.result = 'FAILURE'
              error ("Failure on update $ERROR_JOB. The service(s) $ERROR_JOB was rollback!")
            }
          }
        }
      }
    }
    stage("Update Tags") {
      steps {
        script {
          def STABLE_VERSION = sh (script: "set +x && cat $SWARM_GIT_NAME/tags/lab/analis-wineservice.stable-version" , returnStdout: true).trim()
          def OLD_STABLE_VERSION = sh (script: "set +x && cat $SWARM_GIT_NAME/tags/lab/analis-wineservice.old-stable-version" , returnStdout: true).trim()
          sh "set +x && echo $STABLE_VERSION > $SWARM_GIT_NAME/tags/lab/analis-wineservice.old-stable-version"
          sh "set +x && echo $VERSION_TO_UPDATE > $SWARM_GIT_NAME/tags/lab/analis-wineservice.stable-version" 
        }
      }
    }
    stage("Push New Versions To Git") {
      steps {
        script {
          sh "cat commit.txt"
          sh "cat $SWARM_GIT_NAME/tags/lab/analis-wineservice.stable-version"
          sh "cat $SWARM_GIT_NAME/tags/lab/analis-wineservice.old-stable-version"
          withCredentials([sshUserPrivateKey(credentialsId: 'provision', keyFileVariable: 'GIT_SSH_KEY', passphraseVariable: '', usernameVariable: 'GIT_SSH_USERNAME')]) {
            sh """cd $SWARM_GIT_NAME
                  git add -A
                  git config --global user.email "${JENKINS_MAIL}"
                  git config --global user.name "Jenkins"
                  git commit -F ../commit.txt
                  GIT_SSH_COMMAND='ssh -i ${GIT_SSH_KEY} -o UserKnownHostsFile=/dev/null -o StrictHostKeyChecking=no' \
                  git push origin master
               """
          }
        }
      }
    }
  }
  post {
    always {
      echo "CleaningUp work directory"
      deleteDir()
    }
    failure {
      mail charset: 'UTF-8',
           subject: "Jenkins build ERROR",
           mimeType: 'text/html',
           to: "${mailto}",
           body: "<b>ATTENTION!!!</b> <br> <b>Failure update:</b> $ERROR_JOB <br><b>Was rollback:</b> $TO_ROLLBACK <b><br>Project Name:</b> ${env.JOB_NAME} <b><br>Build Number:</b> ${env.BUILD_NUMBER} <b><br>URL Build:</b> ${RUN_DISPLAY_URL}"
    }
  }
}