container('publish-images') {
    timeout(time: 15, unit: 'MINUTES') {
        dir ("docker/deploy/${env.BINRARY_VERSION}/${env.OS_NAME}") {
            def binaryPackage = "${PROJECT_NAME}-${PACKAGE_VERSION}.tar.gz"

            withCredentials([usernamePassword(credentialsId: "${params.JFROG_CREDENTIALS_ID}", usernameVariable: 'JFROG_USERNAME', passwordVariable: 'JFROG_PASSWORD')]) {
                def downloadStatus = sh(returnStatus: true, script: "curl -u${JFROG_USERNAME}:${JFROG_PASSWORD} -O ${params.JFROG_ARTFACTORY_URL}/milvus/package/${binaryPackage}")

                if (downloadStatus != 0) {
                    error("\" Download \" ${params.JFROG_ARTFACTORY_URL}/milvus/package/${binaryPackage} \" failed!")
                }
            }
            sh "tar zxvf ${binaryPackage}"
            def imageName = "${PROJECT_NAME}/engine:${DOCKER_VERSION}"

            try {
                def isExistSourceImage = sh(returnStatus: true, script: "docker inspect --type=image ${imageName} 2>&1 > /dev/null")
                if (isExistSourceImage == 0) {
                    def removeSourceImageStatus = sh(returnStatus: true, script: "docker rmi ${imageName}")
                }

                def customImage = docker.build("${imageName}")

                def isExistTargeImage = sh(returnStatus: true, script: "docker inspect --type=image ${params.DOKCER_REGISTRY_URL}/${imageName} 2>&1 > /dev/null")
                if (isExistTargeImage == 0) {
                    def removeTargeImageStatus = sh(returnStatus: true, script: "docker rmi ${params.DOKCER_REGISTRY_URL}/${imageName}")
                }

                docker.withRegistry("https://${params.DOKCER_REGISTRY_URL}", "${params.DOCKER_CREDENTIALS_ID}") {
                    customImage.push()
                }
            } catch (exc) {
                throw exc
            } finally {
                def isExistSourceImage = sh(returnStatus: true, script: "docker inspect --type=image ${imageName} 2>&1 > /dev/null")
                if (isExistSourceImage == 0) {
                    def removeSourceImageStatus = sh(returnStatus: true, script: "docker rmi ${imageName}")
                }

                def isExistTargeImage = sh(returnStatus: true, script: "docker inspect --type=image ${params.DOKCER_REGISTRY_URL}/${imageName} 2>&1 > /dev/null")
                if (isExistTargeImage == 0) {
                    def removeTargeImageStatus = sh(returnStatus: true, script: "docker rmi ${params.DOKCER_REGISTRY_URL}/${imageName}")
                }
            }
        } 
    }
}