const Joi = require('joi');
const MongoModels = require('mongo-models');

class Customer extends MongoModels {
    static create(name, email, phone, callback) {

      const document = {
          name,
          email,
          phone
      };

      this.insertOne(document, callback);
    }

    speak() {

        console.log(`${this.name}: call me at ${this.phone}.`);
    }
}

Customer.collection = 'customers'; // the mongodb collection name

Customer.schema = Joi.object().keys({
    name: Joi.string().required(),
    email: Joi.string().email(),
    phone: Joi.string()
});

module.exports = Customer;

const Customer = require('./customer');
const Express = require('express');
const MongoModels = require('mongo-models');

const app = Express();

MongoModels.connect(process.env.MONGODB_URI, {}, (err, db) => {

    if (err) {
        // TODO: throw error or try reconnecting
        return;
    }

    // optionally, we can keep a reference to db if we want
    // access to the db connection outside of our models
    app.db = db;

    console.log('Models are now connected to mongodb.');
});

app.post('/customers', (req, res) => {

    const name = req.body.name;
    const email = req.body.email;
    const phone = req.body.phone;

    Customer.create(name, email, phone, (err, customers) => {

        if (err) {
            res.status(500).json({ error: 'something blew up' });
            return;
        }

        res.json(customers[0]);
    });
});

app.get('/customers', (req, res) => {

    const filter = {
        name: req.query.name
    };

    Customer.find(filter, (err, customers) => {

        if (err) {
            res.status(500).json({ error: 'something blew up' });
            return;
        }

        res.json(customers);
    });
});

app.server.listen(process.env.PORT, () => {

    console.log(`Server is running on port ${process.env.PORT}`);
});