//Importando a biblioteca do Restify
var restify = require('restify');
var mysql = require('mysql');

/*
	Criando objeto com as credenciais
	de conexão com o BD
*/
var con = {
  host: 'localhost',
  user: 'root',
  password: 'root',
  database: 'ec021_av2_frete'
};

/*
	Criando nossas funções do CRUD.
*/



function listarTipoFrete(req, res, next) {
  //Definindo o formato da response
  res.setHeader('Access-Control-Allow-Origin', '*');
  res.setHeader('content-type', 'application/json');
  res.charSet('UTF-8');

  /** Abrindo a conexão com o BD */
  var connection = mysql.createConnection(con);
  connection.connect();

  /** Escrevendo query que será executada */
  var strQuery = "SELECT tipo_id, descricao, valor_minimo FROM tipo_frete;";

  /** Exibindo query no console */
    console.log(strQuery);

  /** Executando query e processando resultados */
    connection.query(strQuery, function(err, rows, fields) {
        if (!err) { //Se não houver erros

      var retorno = [];

      for(var i = 0; i < rows.length; i++) {//Percorrendo todas as rows
        var tipo = rows[i];

        retorno.push(tipo); //Adiciona elemento no vetor

      }
      res.json(retorno);
        } else { //Caso contrário
            res.json(err); //Retornamos dados sobre o erro
        }
    });

  /** Encerrando conexão com o BD */
  connection.end();

  /** Encerrando método da REST API */
  next();
}



function buscarFretePorTipo(req, res, next) {
  //Definindo o formato da response
  res.setHeader('Access-Control-Allow-Origin', '*');
	res.setHeader('content-type', 'application/json');
	res.charSet('UTF-8');

	/** Abrindo a conexão com o BD */
	var connection = mysql.createConnection(con);
	connection.connect();
  var tipo = req.params.tipo_id;
  console.log(req.params);
	/** Escrevendo query que será executada */
	var strQuery = "SELECT frete_id, motorista, data_saida, origem, tipo_id FROM frete where tipo_id="+tipo+";";

	/** Exibindo query no console */
    console.log(strQuery);

	/** Executando query e processando resultados */
    connection.query(strQuery, function(err, rows, fields) {
        if (!err) { //Se não houver erros

			var retorno = [];

			for(var i = 0; i < rows.length; i++) {//Percorrendo todas as rows
				var tipo = rows[i];

				retorno.push(tipo); //Adiciona elemento no vetor

			}
			res.json(retorno);
        } else { //Caso contrário
            res.json(err); //Retornamos dados sobre o erro
        }
    });

	/** Encerrando conexão com o BD */
	connection.end();

	/** Encerrando método da REST API */
	next();
}


//Configurando servidor
var server = restify.createServer({
  name: 'CRUD - Parte 4'
});

/**
 * Utilizando o bodyParser para
 * converter o body da request em
 * um jSON
 * */
server.use(restify.plugins.bodyParser());

/**
 * Utilizando o queryParser para
 * permitir que métodos GET passem
 * parâmetros na URL
 */
server.use(restify.plugins.queryParser());

/*
	Definindo endpoints (ou rotas) da minha aplicação.
*/
var binoPoint = '/frete'; //Carga pesada

server.get(binoPoint + '/listarTipoFrete', listarTipoFrete);
server.get(binoPoint + '/buscarFretePorTipo', buscarFretePorTipo);
//Definindo porta em que subiremos o servidor
var port = process.env.PORT || 5000;

//Subindo o servidor
server.listen(port, function() {
  console.log('%s rodando', server.name);
});