Authors endpoint

Author: davguij

src/authors/authors.routes.js

@@ -0,0 +1,19 @@
+const slug = require('slug')
+
+const db = require('../connectors/db')
+const schema = require('./authors.schema')
+
+module.exports = async (fastify, options) => {
+  fastify.get('/authors', schema, async (req, reply) => {
+    const all = await db.getAll('author')
+    return all
+  })
+  fastify.post('/authors', async (req, reply) => {
+    const authorToSave = Object.assign({}, req.body, {
+      id: slug(req.body.display_name, { lower: true })
+    })
+    await db.saveOne('author', authorToSave)
+    reply.code(201)
+    return {}
+  })
+}

src/authors/authors.schema.js

@@ -0,0 +1,17 @@
+module.exports = {
+  schema: {
+    response: {
+      200: {
+        type: 'array',
+        items: {
+          type: 'object',
+          properties: {
+            id: { type: 'string' },
+            display_name: { type: 'string' },
+            email: { type: 'string', format: 'email' }
+          }
+        }
+      }
+    }
+  }
+}

src/authors/authors.spec.js

@@ -0,0 +1,58 @@
+const { test } = require('ava')
+const request = require('axios')
+const moment = require('moment')
+
+const server = require('../server')
+
+test.beforeEach(async t => {
+  // This runs after each test and other test hooks, even if they failed
+  const rdb = require('rethinkdbdash')({
+    servers: [{ host: process.env.RDB_HOST, port: process.env.RDB_PORT }]
+  })
+  const tableList = await rdb.tableList().run()
+  if (tableList.includes('author')) {
+    await rdb.tableDrop('author').run()
+  }
+})
+
+// Run the server
+server.start({ port: 0 }, (err, fastify) => {
+  test.serial(
+    'The authors endpoint should return an empty array when no entries are saved',
+    async t => {
+      if (err) t.fail()
+      const response = await request.get(
+        `http://localhost:${fastify.server.address().port}/authors`
+      )
+      t.is(response.status, 200)
+      t.deepEqual(response.data, [])
+    }
+  )
+
+  test.serial(
+    'The authors endpoint should accept a POST call with a new author',
+    async t => {
+      if (err) t.fail()
+      const input = {
+        display_name: 'David Guijarro',
+        email: '[email protected]'
+      }
+      const output = {
+        id: 'david-guijarro',
+        display_name: 'David Guijarro',
+        email: '[email protected]'
+      }
+
+      const postResponse = await request.post(
+        `http://localhost:${fastify.server.address().port}/authors`,
+        input
+      )
+      t.is(postResponse.status, 201)
+      const getResponse = await request.get(
+        `http://localhost:${fastify.server.address().port}/authors`
+      )
+      t.is(getResponse.status, 200)
+      t.deepEqual(getResponse.data, [output])
+    }
+  )
+})

src/entries/entries.routes.js

@@ -20,7 +20,7 @@ module.exports = async (fastify, options) => {
     //   }
     // ])
   })
-  fastify.post('/entries', schema, async (req, reply) => {
+  fastify.post('/entries', async (req, reply) => {
     const entryToSave = Object.assign({}, req.body, {
       id: slug(req.body.title, { lower: true }),
       cheers: 0,

src/server.js

@@ -5,7 +5,8 @@ const helmet = require('fastify-helmet')
 fastify.register(helmet)
 fastify.register([
   require('./status/status.routes'),
-  require('./entries/entries.routes')
+  require('./entries/entries.routes'),
+  require('./authors/authors.routes')
 ])
 
 const start = (opts, callback) => {