Remove azure.

routes/middlewares/RepositoryFilter.js

@@ -22,15 +22,6 @@ 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,17 +36,6 @@ 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,7 +14,6 @@ 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');
@@ -48,19 +47,4 @@ 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;