overleaf/services/web/scripts/wfh_2020/wfh_2020_notifications.js

const NotificationsHandler = require('../../app/src/Features/Notifications/NotificationsHandler')

const mongojs = require('../../app/src/infrastructure/mongojs')
const { db } = mongojs
const async = require('async')

const templateKey = 'wfh_2020_upgrade_offer'
const key = 'wfh-2020-upgrade-2020-06-01'

db.subscriptions.aggregate(
  { $match: { teamName: /(Work From Home|Work from Home)/ } },
  { $unwind: '$member_ids' },
  { $group: { _id: null, memberIds: { $addToSet: '$member_ids' } } },
  function(err, results) {
    if (err) {
      throw err
    }

    const userIds = results[0].memberIds

    async.eachLimit(
      userIds,
      10,
      function(userId, callback) {
        NotificationsHandler.createNotification(
          userId,
          key,
          templateKey,
          {},
          null,
          true,
          function(err) {
            if (err) {
              return callback(err)
            }
            console.log('Notification created for user ' + userId)
            callback()
          }
        )
      },
      function() {
        console.log('Done')
        process.exit(0)
      }
    )
  }
)