var express = require('express');
var router = express.Router();
var nodemailer = require('nodemailer');
var MongoClient = require('mongodb');
var url = require('url');
/* GET home page. */
const { spawn } = require('child_process');


router.get('/', function(req, res, next) {

    const bat = spawn('cmd.exe', ['/c', 'C:\\Users\\Peter\\WebstormProjects\\w3tutorial\\routes\\scripts.bat']);

    bat.stdout.on('data', (data) => {
        console.log(data.toString());
    });

    bat.stderr.on('data', (data) => {
        console.log(data.toString());
    });

    bat.on('exit', (code) => {
        console.log(`Child exited with code ${code}`);
    });


   // res.render('index', { title: 'Express' });
});

router.get('/mail', function(req, res, next) {

    var transporter = nodemailer.createTransport({
        service: 'gmail',
        auth: {
            user: 'piotr.wegrzyn@rax.com.pl',
            pass: 'xDlolxD96'
        }
    });

    var mailOptions = {
        from: 'wojtek.zimirski@rax.com.pl',
        to: 'peterw1114@gmail.com',
        subject: 'Sending Email using Node.js',
        text: 'Dupa!'
    };

    transporter.sendMail(mailOptions, function(error, info){
        if (error) {
            console.log(error);
        } else {
            console.log('Email sent: ' + info.response);
        }
    });

});

router.get('/collectionadd',function (req , res , next) {

    const uri = "mongodb+srv://nodejs:root@cluster0-odrxs.mongodb.net/test"
    MongoClient.connect(uri, function(err, db) {
        if(err) {
            console.log('Error occurred while connecting to MongoDB Atlas...\n',err);
        }
        console.log('Connected...');
        var dbo = db.db("test");


        dbo.createCollection("customers", function(err, res) {
            if (err) throw err;
            console.log("Collection created!");
            db.close();
        });
    });
});



router.get('/insert',function (req , res , next) {

    const uri = "mongodb+srv://nodejs:root@cluster0-odrxs.mongodb.net/test"
    MongoClient.connect(uri, function(err, db) {
        if(err) {
            console.log('Error occurred while connecting to MongoDB Atlas...\n',err);
        }
        console.log('Connected...');
        var dbo = db.db("test");

        var myobj = { name: "CompanyOne Inc", address: "Highway 37" };
        var myobj2 = { name: "Second Inc", address: "Park Lane 38" };
        var myobj3 = { name: "Third Inc", address: "Park Lane 38" };
        var tab = {myobj,myobj2,myobj3};
        for(x in tab){
            dbo.collection("customers").insertOne(tab[x], function(err, res) {
                if (err) throw err;
                console.log("1 document inserted");
                db.close();
            });
        }


    });
});


router.get('/find',function (req , res , next) {

    const uri = "mongodb+srv://nodejs:root@cluster0-odrxs.mongodb.net/test"
    MongoClient.connect(uri, function(err, db) {
        if(err) {
            console.log('Error occurred while connecting to MongoDB Atlas...\n',err);
        }
        console.log('Connected...');
        var dbo = db.db("test");

        dbo.collection("customers").findOne({}, function(err, result) {
            if (err) throw err;
            var response = result.name + result.address;
            console.log(result.name + result.address);
            res.writeHead(200, {'Content-Type': 'text/html'});
            res.write(response);
            res.end();
            db.close();
        });

    });
});
router.get('/query',function (req , res , next) {

    const uri = "mongodb+srv://nodejs:root@cluster0-odrxs.mongodb.net/test"
    MongoClient.connect(uri, function(err, db) {
        if(err) {
            console.log('Error occurred while connecting to MongoDB Atlas...\n',err);
        }
        console.log('Connected...');
        var dbo = db.db("test");


        var query = { address: "Park Lane 38" };
        //var query = { address: /^S/ }; //only for strings. reg-exp:   starts with letter 'S'
        dbo.collection("customers").find(query).toArray(function(err, result) {
            if (err) throw err;
            console.log(result);
            db.close();
        });

    });
});




router.get('/sort',function (req , res , next) {

    const uri = "mongodb+srv://nodejs:root@cluster0-odrxs.mongodb.net/test"
    MongoClient.connect(uri, function(err, db) {
        if(err) {
            console.log('Error occurred while connecting to MongoDB Atlas...\n',err);
        }
        console.log('Connected...');
        var dbo = db.db("test");

        var mysort = { name: 1 };
        dbo.collection("customers").find().sort(mysort).toArray(function(err, result) {
            if (err) throw err;
            console.log(result);
            db.close();
        });
    });
});


router.get('/delete',function (req , res , next) {

    const uri = "mongodb+srv://nodejs:root@cluster0-odrxs.mongodb.net/test"
    MongoClient.connect(uri, function(err, db) {
        if(err) {
            console.log('Error occurred while connecting to MongoDB Atlas...\n',err);
        }
        console.log('Connected...');
        var dbo = db.db("test");
        var theidID  = '5bdb93248d8e0562dcb5814e';
        var o_id = new MongoClient.ObjectID(theidID);
        var myquery = { _id:  o_id };
        dbo.collection("customers").deleteOne(myquery, function(err, obj) {
            if (err) throw err;
            console.log("1 document deleted");
            db.close();
        });
    });
});

router.get('/update',function (req , res , next) {

    const uri = "mongodb+srv://nodejs:root@cluster0-odrxs.mongodb.net/test"
    MongoClient.connect(uri, function(err, db) {
        if(err) {
            console.log('Error occurred while connecting to MongoDB Atlas...\n',err);
        }
        console.log('Connected...');
        var dbo = db.db("test");
        var q = url.parse(req.url, true);
        var qdata = q.query; //returns an object: { year: 2017, month: 'february' }
        var sentName = qdata.name.replace(/"/g,'');
        var myquery = { name: sentName };
        console.log(sentName);
        var newvalues = { $set: {name: "Change Inc", address: "Canyon 123" } };
        dbo.collection("customers").updateOne(myquery, newvalues, function(err, res) {
            if (err) throw err;
            console.log("1 document updated");
            db.close();
        });
    });
});

module.exports = router;