Initial commit

.gitignore

@@ -0,0 +1,24 @@
+bin
+obj
+csx
+.vs
+edge
+Publish
+.vscode
+
+*.user
+*.suo
+*.cscfg
+*.Cache
+project.lock.json
+
+/packages
+/TestResults
+
+/tools/NuGet.exe
+/App_Data
+/secrets
+/data
+.secrets
+appsettings.json
+local.settings.json

CreateHero/function.json

@@ -0,0 +1,18 @@
+{
+  "disabled": false,
+  "bindings": [
+    {
+      "authLevel": "anonymous",
+      "type": "httpTrigger",
+      "direction": "in",
+      "name": "req",
+      "route": "hero",
+      "methods": ["post"]
+    },
+    {
+      "type": "http",
+      "direction": "out",
+      "name": "res"
+    }
+  ]
+}

CreateHero/index.js

@@ -0,0 +1,29 @@
+const MongoClient = require('mongodb').MongoClient;
+const auth = require('../shared/index');
+module.exports = function(context, req) {
+  MongoClient.connect(
+    process.env.CosmosDBURL,
+    { auth: auth },
+    (err, database) => {
+      if (err) throw err;
+      let hero = ({ id, name, saying } = req.body);
+      var db = database.db('admin');
+
+      db.collection('Heroes').insertOne(
+        {
+          id: hero.id,
+          name: hero.name,
+          saying: hero.saying
+        },
+        (err, result) => {
+          if (err) throw err;
+          context.res = {
+            body: hero
+          };
+          database.close();
+          context.done();
+        }
+      );
+    }
+  );
+};

CreateHero/sample.dat

@@ -0,0 +1,3 @@
+{
+    "name": "Azure"
+}

DeleteHero/function.json

@@ -0,0 +1,18 @@
+{
+  "disabled": false,
+  "bindings": [
+    {
+      "authLevel": "anonymous",
+      "type": "httpTrigger",
+      "direction": "in",
+      "name": "req",
+      "route": "hero/{id}",
+      "methods": ["delete"]
+    },
+    {
+      "type": "http",
+      "direction": "out",
+      "name": "res"
+    }
+  ]
+}

DeleteHero/index.js

@@ -0,0 +1,25 @@
+const MongoClient = require('mongodb').MongoClient;
+const auth = require('../shared/index');
+module.exports = function(context, req) {
+  context.log('JavaScript HTTP trigger function processed a request.');
+  MongoClient.connect(
+    process.env.CosmosDBURL,
+    { auth: auth },
+    (err, database) => {
+      if (err) throw err;
+      const db = database.db('admin');
+      let heroId = req.params.id;
+      db
+        .collection('Heroes')
+        .findOneAndDelete({ id: heroId }, (err, result) => {
+          if (err) throw err;
+          context.res = {
+            status: 200,
+            body: { message: 'Hero deleted successfully!' }
+          };
+          database.close();
+          context.done();
+        });
+    }
+  );
+};

DeleteHero/sample.dat

@@ -0,0 +1,3 @@
+{
+    "name": "Azure"
+}

GetHeroes/function.json

@@ -0,0 +1,18 @@
+{
+  "disabled": false,
+  "bindings": [
+    {
+      "authLevel": "anonymous",
+      "type": "httpTrigger",
+      "direction": "in",
+      "name": "req",
+      "route": "heroes",
+      "methods": ["get"]
+    },
+    {
+      "type": "http",
+      "direction": "out",
+      "name": "res"
+    }
+  ]
+}

GetHeroes/index.js

@@ -0,0 +1,28 @@
+const MongoClient = require('mongodb').MongoClient;
+const auth = require('../shared/index');
+module.exports = function(context, req) {
+  context.log('JavaScript HTTP trigger function processed a request.');
+  MongoClient.connect(
+    process.env.CosmosDBURL,
+    { auth: auth },
+    (err, database) => {
+      if (err) throw err;
+      console.log('Connected succesfully');
+      const db = database.db(process.env.CosmosDB);
+      db
+        .collection('Heroes')
+        .find()
+        .toArray((err, result) => {
+          if (err) throw err;
+          console.log('retrieved succesfully');
+          result.forEach(hero => delete hero._id);
+          context.res = {
+            //status: 200,
+            body: result
+          };
+          database.close();
+          context.done();
+        });
+    }
+  );
+};

GetHeroes/sample.dat

@@ -0,0 +1,3 @@
+{
+    "name": "Azure"
+}

UpdateHero/function.json

@@ -0,0 +1,18 @@
+{
+  "disabled": false,
+  "bindings": [
+    {
+      "authLevel": "anonymous",
+      "type": "httpTrigger",
+      "direction": "in",
+      "name": "req",
+      "route": "hero/{id}",
+      "methods": ["put"]
+    },
+    {
+      "type": "http",
+      "direction": "out",
+      "name": "res"
+    }
+  ]
+}

UpdateHero/index.js

@@ -0,0 +1,29 @@
+const MongoClient = require('mongodb').MongoClient;
+const auth = require('../shared/index');
+module.exports = function(context, req) {
+  context.log('JavaScript HTTP trigger function processed a request.');
+  MongoClient.connect(
+    process.env.CosmosDBURL,
+    { auth: auth },
+    (err, database) => {
+      if (err) throw err;
+      const db = database.db('admin');
+      let hero = ({ id, name, saying } = req.body);
+      let heroId = req.params.id;
+      db
+        .collection('Heroes')
+        .findOneAndUpdate(
+          { id: heroId },
+          { $set: { id: hero.id, name: hero.name, saying: hero.saying } },
+          (err, heroes) => {
+            if (err) throw err;
+            context.res = {
+              body: hero
+            };
+            database.close();
+            context.done();
+          }
+        );
+    }
+  );
+};

UpdateHero/sample.dat

@@ -0,0 +1,3 @@
+{
+    "name": "Azure"
+}

host.json

@@ -0,0 +1,5 @@
+{
+  "http": {
+    "routePrefix": "api"
+  }
+}

package.json

@@ -0,0 +1,14 @@
+{
+  "name": "serverless",
+  "version": "1.0.0",
+  "description": "",
+  "main": "index.js",
+  "scripts": {
+    "test": "echo \"Error: no test specified\" && exit 1"
+  },
+  "author": "",
+  "license": "ISC",
+  "dependencies": {
+    "mongodb": "^3.0.2"
+  }
+}

shared/index.js

@@ -0,0 +1,6 @@
+module.exports = {
+  auth: {
+    user: process.env.CosmosDBUser,
+    password: process.env.CosmosDBPass
+  }
+};