Skip to content

Commit

Permalink
setTimeout infinity is ackshually instant, so... um, don't
Browse files Browse the repository at this point in the history
  • Loading branch information
amark committed Nov 29, 2024
1 parent 9eac3de commit e9f2a88
Showing 1 changed file with 7 additions and 1 deletion.
8 changes: 7 additions & 1 deletion lib/tag.js
Original file line number Diff line number Diff line change
Expand Up @@ -2,16 +2,22 @@ module.exports = function(root){ // THIS IS THE UNIVERSAL NOTIFICATION MODULE
var to = {}, key = {}, mesh = root.opt.mesh, email = require('./email');
if(email.err){ return }
mesh.hear['tag'] = function(msg, peer, who){
if(who = key[msg.key]){ who.rate = Math.max(msg.rate||1000*60*15, 1000*60); return }
if(who = key[msg.key]){
if(0 === msg.rate || Infinity == msg.rate){ who.go=0; return }
who.rate = Math.max(msg.rate||1000*60*15, 1000*60);
return;
}
if(!msg.src || !msg.email){ return }
if(+new Date < peer.emailed + 1000*60*2){ mesh.say({dam:'tag',err:'too fast'},peer); return } // peer can only send notifications > 2min
var src; try{ src = new URL(msg.src = msg.src.split(/\s/)[0]); } catch(e){ return } // throws if invalid URL.
(who = (to[msg.email] = to[msg.email] || {go:{}})).go[''+src] = 1; // we're keeping in-memory for now, maybe will "stay" to disk in future.
peer.emailed = +new Date;
if(!who.go){ return }
mesh.say({dam:'tag',ok:'queued in-memory'},peer);
if(who.batch){ return }
key[who.key = Math.random().toString(36).slice(2)] = who;
who.batch = setTimeout(function(){
if(!who.go){ return }
email.send({
from: process.env.EMAIL,
to: msg.email,
Expand Down

0 comments on commit e9f2a88

Please sign in to comment.