endpoint to import documents into the database

.gitignore

@@ -36,6 +36,7 @@ jspm_packages
 # Optional REPL history
 .node_repl_history
 
+/public
 .idea
 .DS_Store
 

server.js

@@ -7,7 +7,7 @@ app.get('/health', (req, res) => res.json({ ok: true }))
 
 app.use('/services', require('./services/api'))
 
-// app.use('/import', require('./services/import'))
+app.use('/import', require('./services/import'))
 
 app.use('/font-awesome', express.static('node_modules/font-awesome'))
 

services/api.js

@@ -6,6 +6,7 @@ const router = express.Router()
 
 // example service
 const timeFormat = 'YYYY-MMM-DD hh:mm:ss A Z'
+
 router.get('/now', (req, res, next) => {
   agent.get('http://www.timeapi.org/utc/now')
   .accept('json')

services/config.js

@@ -0,0 +1,6 @@
+module.exports = {
+  couchUrl: process.env.COUCH_URL || 'http://localhost:5984',
+  searchHost: 'search-ocelot-6tqsxtl7pweckdfvle6ty47yiu.us-east-1.es.amazonaws.com',
+  searchUserAccessKeyId: process.env.SEARCH_USER_ACCESS_KEY_ID,
+  searchUserSecretAccessKey: process.env.SEARCH_USER_SECRET_ACCESS_KEY
+}

services/docs.json

@@ -0,0 +1,8 @@
+[
+  {
+    "name": "alice"
+  },
+  {
+    "name": "bob"
+  }
+]

services/import.js

@@ -0,0 +1,14 @@
+const agent = require('../src/agent')
+const { couchUrl } = require('./config')
+const express = require('express')
+
+const router = express.Router()
+
+router.post('/', (req, res, next) => {
+  agent.post(`${couchUrl}/foobar/_bulk_docs`)
+  .send({ docs: require('./docs.json') })
+  .then(({ body }) => res.json(body))
+  .catch(next)
+})
+
+module.exports = router

services/search/searchHttps.js

@@ -0,0 +1,41 @@
+const _ = require('underscore')
+const aws4 = require('aws4')
+const https = require('https')
+
+module.exports = ({ host, credentials }) => {
+  return ({ path, method, body, headers = {}, json = true }) => {
+    const options = {
+      host,
+      path,
+      method: method || (body ? 'POST' : 'GET'),
+      headers
+    }
+    if (_(body).isObject()) {
+      options.body = JSON.stringify(body)
+      headers['Content-Type'] = 'application/json; charset=utf-8'
+    } else if (_(body).isString()) {
+      options.body = body
+    }
+
+    const signed = aws4.sign(options, credentials)
+
+    return new Promise((resolve, reject) => {
+      const request = https.request(signed, (res) => {
+        let responseBody = ''
+        res.on('data', chunk => responseBody += chunk)
+
+        const result = () => json && responseBody ? JSON.parse(responseBody) : responseBody
+
+        res.on('end', () => {
+          if (res.statusCode >= 200 && res.statusCode < 300) {
+            resolve(result())
+          } else {
+            reject({ status: res.statusCode, body: responseBody })
+          }
+        })
+      })
+      request.on('error', reject)
+      request.end(signed.body || '')
+    })
+  }
+}