Huge News!Announcing our $40M Series B led by Abstract Ventures.Learn More
Socket
Sign inDemoInstall
Socket

@akeating-redhat/mongodb-lock

Package Overview
Dependencies
Maintainers
1
Versions
1
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

@akeating-redhat/mongodb-lock

Locks which uses MongoDB's atomic operations.

  • 1.0.0
  • latest
  • Source
  • npm
  • Socket score

Version published
Weekly downloads
2
increased by100%
Maintainers
1
Weekly downloads
 
Created
Source

mongodb-lock

Build Status NPM

A really light-weight way to get distributed locks with a nice API if you're already using MongoDB.

Synopsis

Create a connection to your MongoDB database, and use it to create a lock object:

var mongodb = require('mongodb')
var mongoDbLock = require('mongodb-lock')

var con = 'mongodb://localhost:27017/test'

mongodb.MongoClient.connect(con, function(err, db) {
  // supply the database, the collection to use and the lock name
  var lock = mongoDbLock(db, 'locks', 'database-backup')
})

Now, acquire the lock:

lock.acquire(function(err, code) {
  if (err) {
    return console.error(code)
  }

  if ( code ) {
    // lock was acquired
    console.log('code=' + code)
  }
  else {
    // lock was not acquired
  }
})

Once you have a lock, you have a 30 second timeout until the lock is released. You can release it earlier by supplying the code:

lock.release(code, function(err, ok) {
  if (err) {
    return console.error(err)
  }

  if (ok) {
    console.log('Lock released ok')
  }
  else {
    console.log("Lock was not released, perhaps it's already been released or timed out")
  }
})

MongoDB Indexes

You should make sure any indexes have been added to the collection to make the queries faster:

lock.ensureIndexes(function(err) {
  if (err) {
    return console.error(err)
  }
  // all ok
})

Multiple Locks

Multiple locks can use the same collection and operate quite independently:

var dbBackupLock = mongoDbLock(db, 'locks', 'database-backup')
var hourlyStats = mongoDbLock(db, 'locks', 'hourly-stats')
var sendInvoices = mongoDbLock(db, 'locks', 'send-invoices')

Options

Currently there is only the option of the timeout. Currently the default is 30 seconds, but you can change it (in milliseconds):

// lock for 60 seconds
var uploadFiles = mongoDbLock(db, 'locks', 'upload-files', { timeout : 60 * 1000})

uploadFiles.lock(function(err, code) {
  // locked for 60s
})

0.2.0 (2015-04-17)

  • [FIX] made sure that a 2nd .release() doesn't return ok (ie. it didn't do anything)

0.1.0 (2015-04-17)

  • [NEW] added ability to add indexes to MongoDB
  • [NEW] added lock()
  • [NEW] added release()

Author

Written by Andrew Chilton - Twitter.

License

MIT - http://chilts.mit-license.org/2014/

(Ends)

Keywords

FAQs

Package last updated on 27 Feb 2017

Did you know?

Socket

Socket for GitHub automatically highlights issues in each pull request and monitors the health of all your open source dependencies. Discover the contents of your packages and block harmful activity before you install or update your dependencies.

Install

Related posts

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

Packages

npm

Stay in touch

Get open source security insights delivered straight into your inbox.


  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc