Implement read

Author: doesdev

index.js

@@ -65,6 +65,8 @@ const bodyParse = (req) => new Promise((resolve, reject) => {
   req.on('end', () => resolve(body ? JSON.parse(body) : {}))
 })
 
+const noIdErr = () => JSON.stringify(new Error('no id passed'))
+
 // exports
 module.exports = {register, start, logger, _find, _findAll, _create, _save}
 
@@ -119,7 +121,11 @@ function handleRequest (req, res) {
 function logger () { return null }
 
 // helper: find resource
-function _find () { return null }
+function _find (resource, id) {
+  let attrs = {id_array: [id]}
+  let firstRecord = (d) => Promise.resolve(d[0])
+  return callPgFunc(`${pgPrefix}${resource}_read`, attrs).then(firstRecord)
+}
 
 // helper: find set of resources
 function _findAll () { return null }
@@ -152,7 +158,14 @@ function resourceCreate (req, res, name) {
 
 // resource method: read
 function resourceRead (req, res, name) {
-  return res.end(`{"data": null, "error": null}`)
+  if (!req.id && req.id !== 0) {
+    return res.end(`{"data": null, "error": ${noIdErr()}}`)
+  }
+  _find(name, req.id).then((d) => {
+    return res.end(`{"data": ${JSON.stringify(d)}, "error": null}`)
+  }).catch((err) => {
+    return res.end(`{"data": null, "error": ${JSON.stringify(err)}}`)
+  })
 }
 
 // resource method: update

test/index.js

@@ -27,12 +27,13 @@ test('scrud actions are handled as expected', async (assert) => {
   let s = await axios({method: 'GET', url: `${base}${sParams}`})
   assert.is(s.headers.scrud, 'member:search')
   let c = await axios({method: 'POST', url: `${base}`, data: postBody})
+  let id = c.data.data.id
   assert.is(c.headers.scrud, 'member:create')
-  let r = await axios({method: 'GET', url: `${base}/1`})
+  let r = await axios({method: 'GET', url: `${base}/${id}`})
   assert.is(r.headers.scrud, 'member:read')
-  let u = await axios({method: 'PUT', url: `${base}/1`})
+  let u = await axios({method: 'PUT', url: `${base}/${id}`})
   assert.is(u.headers.scrud, 'member:update')
-  let d = await axios({method: 'DELETE', url: `${base}/1`})
+  let d = await axios({method: 'DELETE', url: `${base}/${id}`})
   assert.is(d.headers.scrud, 'member:delete')
 })