-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathserver.js
More file actions
96 lines (89 loc) · 2.33 KB
/
server.js
File metadata and controls
96 lines (89 loc) · 2.33 KB
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
var fs = require('fs');
var path = require('path');
var express = require('express');
var bodyParser = require('body-parser');
var app = express();
var api_dir = path.join(__dirname, 'api');
app.set('port', (process.env.PORT || 3000));
app.use('/', express.static(path.join(__dirname, 'public_html')));
app.use(bodyParser.json());
app.use(bodyParser.urlencoded({extended: true}));
//helper function
function filesFromDir(startPath, filter, callback){
if (!fs.existsSync(startPath)){
console.log("no dir ",startPath);
return;
}
var files=fs.readdirSync(startPath);
for(var i=0;i<files.length;i++){
var filename=path.join(startPath,files[i]);
var stat = fs.lstatSync(filename);
if (stat.isDirectory()){
filesFromDir(filename, filter, callback); //recurse
}
else if (filename.indexOf(filter)>=0) {
callback(filename);
};
};
};
console.log("Registering api...");
filesFromDir('./api', '.json', function(file){
var url = file.slice(0, -5).replace(/\\/g, "/");
console.log(url);
app.get('/'+url, function(req, res) {
fs.readFile(file, function(err, data) {
if (err) {
console.error(err);
res.status(500).send(err);
return;
}
try{
res.setHeader('Cache-Control', 'no-cache');
res.status(200).json(JSON.parse(data));
}
catch(err){
console.error(err);
res.status(500).send(err);
}
});
});
app.post('/'+url, function(req, res) {
console.log("Post request at " + url + ":");
console.log(req.body);
var new_item = req.body;
fs.readFile(file, function(err, data) {
if (err) {
console.error(err);
res.status(500).send(err);
return;
}
try{
var old_content = JSON.parse(data);
}
catch(err){
console.error(err);
res.status(500).send(err);
return;
}
var new_content;
if (old_content instanceof Array){
old_content.push(new_item);
new_content = old_content;
}
else{
new_content = new_item;
}
fs.writeFile(file, JSON.stringify(new_content), function(err){
if (err){
console.error(err);
res.status(500).send(err);
return;
}
res.status(200).send("OK");
});
});
});
});
app.listen(app.get('port'), function() {
console.log('Server started: http://localhost:' + app.get('port') + '/');
});