2020-04-24 10:54:20 +02:00
|
|
|
const PouchDB = require("pouchdb")
|
2020-09-25 15:47:42 +02:00
|
|
|
const replicationStream = require("pouchdb-replication-stream")
|
2020-04-25 09:35:34 +02:00
|
|
|
const allDbs = require("pouchdb-all-dbs")
|
2020-05-11 16:42:42 +02:00
|
|
|
const { budibaseAppsDir } = require("../utilities/budibaseDir")
|
2020-10-07 12:42:28 +02:00
|
|
|
const { sanitise } = require("../utilities/sanitisedPath")
|
2020-05-14 16:12:30 +02:00
|
|
|
const env = require("../environment")
|
2020-04-07 16:12:08 +02:00
|
|
|
|
2020-05-18 11:28:38 +02:00
|
|
|
const COUCH_DB_URL = env.COUCH_DB_URL || `leveldb://${budibaseAppsDir()}/.data/`
|
2020-05-14 16:12:30 +02:00
|
|
|
const isInMemory = env.NODE_ENV === "jest"
|
|
|
|
|
2020-09-25 15:47:42 +02:00
|
|
|
PouchDB.plugin(replicationStream.plugin)
|
|
|
|
PouchDB.adapter("writableStream", replicationStream.adapters.writableStream)
|
|
|
|
|
2020-05-18 11:28:38 +02:00
|
|
|
let POUCH_DB_DEFAULTS = {
|
2020-05-18 12:01:09 +02:00
|
|
|
prefix: COUCH_DB_URL,
|
|
|
|
}
|
2020-04-28 15:39:35 +02:00
|
|
|
|
2020-05-18 11:28:38 +02:00
|
|
|
if (isInMemory) {
|
|
|
|
PouchDB.plugin(require("pouchdb-adapter-memory"))
|
|
|
|
POUCH_DB_DEFAULTS = {
|
|
|
|
prefix: undefined,
|
2020-05-18 12:01:09 +02:00
|
|
|
adapter: "memory",
|
|
|
|
}
|
2020-05-18 11:28:38 +02:00
|
|
|
}
|
|
|
|
|
|
|
|
const Pouch = PouchDB.defaults(POUCH_DB_DEFAULTS)
|
2020-04-28 15:39:35 +02:00
|
|
|
|
2020-05-07 11:53:34 +02:00
|
|
|
allDbs(Pouch)
|
2020-04-28 15:39:35 +02:00
|
|
|
|
2020-10-07 12:42:28 +02:00
|
|
|
function PouchWrapper(instance) {
|
|
|
|
Pouch.apply(this, [sanitise(instance)])
|
|
|
|
}
|
|
|
|
|
|
|
|
PouchWrapper.prototype = Object.create(Pouch.prototype)
|
|
|
|
|
|
|
|
module.exports = PouchWrapper
|