Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.
module.exports = function (dir, opts) {
if (!opts) opts = {}
if (!has(opts, 'retry')) opts.retry = true
var sockPath = process.platform === 'win32'
? '\\\\.\\pipe\\level-party\\' + path.resolve(dir)
: path.join(dir, 'level-party.sock')
var client = multileveldown.client(opts)
client.open(tryConnect)
function tryConnect () {
if (!client.isOpen()) return
var socket = net.connect(sockPath)
var connected = false
socket.on('connect', function () {
connected = true
})
// we pass socket as the ref option so we dont hang the event loop
pump(socket, client.createRpcStream({ ref: socket }), socket, function () {
if (!client.isOpen()) return
constructor (path, opts) {
super(path, {
...opts,
db: () => memdown()
})
this.db = multileveldown.client({
retry: true,
valueEncoding: 'binary',
compression: false // same default as go
})
this.path = path
this.open()
}
module.exports = function (opts) {
var that = new events.EventEmitter()
var leaderEncoders = []
var sockPath = opts.sockPath
var client = multileveldown.client({retry: true})
var clientAdds = []
var clientEncode
var leader = false
var log
var clientLog
that.changes = 0
that.mainLayer = null
that.leader = that.follower = false
that.update = function (update) {
that.mainLayer = update.mainLayer
that.changes = update.changes
if (!leader) return