Usage of webtask.io

coffee.js

module.exports = function (ctx, done) {
  var MongoClient = require('mongodb').MongoClient;
  var assert = require('assert');
  var ObjectId = require('mongodb').ObjectID;
  var url = ctx.data.MONGO_URL;

  var insertValue = function(db) {
    db.collection('cups').insertOne({
      'date': new Date(),
      'coffee': 1
    }, function(err, result) {
      assert.equal(err, null);
      done(null, "New coffee added!");
    });
  };

  MongoClient.connect(url, function(err, db) {
    assert.equal(null, err);
    insertValue(db, function() {
      db.close();
    });
  });

};

random.js

module.exports =
  function (context, cb) {
    var passwd = "";
    var candidates = "ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789";

    for (var i = 0; i < 15; i++)
      passwd += candidates.charAt(Math.floor(Math.random() * candidates.length));

    cb(null, passwd);
  }

stats.js

module.exports = function (ctx, done) {
  var MongoClient = require('mongodb').MongoClient;
  var assert = require('assert');
  var ObjectId = require('mongodb').ObjectID;
  var url = ctx.data.MONGO_URL;

  var getValue = function(db) {
    var start = new Date();
    var end = new Date();
    start.setHours(0,0,0,0);
    end.setHours(23,59,59,999);

    db.collection('cups').count({
      date: {$gte: start, $lt: end}
    }, function(err, result) {
      assert.equal(err, null);
      done(null, "Cups of coffee today: " + result);

    });
  };

  MongoClient.connect(url, function(err, db) {
    getValue(db, function() {
      db.close();
    })
  });
};