Realm Atlas Triggers Mimos e Triggers - Agendamento trigger baseado em documentos

1
{
2
  _id : ObjectId("5ca4bbcea2dd94ee58162aa7"),
3
  event : "Mooz Meeting",
4
  eventDate : ISODate("2021-03-20:14:00:00Z"),
5
  meetingUrl : "https://mooz.meeting.com/5ca4bbcea2dd94ee58162aa7",
6
  invites : ["jon.doe@myemail.com", "doe.jonas@myemail.com"]
7
 }

1
{
2
  _id : ObjectId("5ca4bbcea2dd94ee58162aa7"),
3
  event : "Mooz Meeting",
4
  eventDate : ISODate("2021-03-20:11:00:00Z"),
5
  meetingUrl : "https://mooz.meeting.com/5ca4bbcea2dd94ee58162aa7"
6
  invites : ["jon.doe@example.com"],
7
  phone : "+123456789"
8
}

1
{
2
  _id : ObjectId("5ca4bbcea2dd94ee58162aa7"),
3
  triggerDate : ISODate("2021-03-10:50:00:00Z")
4
}

1
db.notifications.createIndex( { "triggerDate": 1 }, { expireAfterSeconds: 0 } )

1
exports = function(changeEvent) {
2
  // Get the notifications collection
3
  const coll = context.services.get("<ATLAS-SERVICE>").db("<DATABASE>").collection("notifications");
4
5
  // Calculate the "triggerDate" and populate the trigger collection and duplicate the _id
6
  const calcTriggerDate = new Date(changeEvent.fullDocument.eventDate - 10 * 60000);   
7
  return coll.insertOne({_id:changeEvent.fullDocument._id,triggerDate: calcTriggerDate });
8
};

1
exports = async function(changeEvent) {
2
  // Get meetings collection
3
  const coll = context.services.get("<ATLAS-SERVICE>").db("<DATABASE>").collection("meetings");
4
5
  // Read specific meeting document
6
  const doc = await coll.findOne({ _id: changeEvent.documentKey._id});
7
8
  // Send notification via Twilio SMS
9
  const twilio = context.services.get("<TWILIO-SERVICE>");
10
  twilio.send({
11
    to: doc.phone,
12
    from: "+123456789",
13
    body: `Reminder : Event ${doc.event} is about to start in 10min at ${doc.scheduledOn}`
14
    });
15
};