github webhooks pull_request

Author: zurfyx

docs/webhooks.md

@@ -2,6 +2,10 @@
 
 API webhooks available data, which depends on the event that generated it.
 
+The intention behind custom mappings was to reduce the huge amount of data that GitHub generates,
+and retrieve only the one that fits our needs.<br>
+Most of the resulting mappings are just reduced versions of the [GitHub's API v3](https://developer.github.com/v3/).
+
 ## GitHub
 
 ### issue_comment
@@ -61,6 +65,37 @@ Example output:
 }
 ```
 
+### pull_request
+
+Type: `github`<br>
+Event: `pull_request`
+
+Example output:
+
+```
+"_id": "1234abcd",
+"type": "github",
+"uid": "1234-abcd-1234-abcd",
+"github": {
+  "event": "pull_request",
+  "action": "opened",
+  "repository": "octocat/Hello_world",
+  "pull_request": {
+    "number": "1",
+    "state": "open",
+    "locked": false,
+    "title": "Changes",
+    "user": "octocat",
+    "body": "A lot of changes",
+    "merged": false,
+    "commits": 2,
+    "additions": 1000,
+    "deletions": 0,
+    "changed_files": 0
+  }
+}
+```
+
 ### push
 
 Type: `github`<br>

src/models/Webhook.js

@@ -28,6 +28,20 @@ const webhookSchema = new Schema({
       body: String, // 'i dun know'
     },
 
+    pull_request: {
+      number: Number,
+      state: String, // 'open'
+      locked: Boolean,
+      title: String,
+      user: String, // 'octocat'
+      body: String,
+      merged: Boolean,
+      commits: Number,
+      additions: Number,
+      deletions: Number,
+      changed_files: Number,
+    },
+
     commits: [{
       id: String,
       tree_id: String,

src/services/webhook.js

@@ -50,6 +50,27 @@ export function githubWebhook(event, uid, data) {
       };
       break;
     }
+    case 'pull_request': {
+      webhook.github = {
+        event,
+        action: data.action,
+        repository: data.repository.full_name,
+        pull_request: {
+          number: data.pull_request.number,
+          state: data.pull_request.state,
+          locked: data.pull_request.locked,
+          title: data.pull_request.title,
+          user: data.pull_request.user.login,
+          body: data.pull_request.body,
+          merged: data.pull_request.merged,
+          commits: data.pull_request.commits,
+          additions: data.pull_request.additions,
+          deletions: data.pull_request.deletions,
+          changed_files: data.pull_request.changed_files,
+        },
+      };
+      break;
+    }
     case 'push': {
       webhook.github = {
         event,

test/api/webhook.js

@@ -86,6 +86,33 @@ describe('Webhook', () => {
         });
     });
 
+    it('should create a Webhook entry if the request is valid (pull_request test)', (done) => {
+      request
+        .post(`${server}/webhooks/github`)
+        .set('X-Forwarded-For', GITHUB_VALID_IP)
+        .set('X-GitHub-Delivery', '1111')
+        .set('X-GitHub-Event', 'pull_request')
+        .send({
+          repository: { full_name: 'github/repo' },
+          pull_request: {
+            number: 1,
+            user: { login: 'octocat' },
+          },
+        })
+        .end((err, res) => {
+          expect(res.status).to.equal(200);
+          expect(res.body).to.eql({ message: 'OK' });
+          Webhook.findOne({}).exec().then((webhook) => {
+            expect(webhook.type).to.equal('github');
+            expect(webhook.uid).to.equal('1111');
+            expect(webhook.github.repository).to.equal('github/repo');
+            expect(webhook.github.pull_request.number).to.equal(1);
+            expect(webhook.github.pull_request.user).to.equal('octocat');
+            done();
+          });
+        });
+    });
+
     it('should create a Webhook entry if the request is valid (push test)', (done) => {
       request
         .post(`${server}/webhooks/github`)