/* eslint-disable no-console,import/no-extraneous-dependencies */
const net = require('net');
const http = require('http');
const minimist = require('minimist');
const { host, port } = require('../server/config');
const fetchCustomers = require('./lib/fetch_customers');
const fetchProducts = require('./lib/fetch_products');

const argv = minimist(process.argv.slice(2));
const modelName = argv._[0];

function testConnection(conn) {
  return new Promise((resolve, reject) => {
    const client = net.connect(conn);

    client.on('connect', () => client.end());
    client.on('error', err => reject(err));
    client.on('end', () => resolve(true));
  });
}

function writeRecords(records, opts = {}) {
  const options = Object.assign({
    host,
    port,
    path: '/api/customers',
    method: 'POST',
    headers: {
      'Content-Type': 'application/json',
    },
  }, opts);

  return Promise.all(records.map(record => new Promise((resolve, reject) => {
    const req = http.request(options, (res) => {
      res.setEncoding('utf8');
      res.on('data', () => {});
      res.on('end', resolve);
    });

    req.on('error', reject);
    req.write(JSON.stringify(record));
    req.end();
  })));
}

function populateDatabase(model) {
  console.log('Populating model:', model);
  let task = false;

  switch (model.toLowerCase()) {
    case 'customers':
      task = fetchCustomers(37)
      .then(customers => writeRecords(customers, {
        path: '/api/customers',
      }))
      .then(results => console.log('Customer(s) added', results.length));
      break;

    case 'products':
      task = fetchProducts(25)
      .then(customers => writeRecords(customers, {
        path: '/api/products',
      }))
      .then(results => console.log('Product(s) added', results.length));
      break;

    default:
      throw new Error(`Model not found or supported: ${model}`);
  }

  return task.catch((err) => {
    console.log('FAILED to populate database', err);
    process.exit(3);
  });
}

if (!modelName) {
  console.log('Please specify a model to populate');
  process.exit(1);
}

testConnection({ host, port })
.then(populateDatabase(modelName))
.catch(() => {
  console.log('Start the server to seed the database!');
  process.exit(2);
});