-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathindex.js
63 lines (58 loc) · 1.95 KB
/
index.js
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
var express = require('express');
var log = require('morgan')('dev');
var bodyParser = require('body-parser');
var cors = require('cors');
//user routes
var userRoutes = require('./api/user/user.routes');
var categoryRoutes = require('./api/category/category.routes');
var itemsRoutes = require('./api/items/items.routes');
var properties = require('./config/properties');
var db = require('./config/database');
var app = express();
var http = require('http').Server(app);
var io = require('socket.io')(http, {origins : "*:*"});
//configure bodyParser
var bodyParserJSON = bodyParser.json();
var bodyParserURLEncoded = bodyParser.urlencoded({extended: true});
//call database connectivity
db();
app.use(log);
app.use(cors());
app.use(bodyParserJSON);
app.use(bodyParserURLEncoded);
app.use('/uploads',express.static('uploads'));
// use express router
app.use('/api/user', userRoutes);
app.use('/api/category',categoryRoutes);
app.use('/api/items',itemsRoutes);
//socket
var live_auction = require('./socket/live.controller');
var timeout = require('./socket/timeout.controller');
var bid = require('./socket/bid.controller');
io.sockets.on('connection',function(socket){
console.log("connected");
socket.on('join_auction', function(data){
//itemid, userid, socketid
live_auction.addUser(io,socket,data);
});
socket.on('new_bid', function(data){
bid.addBid(io, socket, data);
});
socket.on('timeout', function(data){
console.log('calling timeout');
timeout.auctionEnd(io, socket, data);
});
socket.on('disconnect', function(data){
console.log('on disconnect')
live_auction.deleteUser(io,socket, data);
});
socket.on('forceDisconnect', function(data){
socket.disconnect();
})
socket.on('fetch_bid_logs', function(data){
bid.getBidLogs(io,socket,data);
});
})
http.listen(properties.PORT, (req, res) =>{
console.log(` Server is running on ${properties.PORT} port`);
});