httpceptor/server.js at master · nabham/httpceptor · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
const express = require('express');
const app = express();
const server = require('http').createServer(app);

const io = require('socket.io')(server);

const path = require('path');
const debug = require('debug');
const bodyParser = require('body-parser');

const debugInfo = debug('info');

const config = require('./config.json');
const controller = require('./src/controller');
const sockets = require('./src/sockets/handler');

app.disable('x-powered-by');
app.disable('etag');

app.use(express.static(path.join(__dirname, 'public')));
app.use(bodyParser.json());

controller.initialize('local');

app.get('/', (req, res) => {
  res.sendFile(path.join(__dirname, 'public', 'main.html'));
});

app.get('/main/:endpoint', (req, res) => {
  controller.checkEndpoint(req, (err) => {
    // console.error(err);
    if(!err) {
      return res.sendFile(path.join(__dirname, 'public', '404.html'));
    }
    res.sendFile(path.join(__dirname, 'public', 'mock.html'));
  });
});

app.all('/mock/:endpoint?/*?', (req, res) => {

  // console.log(req.params);
  // res.send('over');

  if(!req.params.endpoint && !req.params['0']) {
    return res.status(404).send('Bad Input');
  }

  if(!req.params.endpoint && req.params['0']) {
    req.params.endpoint = req.params['0'];
    req.params['0'] = '';
  }

  if(req.params['0'] == undefined) {
    req.params['0'] = '';
  }

  controller.handleMock(req, (err, resp) => {
    if(err) {
      return res.status(err.code || 500).send(err.message || 'Internal error.');
    }
    res.status(resp.code).send(resp.response);
  })
});

app.post('/api/endpoint/create', (req, res) => {

  controller.handleCreateReq(req, (err) => {
    if(err) {
      return res.status(err.code || 500).send(err.message || 'Internal error.');
    }
    res.status(200).send({success: true});
  });
});

app.post('/api/rules/edit/:endpoint', (req, res) => {

  controller.handleEditRules(req, (err) => {
    if(err) {
      return res.status(err.code || 500).send(err.message || 'Internal error.');
    }
    res.status(200).send({success: true});
  });
});

app.get('/api/rules/:endpoint', (req, res) => {

  controller.handleGetRules(req, (err, resp) => {
    if(err) {
      return res.status(err.code || 500).send(err.message || 'Internal error.');
    }
    res.status(200).send({data: resp});
  });
});

app.all('*', (req, res) => {
  res.sendFile(path.join(__dirname, 'public', '404.html'));
});

io.on('connection', (socket) => {
  sockets.socketHandler(socket);
});

server.listen(config.server.port, () => {
  debugInfo('Server started at port', config.server.port);
});