NodeJS SHOP Project

var express = require('express');
var router = express.Router();
var MongoClient = require('mongodb').MongoClient;
var ObjectId = require('mongodb').ObjectId;


var url = 'mongodb://localhost:27017/shop';
router.get('/', function (req, res) {
    MongoClient.connect(url,{ useNewUrlParser: true }, function(err, client)
    {
        var data = [];
        var db = client.db('shop');
        ucitajSveIzOrders(db, function(err, dataIzOrders) {
           dataIzOrders.forEach(function (element, indeks) {
               kreirajBlok(db, element, function (blok) {
                  data.push(blok);
               });
           });
           console.log(data);// RADI SUPER
        });

    });
});

function ucitajSveIzOrders(db, callback) {
    var collection = db.collection('orders');
    collection.find().toArray(function(err, doc)  {
        callback (err, doc);
    });
}

function kreirajBlok(db, element, callback) {
    var blok = {};

    blok['username'] = element.username;
    blok['date'] = element.date;
    blok['astal'] = 1;


    var orders = [];
    var cene = []

    // {id: '', count:3}
    var arrOrders = element.order;
    arrOrders.forEach(function (order) {
        ucitajInformacijeIzBaze(db, order, function (dopunjenNaziv, ukupnaCena) {
            orders.push(dopunjenNaziv);
            cene.push(ukupnaCena);
        });
    });

    //TODO OVO NA DOLE TREBA DA SE IZVRSI KAD SE IZVRSI OVO GORE
    var total = 0;
    cene.forEach(function (element) {
        total += element;
    });

    blok['orders'] = orders;
    blok['cene'] = cene;

    blok['total'] = total;
    callback(blok);
}

function ucitajInformacijeIzBaze(db, order, callback) {
    var collection = db.collection('menu');
    var o_id = new ObjectId(order.id);
    collection.findOne({_id:o_id}, function(err, doc)  {
        callback (order.count+"x "+doc.name, doc.cena*order.count);
    });
}
module.exports = router;