const Hapi = require('hapi');
const Boom = require('boom');
// IMPORT NPM DEPENDENCY
const mongojs = require('hapi-mongojs');
 
// ADD PLUGINS CONFIG
const plugins = [
  {
    register: mongojs,
    options: {
      url: 'mongodb://localhost:27017/myDatabase',
      // ENSURE COLLECTION INDEXES (OPTIONAL)
      collections: [{
        name: 'myCollection1',
        indexes: [{
          keys: {
            'aField': 1
          },
          options: {
            'unique': true,
            'name': 'afield_idx'
          }
        }]
      }]
    }
  }
];
 
const server = new Hapi.Server();
 
server.connection({
  host: 'localhost',
  port: 8888
});
 
server.route([
  {
    method: 'GET',
    path: '/example',
    handler: function (request, reply) {
 
      // GET DB CONNECTION
      const myCollection = mongojs.db().collection('myCollection1');
 
      // EXECUTE A QUERY
      myCollection.find((error, value) => {
        if (error) {
          return reply(Boom.badData('Internal MongoDB error', error));
        }
        reply(value);
      });
 
    }
  }
]);
 
server.register(plugins, (err) => {
  if (err) {
    console.error(err);
    throw err;
  }
 
  server.start((err) => {
    if (err) {
      console.error(err);
      throw err;
    }
    console.log('info', `Server running at: ${server.info.uri}`);
  });
});