Archive ride job

archive-ride.js

// Sendgrid API
const sgMail = require('@sendgrid/mail');
sgMail.setApiKey(process.env.SENDGRID_API_KEY);

const MongoClient = require('mongodb').MongoClient;

module.exports = function(agenda) {
    agenda.define('archive ride', function(job, done) {

        // Connect to the db
        MongoClient.connect("mongodb://localhost:27017/yourdatabase", function(err, db) {
            if(!err) {
                db.collection('rides').findOneAndUpdate({_id: job.attrs.data.rideId},
                    { $set: { status: 'expired' }}, function (err) {
                    if(!err) {
                        done();
                    }
                })
            }
            if(err) {
                console.log(err);
                done();
            }
        });
    });
};