Merge pull request #13 from domapic/services-api

Services api

.narval.yml

@@ -117,6 +117,15 @@ suites:
         specs:
           - test/functional/specs/authentication-api.specs.js
       coverage: *base-coverage
+    - name: services
+      describe: Services api should work as expected
+      before: *base-before
+      services: *base-services
+      test: 
+        <<: *base-test
+        specs:
+          - test/functional/specs/services-api.specs.js
+      coverage: *base-coverage
     - name: users-cli
       describe: Users cli should be able to add and remove users
       before: *base-before

cli/commands/user.js

@@ -7,7 +7,8 @@ const autocomplete = require('inquirer-autocomplete-prompt')
 const lib = require('../../lib')
 const templates = require('../../lib/templates')
 const { roles } = require('../../lib/security/utils')
-const { isValidEmail, isValidName } = require('../../lib/models/user')
+const { isValidEmail } = require('../../lib/models/user')
+const { isValidName } = require('../../lib/utils')
 
 inquirer.registerPrompt('autocomplete', autocomplete)
 

lib/Api.js

@@ -2,15 +2,18 @@
 
 const users = require('./api/users')
 const securityTokens = require('./api/securityTokens')
+const services = require('./api/services')
 
 const Api = (service, commands) => ({
   openapis: [
     ...users.openapi(),
-    ...securityTokens.openapi()
+    ...securityTokens.openapi(),
+    ...services.openapi()
   ],
   operations: {
     ...users.Operations(service, commands),
-    ...securityTokens.Operations(service, commands)
+    ...securityTokens.Operations(service, commands),
+    ...services.Operations(service, commands)
   }
 })
 

lib/Commands.js

@@ -3,11 +3,13 @@
 const user = require('./commands/user')
 const securityToken = require('./commands/securityToken')
 const composed = require('./commands/composed')
+const serviceCommand = require('./commands/service')
 
 const Commands = (service, models, client) => {
   const commands = {
     user: user.Commands(service, models, client),
-    securityToken: securityToken.Commands(service, models, client)
+    securityToken: securityToken.Commands(service, models, client),
+    service: serviceCommand.Commands(service, models, client)
   }
 
   return {

lib/Models.js

@@ -2,10 +2,12 @@
 
 const user = require('./models/user')
 const securityToken = require('./models/securityToken')
+const serviceModel = require('./models/service')
 
 const Models = service => ({
   User: user.Model(service),
-  SecurityToken: securityToken.Model(service)
+  SecurityToken: securityToken.Model(service),
+  Service: serviceModel.Model(service)
 })
 
 module.exports = Models

lib/api/securityTokens.js

@@ -28,7 +28,7 @@ const Operations = (service, commands) => ({
         type: params.query.type,
         _user: params.query.user
       }, isUndefined)
-      return commands.securityToken.getAll(filter)
+      return commands.securityToken.getFiltered(filter)
     }
   }
 })

lib/api/services.js

@@ -0,0 +1,71 @@
+'use strict'
+
+const { omitBy, isUndefined } = require('lodash')
+
+const definition = require('./services.json')
+const { roles } = require('../security/utils')
+
+const Operations = (service, commands) => {
+  const authService = (userData, params, body) => {
+    if (userData.role === roles.ADMIN || userData.role === roles.SERVICE_REGISTERER) {
+      return true
+    }
+    return commands.service.get({
+      name: params.path.name
+    }).then(serviceData => {
+      if (serviceData._user === userData._id) {
+        return Promise.resolve()
+      }
+      return Promise.reject(new service.errors.Forbidden())
+    })
+  }
+
+  return {
+    getServices: {
+      auth: (userData, params, body) => {
+        if (userData.role === roles.ADMIN || userData.role === roles.SERVICE_REGISTERER || userData._id.toString() === params.query.user) {
+          return true
+        }
+        return false
+      },
+      handler: (params, body, res) => {
+        const filter = omitBy({
+          _user: params.query.user
+        }, isUndefined)
+        return commands.service.getFiltered(filter)
+      }
+    },
+    getService: {
+      auth: authService,
+      handler: (params, body, res) => commands.service.get({
+        name: params.path.name
+      })
+    },
+    updateService: {
+      auth: authService,
+      handler: (params, body, res) => commands.service.update(params.path.name, body).then(serviceData => {
+        res.status(204)
+        res.header('location', `/api/services/${serviceData.name}`)
+        return Promise.resolve()
+      })
+    },
+    addService: {
+      auth: (userData, params, body) => (
+        userData.role === roles.ADMIN || userData.role === roles.SERVICE_REGISTERER || userData._id.toString() === body._user
+      ),
+      handler: (params, body, res) => commands.service.add(body)
+        .then(serviceData => {
+          res.status(201)
+          res.header('location', `/api/services/${serviceData.name}`)
+          return Promise.resolve()
+        })
+    }
+  }
+}
+
+const openapi = () => [definition]
+
+module.exports = {
+  Operations,
+  openapi
+}