+ Added [router] and cleaned some code
This commit is contained in:
@@ -1,10 +1,10 @@
|
||||
// MODULES
|
||||
const fs = require('fs');
|
||||
const mysql = require('mysql');
|
||||
const fs = require('fs')
|
||||
const mysql = require('mysql')
|
||||
|
||||
// Fetches and parses credentials file
|
||||
let credentials_data = fs.readFileSync('./database/credentials.json');
|
||||
let credentials = JSON.parse(credentials_data);
|
||||
let credentials_data = fs.readFileSync('./database/credentials.json')
|
||||
let credentials = JSON.parse(credentials_data)
|
||||
|
||||
const db = mysql.createConnection({
|
||||
host: credentials.host,
|
||||
@@ -13,24 +13,4 @@ const db = mysql.createConnection({
|
||||
database: credentials.database,
|
||||
})
|
||||
|
||||
const getSpells = () => {
|
||||
return new Promise((resolve, reject) => {
|
||||
let query =
|
||||
"SELECT * " +
|
||||
"FROM spell";
|
||||
|
||||
db.query(query, (err, result, fields) => {
|
||||
if (err) {
|
||||
return reject;
|
||||
}
|
||||
resolve(result);
|
||||
})
|
||||
|
||||
})
|
||||
}
|
||||
|
||||
const closeConnection = (err) => {
|
||||
db.end();
|
||||
}
|
||||
|
||||
module.exports = { db, getSpells, closeConnection }
|
||||
module.exports = { db }
|
||||
30
index.js
30
index.js
@@ -1,32 +1,24 @@
|
||||
// MODULES
|
||||
const express = require('express');
|
||||
|
||||
const connection = require('./database/connection');
|
||||
const getSpells = connection.getSpells;
|
||||
const closeConnection = connection.closeConnection;
|
||||
const db = connection.db;
|
||||
|
||||
//
|
||||
const routes = require('./routes');
|
||||
|
||||
// CONSTANTS
|
||||
const port = 2814;
|
||||
|
||||
// APP
|
||||
app = express();
|
||||
const server = app.listen(port, () => {console.log(`App listening on port ${port}`)});
|
||||
const server = app.listen( port, () => {console.log(`App listening on port ${port}`)});
|
||||
|
||||
// getSpells().then((v) => {
|
||||
// console.log(v);
|
||||
// }).catch(r => {
|
||||
// console.log(r);
|
||||
// })
|
||||
app.use('/spells', routes.spells);
|
||||
|
||||
app.route('/spells')
|
||||
.get((req, res, next) => {
|
||||
getSpells().then(v => {
|
||||
res.setHeader('Content-Type', 'application/json');
|
||||
res.end(JSON.stringify({spells : v}));
|
||||
})
|
||||
})
|
||||
|
||||
// On process exit
|
||||
// On process kill with SIGINT
|
||||
process.on('SIGINT', () => {
|
||||
closeConnection();
|
||||
db.end();
|
||||
server.close();
|
||||
})
|
||||
console.log('Server closed');
|
||||
})
|
||||
|
||||
5
routes/index.js
Normal file
5
routes/index.js
Normal file
@@ -0,0 +1,5 @@
|
||||
const spells = require('./spells');
|
||||
|
||||
module.exports = {
|
||||
spells,
|
||||
}
|
||||
32
routes/spells.js
Normal file
32
routes/spells.js
Normal file
@@ -0,0 +1,32 @@
|
||||
const express = require('express');
|
||||
let router = express.Router();
|
||||
|
||||
const connection = require('../database/connection');
|
||||
const db = connection.db;
|
||||
|
||||
getSpells = () => {
|
||||
return new Promise((resolve, reject) => {
|
||||
let query =
|
||||
"SELECT * " +
|
||||
"FROM spell";
|
||||
|
||||
db.query(query, (err, result) => {
|
||||
if (err) {
|
||||
return reject;
|
||||
}
|
||||
resolve(result);
|
||||
})
|
||||
|
||||
})
|
||||
}
|
||||
|
||||
router
|
||||
.get('/', (req, res, next) => {
|
||||
getSpells().then(v => {
|
||||
res.setHeader('Content-Type', 'application/json');
|
||||
res.end(JSON.stringify({spells : v}));
|
||||
})
|
||||
})
|
||||
|
||||
|
||||
module.exports = router
|
||||
Reference in New Issue
Block a user