Skip to content

Commit

Permalink
Merge pull request #59 from jo/feat/update-dependencies
Browse files Browse the repository at this point in the history
feat: update dependencies
  • Loading branch information
jo authored Feb 28, 2021
2 parents 83d78f1 + 2af9a3a commit 0055491
Show file tree
Hide file tree
Showing 8 changed files with 23,768 additions and 32,585 deletions.
10 changes: 5 additions & 5 deletions cli.js
Original file line number Diff line number Diff line change
@@ -1,8 +1,8 @@
#!/usr/bin/env node
var minimist = require('minimist')
var bootstrap = require('./')
const minimist = require('minimist')
const bootstrap = require('./')

var options = minimist(process.argv.slice(2), {
const options = minimist(process.argv.slice(2), {
boolean: ['multipart', 'watch'],
string: ['concurrency', 'mapDbName']
})
Expand All @@ -12,8 +12,8 @@ if (!options._.length) {
process.exit()
}

var url = options._[0]
var source = options._[1] || process.cwd()
const url = options._[0]
const source = options._[1] || process.cwd()

if (options.mapDbName) {
options.mapDbName = JSON.parse(options.mapDbName)
Expand Down
48 changes: 24 additions & 24 deletions index.js
Original file line number Diff line number Diff line change
@@ -1,15 +1,15 @@
var path = require('path')
var async = require('async')
var nanoOption = require('nano-option')
var assert = require('assert')
const path = require('path')
const async = require('async')
const nanoOption = require('nano-option')
const assert = require('assert')

var compile = require('couchdb-compile')
var couchdbConfigure = require('couchdb-configure')
var couchdbSecure = require('couchdb-secure')
var couchdbPush = require('couchdb-push')
const compile = require('couchdb-compile')
const couchdbConfigure = require('couchdb-configure')
const couchdbSecure = require('couchdb-secure')
const couchdbPush = require('couchdb-push')

var DOCS_REGEX = /^(_design|_local|[^_].*)$/
var DBS_REGEX = /^(_users|_dbs|_global_changes|_replicator|[^_].*)$/
const DOCS_REGEX = /^(_design|_local|[^_].*)$/
const DBS_REGEX = /^(_users|_dbs|_global_changes|_replicator|[^_].*)$/

function isDb (key) {
return key.match(DBS_REGEX)
Expand All @@ -23,7 +23,7 @@ function groupByDatabase (dbname, callback) {
return function (error, results) {
if (error) return callback(error)

var result = {}
const result = {}
result[dbname] = results

callback(null, result)
Expand All @@ -34,7 +34,7 @@ function reduceGroupedResult (callback) {
return function (error, results) {
if (error) return callback(error)

var result = results.reduce(function (memo, res) {
const result = results.reduce(function (memo, res) {
if (typeof res !== 'object') return memo

Object.keys(res).forEach(function (key) {
Expand Down Expand Up @@ -62,7 +62,7 @@ module.exports = function (url, source, options, callback) {
options = {}
}

var couch = nanoOption(url)
const couch = nanoOption(url)

assert(typeof couch.request === 'function',
'URL must point to the root of a CouchDB server (not to a database).')
Expand All @@ -78,35 +78,35 @@ module.exports = function (url, source, options, callback) {

options.concurrency = 'concurrency' in options ? options.concurrency : 100

var series = {}
const series = {}

if ('_config' in source) series.configure = couchdbConfigure.bind(null, couch, source._config)

var dbs = Object.keys(source).filter(isDb)
const dbs = Object.keys(source).filter(isDb)

var dbsWithSecurity = dbs.filter(dbname => '_security' in source[dbname])
const dbsWithSecurity = dbs.filter(dbname => '_security' in source[dbname])
if (dbsWithSecurity.length) {
series.secure = done => {
async.map(dbsWithSecurity, (dbname, next) => {
var db = mapDbName(options, dbname)
const db = mapDbName(options, dbname)
couchdbSecure(couch.use(db), source[dbname]._security, groupByDatabase(db, next))
}, reduceGroupedResult(done))
}
}

var dbsWithDocs = dbs.filter(dbname => Object.keys(source[dbname]).filter(isDoc).length)
const dbsWithDocs = dbs.filter(dbname => Object.keys(source[dbname]).filter(isDoc).length)
if (dbsWithDocs.length) {
series.push = done => {
async.map(dbsWithDocs, (dbname, next) => {
var docs = Object.keys(source[dbname])
const docs = Object.keys(source[dbname])
.filter(isDoc)
.reduce((memo, id) => {
var docs = []
let docs = []

if (id === '_local') {
docs = Object.keys(source[dbname]._local)
.map(name => {
var doc = source[dbname]._local[name]
const doc = source[dbname]._local[name]
if (!('_id' in doc)) doc._id = '_local/' + name
return doc
})
Expand All @@ -117,22 +117,22 @@ module.exports = function (url, source, options, callback) {
if (id === '_design') {
docs = Object.keys(source[dbname]._design)
.map(name => {
var doc = source[dbname]._design[name]
const doc = source[dbname]._design[name]
if (!('_id' in doc)) doc._id = '_design/' + name
return doc
})

return memo.concat(docs)
}

var doc = source[dbname][id]
const doc = source[dbname][id]

if (!('_id' in doc)) doc._id = id

return memo.concat(doc)
}, [])

var db = mapDbName(options, dbname)
const db = mapDbName(options, dbname)
async.mapLimit(docs, options.concurrency, (doc, next) => {
couchdbPush(couch.use(db), doc, options, next)
}, groupByDatabase(db, next))
Expand Down
Loading

0 comments on commit 0055491

Please sign in to comment.