Merge pull request #56 from greenkeeperio/feat/sync

feat: add sync hook

Author: janl

index.js

@@ -57,6 +57,12 @@ require('./lib/rollbar')
       env,
       channel
     }
+  }, {
+    register: require('./lib/sync-event'),
+    options: {
+      env,
+      channel
+    }
   }, {
     register: require('./lib/update-node-event'),
     options: {

lib/sync-event.js

@@ -0,0 +1,52 @@
+const _ = require('lodash')
+const Boom = require('boom')
+
+const rollbar = require('./rollbar')
+
+module.exports = resetEvent
+module.exports.attributes = {
+  name: 'sync'
+}
+
+function resetEvent (server, {env, channel}, next) {
+  server.route({
+    method: 'POST',
+    path: '/sync',
+    config: {
+      pre: [{method: (request, reply) => {
+        if (request.headers['bearer-token'] === env.BEARER_TOKEN) {
+          return reply.continue()
+        }
+        return reply(Boom.unauthorized())
+      }}]
+    },
+    handler
+  })
+
+  async function handler (request, reply) {
+    if (!_.get(request, 'payload.accountId')) return reply({error: 'accountId missing'}).code(400)
+
+    const job = {
+      name: 'sync-repos',
+      accountId: request.payload.accountId
+    }
+
+    try {
+      await channel.sendToQueue(env.QUEUE_NAME, Buffer.from(JSON.stringify(job)), {priority: 5})
+    } catch (err) {
+      rollbar.error(err, _.assign({}, request.raw.req, {
+        socket: {
+          encrypted: request.server.info.protocol === 'https'
+        },
+        connection: {
+          remoteAddress: request.info.remoteAddress
+        }
+      }))
+      return reply({error: true}).code(500)
+    }
+
+    reply({ok: true}).code(202)
+  }
+
+  next()
+}