Mongoose pre.save() asynchroniczny middleware nie działa zgodnie z oczekiwaniami

Question

Kontynuując od: Mongoose unique validation error type

Używam tego schematu z mongoose 3.0.3 z KMP:

var schema = new Schema({ 

    _id: Schema.ObjectId, 
    email: {type: String, required: true, unique: true} 

}); 

Dzięki tej warstwy pośredniej, aby uzyskać validationError od unikalny: true

schema.pre("save", function(next, done) { 
    var self = this; 

    model.findOne({email : this.email}, 'email', function(err, results) { 
     if(err) { 
      done(err); 
     } else if(results) { 
      console.warn('results', results); 
      self.invalidate("email", "email must be unique"); 
      done(new Error("email must be unique")); 
     } else { 
      done(); 
     } 
    }); 

    next(); 
}); 

Jednak to nie działa!

Users.create() nadal będzie zwracać numer MongoError: E11000 duplicate key error index, a console.warn() jest wywoływany tylko po tym.

Czynność składowania nie powinna być wywoływana, dopóki nie zostanie wywołane wszystkie oprogramowanie warstwy pośredniej done() zgodnie z dokumentami, i powinienem otrzymać błąd sprawdzania poprawności.

Wygląda na to zachowanie done() nie działa zgodnie z oczekiwaniami,

jakiś pomysł, dlaczego?

Answer 1

Używasz funkcji wywołania zwrotnego równoległego oprogramowania pośredniego (zarówno z next, jak i done), ale nie ustawiasz flagi równoległej w parametrach schema.pre, więc używa ona reguł szeregowych.

Więc albo to równoległe flagę w swojej rozmowy:

schema.pre("save", true, function(next, done) { ... 

lub przełączyć do seryjnego middleware zwrotnej stylu, czy to wszystko, co trzeba w każdym razie:

schema.pre("save", function(next) { 
    var self = this; 

    model.findOne({email : this.email}, 'email', function(err, results) { 
     if(err) { 
      next(err); 
     } else if(results) { 
      console.warn('results', results); 
      self.invalidate("email", "email must be unique"); 
      next(new Error("email must be unique")); 
     } else { 
      next(); 
     } 
    }); 
});