JenkinsfilePRCommentTrigger

#!groovy

timestamps {
    // canned CI_MESSAGE
    // Might just keep this for legacy reasons for now
    def CANNED_CI_MESSAGE = '{"commit":{"username":"zdohnal","stats":{"files":{"README.patches":{"deletions":0,"additions":30,"lines":30},"sources":{"deletions":1,"additions":1,"lines":2},"vim.spec":{"deletions":7,"additions":19,"lines":26},".gitignore":{"deletions":0,"additions":1,"lines":1},"vim-8.0-rhbz1365258.patch":{"deletions":0,"additions":12,"lines":12}},"total":{"deletions":8,"files":5,"additions":63,"lines":71}},"name":"Zdenek Dohnal","rev":"3ff427e02625f810a2cedb754342be44d6161b39","namespace":"rpms","agent":"zdohnal","summary":"Merge branch f25 into f26","repo":"vim","branch":"f26","seen":false,"path":"/srv/git/repositories/rpms/vim.git","message":"Merge branch \'f25\' into f26\n","email":"zdohnal@redhat.com"},"topic":"org.fedoraproject.prod.git.receive"}'

    def libraries = ['upstream-fedora-pipeline': ['master', 'https://github.com/CentOS-PaaS-SIG/upstream-fedora-pipeline.git'],
                     'contra-lib'              : ['master', 'https://github.com/openshift/contra-lib.git']]

    libraries.each { name, repo ->
        library identifier: "${name}@${repo[0]}",
                retriever: modernSCM([$class: 'GitSCMSource',
                                      remote: repo[1]])

    }

    //noinspection GroovyAssignabilityCheck
    properties(
            [
                    buildDiscarder(logRotator(artifactDaysToKeepStr: '', artifactNumToKeepStr: '100', daysToKeepStr: '', numToKeepStr: '100')),
                    pipelineTriggers(
                        [[$class: 'CIBuildTrigger',
                          noSquash: true,
                          providerData: [
                              $class: 'RabbitMQSubscriberProviderData',
                              name: 'FedoraMessaging',
                              overrides: [
                                  topic: 'org.fedoraproject.prod.pagure.pull-request.comment.added',
                                  queue: 'osci-pipelines-queue-9'
                              ],
                              checks: [
                                  [field: '$.pullrequest.project.namespace', expectedValue: 'rpms|tests'],
                                  [field: '$.pullrequest.status', expectedValue: 'Open']
                              ]
                          ]
                        ]]
                    ),

                    parameters(
                            [
                                    string(defaultValue: CANNED_CI_MESSAGE, description: 'CI_MESSAGE', name: 'CI_MESSAGE')
                            ]
                    )
            ]
    )

    def TRIGGER_RETRY_COUNT = 3
    def validMessage = true
    def testsExist = false
    def stepName = null

    node('master') {

        // pull in ciMetrics from ci-pipeline
        // ciMetrics.prefix = packagepipelineUtils.influxDBPrefix()
        // packagepipelineUtils.cimetrics = ciMetrics
        // def jobMeasurement = packagepipelineUtils.timedMeasurement()


        timeout(time: 30, unit: 'MINUTES') {

            packagepipelineUtils.ciPipeline {
                try {
                    stepName = 'fedora-pr-pipeline-trigger'
                    stage(stepName) {

                        packagepipelineUtils.handlePipelineStep(stepName: stepName, debug: true) {

                            print "CI_MESSAGE"
                            print CI_MESSAGE

                            packagepipelineUtils.setDefaultEnvVars()
                            parsedMsg = kojiMessage(message: env.CI_MESSAGE, ignoreErrors: true)
                            currentBuild.displayName = "BUILD#: ${env.BUILD_NUMBER} - Branch: ${parsedMsg['pullrequest']['branch']} - Package: ${parsedMsg['pullrequest']['project']['name']}"
                            validMessage = packagepipelineUtils.checkBranch(parsedMsg['pullrequest']['branch'])
                            // Function only returns false if comments exist,
                            // but the latest was uninteresting
                            commentTrigger = contraUtils.checkUpdatedPR(env.CI_MESSAGE, '[citest]')
                            if (validMessage && commentTrigger) {
                                testsExist = contraUtils.checkTests(parsedMsg['pullrequest']['project']['name'], parsedMsg['pullrequest']['branch'], 'classic', parsedMsg['pullrequest']['id'].toString(), parsedMsg['pullrequest']['project']['namespace'])
                            }
                        }
                    }

                    if (validMessage && testsExist && commentTrigger) {
                        // Send message org.centos.prod.ci.dist-git-pr.test.queued on fedmsg
                        messageFields = packagepipelineUtils.setMessageFields("queued", "dist-git-pr", parsedMsg)
                        contraUtils.sendMessage(messageFields['topic'], messageFields['properties'], messageFields['content'])

                        stepName = 'schedule build'
                        stage(stepName) {

                            try {
                                retry(TRIGGER_RETRY_COUNT) {
                                    packagepipelineUtils.handlePipelineStep(stepName: stepName, debug: true) {
                                        branch = (parsedMsg['pullrequest']['branch'] == 'master') ? 'rawhide' : parsedMsg['pullrequest']['branch']
                                        build job: "fedora-${branch}-pr-pipeline",
                                                parameters: [string(name: 'CI_MESSAGE', value: env.CI_MESSAGE),
                                                             string(name: 'pipelineId', value: UUID.randomUUID().toString())],
                                                wait: false
                                    }

                                }
                            } catch (Throwable err) {
                                currentBuild.description = "*TRIGGER FAILURE*"
                                error "Error: Build could not be added to queue after " + TRIGGER_RETRY_COUNT + " tries"
                                throw err
                            }
                        }

                    } else {
                        echo "CI_MESSAGE was invalid. Skipping..."
                        currentBuild.description = "*Build Skipped*"
                    }

                    currentBuild.result = 'SUCCESS'

                } catch (Throwable err) {
                    currentBuild.result = 'FAILURE'
                    throw err

                } // finally {
                    // set the metrics we want
                    // ciMetrics.setMetricTag(jobMeasurement, 'package_name', env.fed_repo)
                    // ciMetrics.setMetricTag(jobMeasurement, 'build_result', currentBuild.result)
                    // ciMetrics.setMetricField(jobMeasurement, 'build_time', currentBuild.getDuration())
                // }
            }
        }
    }
}