diff --git a/api/src/connection.js b/api/src/connection.js deleted file mode 100644 index ea21a364e..000000000 --- a/api/src/connection.js +++ /dev/null @@ -1,36 +0,0 @@ -const os = require('os'); -const path = require('path'); -const fs = require('fs-extra'); -const express = require('express'); -const router = express.Router(); -const { fork } = require('child_process'); -const _ = require('lodash'); - -function datadir() { - return path.join(os.homedir(), 'dbgate-data'); -} - -router.post('/test', async (req, res) => { - const subprocess = fork(`${__dirname}/connectProcess.js`); - subprocess.send(req.body); - subprocess.on('message', resp => res.json(resp)); -}); - -router.post('/save', async (req, res) => { - await fs.mkdir(datadir()); - const fileName = `${new Date().getTime()}.con`; - await fs.writeFile(path.join(datadir(), fileName), JSON.stringify(req.body)); - res.json({ fileName }); -}); - -router.get('/list', async (req, res) => { - const files = await fs.readdir(datadir()); - - res - .json( - await Promise.all(files.filter(x => x.endsWith('.con')).map(x => fs.readFile(path.join(datadir(), x), 'utf-8'))) - ) - .map(x => _.omit(JSON.parse(x), 'password')); -}); - -module.exports = router; diff --git a/api/src/controllers/connections.js b/api/src/controllers/connections.js index ff1c3dfff..b53f3087e 100644 --- a/api/src/controllers/connections.js +++ b/api/src/controllers/connections.js @@ -14,10 +14,12 @@ module.exports = { const dir = await datadir(); this.datastore = nedb.create(path.join(dir, 'connections.jsonl')); }, + list_meta: 'get', async list() { return this.datastore.find(); }, + test_meta: { method: 'post', raw: true, diff --git a/api/src/index.js b/api/src/index.js index c4105f647..0a281b1cb 100644 --- a/api/src/index.js +++ b/api/src/index.js @@ -1,7 +1,6 @@ const express = require('express'); const bodyParser = require('body-parser'); const cors = require('cors'); -const connection = require('./connection'); const useController = require('./utility/useController'); const connections = require('./controllers/connections'); const app = express(); @@ -14,6 +13,5 @@ app.get('/', (req, res) => { }); useController(app, '/connections', connections); -app.use('/connection', connection); app.listen(3000); diff --git a/api/src/utility/useController.js b/api/src/utility/useController.js index c43f85a3e..9daeac76e 100644 --- a/api/src/utility/useController.js +++ b/api/src/utility/useController.js @@ -33,7 +33,7 @@ module.exports = function useController(app, route, controller) { controller._init_called = true; } try { - let params = [{ ...req.body }]; + let params = [{ ...req.body, ...req.query }]; if (rawParams) params = [req, res]; const data = await controller[key](...params); res.json(data);