diff --git a/src/libs/routes/state.js b/src/libs/routes/state.js index a1fa64a5207e0bec5ae4323c2649f2475c6a3e36..c5493f200aead1dfcaef60a3679e36f4a1948b87 100644 --- a/src/libs/routes/state.js +++ b/src/libs/routes/state.js @@ -1,58 +1,26 @@ const express = require('express'); - -const xml = require('js2xmlparser'); - const stateApp = express(); - const libs = `${process.cwd()}/libs`; - const log = require(`${libs}/log`)(module); - -const dbQuery = require(`${libs}/db/query_exec`); - -function response(req, res) { - if (req.query.format === 'csv') { - res.csv(req.result.data); - } else if (req.query.format === 'xml') { - res.send(xml('result', JSON.stringify({ state: req.result.data }))); - } else { - res.json({ result: req.result.data }); - } -} +const squel = require('squel'); +const query = require(`${libs}/middlewares/query`); +const response = require(`${libs}/middlewares/response`); stateApp.get('/', (req, res, next) => { - const stateSql = 'SELECT * FROM estados'; - dbQuery(stateSql).then((result) => { - req.result = result; - return response(req, res); - }, (error) => { - log.error(`[${req.originalUrl}] SQL query error: ${error}`); - next('Internal error, request could not be satisfied at this moment. Please, try again later'); - }); -}); + req.query = squel.select().from('estados').toParam(); + next(); +}, query, response); stateApp.get('/:id', (req, res, next) => { - const stateSql = 'SELECT * FROM estados WHERE pk_estado_id = ?'; - const stateId = parseInt(req.params.id, 10); - dbQuery(stateSql, [stateId]).then((result) => { - req.result = result; - return response(req, res); - }, (error) => { - log.error(`[${req.originalUrl}] SQL query error: ${error}`); - next('Internal error, request could not be satisfied at this moment. Please, try again later'); - }); -}); + req.query = squel.select().from('estados').where('pk_estado_id = ?', + parseInt(req.params.id, 10)).toParam(); + next(); +}, query, response); stateApp.get('/region/:id', (req, res, next) => { - const stateSql = 'SELECT * FROM estados WHERE fk_regiao_id = ?'; - const regionId = parseInt(req.params.id, 10); - dbQuery(stateSql, [regionId]).then((result) => { - req.result = result; - return response(req, res); - }, (error) => { - log.error(`[${req.originalUrl}] SQL query error: ${error}`); - next('Internal error, request could not be satisfied at this moment. Please, try again later'); - }); -}); + req.query = squel.select().from('estados').where('fk_regiao_id = ?', + parseInt(req.params.id, 10)).toParam(); + next(); +}, query, response); module.exports = stateApp; diff --git a/src/libs/routes/states.js b/src/libs/routes/states.js deleted file mode 100644 index 79959ef8fd4a19c3afc3f51328ec737396cb0bbe..0000000000000000000000000000000000000000 --- a/src/libs/routes/states.js +++ /dev/null @@ -1,44 +0,0 @@ -var express = require('express') -var xml = require('js2xmlparser') -var router = express.Router() -var squel = require('squel') - -var libs = process.cwd() + '/libs/' - -var log = require(libs + 'log')(module) -var config = require(libs + 'config') - -var conn = require(libs + 'db/monet') - -var query = require(libs + 'middlewares/query') - -function response(req, res) { - console.log('respostas :)') - if (req.query.format === 'csv') { - res.csv(req.result.data) - } else if (req.query.format === 'xml') { - res.send(xml("result", JSON.stringify({state: req.result.data}))) - } - else { - res.json({ - result: req.result.data - }) - } -} - -router.get('/', function(req, res, next) { - req.query = squel.select().from('estados').toParam() - next() -}, query, response) - -router.get('/:id', function(req, res, next) { - req.query = squel.select().from('estados').where('pk_estado_id = ?', parseInt(req.params.id, 10)).toParam() - next() -}, query, response) - -router.get('/region/:id', function(req, res, next) { - req.query = squel.select().from('estados').where('fk_regiao_id = ?', parseInt(req.params.id, 10)).toParam() - next() -}, query, response) - -module.exports = router