Insérer des données dans mongodb en utilisant Socket.io

Question

Je développe une application de chat simple et je veux stocker les messages dans mongoDb. Mais j'obtiens une erreur lorsque j'exécute ce code. Impossible de lire la propriété '_id' d'undefined. J'ai déjà créé une collection appelée chat.

var MongoClient= require('mongodb').MongoClient;
var assert=require('assert');
var ObjectId= require('mongodb').ObjectId;
var bodyParser= require('body-parser'); 
var express = require('express'),
    app=express();
    server=require('http').createServer(app),
    io= require('socket.io').listen(server),
    app.use(bodyParser.urlencoded({extended:false}));
    var mongo=require('mongodb');
    users = {};
    url='mongodb://localhost:27017/anant';

server.listen(9000, function(){
    var host= server.address().address;
    var port=server.address().port;

    console.log("save app listen on http://%s:%s", host , port);
});

/*var server = app.listen(9000, function(){
    var host= server.address().address;
    var port=server.address().port;

    console.log("save app listen on http://%s:%s", host , port);
});*/

app.get('/', function(req, res){
    res.sendFile(__dirname + '/index.html');
});

io.sockets.on('connection', function(socket){
    socket.on('new user', function(data , callback){
        if(data in users){
                callback(false);
        }else{
            callback(true);
            socket.nickname= data;
            users[socket.nickname]= socket;
            updatenicknames();
        }
    });

    io.sockets.on('send request', function(data , callback){
            var name=data;
            console.log(data);
    });

    socket.on('send message', function(data , callback){
        var msg=data.trim();
        if(msg.substr(0,3) === '/w '){
                msg = msg.substr(3);
                var  ind = msg.indexOf(' ');
                console.log(ind);
                console.log("got it after ind ");
                if(ind !== -1)
                {
                    var  name=msg.substr(0, ind);
                    var msg=msg.substring(ind + 1);
                    console.log(name);
                    console.log(msg);
                    if(name in users){
                        console.log("got it in if name condition");
                        users[name].emit('wishper', {msg: msg , nick: socket.nickname} );
                    console.log('whisper..! ');
                    } else
                    {
                        callback("enter a vlid user");
                    }
                } else{
                        callback('please enter message for your wishper');
                }
        }else {
        insertData(data);
        io.sockets.emit('new message', {msg: msg , nick: socket.nickname} );
        }   
    }); 

    function updatenicknames(){
            io.sockets.emit('usernames', Object.keys(users));
    }

    function insertData(data)
    {   

            MongoClient.connect(url, function(err, db){
            console.log(data);
            db.collection('chat').save(data.msg , (err,result)=>{
                if(err){
                    console.log("not inserted");
                }else {
                    console.log("inserted");
                }
            });
        });

    }
    socket.on('disconnect', function(data){
        if(!socket.nickname) return;
        delete users[socket.nickname];
        updatenicknames();
    });
});

Answer 1

C'est parce que vous passez un chaîne de caractères data à votre insertData (à en juger par votre code, je suppose que vous supposez que la fonction data est en fait un objet ).

Alors vous donnez data.msg ce qui est évidemment undefined en tant que premier argument de la méthode save qui s'attend à ce que vous fournissiez un numéro d'identification valide. objet ici.

Veuillez également noter que vous utilisez l'option save sur un document nouvellement créé, au lieu d'utiliser la méthode insertOne .

Comme vous pouvez le voir dans le documentation api en utilisant save est maintenant déprécié. (Je suppose que vous utilisez la dernière version, qui est actuellement la 2.1).