Repository navigation
Expand file tree
/
Copy pathindex.js
More file actions
108 lines (86 loc) · 3.42 KB
/
Copy pathindex.js
File metadata and controls
108 lines (86 loc) · 3.42 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
97
98
99
100
101
102
103
104
105
106
107
108
var express = require("express");
var Firebase = require('firebase');
var ModelAdmin = require("model-admin").ModelAdmin;
var ModelAdminEvents = require("model-admin").ModelAdminEvents;
var ServerAdminEvents = require("model-admin").ServerAdminEvents;
var app = express();
var port = process.env.PORT || 8002;
//Set view
app.set('views', __dirname + '/tpl');
app.set('view engine', "jade");
app.engine('jade', require('jade').__express);
app.use(express.static(__dirname + '/public'));
var io = require('socket.io').listen(app.listen(port));
io.configure(function () {
io.set("transports", ["xhr-polling"]);
io.set("polling duration", 10);
});
// var mainFirebase = new Firebase('https://ramp-model.firebaseio.com/');
var fieldTypes = new Firebase('https://ramp-model.firebaseio.com/field-types');
var modelRels = new Firebase('https://ramp-model.firebaseio.com/relationships');
var initSockets = function () {
io.sockets.on('connection', function (socket) {
socket.emit(ServerAdminEvents.SOCKET_CONNECTED, socket.id);
socket.on(ModelAdminEvents.MODEL_CREATED, function (history) {
socket.broadcast.emit(ServerAdminEvents.MODEL_CREATED, history);
});
socket.on(ModelAdminEvents.MODEL_DELETED, function (history) {
socket.broadcast.emit(ServerAdminEvents.MODEL_DELETED, history);
});
socket.on(ModelAdminEvents.ATTRIBUTE_ADDED, function (history) {
socket.broadcast.emit(ServerAdminEvents.ATTRIBUTE_ADDED, history);
});
socket.on(ModelAdminEvents.ATTRIBUTE_REMOVED, function (history) {
socket.broadcast.emit(ServerAdminEvents.ATTRIBUTE_REMOVED, history);
});
socket.on(ModelAdminEvents.RELATIONSHIP_ADDED, function (history) {
socket.broadcast.emit(ServerAdminEvents.RELATIONSHIP_ADDED, history);
});
socket.on(ModelAdminEvents.RELATIONSHIP_REMOVED, function (history) {
socket.broadcast.emit(ServerAdminEvents.RELATIONSHIP_REMOVED, history);
});
});
};
initSockets ();
app.get("/", function(req, res){
res.render("page");
});
app.get("/get_app/:id", function(req, res) {
var modelAdmin = new Firebase('https://ramp-model.firebaseio.com/model-admin');
modelAdmin.on('value', function(snapshot) {
var result = findById(snapshot.val(), req.params.id);
if (result instanceof Object) {
console.log('[Firebase]Successfully sent!');
res.send(JSON.stringify(result));
} else {
console.log('[Firebase]404 not found!');
res.status(404).send(result);
}
});
});
app.post("/save", function(req, res) {
req.content = "";
req.addListener("data", function(chunk) {
req.content += chunk;
});
req.addListener("end", function() {
var modelAdmin = new Firebase('https://ramp-model.firebaseio.com/model-admin');
if (modelAdmin.push(JSON.parse(req.content))) {
console.log('[Firebase]Saving done!');
res.status(200).send("App models saved!");
} else {
console.log('[Firebase]Saving failed!');
res.status(404).send("App models not saved!");
}
res.end();
});
});
function findById(source, id) {
for (var key in source) {
if (source[key]["id"] == id) {
return source[key];
}
}
return "Couldn't find damn app with id: " + id;
}
console.log("Listening on port " + port);