Preliminary Azure DevOps support

Author: jmgasper

models/IssueClosedEvent.js

@@ -18,7 +18,7 @@ const IssueClosedEvent = {
     issue: issueSchema.required(),
     repository: repositorySchema.required(),
     assignee: Joi.object().keys({
-      id: Joi.number().allow(null)
+      id: Joi.alternatives().try(Joi.string(), Joi.number()).allow(null)
     }).required()
   })
 };

models/Project.js

@@ -30,6 +30,7 @@ const schema = new Schema({
     }
   },
   repoUrl: {type: String, required: true},
+  repoId: {type: String, required: false},
   rocketChatWebhook: {type: String, required: false},
   rocketChatChannelName: {type: String, required: false},
   archived: {type: String, required: true},

models/UserAssignedEvent.js

@@ -19,7 +19,7 @@ UserAssignedEvent.schema = Joi.object().keys({
   issue: issueSchema.required(),
   repository: repositorySchema.required(),
   assignee: Joi.object().keys({
-    id: Joi.number().required()
+    id: Joi.alternatives().try(Joi.string(), Joi.number()).required()
   }).required()
 });
 

models/common.js

@@ -16,7 +16,7 @@ const Joi = require('joi');
 
 // the repository schema
 const repositorySchema = Joi.object().keys({
-  id: Joi.number().required(),
+  id: Joi.alternatives().try(Joi.string(), Joi.number()).required(),
   name: Joi.string().required(),
   full_name: Joi.string().required()
 });
@@ -28,10 +28,10 @@ const issueSchema = Joi.object().keys({
   body: Joi.string().allow(''),
   labels: Joi.array().items(Joi.string()),
   assignees: Joi.array().items(Joi.object().keys({
-    id: Joi.number().required()
+    id: Joi.alternatives().try(Joi.string(), Joi.number()).required()
   })),
   owner: Joi.object().keys({
-    id: Joi.number().required()
+    id: Joi.alternatives().try(Joi.string(), Joi.number()).required()
   }).required()
 });
 
@@ -43,10 +43,10 @@ const pullRequestSchema = Joi.object().keys({
   body: Joi.string().allow(''),
   title: Joi.string().required(),
   user: Joi.object().keys({
-    id: Joi.number().required()
+    id: Joi.alternatives().try(Joi.string(), Joi.number()).required()
   }),
   assignees: Joi.array().items({
-    id: Joi.number().required()
+    id: Joi.alternatives().try(Joi.string(), Joi.number()).required()
   })
 });
 

models/index.js

@@ -31,7 +31,7 @@ dynamoose.setDefaults({
 if (process.env.CREATE_DB) {
   dynamoose.setDefaults({
     create: true,
-    update: true,
+    update: true
   });
 }
 

routes/middlewares/RepositoryFilter.js

@@ -22,6 +22,15 @@ module.exports = (provider) => async (req, res, next) => {
   } else if (provider === 'gitlab') {
     const repo = req.body.project || {};
     repoNames = [repo.homepage, repo.http_url, repo.url, repo.ssh_url, repo.web_url];
+  } else if (provider === 'azure') {
+    const projectId = req.body.resourceContainers.project.id;
+    const projects = await dbHelper.scan(Project, {
+      repoId: projectId,
+      archived: 'false'
+    });
+    if (projects && projects.length > 0) {
+      return next();
+    }
   }
   const projects = await dbHelper.scan(Project, {
     archived: 'false'

routes/middlewares/SecurityChecker.js

@@ -36,6 +36,17 @@ module.exports = (provider) => async (req, res, next) => {
         isValid = true;
       }
     });
+  } else if (provider === 'azure') {
+    const projectId = req.body.resourceContainers.project.id;
+    const project = await dbHelper.scanOne(Project, {
+      repoId: projectId
+    });
+    const buff = Buffer.from(req.headers.authorization.split(' ')[1], 'base64'); // Ta-da
+    const authorization = buff.toString('utf-8');
+    const pwd = authorization.split(':')[1];
+    if (pwd === project.secretWebhookKey) {
+      isValid = true;
+    }
   } else {
     // unknown provider
     return next();

routes/webhooks.js

@@ -14,6 +14,7 @@ const logger = require('../utils/logger');
 const kafka = require('../utils/kafka');
 const GithubEventDetector = require('../utils/GithubEventDetector');
 const GitlabEventDetector = require('../utils/GitlabEventDetector');
+const AzureEventDetector = require('../utils/AzureEventDetector');
 
 const RepositoryFilter = require('./middlewares/RepositoryFilter');
 const SecurityChecker = require('./middlewares/SecurityChecker');
@@ -47,4 +48,19 @@ router.post('/gitlab', SecurityChecker('gitlab'), RepositoryFilter('gitlab'), wr
   res.json({success: true});
 }));
 
+router.post('/azure', SecurityChecker('azure'), RepositoryFilter('azure'), wrapper(async (req, res) => {
+  const result = AzureEventDetector.detectMany(req.body);
+  if (!result || result.length === 0) {
+    logger.info('unknown event detected');
+    logger.debug(req.body);
+  } else {
+    for (const event of result) { // eslint-disable-line no-restricted-syntax
+      await kafka.send(JSON.stringify(event));
+      logger.info(`successfully add event: ${event.event} to kafka queue`);
+      logger.debug(`kafka message: ${JSON.stringify(event)}`);
+    }
+  }
+  res.json({success: true});
+}));
+
 module.exports = router;