Clash Royale CLAN TAG#URR8PPP

Express-Session undefined req.session

I am trying to modify source code using the Kurento Media Server framework that I clone from one of the developers githubs.

The only thing that I changed was the IP address for the media serves websocket and adding a new key word to var wss = ws.Server( port: 8080 );

new

var wss = ws.Server( port: 8080 );

however I'm getting an undefined error

/home/adam/rtpend/node_modules/express-session/index.js:180
if (req.session) {
^

TypeError: Cannot read property 'session' of undefined
at session (/home/adam/rtpend/node_modules/express-session/index.js:180:13)
at WebSocketServer.connect (/home/adam/rtpend/server.js:47:5)
at WebSocketServer.emit (events.js:182:13)
at WebSocketServer.EventEmitter.emit (domain.js:442:20)
at handleUpgrade (/home/adam/rtpend/node_modules/ws/lib/websocket-server.js:82:18)
at WebSocketServer.completeUpgrade (/home/adam/rtpend/node_modules/ws/lib/websocket-server.js:294:5)
at WebSocketServer.handleUpgrade (/home/adam/rtpend/node_modules/ws/lib/websocket-server.js:233:10)
at Server.upgrade (/home/adam/rtpend/node_modules/ws/lib/websocket-server.js:81:16)
at Server.emit (events.js:182:13)
at Server.EventEmitter.emit (domain.js:442:20)

I asked the developer about 3 weeks ago but have not received any reply yet so I'd appreciate any input.

var express = require('express');
var session = require('express-session')
var ws = require('ws');
var KurentoClient = require('./Kurento/KurentoClient');
var fs = require('fs');

const KURENTO_WS_URL = 'ws://192.168.6.20:8888/kurento';

//
// Express
//
var app = express();

var sessionHandler = session(
secret : 'none',
rolling : true,
resave : true,
saveUninitialized : true
);

app.use(sessionHandler);

//
// Static
//
app.use(express.static('client'));

app.listen(3000, function()
console.log('listenning at 3000');
);

//
// Web Socket
//
var wss = ws.Server(
port: 8080,
);

wss.on('connection', function connect(newSocket, req)
//let sessionId = newSocket.upgradeReq.session.id;
let sessionId;
let request = newSocket.upgradeReq;
let response =
writeHead :
;

sessionHandler(request, response, function(err)
sessionId = request.session.id;
console.log('Connection received with sessionId ' + sessionId);
);

// create a new KurentoClient for each client
let kClient = new KurentoClient(KURENTO_WS_URL, newSocket);

newSocket.on('open', function()
console.log(`connected to $req.connection.remoteAddress`);
);

newSocket.on('close', function()
console.log('disconnected');
kClient.destroyPipeline(sessionId);
);

newSocket.on('error', function(err)
console.log(err);
kClient.destroyPipeline(sessionId);
);

//
// Message
//
newSocket.on('message', function onMessage(msg)
var parsedMsg = JSON.parse(msg);

switch(parsedMsg.id)
case 'start':
console.log('received "start" message ');

kClient.createPipeline(sessionId, parsedMsg.sdpOffer, function(err, sdpAnswer)
let response;
if(err)
console.error(err);

response = JSON.stringify(
id: 'error',
message: err
);

else
if(parsedMsg.sdpOffer != null)
response = JSON.stringify(
id: 'sdpAnswer',
sdpAnswer: sdpAnswer
);

else
console.log('f');
response = JSON.stringify();



return newSocket.send(response);
);
break;

case 'stop':
kClient.destroyPipeline(sessionId);
break;

case 'iceCandidate':
console.log('received ice candidate');

kClient.addClientIceCandidate(sessionId, parsedMsg.candidate);
break;

default:
newSocket.send(JSON.stringify(
id: 'error',
message: 'Invalid message '
));
break;

);
);


By clicking "Post Your Answer", you acknowledge that you have read our updated terms of service, privacy policy and cookie policy, and that your continued use of the website is subject to these policies.