Add fixtures
This commit is contained in:
parent
9d5bba8f20
commit
8d16fd0e73
3 changed files with 71 additions and 1 deletions
|
|
@ -27,6 +27,7 @@ mongoConnect.connectToServer(function( err, client ) {
|
||||||
queries.register('khai','test');
|
queries.register('khai','test');
|
||||||
queries.register('wilfried','test');
|
queries.register('wilfried','test');
|
||||||
queries.register('yuki','test');
|
queries.register('yuki','test');
|
||||||
|
queries.register('cloud','computing');
|
||||||
|
|
||||||
app.post('/verify:token', (req, res) => {
|
app.post('/verify:token', (req, res) => {
|
||||||
if(typeof req.body !== 'undefined'){
|
if(typeof req.body !== 'undefined'){
|
||||||
|
|
|
||||||
|
|
@ -22,6 +22,34 @@ app.use(bodyParser.json());
|
||||||
app.use(cors({origin: 'http://127.0.0.1:4200', credentials: true}));
|
app.use(cors({origin: 'http://127.0.0.1:4200', credentials: true}));
|
||||||
app.use(cookieParser());
|
app.use(cookieParser());
|
||||||
|
|
||||||
|
|
||||||
|
messages.insertMany([
|
||||||
|
{
|
||||||
|
username: 'yuki',
|
||||||
|
date: new Date(),
|
||||||
|
channel: 'general',
|
||||||
|
message: 'Ceci est un message de test de la part de Yûki'
|
||||||
|
},
|
||||||
|
{
|
||||||
|
username: 'wilfried',
|
||||||
|
date: new Date(),
|
||||||
|
channel: 'general',
|
||||||
|
message: 'Ceci est un message de test de la part de Wilfried'
|
||||||
|
},
|
||||||
|
{
|
||||||
|
username: 'khai',
|
||||||
|
date: new Date(),
|
||||||
|
channel: 'general',
|
||||||
|
message: 'Ceci est un message de test de la part de Khai'
|
||||||
|
},
|
||||||
|
{
|
||||||
|
username: 'cloud',
|
||||||
|
date: new Date(),
|
||||||
|
channel: 'general',
|
||||||
|
message: 'Ceci est un message à des fins de démonstration'
|
||||||
|
},
|
||||||
|
]);
|
||||||
|
|
||||||
io.on('connection',socket => {
|
io.on('connection',socket => {
|
||||||
|
|
||||||
auth.getSession(socket.request, function(res){
|
auth.getSession(socket.request, function(res){
|
||||||
|
|
|
||||||
|
|
@ -24,10 +24,51 @@ app.use(cors({origin: 'http://127.0.0.1:4200', credentials: true}));
|
||||||
|
|
||||||
const auth = require("./auth");
|
const auth = require("./auth");
|
||||||
|
|
||||||
const Message = require("../service-privateroom/models/Message");
|
const Message = require("./models/Message");
|
||||||
const conversationRoute = require("./routes/conversations");
|
const conversationRoute = require("./routes/conversations");
|
||||||
app.use("/conversations", conversationRoute);
|
app.use("/conversations", conversationRoute);
|
||||||
|
|
||||||
|
const Conversation = require("./models/Conversation");
|
||||||
|
Conversation.updateOne(
|
||||||
|
{roomName: 'Demonstration Room'},
|
||||||
|
{$setOnInsert: {members: ['cloud','yuki','wilfried','khai'], owner: 'cloud', roomName: 'Demonstration Room'}},
|
||||||
|
{upsert:true},function(err,result){
|
||||||
|
if(result !== undefined){
|
||||||
|
if(typeof result.upserted !== 'undefined'){
|
||||||
|
Message.insertMany([
|
||||||
|
{
|
||||||
|
conversationId: result.upserted[0]._id,
|
||||||
|
sender: 'yuki',
|
||||||
|
text: 'Message à des fins de démonstration pour private room de Yûki',
|
||||||
|
date: new Date()
|
||||||
|
},
|
||||||
|
{
|
||||||
|
conversationId: result.upserted[0]._id,
|
||||||
|
sender: 'wilfried',
|
||||||
|
text: 'Message à des fins de démonstration pour private room de Wilfried',
|
||||||
|
date: new Date()
|
||||||
|
},
|
||||||
|
{
|
||||||
|
conversationId: result.upserted[0]._id,
|
||||||
|
sender: 'khai',
|
||||||
|
text: 'Message à des fins de démonstration pour private room de Khai',
|
||||||
|
date: new Date()
|
||||||
|
},
|
||||||
|
{
|
||||||
|
conversationId: result.upserted[0]._id,
|
||||||
|
sender: 'cloud',
|
||||||
|
text: 'Message à des fins de démonstration pour private room de Cloud',
|
||||||
|
date: new Date()
|
||||||
|
},
|
||||||
|
]);
|
||||||
|
}else{
|
||||||
|
console.log('Room already exist');
|
||||||
|
}
|
||||||
|
}else{
|
||||||
|
console.log(err);
|
||||||
|
}
|
||||||
|
});
|
||||||
|
|
||||||
io.on('connection',socket => {
|
io.on('connection',socket => {
|
||||||
|
|
||||||
auth.getSession(socket.request, function(res){
|
auth.getSession(socket.request, function(res){
|
||||||
|
|
|
||||||
Reference in a new issue