v0.1.0

Author: Raynos

.gitignore

@@ -0,0 +1 @@
+node_modules

.travis.yml

@@ -0,0 +1,3 @@
+language: node_js
+node_js:
+  - 0.6

LICENCE

@@ -0,0 +1,19 @@
+Copyright (c) 2011 Raynos.
+
+Permission is hereby granted, free of charge, to any person obtaining a copy
+of this software and associated documentation files (the "Software"), to deal
+in the Software without restriction, including without limitation the rights
+to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+copies of the Software, and to permit persons to whom the Software is
+furnished to do so, subject to the following conditions:
+
+The above copyright notice and this permission notice shall be included in
+all copies or substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
+THE SOFTWARE.

Makefile

@@ -0,0 +1,8 @@
+REPORTER = spec
+
+test: 
+	@NODE_ENV=test ./node_modules/.bin/mocha \
+		--ui bdd \
+		--reporter $(REPORTER)
+
+.PHONY: test

README.md

@@ -0,0 +1,53 @@
+# mongo-col [![Build Status][1]][2]
+
+mongoDB collection wrapper
+
+## Status: production ready
+
+## Example
+
+    var collection = require("mongo-col"),
+        Users = collection("Users")
+
+    Users.insert({
+        name: "foo",
+        password: "bar"
+    })
+
+## Motivation
+
+Setting up a mongodb database connection requires too much callback soup, remove it.
+
+## Documentation
+
+### <a name="colleciton" href="#collection">collection(collectionName)</a>
+
+`collection` takes a collection name and returns a collection object. This collection object has all the mongodb collection methods and sets up a database connection internally
+
+See the [MongoDB collection API][3]
+
+    var collection = require("mongo-col"),
+        Users = collection("Users")
+
+    Users.insert({
+        name: "foo",
+        password: "bar"
+    })
+
+## Installation
+
+`npm install mongo-col`
+
+## Tests
+
+`make test`
+
+## Contributors
+
+ - Raynos
+
+## MIT Licenced
+
+  [1]: https://secure.travis-ci.org/Raynos/mongo-col.png
+  [2]: http://travis-ci.org/Raynos/mongo-col
+  [3]: http://christkv.github.com/node-mongodb-native/api-generated/collection.html

index.js

@@ -0,0 +1 @@
+module.exports = require("./lib/mongo")

lib/mongo.js

@@ -0,0 +1,115 @@
+var mongodb = require("mongodb"),
+    // Grab the database HOST, PORT, USER and PASSWORD from the environment
+    HOST = process.env["MONGODB_HOST"] || "localhost",
+    PORT = +process.env["MONGODB_PORT"] || 27017,
+    USER = process.env["MONGODB_USER"],
+    PASSWORD = process.env["MONGODB_PASSWORD"],
+    Db = mongodb.Db,
+    Server = mongodb.Server,
+    cachedResults,
+    callbackQueue
+
+var Collection = {
+    constructor: function (collection) {
+        this.collection = collection
+        return this
+    }
+}
+
+Object.keys(mongodb.Collection.prototype).forEach(addToCollection)
+    
+module.exports = collection
+
+function mongo(collectionName) {
+    return getCollection
+
+    function getCollection(callback) {
+        openDatabase(openCollection)
+
+        function openCollection(err, db) {
+            if (err) {
+                return callback(err)
+            }
+            db.collection(collectionName, callCallback)
+        }
+
+        function callCallback(err, collection) {
+            callback.call(collection, err, collection)
+        }
+    }
+}
+
+function openDatabase(callback) {
+    if (cachedResults) {
+        return callback.apply(cachedResults[1], memo)
+    } else if (callbackQueue) {
+        return callbackQueue.push(callback)
+    }
+
+    callbackQueue = [callback]
+
+    var db = new Db('DATABASE', new Server(HOST, PORT, {
+        auto_reconnect: true,
+        poolSize: 4
+    }), {})
+    db.open(authenticateDatabase)
+
+    function authenticateDatabase(err, db) {
+        if (err) {
+            return invokeCallbacks(err)
+        }
+
+        if (USER || PASSWORD) {
+            db.authenticate(USER, PASSWORD, saveDatabase)    
+        } else {
+            invokeCallbacks(err, db)
+        }
+        
+        function saveDatabase(err, success) {
+            if (success) {
+                return invokeCallbacks(err, db)
+            }
+            return invokeCallbacks(new Error("auth failed"))
+        }
+    }
+
+    function invokeCallbacks(err, data) {
+        var callbackList = callbackQueue
+        cachedResults = arguments
+        callbackQueue = null
+        for (var i = 0, len = callbackList.length; i < len; i++) {
+            callbackList[i].apply(arguments[1], arguments)
+        }
+    }
+}
+
+function collection (collectionName) {
+    return Object.create(Collection).constructor(mongo(collectionName))
+}
+
+function addToCollection(methodName) {
+    if (typeof mongodb.Collection.prototype[methodName] === "function") {
+        Collection[methodName] = tunnel(methodName)    
+    }
+}
+
+function tunnel (methodName) {
+    return proxy
+
+    function proxy() {
+        var args = arguments,
+            callback = args[args.length - 1]
+
+        this.collection(invokeMethod)
+
+        function invokeMethod(err, collection) {
+            if (err) {
+                if (callback.call) {
+                    callback(err)
+                }
+                return 
+            }
+            collection[methodName].apply(collection, args)
+        }
+    }
+}

package.json

@@ -0,0 +1,28 @@
+{
+    "name": "mongo-col",
+    "description": "mongoDB collection wrapper",
+    "version": "0.1.0",
+    "author": "Raynos <[email protected]>",
+    "contributors": [
+        {
+            "name": "Raynos",
+            "email": "[email protected]",
+            "url": "http://raynos.org"
+        }
+    ],
+    "dependencies": {
+        "mongodb": "0.9.9-7"
+    },
+    "scripts": {
+        "test": "make test"
+    },
+    "devDependencies": {
+        "mocha": "0.14.1"
+    },
+    "keywords": ["mongo", "db", "database", "collection", "orm"],
+    "repository": "git://github.com/Raynos/mongo-col.git",
+    "main": "index.js",
+    "engines": {
+        "node": "0.6"
+    }
+}

test/mongo-test.js

@@ -0,0 +1,16 @@
+var collection = require("../"),
+    assert = require("assert"),
+    Users = collection("Users")
+
+Users.drop()
+
+describe("mongo-collection", function () {
+    it("should allow inserting", function (done) {
+        Users.insert({ name: "foo" })
+        Users.findOne({ name: "foo" }, function (err, data) {
+            assert(data.name === "foo",
+                "data name incorrect")
+            done()
+        })
+    })
+})