Express: run-Middleware einmal pro Sekunde

Question

Ich habe einen Express-Server, der als eine API ausgeführt wird, und ich habe eine Middleware als solche geladen:

app.js

const lastActivity = require('./middleware/lastActivity'); 
app.use(lastActivity);` 

Middleware/lastActivity.js

module.exports = function(req, res, next) { 
    if (req.user && isDifferentDay(req.user.last_activity) { 
     User.findById(req.user.id, (err, user) => { 
      user.last_activity = Date.now(); 
      user.save((err) => { 
       // also do another async call to an external service, then 
       return next(); 
      } 
     }); 
    } 
}); 

So prüft sie, ob die last_activity Datum auf dem Benutzer gespeichert ist eine andere Tag als heute, und wenn ja, aktualisiert der Benutzer (ich interessiere mich nur für das Datum, nicht den bestimmten Zeitstempel). Es führt auch einen API-Aufruf an einen externen Dienst aus, um E-Mail-Marketingkampagnen zu verwalten.

Das Problem ist jedoch, dass meine Web-App zwei Ressourcen beim Laden der Seite zur gleichen Zeit anfordert. Das bedeutet, dass die isDifferentDay für beide zurückgegeben wird, und das Benutzermodell zweimal aktualisiert wird, und noch wichtiger, ich mache zwei API-Aufrufe an den externen Dienst, der ratenbegrenzt ist.

Eine naheliegende Lösung besteht darin, nur eine Anfrage gleichzeitig auf meinem Client zu stellen, aber ich möchte mich nicht darauf beschränken. Was ich will ist eine Art Express-Sperre, die nur die Middleware einmal pro Sekunde laufen lässt? Oder eine andere Lösung, die ich nicht sehen kann.

Was ist der beste Weg, dies in einer Express/Node-Art zu handhaben?

Vielen Dank.

Answer 1

Dieses Problem ist eine typische Wettlaufsituation.
Da Sie nur last_activity des Benutzers einmal pro Tag interessieren, anstelle findById zu verwenden, können Sie einen zusätzlichen Filter zur DB Anfrage hinzufügen UND sie in einem Zug aktualisieren. Zum Beispiel

var query = { 
    _id: req.user.id, 
    last_activity: req.user.last_activity 
}; 
User.findOneAndUpdate(query, { last_activity: Date.now() }, (err, user) => { 
    if (!user) 
     return; // user was changed between requests, do nothing 
    // ... the rest of your code 
}); 

Auf diese Weise werden Sie nur den Benutzer aktualisieren, wenn es last_activity zwischen Aktionen unverändert gelassen wurde wird.