You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@apex.apache.org by da...@apache.org on 2015/11/30 22:06:24 UTC
[18/98] [abbrv] [partial] incubator-apex-malhar git commit: Removing
all web demos
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/e1a45507/web/demos/package/node_modules/jquery-deferred/lib/jquery-deferred.js
----------------------------------------------------------------------
diff --git a/web/demos/package/node_modules/jquery-deferred/lib/jquery-deferred.js b/web/demos/package/node_modules/jquery-deferred/lib/jquery-deferred.js
deleted file mode 100644
index 0ea524d..0000000
--- a/web/demos/package/node_modules/jquery-deferred/lib/jquery-deferred.js
+++ /dev/null
@@ -1,163 +0,0 @@
-
-/*!
-* jquery-deferred
-* Copyright(c) 2011 Hidden <zz...@gmail.com>
-* MIT Licensed
-*/
-
-/**
-* Library version.
-*/
-
-var jQuery = module.exports = require("./jquery-callbacks.js"),
- core_slice = Array.prototype.slice;
-
-/**
-* jQuery deferred
-*
-* Code from: https://github.com/jquery/jquery/blob/master/src/deferred.js
-* Doc: http://api.jquery.com/category/deferred-object/
-*
-*/
-
-jQuery.extend({
-
- Deferred: function( func ) {
- var tuples = [
- // action, add listener, listener list, final state
- [ "resolve", "done", jQuery.Callbacks("once memory"), "resolved" ],
- [ "reject", "fail", jQuery.Callbacks("once memory"), "rejected" ],
- [ "notify", "progress", jQuery.Callbacks("memory") ]
- ],
- state = "pending",
- promise = {
- state: function() {
- return state;
- },
- always: function() {
- deferred.done( arguments ).fail( arguments );
- return this;
- },
- then: function( /* fnDone, fnFail, fnProgress */ ) {
- var fns = arguments;
- return jQuery.Deferred(function( newDefer ) {
- jQuery.each( tuples, function( i, tuple ) {
- var action = tuple[ 0 ],
- fn = fns[ i ];
- // deferred[ done | fail | progress ] for forwarding actions to newDefer
- deferred[ tuple[1] ]( jQuery.isFunction( fn ) ?
- function() {
- var returned = fn.apply( this, arguments );
- if ( returned && jQuery.isFunction( returned.promise ) ) {
- returned.promise()
- .done( newDefer.resolve )
- .fail( newDefer.reject )
- .progress( newDefer.notify );
- } else {
- newDefer[ action + "With" ]( this === deferred ? newDefer : this, [ returned ] );
- }
- } :
- newDefer[ action ]
- );
- });
- fns = null;
- }).promise();
- },
- // Get a promise for this deferred
- // If obj is provided, the promise aspect is added to the object
- promise: function( obj ) {
- return obj != null ? jQuery.extend( obj, promise ) : promise;
- }
- },
- deferred = {};
-
- // Keep pipe for back-compat
- promise.pipe = promise.then;
-
- // Add list-specific methods
- jQuery.each( tuples, function( i, tuple ) {
- var list = tuple[ 2 ],
- stateString = tuple[ 3 ];
-
- // promise[ done | fail | progress ] = list.add
- promise[ tuple[1] ] = list.add;
-
- // Handle state
- if ( stateString ) {
- list.add(function() {
- // state = [ resolved | rejected ]
- state = stateString;
-
- // [ reject_list | resolve_list ].disable; progress_list.lock
- }, tuples[ i ^ 1 ][ 2 ].disable, tuples[ 2 ][ 2 ].lock );
- }
-
- // deferred[ resolve | reject | notify ] = list.fire
- deferred[ tuple[0] ] = list.fire;
- deferred[ tuple[0] + "With" ] = list.fireWith;
- });
-
- // Make the deferred a promise
- promise.promise( deferred );
-
- // Call given func if any
- if ( func ) {
- func.call( deferred, deferred );
- }
-
- // All done!
- return deferred;
- },
-
- // Deferred helper
- when: function( subordinate /* , ..., subordinateN */ ) {
- var i = 0,
- resolveValues = core_slice.call( arguments ),
- length = resolveValues.length,
-
- // the count of uncompleted subordinates
- remaining = length !== 1 || ( subordinate && jQuery.isFunction( subordinate.promise ) ) ? length : 0,
-
- // the master Deferred. If resolveValues consist of only a single Deferred, just use that.
- deferred = remaining === 1 ? subordinate : jQuery.Deferred(),
-
- // Update function for both resolve and progress values
- updateFunc = function( i, contexts, values ) {
- return function( value ) {
- contexts[ i ] = this;
- values[ i ] = arguments.length > 1 ? core_slice.call( arguments ) : value;
- if( values === progressValues ) {
- deferred.notifyWith( contexts, values );
- } else if ( !( --remaining ) ) {
- deferred.resolveWith( contexts, values );
- }
- };
- },
-
- progressValues, progressContexts, resolveContexts;
-
- // add listeners to Deferred subordinates; treat others as resolved
- if ( length > 1 ) {
- progressValues = new Array( length );
- progressContexts = new Array( length );
- resolveContexts = new Array( length );
- for ( ; i < length; i++ ) {
- if ( resolveValues[ i ] && jQuery.isFunction( resolveValues[ i ].promise ) ) {
- resolveValues[ i ].promise()
- .done( updateFunc( i, resolveContexts, resolveValues ) )
- .fail( deferred.reject )
- .progress( updateFunc( i, progressContexts, progressValues ) );
- } else {
- --remaining;
- }
- }
- }
-
- // if we're not waiting on anything, resolve the master
- if ( !remaining ) {
- deferred.resolveWith( resolveContexts, resolveValues );
- }
-
- return deferred.promise();
- }
-});
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/e1a45507/web/demos/package/node_modules/jquery-deferred/package.json
----------------------------------------------------------------------
diff --git a/web/demos/package/node_modules/jquery-deferred/package.json b/web/demos/package/node_modules/jquery-deferred/package.json
deleted file mode 100644
index f6bf099..0000000
--- a/web/demos/package/node_modules/jquery-deferred/package.json
+++ /dev/null
@@ -1,29 +0,0 @@
-{
- "name": "jquery-deferred",
- "version": "0.3.0",
- "description": "jQuery 1.8.2 deferred lib for nodeJS.",
- "keywords": [
- "deferred"
- ],
- "author": {
- "name": "Hidden",
- "email": "zzdhidden@gmail.com"
- },
- "repository": {
- "type": "git",
- "url": "http://github.com/zzdhidden/node-jquery-deferred.git"
- },
- "dependencies": {},
- "main": "index",
- "engines": {
- "node": ">=0.4.0"
- },
- "readme": "\njquery-deferred\n=============================\n\njQuery deferred lib for nodeJS.\n\njQuery.Deferred(), is a chainable utility object that can register multiple callbacks into callback queues, invoke callback queues, and relay the success or failure state of any synchronous or asynchronous function.\n\nDoc [http://api.jquery.com/category/deferred-object/](http://api.jquery.com/category/deferred-object/)\n\nInstallation\n-----------------------------\n \n> npm install jquery-deferred\n\nIn nodeJS\n\n`var jQuery = require('jquery-deferred');`\n\n\n\n## License \n\n(The MIT License)\n\nCopyright (c) 2011 Hidden <zzdhidden@gmail.com>\n\nPermission is hereby granted, free of charge, to any person obtaining\na copy of this software and associated documentation files (the\n'Software'), to deal in the Software without restriction, including\nwithout limitation the rights to use, copy, modify, merge, publish,\ndistribute, sublicense, and/or sell copies of the Softwa
re, and to\npermit persons to whom the Software is furnished to do so, subject to\nthe following conditions:\n\nThe above copyright notice and this permission notice shall be\nincluded in all copies or substantial portions of the Software.\n\nTHE SOFTWARE IS PROVIDED 'AS IS', WITHOUT WARRANTY OF ANY KIND,\nEXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF\nMERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT.\nIN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY\nCLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT,\nTORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE\nSOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.\n",
- "readmeFilename": "Readme.md",
- "bugs": {
- "url": "https://github.com/zzdhidden/node-jquery-deferred/issues"
- },
- "homepage": "https://github.com/zzdhidden/node-jquery-deferred",
- "_id": "jquery-deferred@0.3.0",
- "_from": "jquery-deferred@~0.3.0"
-}
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/e1a45507/web/demos/package/node_modules/mongodb/.travis.yml
----------------------------------------------------------------------
diff --git a/web/demos/package/node_modules/mongodb/.travis.yml b/web/demos/package/node_modules/mongodb/.travis.yml
deleted file mode 100644
index 7ef2762..0000000
--- a/web/demos/package/node_modules/mongodb/.travis.yml
+++ /dev/null
@@ -1,6 +0,0 @@
-language: node_js
-node_js:
- - 0.6
- - 0.8
- - 0.10
- - 0.11
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/e1a45507/web/demos/package/node_modules/mongodb/CONTRIBUTING.md
----------------------------------------------------------------------
diff --git a/web/demos/package/node_modules/mongodb/CONTRIBUTING.md b/web/demos/package/node_modules/mongodb/CONTRIBUTING.md
deleted file mode 100644
index c23e426..0000000
--- a/web/demos/package/node_modules/mongodb/CONTRIBUTING.md
+++ /dev/null
@@ -1,23 +0,0 @@
-## Contributing to the driver
-
-### Bugfixes
-
-- Before starting to write code, look for existing [tickets](https://jira.mongodb.org/browse/NODE) or [create one](https://jira.mongodb.org/secure/CreateIssue!default.jspa) for your specific issue under the "Node Driver" project. That way you avoid working on something that might not be of interest or that has been addressed already in a different branch.
-- Fork the [repo](https://github.com/mongodb/node-mongodb-native) _or_ for small documentation changes, navigate to the source on github and click the [Edit](https://github.com/blog/844-forking-with-the-edit-button) button.
-- Follow the general coding style of the rest of the project:
- - 2 space tabs
- - no trailing whitespace
- - comma last
- - inline documentation for new methods, class members, etc
- - 0 space between conditionals/functions, and their parenthesis and curly braces
- - `if(..) {`
- - `for(..) {`
- - `while(..) {`
- - `function(err) {`
-- Write tests and make sure they pass (execute `npm test` from the cmd line to run the test suite).
-
-### Documentation
-
-To contribute to the [API documentation](http://mongodb.github.com/node-mongodb-native/) just make your changes to the inline documentation of the appropriate [source code](https://github.com/mongodb/node-mongodb-native/tree/master/docs) in the master branch and submit a [pull request](https://help.github.com/articles/using-pull-requests/). You might also use the github [Edit](https://github.com/blog/844-forking-with-the-edit-button) button.
-
-If you'd like to preview your documentation changes, first commit your changes to your local master branch, then execute `make generate_docs`. Make sure you have the python documentation framework sphinx installed `easy_install sphinx`. The docs are generated under `docs/build'. If all looks good, submit a [pull request](https://help.github.com/articles/using-pull-requests/) to the master branch with your changes.
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/e1a45507/web/demos/package/node_modules/mongodb/LICENSE
----------------------------------------------------------------------
diff --git a/web/demos/package/node_modules/mongodb/LICENSE b/web/demos/package/node_modules/mongodb/LICENSE
deleted file mode 100644
index 261eeb9..0000000
--- a/web/demos/package/node_modules/mongodb/LICENSE
+++ /dev/null
@@ -1,201 +0,0 @@
- Apache License
- Version 2.0, January 2004
- http://www.apache.org/licenses/
-
- TERMS AND CONDITIONS FOR USE, REPRODUCTION, AND DISTRIBUTION
-
- 1. Definitions.
-
- "License" shall mean the terms and conditions for use, reproduction,
- and distribution as defined by Sections 1 through 9 of this document.
-
- "Licensor" shall mean the copyright owner or entity authorized by
- the copyright owner that is granting the License.
-
- "Legal Entity" shall mean the union of the acting entity and all
- other entities that control, are controlled by, or are under common
- control with that entity. For the purposes of this definition,
- "control" means (i) the power, direct or indirect, to cause the
- direction or management of such entity, whether by contract or
- otherwise, or (ii) ownership of fifty percent (50%) or more of the
- outstanding shares, or (iii) beneficial ownership of such entity.
-
- "You" (or "Your") shall mean an individual or Legal Entity
- exercising permissions granted by this License.
-
- "Source" form shall mean the preferred form for making modifications,
- including but not limited to software source code, documentation
- source, and configuration files.
-
- "Object" form shall mean any form resulting from mechanical
- transformation or translation of a Source form, including but
- not limited to compiled object code, generated documentation,
- and conversions to other media types.
-
- "Work" shall mean the work of authorship, whether in Source or
- Object form, made available under the License, as indicated by a
- copyright notice that is included in or attached to the work
- (an example is provided in the Appendix below).
-
- "Derivative Works" shall mean any work, whether in Source or Object
- form, that is based on (or derived from) the Work and for which the
- editorial revisions, annotations, elaborations, or other modifications
- represent, as a whole, an original work of authorship. For the purposes
- of this License, Derivative Works shall not include works that remain
- separable from, or merely link (or bind by name) to the interfaces of,
- the Work and Derivative Works thereof.
-
- "Contribution" shall mean any work of authorship, including
- the original version of the Work and any modifications or additions
- to that Work or Derivative Works thereof, that is intentionally
- submitted to Licensor for inclusion in the Work by the copyright owner
- or by an individual or Legal Entity authorized to submit on behalf of
- the copyright owner. For the purposes of this definition, "submitted"
- means any form of electronic, verbal, or written communication sent
- to the Licensor or its representatives, including but not limited to
- communication on electronic mailing lists, source code control systems,
- and issue tracking systems that are managed by, or on behalf of, the
- Licensor for the purpose of discussing and improving the Work, but
- excluding communication that is conspicuously marked or otherwise
- designated in writing by the copyright owner as "Not a Contribution."
-
- "Contributor" shall mean Licensor and any individual or Legal Entity
- on behalf of whom a Contribution has been received by Licensor and
- subsequently incorporated within the Work.
-
- 2. Grant of Copyright License. Subject to the terms and conditions of
- this License, each Contributor hereby grants to You a perpetual,
- worldwide, non-exclusive, no-charge, royalty-free, irrevocable
- copyright license to reproduce, prepare Derivative Works of,
- publicly display, publicly perform, sublicense, and distribute the
- Work and such Derivative Works in Source or Object form.
-
- 3. Grant of Patent License. Subject to the terms and conditions of
- this License, each Contributor hereby grants to You a perpetual,
- worldwide, non-exclusive, no-charge, royalty-free, irrevocable
- (except as stated in this section) patent license to make, have made,
- use, offer to sell, sell, import, and otherwise transfer the Work,
- where such license applies only to those patent claims licensable
- by such Contributor that are necessarily infringed by their
- Contribution(s) alone or by combination of their Contribution(s)
- with the Work to which such Contribution(s) was submitted. If You
- institute patent litigation against any entity (including a
- cross-claim or counterclaim in a lawsuit) alleging that the Work
- or a Contribution incorporated within the Work constitutes direct
- or contributory patent infringement, then any patent licenses
- granted to You under this License for that Work shall terminate
- as of the date such litigation is filed.
-
- 4. Redistribution. You may reproduce and distribute copies of the
- Work or Derivative Works thereof in any medium, with or without
- modifications, and in Source or Object form, provided that You
- meet the following conditions:
-
- (a) You must give any other recipients of the Work or
- Derivative Works a copy of this License; and
-
- (b) You must cause any modified files to carry prominent notices
- stating that You changed the files; and
-
- (c) You must retain, in the Source form of any Derivative Works
- that You distribute, all copyright, patent, trademark, and
- attribution notices from the Source form of the Work,
- excluding those notices that do not pertain to any part of
- the Derivative Works; and
-
- (d) If the Work includes a "NOTICE" text file as part of its
- distribution, then any Derivative Works that You distribute must
- include a readable copy of the attribution notices contained
- within such NOTICE file, excluding those notices that do not
- pertain to any part of the Derivative Works, in at least one
- of the following places: within a NOTICE text file distributed
- as part of the Derivative Works; within the Source form or
- documentation, if provided along with the Derivative Works; or,
- within a display generated by the Derivative Works, if and
- wherever such third-party notices normally appear. The contents
- of the NOTICE file are for informational purposes only and
- do not modify the License. You may add Your own attribution
- notices within Derivative Works that You distribute, alongside
- or as an addendum to the NOTICE text from the Work, provided
- that such additional attribution notices cannot be construed
- as modifying the License.
-
- You may add Your own copyright statement to Your modifications and
- may provide additional or different license terms and conditions
- for use, reproduction, or distribution of Your modifications, or
- for any such Derivative Works as a whole, provided Your use,
- reproduction, and distribution of the Work otherwise complies with
- the conditions stated in this License.
-
- 5. Submission of Contributions. Unless You explicitly state otherwise,
- any Contribution intentionally submitted for inclusion in the Work
- by You to the Licensor shall be under the terms and conditions of
- this License, without any additional terms or conditions.
- Notwithstanding the above, nothing herein shall supersede or modify
- the terms of any separate license agreement you may have executed
- with Licensor regarding such Contributions.
-
- 6. Trademarks. This License does not grant permission to use the trade
- names, trademarks, service marks, or product names of the Licensor,
- except as required for reasonable and customary use in describing the
- origin of the Work and reproducing the content of the NOTICE file.
-
- 7. Disclaimer of Warranty. Unless required by applicable law or
- agreed to in writing, Licensor provides the Work (and each
- Contributor provides its Contributions) on an "AS IS" BASIS,
- WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
- implied, including, without limitation, any warranties or conditions
- of TITLE, NON-INFRINGEMENT, MERCHANTABILITY, or FITNESS FOR A
- PARTICULAR PURPOSE. You are solely responsible for determining the
- appropriateness of using or redistributing the Work and assume any
- risks associated with Your exercise of permissions under this License.
-
- 8. Limitation of Liability. In no event and under no legal theory,
- whether in tort (including negligence), contract, or otherwise,
- unless required by applicable law (such as deliberate and grossly
- negligent acts) or agreed to in writing, shall any Contributor be
- liable to You for damages, including any direct, indirect, special,
- incidental, or consequential damages of any character arising as a
- result of this License or out of the use or inability to use the
- Work (including but not limited to damages for loss of goodwill,
- work stoppage, computer failure or malfunction, or any and all
- other commercial damages or losses), even if such Contributor
- has been advised of the possibility of such damages.
-
- 9. Accepting Warranty or Additional Liability. While redistributing
- the Work or Derivative Works thereof, You may choose to offer,
- and charge a fee for, acceptance of support, warranty, indemnity,
- or other liability obligations and/or rights consistent with this
- License. However, in accepting such obligations, You may act only
- on Your own behalf and on Your sole responsibility, not on behalf
- of any other Contributor, and only if You agree to indemnify,
- defend, and hold each Contributor harmless for any liability
- incurred by, or claims asserted against, such Contributor by reason
- of your accepting any such warranty or additional liability.
-
- END OF TERMS AND CONDITIONS
-
- APPENDIX: How to apply the Apache License to your work.
-
- To apply the Apache License to your work, attach the following
- boilerplate notice, with the fields enclosed by brackets "[]"
- replaced with your own identifying information. (Don't include
- the brackets!) The text should be enclosed in the appropriate
- comment syntax for the file format. We also recommend that a
- file or class name and description of purpose be included on the
- same "printed page" as the copyright notice for easier
- identification within third-party archives.
-
- Copyright [yyyy] [name of copyright owner]
-
- Licensed under the Apache License, Version 2.0 (the "License");
- you may not use this file except in compliance with the License.
- You may obtain a copy of the License at
-
- http://www.apache.org/licenses/LICENSE-2.0
-
- Unless required by applicable law or agreed to in writing, software
- distributed under the License is distributed on an "AS IS" BASIS,
- WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- See the License for the specific language governing permissions and
- limitations under the License.
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/e1a45507/web/demos/package/node_modules/mongodb/Makefile
----------------------------------------------------------------------
diff --git a/web/demos/package/node_modules/mongodb/Makefile b/web/demos/package/node_modules/mongodb/Makefile
deleted file mode 100644
index 59d2bfe..0000000
--- a/web/demos/package/node_modules/mongodb/Makefile
+++ /dev/null
@@ -1,28 +0,0 @@
-NODE = node
-NPM = npm
-NODEUNIT = node_modules/nodeunit/bin/nodeunit
-DOX = node_modules/dox/bin/dox
-name = all
-
-total: build_native
-
-test_functional:
- node test/runner.js -t functional
-
-test_ssl:
- node test/runner.js -t ssl
-
-test_replicaset:
- node test/runner.js -t replicaset
-
-test_sharded:
- node test/runner.js -t sharded
-
-test_auth:
- node test/runner.js -t auth
-
-generate_docs:
- $(NODE) dev/tools/build-docs.js
- make --directory=./docs/sphinx-docs --file=Makefile html
-
-.PHONY: total
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/e1a45507/web/demos/package/node_modules/mongodb/Readme.md
----------------------------------------------------------------------
diff --git a/web/demos/package/node_modules/mongodb/Readme.md b/web/demos/package/node_modules/mongodb/Readme.md
deleted file mode 100644
index c61fbc0..0000000
--- a/web/demos/package/node_modules/mongodb/Readme.md
+++ /dev/null
@@ -1,414 +0,0 @@
-## MongoDB Node.JS Driver
-
-| what | where |
-|---------------|------------------------------------------------|
-| documentation | http://mongodb.github.io/node-mongodb-native/ |
-| apidoc | http://mongodb.github.io/node-mongodb-native/ |
-| source | https://github.com/mongodb/node-mongodb-native |
-| mongodb | http://www.mongodb.org/ |
-
-### Bugs / Feature Requests
-
-Think you’ve found a bug? Want to see a new feature in PyMongo? Please open a
-case in our issue management tool, JIRA:
-
-- Create an account and login <https://jira.mongodb.org>.
-- Navigate to the NODE project <https://jira.mongodb.org/browse/NODE>.
-- Click **Create Issue** - Please provide as much information as possible about the issue type and how to reproduce it.
-
-Bug reports in JIRA for all driver projects (i.e. NODE, PYTHON, CSHARP, JAVA) and the
-Core Server (i.e. SERVER) project are **public**.
-
-### Questions and Bug Reports
-
- * mailing list: https://groups.google.com/forum/#!forum/node-mongodb-native
- * jira: http://jira.mongodb.org/
-
-### Change Log
-
-http://jira.mongodb.org/browse/NODE
-
-## Install
-
-To install the most recent release from npm, run:
-
- npm install mongodb
-
-That may give you a warning telling you that bugs['web'] should be bugs['url'], it would be safe to ignore it (this has been fixed in the development version)
-
-To install the latest from the repository, run::
-
- npm install path/to/node-mongodb-native
-
-## Live Examples
-<a href="https://runnable.com/node-mongodb-native" target="_blank"><img src="https://runnable.com/external/styles/assets/runnablebtn.png" style="width:67px;height:25px;"></a>
-
-## Introduction
-
-This is a node.js driver for MongoDB. It's a port (or close to a port) of the library for ruby at http://github.com/mongodb/mongo-ruby-driver/.
-
-A simple example of inserting a document.
-
-```javascript
- var MongoClient = require('mongodb').MongoClient
- , format = require('util').format;
-
- MongoClient.connect('mongodb://127.0.0.1:27017/test', function(err, db) {
- if(err) throw err;
-
- var collection = db.collection('test_insert');
- collection.insert({a:2}, function(err, docs) {
-
- collection.count(function(err, count) {
- console.log(format("count = %s", count));
- });
-
- // Locate all the entries using find
- collection.find().toArray(function(err, results) {
- console.dir(results);
- // Let's close the db
- db.close();
- });
- });
- })
-```
-
-## Data types
-
-To store and retrieve the non-JSON MongoDb primitives ([ObjectID](http://www.mongodb.org/display/DOCS/Object+IDs), Long, Binary, [Timestamp](http://www.mongodb.org/display/DOCS/Timestamp+data+type), [DBRef](http://www.mongodb.org/display/DOCS/Database+References#DatabaseReferences-DBRef), Code).
-
-In particular, every document has a unique `_id` which can be almost any type, and by default a 12-byte ObjectID is created. ObjectIDs can be represented as 24-digit hexadecimal strings, but you must convert the string back into an ObjectID before you can use it in the database. For example:
-
-```javascript
- // Get the objectID type
- var ObjectID = require('mongodb').ObjectID;
-
- var idString = '4e4e1638c85e808431000003';
- collection.findOne({_id: new ObjectID(idString)}, console.log) // ok
- collection.findOne({_id: idString}, console.log) // wrong! callback gets undefined
-```
-
-Here are the constructors the non-Javascript BSON primitive types:
-
-```javascript
- // Fetch the library
- var mongo = require('mongodb');
- // Create new instances of BSON types
- new mongo.Long(numberString)
- new mongo.ObjectID(hexString)
- new mongo.Timestamp() // the actual unique number is generated on insert.
- new mongo.DBRef(collectionName, id, dbName)
- new mongo.Binary(buffer) // takes a string or Buffer
- new mongo.Code(code, [context])
- new mongo.Symbol(string)
- new mongo.MinKey()
- new mongo.MaxKey()
- new mongo.Double(number) // Force double storage
-```
-
-### The C/C++ bson parser/serializer
-
-If you are running a version of this library has the C/C++ parser compiled, to enable the driver to use the C/C++ bson parser pass it the option native_parser:true like below
-
-```javascript
- // using native_parser:
- MongoClient.connect('mongodb://127.0.0.1:27017/test'
- , {db: {native_parser: true}}, function(err, db) {})
-```
-
-The C++ parser uses the js objects both for serialization and deserialization.
-
-## GitHub information
-
-The source code is available at http://github.com/mongodb/node-mongodb-native.
-You can either clone the repository or download a tarball of the latest release.
-
-Once you have the source you can test the driver by running
-
- $ make test
-
-in the main directory. You will need to have a mongo instance running on localhost for the integration tests to pass.
-
-## Examples
-
-For examples look in the examples/ directory. You can execute the examples using node.
-
- $ cd examples
- $ node queries.js
-
-## GridStore
-
-The GridStore class allows for storage of binary files in mongoDB using the mongoDB defined files and chunks collection definition.
-
-For more information have a look at [Gridstore](https://github.com/mongodb/node-mongodb-native/blob/master/docs/gridfs.md)
-
-## Replicasets
-
-For more information about how to connect to a replicaset have a look at the extensive documentation [Documentation](http://mongodb.github.com/node-mongodb-native/)
-
-### Primary Key Factories
-
-Defining your own primary key factory allows you to generate your own series of id's
-(this could f.ex be to use something like ISBN numbers). The generated the id needs to be a 12 byte long "string".
-
-Simple example below
-
-```javascript
- var MongoClient = require('mongodb').MongoClient
- , format = require('util').format;
-
- // Custom factory (need to provide a 12 byte array);
- CustomPKFactory = function() {}
- CustomPKFactory.prototype = new Object();
- CustomPKFactory.createPk = function() {
- return new ObjectID("aaaaaaaaaaaa");
- }
-
- MongoClient.connect('mongodb://127.0.0.1:27017/test', function(err, db) {
- if(err) throw err;
-
- db.dropDatabase(function(err, done) {
-
- db.createCollection('test_custom_key', function(err, collection) {
-
- collection.insert({'a':1}, function(err, docs) {
-
- collection.find({'_id':new ObjectID("aaaaaaaaaaaa")}).toArray(function(err, items) {
- console.dir(items);
- // Let's close the db
- db.close();
- });
- });
- });
- });
- });
-```
-
-## Documentation
-
-If this document doesn't answer your questions, see the source of
-[Collection](https://github.com/mongodb/node-mongodb-native/blob/master/lib/mongodb/collection.js)
-or [Cursor](https://github.com/mongodb/node-mongodb-native/blob/master/lib/mongodb/cursor.js),
-or the documentation at MongoDB for query and update formats.
-
-### Find
-
-The find method is actually a factory method to create
-Cursor objects. A Cursor lazily uses the connection the first time
-you call `nextObject`, `each`, or `toArray`.
-
-The basic operation on a cursor is the `nextObject` method
-that fetches the next matching document from the database. The convenience
-methods `each` and `toArray` call `nextObject` until the cursor is exhausted.
-
-Signatures:
-
-```javascript
- var cursor = collection.find(query, [fields], options);
- cursor.sort(fields).limit(n).skip(m).
-
- cursor.nextObject(function(err, doc) {});
- cursor.each(function(err, doc) {});
- cursor.toArray(function(err, docs) {});
-
- cursor.rewind() // reset the cursor to its initial state.
-```
-
-Useful chainable methods of cursor. These can optionally be options of `find` instead of method calls:
-
- * `.limit(n).skip(m)` to control paging.
- * `.sort(fields)` Order by the given fields. There are several equivalent syntaxes:
- * `.sort({field1: -1, field2: 1})` descending by field1, then ascending by field2.
- * `.sort([['field1', 'desc'], ['field2', 'asc']])` same as above
- * `.sort([['field1', 'desc'], 'field2'])` same as above
- * `.sort('field1')` ascending by field1
-
-Other options of `find`:
-
-* `fields` the fields to fetch (to avoid transferring the entire document)
-* `tailable` if true, makes the cursor [tailable](http://www.mongodb.org/display/DOCS/Tailable+Cursors).
-* `batchSize` The number of the subset of results to request the database
-to return for every request. This should initially be greater than 1 otherwise
-the database will automatically close the cursor. The batch size can be set to 1
-with `batchSize(n, function(err){})` after performing the initial query to the database.
-* `hint` See [Optimization: hint](http://www.mongodb.org/display/DOCS/Optimization#Optimization-Hint).
-* `explain` turns this into an explain query. You can also call
-`explain()` on any cursor to fetch the explanation.
-* `snapshot` prevents documents that are updated while the query is active
-from being returned multiple times. See more
-[details about query snapshots](http://www.mongodb.org/display/DOCS/How+to+do+Snapshotted+Queries+in+the+Mongo+Database).
-* `timeout` if false, asks MongoDb not to time out this cursor after an
-inactivity period.
-
-For information on how to create queries, see the
-[MongoDB section on querying](http://www.mongodb.org/display/DOCS/Querying).
-
-```javascript
- var MongoClient = require('mongodb').MongoClient
- , format = require('util').format;
-
- MongoClient.connect('mongodb://127.0.0.1:27017/test', function(err, db) {
- if(err) throw err;
-
- var collection = db
- .collection('test')
- .find({})
- .limit(10)
- .toArray(function(err, docs) {
- console.dir(docs);
- });
- });
-```
-
-### Insert
-
-Signature:
-
-```javascript
- collection.insert(docs, options, [callback]);
-```
-
-where `docs` can be a single document or an array of documents.
-
-Useful options:
-
-* `safe:true` Should always set if you have a callback.
-
-See also: [MongoDB docs for insert](http://www.mongodb.org/display/DOCS/Inserting).
-
-```javascript
- var MongoClient = require('mongodb').MongoClient
- , format = require('util').format;
-
- MongoClient.connect('mongodb://127.0.0.1:27017/test', function(err, db) {
- if(err) throw err;
-
- db.collection('test').insert({hello: 'world'}, {w:1}, function(err, objects) {
- if (err) console.warn(err.message);
- if (err && err.message.indexOf('E11000 ') !== -1) {
- // this _id was already inserted in the database
- }
- });
- });
-```
-
-Note that there's no reason to pass a callback to the insert or update commands
-unless you use the `safe:true` option. If you don't specify `safe:true`, then
-your callback will be called immediately.
-
-### Update: update and insert (upsert)
-
-The update operation will update the first document that matches your query
-(or all documents that match if you use `multi:true`).
-If `safe:true`, `upsert` is not set, and no documents match, your callback will return 0 documents updated.
-
-See the [MongoDB docs](http://www.mongodb.org/display/DOCS/Updating) for
-the modifier (`$inc`, `$set`, `$push`, etc.) formats.
-
-Signature:
-
-```javascript
- collection.update(criteria, objNew, options, [callback]);
-```
-
-Useful options:
-
-* `safe:true` Should always set if you have a callback.
-* `multi:true` If set, all matching documents are updated, not just the first.
-* `upsert:true` Atomically inserts the document if no documents matched.
-
-Example for `update`:
-
-```javascript
- var MongoClient = require('mongodb').MongoClient
- , format = require('util').format;
-
- MongoClient.connect('mongodb://127.0.0.1:27017/test', function(err, db) {
- if(err) throw err;
-
- db.collection('test').update({hi: 'here'}, {$set: {hi: 'there'}}, {w:1}, function(err) {
- if (err) console.warn(err.message);
- else console.log('successfully updated');
- });
- });
-```
-
-### Find and modify
-
-`findAndModify` is like `update`, but it also gives the updated document to
-your callback. But there are a few key differences between findAndModify and
-update:
-
- 1. The signatures differ.
- 2. You can only findAndModify a single item, not multiple items.
-
-Signature:
-
-```javascript
- collection.findAndModify(query, sort, update, options, callback)
-```
-
-The sort parameter is used to specify which object to operate on, if more than
-one document matches. It takes the same format as the cursor sort (see
-Connection.find above).
-
-See the
-[MongoDB docs for findAndModify](http://www.mongodb.org/display/DOCS/findAndModify+Command)
-for more details.
-
-Useful options:
-
-* `remove:true` set to a true to remove the object before returning
-* `new:true` set to true if you want to return the modified object rather than the original. Ignored for remove.
-* `upsert:true` Atomically inserts the document if no documents matched.
-
-Example for `findAndModify`:
-
-```javascript
- var MongoClient = require('mongodb').MongoClient
- , format = require('util').format;
-
- MongoClient.connect('mongodb://127.0.0.1:27017/test', function(err, db) {
- if(err) throw err;
- db.collection('test').findAndModify({hello: 'world'}, [['_id','asc']], {$set: {hi: 'there'}}, {}, function(err, object) {
- if (err) console.warn(err.message);
- else console.dir(object); // undefined if no matching object exists.
- });
- });
-```
-
-### Save
-
-The `save` method is a shorthand for upsert if the document contains an
-`_id`, or an insert if there is no `_id`.
-
-## Release Notes
-
-See HISTORY
-
-## Credits
-
-1. [10gen](http://github.com/mongodb/mongo-ruby-driver/)
-2. [Google Closure Library](http://code.google.com/closure/library/)
-3. [Jonas Raoni Soares Silva](http://jsfromhell.com/classes/binary-parser)
-
-## Contributors
-
-Aaron Heckmann, Christoph Pojer, Pau Ramon Revilla, Nathan White, Emmerman, Seth LaForge, Boris Filipov, Stefan Schärmeli, Tedde Lundgren, renctan, Sergey Ukustov, Ciaran Jessup, kuno, srimonti, Erik Abele, Pratik Daga, Slobodan Utvic, Kristina Chodorow, Yonathan Randolph, Brian Noguchi, Sam Epstein, James Harrison Fisher, Vladimir Dronnikov, Ben Hockey, Henrik Johansson, Simon Weare, Alex Gorbatchev, Shimon Doodkin, Kyle Mueller, Eran Hammer-Lahav, Marcin Ciszak, François de Metz, Vinay Pulim, nstielau, Adam Wiggins, entrinzikyl, Jeremy Selier, Ian Millington, Public Keating, andrewjstone, Christopher Stott, Corey Jewett, brettkiefer, Rob Holland, Senmiao Liu, heroic, gitfy
-
-## License
-
- Copyright 2009 - 2013 MongoDb Inc.
-
- Licensed under the Apache License, Version 2.0 (the "License");
- you may not use this file except in compliance with the License.
- You may obtain a copy of the License at
-
- http://www.apache.org/licenses/LICENSE-2.0
-
- Unless required by applicable law or agreed to in writing, software
- distributed under the License is distributed on an "AS IS" BASIS,
- WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- See the License for the specific language governing permissions and
- limitations under the License.
-
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/e1a45507/web/demos/package/node_modules/mongodb/index.js
----------------------------------------------------------------------
diff --git a/web/demos/package/node_modules/mongodb/index.js b/web/demos/package/node_modules/mongodb/index.js
deleted file mode 100755
index 4f59e9d..0000000
--- a/web/demos/package/node_modules/mongodb/index.js
+++ /dev/null
@@ -1 +0,0 @@
-module.exports = require('./lib/mongodb');
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/e1a45507/web/demos/package/node_modules/mongodb/lib/mongodb/admin.js
----------------------------------------------------------------------
diff --git a/web/demos/package/node_modules/mongodb/lib/mongodb/admin.js b/web/demos/package/node_modules/mongodb/lib/mongodb/admin.js
deleted file mode 100644
index 0bd01b5..0000000
--- a/web/demos/package/node_modules/mongodb/lib/mongodb/admin.js
+++ /dev/null
@@ -1,339 +0,0 @@
-/*!
- * Module dependencies.
- */
-var Collection = require('./collection').Collection,
- Cursor = require('./cursor').Cursor,
- DbCommand = require('./commands/db_command').DbCommand,
- utils = require('./utils');
-
-/**
- * Allows the user to access the admin functionality of MongoDB
- *
- * @class Represents the Admin methods of MongoDB.
- * @param {Object} db Current db instance we wish to perform Admin operations on.
- * @return {Function} Constructor for Admin type.
- */
-function Admin(db) {
- if(!(this instanceof Admin)) return new Admin(db);
- this.db = db;
-};
-
-/**
- * Retrieve the server information for the current
- * instance of the db client
- *
- * @param {Function} callback this will be called after executing this method. The first parameter will contain the Error object if an error occured, or null otherwise. While the second parameter will contain the results from buildInfo or null if an error occured.
- * @return {null} Returns no result
- * @api public
- */
-Admin.prototype.buildInfo = function(callback) {
- this.serverInfo(callback);
-}
-
-/**
- * Retrieve the server information for the current
- * instance of the db client
- *
- * @param {Function} callback this will be called after executing this method. The first parameter will contain the Error object if an error occured, or null otherwise. While the second parameter will contain the results from serverInfo or null if an error occured.
- * @return {null} Returns no result
- * @api private
- */
-Admin.prototype.serverInfo = function(callback) {
- this.db.executeDbAdminCommand({buildinfo:1}, function(err, doc) {
- if(err != null) return callback(err, null);
- return callback(null, doc.documents[0]);
- });
-}
-
-/**
- * Retrieve this db's server status.
- *
- * @param {Function} callback this will be called after executing this method. The first parameter will contain the Error object if an error occured, or null otherwise. While the second parameter will contain the results from serverStatus or null if an error occured.
- * @return {null}
- * @api public
- */
-Admin.prototype.serverStatus = function(callback) {
- var self = this;
-
- this.db.executeDbAdminCommand({serverStatus: 1}, function(err, doc) {
- if(err == null && doc.documents[0].ok === 1) {
- callback(null, doc.documents[0]);
- } else {
- if(err) return callback(err, false);
- return callback(utils.toError(doc.documents[0]), false);
- }
- });
-};
-
-/**
- * Retrieve the current profiling Level for MongoDB
- *
- * @param {Function} callback this will be called after executing this method. The first parameter will contain the Error object if an error occured, or null otherwise. While the second parameter will contain the results from profilingLevel or null if an error occured.
- * @return {null} Returns no result
- * @api public
- */
-Admin.prototype.profilingLevel = function(callback) {
- var self = this;
-
- this.db.executeDbAdminCommand({profile:-1}, function(err, doc) {
- doc = doc.documents[0];
-
- if(err == null && doc.ok === 1) {
- var was = doc.was;
- if(was == 0) return callback(null, "off");
- if(was == 1) return callback(null, "slow_only");
- if(was == 2) return callback(null, "all");
- return callback(new Error("Error: illegal profiling level value " + was), null);
- } else {
- err != null ? callback(err, null) : callback(new Error("Error with profile command"), null);
- }
- });
-};
-
-/**
- * Ping the MongoDB server and retrieve results
- *
- * @param {Function} callback this will be called after executing this method. The first parameter will contain the Error object if an error occured, or null otherwise. While the second parameter will contain the results from ping or null if an error occured.
- * @return {null} Returns no result
- * @api public
- */
-Admin.prototype.ping = function(options, callback) {
- // Unpack calls
- var args = Array.prototype.slice.call(arguments, 0);
- callback = args.pop();
-
- this.db.executeDbAdminCommand({ping: 1}, callback);
-}
-
-/**
- * Authenticate against MongoDB
- *
- * @param {String} username The user name for the authentication.
- * @param {String} password The password for the authentication.
- * @param {Function} callback this will be called after executing this method. The first parameter will contain the Error object if an error occured, or null otherwise. While the second parameter will contain the results from authenticate or null if an error occured.
- * @return {null} Returns no result
- * @api public
- */
-Admin.prototype.authenticate = function(username, password, callback) {
- this.db.authenticate(username, password, {authdb: 'admin'}, function(err, doc) {
- return callback(err, doc);
- })
-}
-
-/**
- * Logout current authenticated user
- *
- * @param {Object} [options] Optional parameters to the command.
- * @param {Function} callback this will be called after executing this method. The first parameter will contain the Error object if an error occured, or null otherwise. While the second parameter will contain the results from logout or null if an error occured.
- * @return {null} Returns no result
- * @api public
- */
-Admin.prototype.logout = function(callback) {
- this.db.logout({authdb: 'admin'}, function(err, doc) {
- return callback(err, doc);
- })
-}
-
-/**
- * Add a user to the MongoDB server, if the user exists it will
- * overwrite the current password
- *
- * Options
- * - **safe** {true | {w:n, wtimeout:n} | {fsync:true}, default:false}, executes with a getLastError command returning the results of the command on MongoDB.
- *
- * @param {String} username The user name for the authentication.
- * @param {String} password The password for the authentication.
- * @param {Object} [options] additional options during update.
- * @param {Function} callback this will be called after executing this method. The first parameter will contain the Error object if an error occured, or null otherwise. While the second parameter will contain the results from addUser or null if an error occured.
- * @return {null} Returns no result
- * @api public
- */
-Admin.prototype.addUser = function(username, password, options, callback) {
- var args = Array.prototype.slice.call(arguments, 2);
- callback = args.pop();
- options = args.length ? args.shift() : {};
- // Set the db name to admin
- options.dbName = 'admin';
- // Add user
- this.db.addUser(username, password, options, function(err, doc) {
- return callback(err, doc);
- })
-}
-
-/**
- * Remove a user from the MongoDB server
- *
- * Options
- * - **safe** {true | {w:n, wtimeout:n} | {fsync:true}, default:false}, executes with a getLastError command returning the results of the command on MongoDB.
- *
- * @param {String} username The user name for the authentication.
- * @param {Object} [options] additional options during update.
- * @param {Function} callback this will be called after executing this method. The first parameter will contain the Error object if an error occured, or null otherwise. While the second parameter will contain the results from removeUser or null if an error occured.
- * @return {null} Returns no result
- * @api public
- */
-Admin.prototype.removeUser = function(username, options, callback) {
- var self = this;
- var args = Array.prototype.slice.call(arguments, 1);
- callback = args.pop();
- options = args.length ? args.shift() : {};
- options.dbName = 'admin';
-
- this.db.removeUser(username, options, function(err, doc) {
- return callback(err, doc);
- })
-}
-
-/**
- * Set the current profiling level of MongoDB
- *
- * @param {String} level The new profiling level (off, slow_only, all)
- * @param {Function} callback this will be called after executing this method. The first parameter will contain the Error object if an error occured, or null otherwise. While the second parameter will contain the results from setProfilingLevel or null if an error occured.
- * @return {null} Returns no result
- * @api public
- */
-Admin.prototype.setProfilingLevel = function(level, callback) {
- var self = this;
- var command = {};
- var profile = 0;
-
- if(level == "off") {
- profile = 0;
- } else if(level == "slow_only") {
- profile = 1;
- } else if(level == "all") {
- profile = 2;
- } else {
- return callback(new Error("Error: illegal profiling level value " + level));
- }
-
- // Set up the profile number
- command['profile'] = profile;
-
- this.db.executeDbAdminCommand(command, function(err, doc) {
- doc = doc.documents[0];
-
- if(err == null && doc.ok === 1)
- return callback(null, level);
- return err != null ? callback(err, null) : callback(new Error("Error with profile command"), null);
- });
-};
-
-/**
- * Retrive the current profiling information for MongoDB
- *
- * @param {Function} callback this will be called after executing this method. The first parameter will contain the Error object if an error occured, or null otherwise. While the second parameter will contain the results from profilingInfo or null if an error occured.
- * @return {null} Returns no result
- * @api public
- */
-Admin.prototype.profilingInfo = function(callback) {
- try {
- new Cursor(this.db, new Collection(this.db, DbCommand.SYSTEM_PROFILE_COLLECTION), {}, {}, {dbName: 'admin'}).toArray(function(err, items) {
- return callback(err, items);
- });
- } catch (err) {
- return callback(err, null);
- }
-};
-
-/**
- * Execute a db command against the Admin database
- *
- * @param {Object} command A command object `{ping:1}`.
- * @param {Object} [options] Optional parameters to the command.
- * @param {Function} callback this will be called after executing this method. The command always return the whole result of the command as the second parameter.
- * @return {null} Returns no result
- * @api public
- */
-Admin.prototype.command = function(command, options, callback) {
- var self = this;
- var args = Array.prototype.slice.call(arguments, 1);
- callback = args.pop();
- options = args.length ? args.shift() : {};
-
- // Execute a command
- this.db.executeDbAdminCommand(command, options, function(err, doc) {
- // Ensure change before event loop executes
- return callback != null ? callback(err, doc) : null;
- });
-}
-
-/**
- * Validate an existing collection
- *
- * @param {String} collectionName The name of the collection to validate.
- * @param {Object} [options] Optional parameters to the command.
- * @param {Function} callback this will be called after executing this method. The first parameter will contain the Error object if an error occured, or null otherwise. While the second parameter will contain the results from validateCollection or null if an error occured.
- * @return {null} Returns no result
- * @api public
- */
-Admin.prototype.validateCollection = function(collectionName, options, callback) {
- var args = Array.prototype.slice.call(arguments, 1);
- callback = args.pop();
- options = args.length ? args.shift() : {};
-
- var self = this;
- var command = {validate: collectionName};
- var keys = Object.keys(options);
-
- // Decorate command with extra options
- for(var i = 0; i < keys.length; i++) {
- if(options.hasOwnProperty(keys[i])) {
- command[keys[i]] = options[keys[i]];
- }
- }
-
- this.db.executeDbCommand(command, function(err, doc) {
- if(err != null) return callback(err, null);
- doc = doc.documents[0];
-
- if(doc.ok === 0)
- return callback(new Error("Error with validate command"), null);
- if(doc.result != null && doc.result.constructor != String)
- return callback(new Error("Error with validation data"), null);
- if(doc.result != null && doc.result.match(/exception|corrupt/) != null)
- return callback(new Error("Error: invalid collection " + collectionName), null);
- if(doc.valid != null && !doc.valid)
- return callback(new Error("Error: invalid collection " + collectionName), null);
-
- return callback(null, doc);
- });
-};
-
-/**
- * List the available databases
- *
- * @param {Function} callback this will be called after executing this method. The first parameter will contain the Error object if an error occured, or null otherwise. While the second parameter will contain the results from listDatabases or null if an error occured.
- * @return {null} Returns no result
- * @api public
- */
-Admin.prototype.listDatabases = function(callback) {
- // Execute the listAllDatabases command
- this.db.executeDbAdminCommand({listDatabases:1}, {}, function(err, doc) {
- if(err != null) return callback(err, null);
- return callback(null, doc.documents[0]);
- });
-}
-
-/**
- * Get ReplicaSet status
- *
- * @param {Function} callback this will be called after executing this method. The first parameter will contain the Error object if an error occured, or null otherwise. While the second parameter will contain the results from replSetGetStatus or null if an error occured.
- * @return {null}
- * @api public
- */
-Admin.prototype.replSetGetStatus = function(callback) {
- var self = this;
-
- this.db.executeDbAdminCommand({replSetGetStatus:1}, function(err, doc) {
- if(err == null && doc.documents[0].ok === 1)
- return callback(null, doc.documents[0]);
- if(err) return callback(err, false);
- return callback(utils.toError(doc.documents[0]), false);
- });
-};
-
-/**
- * @ignore
- */
-exports.Admin = Admin;
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/e1a45507/web/demos/package/node_modules/mongodb/lib/mongodb/aggregation_cursor.js
----------------------------------------------------------------------
diff --git a/web/demos/package/node_modules/mongodb/lib/mongodb/aggregation_cursor.js b/web/demos/package/node_modules/mongodb/lib/mongodb/aggregation_cursor.js
deleted file mode 100644
index 0f424d3..0000000
--- a/web/demos/package/node_modules/mongodb/lib/mongodb/aggregation_cursor.js
+++ /dev/null
@@ -1,257 +0,0 @@
-var ReadPreference = require('./connection/read_preference').ReadPreference
- , Readable = require('stream').Readable
- , CommandCursor = require('./command_cursor').CommandCursor
- , utils = require('./utils')
- , shared = require('./collection/shared')
- , inherits = require('util').inherits;
-
-var AggregationCursor = function(collection, serverCapabilities, options) {
- var pipe = [];
- var self = this;
- var results = null;
- var _cursor_options = {};
- // Ensure we have options set up
- options = options == null ? {} : options;
-
- // If a pipeline was provided
- pipe = Array.isArray(options.pipe) ? options.pipe : pipe;
- // Set passed in batchSize if provided
- if(typeof options.batchSize == 'number') _cursor_options.batchSize = options.batchSize;
- // Get the read Preference
- var readPreference = shared._getReadConcern(collection, options);
-
- // Set up
- Readable.call(this, {objectMode: true});
-
- // Contains connection
- var connection = null;
-
- // Set the read preference
- var _options = {
- readPreference: readPreference
- };
-
- // Actual command
- var command = {
- aggregate: collection.collectionName
- , pipeline: pipe
- , cursor: _cursor_options
- }
-
- // If allowDiskUsage is set
- if(typeof options.allowDiskUsage == 'boolean')
- command.allowDiskUsage = options.allowDiskUsage;
-
- // Command cursor (if we support one)
- var commandCursor = new CommandCursor(collection.db, collection, command);
-
- // // Internal cursor methods
- // this.find = function(selector) {
- // pipe.push({$match: selector});
- // return self;
- // }
-
- // this.unwind = function(unwind) {
- // pipe.push({$unwind: unwind});
- // return self;
- // }
-
- // this.group = function(group) {
- // pipe.push({$group: group});
- // return self;
- // }
-
- // this.project = function(project) {
- // pipe.push({$project: project});
- // return self;
- // }
-
- // this.limit = function(limit) {
- // pipe.push({$limit: limit});
- // return self;
- // }
-
- // this.geoNear = function(geoNear) {
- // pipe.push({$geoNear: geoNear});
- // return self;
- // }
-
- // this.sort = function(sort) {
- // pipe.push({$sort: sort});
- // return self;
- // }
-
- // this.withReadPreference = function(read_preference) {
- // _options.readPreference = read_preference;
- // return self;
- // }
-
- // this.withQueryOptions = function(options) {
- // if(options.batchSize) {
- // _cursor_options.batchSize = options.batchSize;
- // }
-
- // // Return the cursor
- // return self;
- // }
-
- // this.skip = function(skip) {
- // pipe.push({$skip: skip});
- // return self;
- // }
-
- // this.allowDiskUsage = function(allowDiskUsage) {
- // command.allowDiskUsage = allowDiskUsage;
- // return self;
- // }
-
- this.explain = function(callback) {
- if(typeof callback != 'function')
- throw utils.toError("AggregationCursor explain requires a callback function");
-
- // Add explain options
- _options.explain = true;
- // Execute aggregation pipeline
- collection.aggregate(pipe, _options, function(err, results) {
- if(err) return callback(err, null);
- callback(null, results);
- });
- }
-
- // this.maxTimeMS = function(maxTimeMS) {
- // if(typeof maxTimeMS != 'number') {
- // throw new Error("maxTimeMS must be a number");
- // }
-
- // // Save the maxTimeMS
- // _options.maxTimeMS = maxTimeMS
- // // Set the maxTimeMS on the command cursor
- // commandCursor.maxTimeMS(maxTimeMS);
- // return self;
- // }
-
- this.get = function(callback) {
- if(typeof callback != 'function')
- throw utils.toError("AggregationCursor get requires a callback function");
- // Checkout a connection
- var _connection = collection.db.serverConfig.checkoutReader(_options.readPreference);
- // Fall back
- if(!_connection.serverCapabilities.hasAggregationCursor) {
- return collection.aggregate(pipe, _options, function(err, results) {
- if(err) return callback(err);
- callback(null, results);
- });
- }
-
- // Execute get using command Cursor
- commandCursor.get({connection: _connection}, callback);
- }
-
- this.getOne = function(callback) {
- if(typeof callback != 'function')
- throw utils.toError("AggregationCursor getOne requires a callback function");
- // Set the limit to 1
- pipe.push({$limit: 1});
- // For now we have no cursor command so let's just wrap existing results
- collection.aggregate(pipe, _options, function(err, results) {
- if(err) return callback(err);
- callback(null, results[0]);
- });
- }
-
- this.each = function(callback) {
- // Checkout a connection if we have none
- if(!connection)
- connection = collection.db.serverConfig.checkoutReader(_options.readPreference);
-
- // Fall back
- if(!connection.serverCapabilities.hasAggregationCursor) {
- collection.aggregate(pipe, _options, function(err, _results) {
- if(err) return callback(err);
-
- while(_results.length > 0) {
- callback(null, _results.shift());
- }
-
- callback(null, null);
- });
- }
-
- // Execute each using command Cursor
- commandCursor.each({connection: connection}, callback);
- }
-
- this.next = function(callback) {
- if(typeof callback != 'function')
- throw utils.toError("AggregationCursor next requires a callback function");
-
- // Checkout a connection if we have none
- if(!connection)
- connection = collection.db.serverConfig.checkoutReader(_options.readPreference);
-
- // Fall back
- if(!connection.serverCapabilities.hasAggregationCursor) {
- if(!results) {
- // For now we have no cursor command so let's just wrap existing results
- return collection.aggregate(pipe, _options, function(err, _results) {
- if(err) return callback(err);
- results = _results;
-
- // Ensure we don't issue undefined
- var item = results.shift();
- callback(null, item ? item : null);
- });
- }
-
- // Ensure we don't issue undefined
- var item = results.shift();
- // Return the item
- return callback(null, item ? item : null);
- }
-
- // Execute next using command Cursor
- commandCursor.next({connection: connection}, callback);
- }
-
- //
- // Close method
- //
- this.close = function(callback) {
- if(typeof callback != 'function')
- throw utils.toError("AggregationCursor close requires a callback function");
-
- // Checkout a connection if we have none
- if(!connection)
- connection = collection.db.serverConfig.checkoutReader(_options.readPreference);
-
- // Fall back
- if(!connection.serverCapabilities.hasAggregationCursor) {
- return callback(null, null);
- }
-
- // Execute next using command Cursor
- commandCursor.close({connection: connection}, callback);
- }
-
- //
- // Stream method
- //
- this._read = function(n) {
- self.next(function(err, result) {
- if(err) {
- self.emit('error', err);
- return self.push(null);
- }
-
- self.push(result);
- });
- }
-}
-
-// Inherit from Readable
-if(Readable != null) {
- inherits(AggregationCursor, Readable);
-}
-
-// Exports the Aggregation Framework
-exports.AggregationCursor = AggregationCursor;
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/e1a45507/web/demos/package/node_modules/mongodb/lib/mongodb/auth/mongodb_cr.js
----------------------------------------------------------------------
diff --git a/web/demos/package/node_modules/mongodb/lib/mongodb/auth/mongodb_cr.js b/web/demos/package/node_modules/mongodb/lib/mongodb/auth/mongodb_cr.js
deleted file mode 100644
index 39bf2ab..0000000
--- a/web/demos/package/node_modules/mongodb/lib/mongodb/auth/mongodb_cr.js
+++ /dev/null
@@ -1,62 +0,0 @@
-var DbCommand = require('../commands/db_command').DbCommand
- , utils = require('../utils');
-
-var authenticate = function(db, username, password, authdb, options, callback) {
- var numberOfConnections = 0;
- var errorObject = null;
-
- if(options['connection'] != null) {
- //if a connection was explicitly passed on options, then we have only one...
- numberOfConnections = 1;
- } else {
- // Get the amount of connections in the pool to ensure we have authenticated all comments
- numberOfConnections = db.serverConfig.allRawConnections().length;
- options['onAll'] = true;
- }
-
- // Execute all four
- db._executeQueryCommand(DbCommand.createGetNonceCommand(db), options, function(err, result, connection) {
- // console.log("--------------------------------------------- MONGODB-CR 0")
- // console.dir(err)
- // Execute on all the connections
- if(err == null) {
- // Nonce used to make authentication request with md5 hash
- var nonce = result.documents[0].nonce;
- // Execute command
- db._executeQueryCommand(DbCommand.createAuthenticationCommand(db, username, password, nonce, authdb), {connection:connection}, function(err, result) {
- // console.log("--------------------------------------------- MONGODB-CR 1")
- // console.dir(err)
- // console.dir(result)
- // Count down
- numberOfConnections = numberOfConnections - 1;
- // Ensure we save any error
- if(err) {
- errorObject = err;
- } else if(result
- && Array.isArray(result.documents)
- && result.documents.length > 0
- && (result.documents[0].err != null || result.documents[0].errmsg != null)) {
- errorObject = utils.toError(result.documents[0]);
- }
-
- // Work around the case where the number of connections are 0
- if(numberOfConnections <= 0 && typeof callback == 'function') {
- var internalCallback = callback;
- callback = null;
-
- if(errorObject == null
- && result && Array.isArray(result.documents) && result.documents.length > 0
- && result.documents[0].ok == 1) { // We authenticated correctly save the credentials
- db.serverConfig.auth.add('MONGODB-CR', db.databaseName, username, password, authdb);
- // Return callback
- internalCallback(errorObject, true);
- } else {
- internalCallback(errorObject, false);
- }
- }
- });
- }
- });
-}
-
-exports.authenticate = authenticate;
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/e1a45507/web/demos/package/node_modules/mongodb/lib/mongodb/auth/mongodb_gssapi.js
----------------------------------------------------------------------
diff --git a/web/demos/package/node_modules/mongodb/lib/mongodb/auth/mongodb_gssapi.js b/web/demos/package/node_modules/mongodb/lib/mongodb/auth/mongodb_gssapi.js
deleted file mode 100644
index 47b5155..0000000
--- a/web/demos/package/node_modules/mongodb/lib/mongodb/auth/mongodb_gssapi.js
+++ /dev/null
@@ -1,149 +0,0 @@
-var DbCommand = require('../commands/db_command').DbCommand
- , utils = require('../utils')
- , format = require('util').format;
-
-// Kerberos class
-var Kerberos = null;
-var MongoAuthProcess = null;
-// Try to grab the Kerberos class
-try {
- Kerberos = require('kerberos').Kerberos
- // Authentication process for Mongo
- MongoAuthProcess = require('kerberos').processes.MongoAuthProcess
-} catch(err) {}
-
-var authenticate = function(db, username, password, authdb, options, callback) {
- var numberOfConnections = 0;
- var errorObject = null;
- // We don't have the Kerberos library
- if(Kerberos == null) return callback(new Error("Kerberos library is not installed"));
-
- if(options['connection'] != null) {
- //if a connection was explicitly passed on options, then we have only one...
- numberOfConnections = 1;
- } else {
- // Get the amount of connections in the pool to ensure we have authenticated all comments
- numberOfConnections = db.serverConfig.allRawConnections().length;
- options['onAll'] = true;
- }
-
- // Grab all the connections
- var connections = options['connection'] != null ? [options['connection']] : db.serverConfig.allRawConnections();
- var gssapiServiceName = options['gssapiServiceName'] || 'mongodb';
- var error = null;
- // Authenticate all connections
- for(var i = 0; i < numberOfConnections; i++) {
-
- // Start Auth process for a connection
- GSSAPIInitialize(db, username, password, authdb, gssapiServiceName, connections[i], function(err, result) {
- // Adjust number of connections left to connect
- numberOfConnections = numberOfConnections - 1;
- // If we have an error save it
- if(err) error = err;
-
- // We are done
- if(numberOfConnections == 0) {
- if(err) return callback(error, false);
- // We authenticated correctly save the credentials
- db.serverConfig.auth.add('GSSAPI', db.databaseName, username, password, authdb, gssapiServiceName);
- // Return valid callback
- return callback(null, true);
- }
- });
- }
-}
-
-//
-// Initialize step
-var GSSAPIInitialize = function(db, username, password, authdb, gssapiServiceName, connection, callback) {
- // Create authenticator
- var mongo_auth_process = new MongoAuthProcess(connection.socketOptions.host, connection.socketOptions.port, gssapiServiceName);
-
- // Perform initialization
- mongo_auth_process.init(username, password, function(err, context) {
- if(err) return callback(err, false);
-
- // Perform the first step
- mongo_auth_process.transition('', function(err, payload) {
- if(err) return callback(err, false);
-
- // Call the next db step
- MongoDBGSSAPIFirstStep(mongo_auth_process, payload, db, username, password, authdb, connection, callback);
- });
- });
-}
-
-//
-// Perform first step against mongodb
-var MongoDBGSSAPIFirstStep = function(mongo_auth_process, payload, db, username, password, authdb, connection, callback) {
- // Build the sasl start command
- var command = {
- saslStart: 1
- , mechanism: 'GSSAPI'
- , payload: payload
- , autoAuthorize: 1
- };
-
- // Execute first sasl step
- db._executeQueryCommand(DbCommand.createDbCommand(db, command, {}, '$external'), {connection:connection}, function(err, doc) {
- if(err) return callback(err, false);
- // Get the payload
- doc = doc.documents[0];
- var db_payload = doc.payload;
-
- mongo_auth_process.transition(doc.payload, function(err, payload) {
- if(err) return callback(err, false);
-
- // MongoDB API Second Step
- MongoDBGSSAPISecondStep(mongo_auth_process, payload, doc, db, username, password, authdb, connection, callback);
- });
- });
-}
-
-//
-// Perform first step against mongodb
-var MongoDBGSSAPISecondStep = function(mongo_auth_process, payload, doc, db, username, password, authdb, connection, callback) {
- // Build Authentication command to send to MongoDB
- var command = {
- saslContinue: 1
- , conversationId: doc.conversationId
- , payload: payload
- };
-
- // Execute the command
- db._executeQueryCommand(DbCommand.createDbCommand(db, command, {}, '$external'), {connection:connection}, function(err, doc) {
- if(err) return callback(err, false);
-
- // Get the result document
- doc = doc.documents[0];
-
- // Call next transition for kerberos
- mongo_auth_process.transition(doc.payload, function(err, payload) {
- if(err) return callback(err, false);
-
- // Call the last and third step
- MongoDBGSSAPIThirdStep(mongo_auth_process, payload, doc, db, username, password, authdb, connection, callback);
- });
- });
-}
-
-var MongoDBGSSAPIThirdStep = function(mongo_auth_process, payload, doc, db, username, password, authdb, connection, callback) {
- // Build final command
- var command = {
- saslContinue: 1
- , conversationId: doc.conversationId
- , payload: payload
- };
-
- // Let's finish the auth process against mongodb
- db._executeQueryCommand(DbCommand.createDbCommand(db, command, {}, '$external'), {connection:connection}, function(err, doc) {
- if(err) return callback(err, false);
-
- mongo_auth_process.transition(null, function(err, payload) {
- if(err) return callback(err, false);
- callback(null, true);
- });
- });
-}
-
-exports.authenticate = authenticate;
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/e1a45507/web/demos/package/node_modules/mongodb/lib/mongodb/auth/mongodb_plain.js
----------------------------------------------------------------------
diff --git a/web/demos/package/node_modules/mongodb/lib/mongodb/auth/mongodb_plain.js b/web/demos/package/node_modules/mongodb/lib/mongodb/auth/mongodb_plain.js
deleted file mode 100644
index 594181d..0000000
--- a/web/demos/package/node_modules/mongodb/lib/mongodb/auth/mongodb_plain.js
+++ /dev/null
@@ -1,66 +0,0 @@
-var DbCommand = require('../commands/db_command').DbCommand
- , utils = require('../utils')
- , Binary = require('bson').Binary
- , format = require('util').format;
-
-var authenticate = function(db, username, password, options, callback) {
- var numberOfConnections = 0;
- var errorObject = null;
-
- if(options['connection'] != null) {
- //if a connection was explicitly passed on options, then we have only one...
- numberOfConnections = 1;
- } else {
- // Get the amount of connections in the pool to ensure we have authenticated all comments
- numberOfConnections = db.serverConfig.allRawConnections().length;
- options['onAll'] = true;
- }
-
- // Create payload
- var payload = new Binary(format("\x00%s\x00%s", username, password));
-
- // Let's start the sasl process
- var command = {
- saslStart: 1
- , mechanism: 'PLAIN'
- , payload: payload
- , autoAuthorize: 1
- };
-
- // Grab all the connections
- var connections = options['connection'] != null ? [options['connection']] : db.serverConfig.allRawConnections();
-
- // Authenticate all connections
- for(var i = 0; i < numberOfConnections; i++) {
- var connection = connections[i];
- // Execute first sasl step
- db._executeQueryCommand(DbCommand.createDbCommand(db, command, {}, '$external'), {connection:connection}, function(err, result) {
- // Count down
- numberOfConnections = numberOfConnections - 1;
-
- // Ensure we save any error
- if(err) {
- errorObject = err;
- } else if(result.documents[0].err != null || result.documents[0].errmsg != null){
- errorObject = utils.toError(result.documents[0]);
- }
-
- // Work around the case where the number of connections are 0
- if(numberOfConnections <= 0 && typeof callback == 'function') {
- var internalCallback = callback;
- callback = null;
-
- if(errorObject == null && result.documents[0].ok == 1) {
- // We authenticated correctly save the credentials
- db.serverConfig.auth.add('PLAIN', db.databaseName, username, password);
- // Return callback
- internalCallback(errorObject, true);
- } else {
- internalCallback(errorObject, false);
- }
- }
- });
- }
-}
-
-exports.authenticate = authenticate;
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/e1a45507/web/demos/package/node_modules/mongodb/lib/mongodb/auth/mongodb_sspi.js
----------------------------------------------------------------------
diff --git a/web/demos/package/node_modules/mongodb/lib/mongodb/auth/mongodb_sspi.js b/web/demos/package/node_modules/mongodb/lib/mongodb/auth/mongodb_sspi.js
deleted file mode 100644
index 316fa3a..0000000
--- a/web/demos/package/node_modules/mongodb/lib/mongodb/auth/mongodb_sspi.js
+++ /dev/null
@@ -1,135 +0,0 @@
-var DbCommand = require('../commands/db_command').DbCommand
- , utils = require('../utils')
- , format = require('util').format;
-
-// Kerberos class
-var Kerberos = null;
-var MongoAuthProcess = null;
-// Try to grab the Kerberos class
-try {
- Kerberos = require('kerberos').Kerberos
- // Authentication process for Mongo
- MongoAuthProcess = require('kerberos').processes.MongoAuthProcess
-} catch(err) {}
-
-var authenticate = function(db, username, password, authdb, options, callback) {
- var numberOfConnections = 0;
- var errorObject = null;
- // We don't have the Kerberos library
- if(Kerberos == null) return callback(new Error("Kerberos library is not installed"));
-
- if(options['connection'] != null) {
- //if a connection was explicitly passed on options, then we have only one...
- numberOfConnections = 1;
- } else {
- // Get the amount of connections in the pool to ensure we have authenticated all comments
- numberOfConnections = db.serverConfig.allRawConnections().length;
- options['onAll'] = true;
- }
-
- // Set the sspi server name
- var gssapiServiceName = options['gssapiServiceName'] || 'mongodb';
-
- // Grab all the connections
- var connections = db.serverConfig.allRawConnections();
- var error = null;
-
- // Authenticate all connections
- for(var i = 0; i < numberOfConnections; i++) {
- // Start Auth process for a connection
- SSIPAuthenticate(db, username, password, authdb, gssapiServiceName, connections[i], function(err, result) {
- // Adjust number of connections left to connect
- numberOfConnections = numberOfConnections - 1;
- // If we have an error save it
- if(err) error = err;
-
- // We are done
- if(numberOfConnections == 0) {
- if(err) return callback(err, false);
- // We authenticated correctly save the credentials
- db.serverConfig.auth.add('GSSAPI', db.databaseName, username, password, authdb, gssapiServiceName);
- // Return valid callback
- return callback(null, true);
- }
- });
- }
-}
-
-var SSIPAuthenticate = function(db, username, password, authdb, service_name, connection, callback) {
- // --------------------------------------------------------------
- // Async Version
- // --------------------------------------------------------------
- var command = {
- saslStart: 1
- , mechanism: 'GSSAPI'
- , payload: ''
- , autoAuthorize: 1
- };
-
- // Create authenticator
- var mongo_auth_process = new MongoAuthProcess(connection.socketOptions.host, connection.socketOptions.port, service_name);
-
- // Execute first sasl step
- db._executeQueryCommand(DbCommand.createDbCommand(db, command, {}, '$external'), {connection:connection}, function(err, doc) {
- if(err) return callback(err);
- doc = doc.documents[0];
-
- mongo_auth_process.init(username, password, function(err) {
- if(err) return callback(err);
-
- mongo_auth_process.transition(doc.payload, function(err, payload) {
- if(err) return callback(err);
-
- // Perform the next step against mongod
- var command = {
- saslContinue: 1
- , conversationId: doc.conversationId
- , payload: payload
- };
-
- // Execute the command
- db._executeQueryCommand(DbCommand.createDbCommand(db, command, {}, '$external'), {connection:connection}, function(err, doc) {
- if(err) return callback(err);
- doc = doc.documents[0];
-
- mongo_auth_process.transition(doc.payload, function(err, payload) {
- if(err) return callback(err);
-
- // Perform the next step against mongod
- var command = {
- saslContinue: 1
- , conversationId: doc.conversationId
- , payload: payload
- };
-
- // Execute the command
- db._executeQueryCommand(DbCommand.createDbCommand(db, command, {}, '$external'), {connection:connection}, function(err, doc) {
- if(err) return callback(err);
- doc = doc.documents[0];
-
- mongo_auth_process.transition(doc.payload, function(err, payload) {
- // Perform the next step against mongod
- var command = {
- saslContinue: 1
- , conversationId: doc.conversationId
- , payload: payload
- };
-
- // Execute the command
- db._executeQueryCommand(DbCommand.createDbCommand(db, command, {}, '$external'), {connection:connection}, function(err, doc) {
- if(err) return callback(err);
- doc = doc.documents[0];
-
- if(doc.done) return callback(null, true);
- callback(new Error("Authentication failed"), false);
- });
- });
- });
- });
- });
- });
- });
- });
-}
-
-exports.authenticate = authenticate;
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/e1a45507/web/demos/package/node_modules/mongodb/lib/mongodb/auth/mongodb_x509.js
----------------------------------------------------------------------
diff --git a/web/demos/package/node_modules/mongodb/lib/mongodb/auth/mongodb_x509.js b/web/demos/package/node_modules/mongodb/lib/mongodb/auth/mongodb_x509.js
deleted file mode 100644
index de68030..0000000
--- a/web/demos/package/node_modules/mongodb/lib/mongodb/auth/mongodb_x509.js
+++ /dev/null
@@ -1,62 +0,0 @@
-var DbCommand = require('../commands/db_command').DbCommand
- , utils = require('../utils')
- , Binary = require('bson').Binary
- , format = require('util').format;
-
-var authenticate = function(db, username, password, options, callback) {
- var numberOfConnections = 0;
- var errorObject = null;
-
- if(options['connection'] != null) {
- //if a connection was explicitly passed on options, then we have only one...
- numberOfConnections = 1;
- } else {
- // Get the amount of connections in the pool to ensure we have authenticated all comments
- numberOfConnections = db.serverConfig.allRawConnections().length;
- options['onAll'] = true;
- }
-
- // Let's start the sasl process
- var command = {
- authenticate: 1
- , mechanism: 'MONGODB-X509'
- , user: username
- };
-
- // Grab all the connections
- var connections = options['connection'] != null ? [options['connection']] : db.serverConfig.allRawConnections();
-
- // Authenticate all connections
- for(var i = 0; i < numberOfConnections; i++) {
- var connection = connections[i];
- // Execute first sasl step
- db._executeQueryCommand(DbCommand.createDbCommand(db, command, {}, '$external'), {connection:connection}, function(err, result) {
- // Count down
- numberOfConnections = numberOfConnections - 1;
-
- // Ensure we save any error
- if(err) {
- errorObject = err;
- } else if(result.documents[0].err != null || result.documents[0].errmsg != null){
- errorObject = utils.toError(result.documents[0]);
- }
-
- // Work around the case where the number of connections are 0
- if(numberOfConnections <= 0 && typeof callback == 'function') {
- var internalCallback = callback;
- callback = null;
-
- if(errorObject == null && result.documents[0].ok == 1) {
- // We authenticated correctly save the credentials
- db.serverConfig.auth.add('MONGODB-X509', db.databaseName, username, password);
- // Return callback
- internalCallback(errorObject, true);
- } else {
- internalCallback(errorObject, false);
- }
- }
- });
- }
-}
-
-exports.authenticate = authenticate;
\ No newline at end of file