Merge branch 'example2'

bin/cli.js

@@ -42,7 +42,7 @@ if (cli.flags.transform) {
       process.exit(-1);
     });
 } else {
-  asyncNode(cli.input[0])
+  asyncNode(cli.input[0], cli.input.slice(1))
     .then(data => {
       process.stdout.write(data);
     })

examples/mongo/README.md

@@ -0,0 +1,11 @@
+# mongo
+
+Get / Set values to MongoDB
+
+## Usage
+
+```
+$ npm i
+$ async-node index.js -- -s '{"name":"foo"}'  # Insert a document
+$ async-node index.js -- -g '{"name":"foo"}'  # Find a document by name 'foo'
+```

examples/mongo/index.js

@@ -0,0 +1,37 @@
+const MongoClient = require('mongodb').MongoClient;
+
+// Parse args
+const o = require('minimist')(process.argv.slice(2));
+if (!(o.s || o.set || o.g || o.get)) {
+  console.log(`
+  Usage:
+    $ async-node index.js -s '{"name":"foo"}'
+    $ async-node index.js -g '{"name":"foo"}'
+  `);
+  process.exit(-1);
+}
+
+// Parse JSON
+let doc;
+try {
+  doc = JSON.parse(`${o.s || o.set || o.g || o.get}`);
+} catch (e) {
+  console.error('Invalid JSON format');
+  process.exit(-1);
+}
+
+// Connect to MongoDB
+const db = await MongoClient.connect('mongodb://localhost:27017/async-node-example-mongo');
+const collection = db.collection('async-node-example-mongo');
+
+// Execute
+if (o.s || o.set) {
+  const res = await collection.insertOne(doc);
+  console.log(res.ops[0]);
+}
+if (o.g || o.get) {
+  const res = await collection.findOne(doc);
+  console.log(res);
+}
+
+db.close();

examples/mongo/package.json

@@ -0,0 +1,19 @@
+{
+  "name": "mongo",
+  "version": "0.0.0",
+  "description": "",
+  "main": "index.js",
+  "scripts": {
+    "get": "$(npm bin)/async-node index.js -- -g",
+    "set": "$(npm bin)/async-node index.js -- -s",
+    "test": "echo \"Error: no test specified\" && exit 1"
+  },
+  "keywords": [],
+  "author": "fand <fand@gmork.in>",
+  "license": "MIT",
+  "dependencies": {
+    "@fand/async-node": "^0.1.1",
+    "minimist": "^1.2.0",
+    "mongodb": "^2.2.25"
+  }
+}