Relay Jenkins events to Github Action workflows

lib/jenkins-events.js

@@ -3,7 +3,9 @@
 const pushJenkinsUpdate = require('../lib/push-jenkins-update')
 
 const debug = require('debug')('jenkins-events')
-const enabledRepos = ['citgm', 'http-parser', 'node', 'node-auto-test']
+const enabledRepos = process.env.JENKINS_ENABLED_REPOS
+  ? process.env.JENKINS_ENABLED_REPOS.split(',')
+  : ['citgm', 'http-parser', 'node', 'node-auto-test']
 
 const listOfKnownJenkinsIps = process.env.JENKINS_WORKER_IPS ? process.env.JENKINS_WORKER_IPS.split(',') : []
 
@@ -74,6 +76,7 @@ module.exports = (app, events) => {
     data.logger.info('Emitting Jenkins event')
     debug(data)
 
+    events.emit(`jenkins`, data)
     return events.emit(`jenkins.${event}`, data)
   }
 }

scripts/event-relay.js

@@ -0,0 +1,25 @@
+'use strict'
+
+const githubClient = require('../lib/github-client')
+
+async function handleJenkinsRelay (event) {
+  const { owner, repo, identifier } = event
+  const eventType = `jenkins.${identifier}.${event.event}`
+  try {
+    event.logger.debug(`Relaying ${eventType} to ${owner}/${repo}`)
+    await githubClient.repos.createDispatchEvent({
+      owner,
+      repo,
+      event_type: eventType,
+      client_payload: event
+    })
+    return true
+  } catch (err) {
+    event.logger.error(err, `Failed to relay ${eventType} to ${owner}/${repo}`)
+    return false
+  }
+}
+
+module.exports = function (_, event) {
+  event.on('jenkins', handleJenkinsRelay)
+}

test/integration/event-relay-to-github-actions.test.js

@@ -0,0 +1,38 @@
+'use strict'
+
+const tap = require('tap')
+const url = require('url')
+const nock = require('nock')
+const supertest = require('supertest')
+
+const { app, events } = require('../../app')
+
+const readFixture = require('../read-fixture')
+
+require('../../scripts/event-relay')(app, events)
+
+tap.test('Sends POST requests to https://api.github.com/repos/nodejs/<repo>/dispatches', (t) => {
+  const jenkinsPayload = readFixture('success-payload.json')
+
+  nock('https://api.github.com')
+    .filteringPath(ignoreQueryParams)
+    .post('/repos/nodejs/node/dispatches')
+    .reply(204)
+    .on('replied', (req, interceptor) => {
+      t.doesNotThrow(() => interceptor.scope.done())
+    })
+
+  t.plan(2)
+
+  supertest(app)
+    .post('/node/jenkins/start')
+    .send(jenkinsPayload)
+    .expect(200)
+    .end((err, res) => {
+      t.equal(err, null)
+    })
+})
+
+function ignoreQueryParams (pathAndQuery) {
+  return url.parse(pathAndQuery, true).pathname
+}