@@ -26,7 +26,7 @@ const sessionParser = session({
26
26
app . use ( express . static ( 'public' ) ) ;
27
27
app . use ( sessionParser ) ;
28
28
29
- app . post ( '/login' , function ( req , res ) {
29
+ app . post ( '/login' , function ( req , res ) {
30
30
//
31
31
// "Log in" user and set userId to session.
32
32
//
@@ -37,11 +37,11 @@ app.post('/login', function(req, res) {
37
37
res . send ( { result : 'OK' , message : 'Session updated' } ) ;
38
38
} ) ;
39
39
40
- app . delete ( '/logout' , function ( request , response ) {
40
+ app . delete ( '/logout' , function ( request , response ) {
41
41
const ws = map . get ( request . session . userId ) ;
42
42
43
43
console . log ( 'Destroying session' ) ;
44
- request . session . destroy ( function ( ) {
44
+ request . session . destroy ( function ( ) {
45
45
if ( ws ) ws . close ( ) ;
46
46
47
47
response . send ( { result : 'OK' , message : 'Session destroyed' } ) ;
@@ -54,7 +54,7 @@ app.delete('/logout', function(request, response) {
54
54
const server = http . createServer ( app ) ;
55
55
const wss = new WebSocket . Server ( { clientTracking : false , noServer : true } ) ;
56
56
57
- server . on ( 'upgrade' , function ( request , socket , head ) {
57
+ server . on ( 'upgrade' , function ( request , socket , head ) {
58
58
console . log ( 'Parsing session from request...' ) ;
59
59
60
60
sessionParser ( request , { } , ( ) => {
@@ -65,32 +65,32 @@ server.on('upgrade', function(request, socket, head) {
65
65
66
66
console . log ( 'Session is parsed!' ) ;
67
67
68
- wss . handleUpgrade ( request , socket , head , function ( ws ) {
68
+ wss . handleUpgrade ( request , socket , head , function ( ws ) {
69
69
wss . emit ( 'connection' , ws , request ) ;
70
70
} ) ;
71
71
} ) ;
72
72
} ) ;
73
73
74
- wss . on ( 'connection' , function ( ws , request ) {
74
+ wss . on ( 'connection' , function ( ws , request ) {
75
75
const userId = request . session . userId ;
76
76
77
77
map . set ( userId , ws ) ;
78
78
79
- ws . on ( 'message' , function ( message ) {
79
+ ws . on ( 'message' , function ( message ) {
80
80
//
81
81
// Here we can now use session parameters.
82
82
//
83
83
console . log ( `Received message ${ message } from user ${ userId } ` ) ;
84
84
} ) ;
85
85
86
- ws . on ( 'close' , function ( ) {
86
+ ws . on ( 'close' , function ( ) {
87
87
map . delete ( userId ) ;
88
88
} ) ;
89
89
} ) ;
90
90
91
91
//
92
92
// Start the server.
93
93
//
94
- server . listen ( 8080 , function ( ) {
94
+ server . listen ( 8080 , function ( ) {
95
95
console . log ( 'Listening on http://localhost:8080' ) ;
96
96
} ) ;
0 commit comments