Merge pull request #1094 from 20minutes/feature/artifacts-function

Add artifacts function

Author: j0k3r

functions/artifacts.js

@@ -0,0 +1,18 @@
+import { ArtifactsHandler } from './classes/ArtifactsHandler'
+
+const artifacts = new ArtifactsHandler(
+  process.env.GITHUB_TOKEN,
+  process.env.NAMESPACE,
+  process.env.ARTIFACTS_REGEX
+)
+
+export async function handler(event, context, callback) {
+  if (event.headers?.['content-type'] === 'application/x-www-form-urlencoded') {
+    return callback(null, {
+      statusCode: 500,
+      body: 'Please choose "application/json" as Content type in the webhook definition (you should re-create it)',
+    })
+  }
+
+  return artifacts.handle(JSON.parse(event.body), callback)
+}

functions/classes/ArtifactsHandler.js

@@ -0,0 +1,74 @@
+import { Handler } from './Handler'
+
+export class ArtifactsHandler extends Handler {
+  constructor(githubToken, namespace = '', artifactsRegex = '') {
+    super(githubToken)
+
+    this.namespace = namespace
+    this.artifactsRegex = artifactsRegex
+  }
+
+  async handle(body, callback) {
+    let response = this.validateEvent(body)
+
+    if (response !== true) {
+      return callback(null, response)
+    }
+
+    console.log(`Working on repo ${body.repository.full_name} for PR #${body.pull_request.number}`)
+
+    const payload = {
+      success: {
+        state: 'success',
+        description: 'No artifacts found in deps',
+        context: `${this.namespace} - Artifacts check`,
+      },
+      failure: {
+        state: 'failure',
+        description: 'Artifacts found in deps, remove them to merge',
+        context: `${this.namespace} - Artifacts check`,
+      },
+    }
+
+    const files = await this.githubClient.rest.pulls.listFiles({
+      owner: body.repository.owner.login,
+      repo: body.repository.name,
+      pull_number: body.pull_request.number,
+    })
+
+    // loop through all files to see if package.json has been updated
+    const file = files.data.find(({ filename }) => filename.includes('package.json'))
+
+    if (!file) {
+      response = await this.updateStatus(body, payload.success)
+
+      return callback(null, response)
+    }
+
+    const refMatch = file.contents_url.match(/ref=([a-z0-9]+)/)
+    if (!refMatch?.[1]) {
+      response = await this.updateStatus(body, payload.success)
+
+      return callback(null, response)
+    }
+
+    const content = await this.githubClient.rest.repos.getContent({
+      owner: body.repository.owner.login,
+      repo: body.repository.name,
+      path: file.filename,
+      ref: refMatch[1],
+    })
+
+    const match = Buffer.from(content.data.content.toString('utf8'), 'base64')
+      .toString('ascii')
+      .match(this.artifactsRegex)
+
+    if (match === null) {
+      response = await this.updateStatus(body, payload.success)
+    } else {
+      response = await this.updateStatus(body, payload.failure)
+    }
+
+    return callback(null, response)
+  }
+}

functions/classes/FixupHandler.js

@@ -24,7 +24,7 @@ export class FixupHandler extends Handler {
       },
       failure: {
         state: 'failure',
-        description: 'Fixup commits in history, please squash them!',
+        description: 'Fixup commits in history, squash them to merge',
         context: `${this.namespace} - Fixup check`,
       },
     }

serverless.yml

@@ -83,3 +83,15 @@ functions:
                     path: webhook/auto-merge
                     method: post
                     cors: true
+
+    artifacts:
+        handler: functions/artifacts.handler
+        description: Check if an artifact in deps to block merge
+        environment:
+            ARTIFACTS_REGEX: '(fixtures\.20mn\.it|localhost:)'
+        events:
+            -
+                http:
+                    path: webhook/artifacts
+                    method: post
+                    cors: true