confirmed_at_to_dates.js 1.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354
  1. const { db, waitForDb } = require('../app/src/infrastructure/mongodb')
  2. async function updateStringDates() {
  3. await waitForDb()
  4. const users = await db.users.aggregate([
  5. { $unwind: { path: '$emails' } },
  6. {
  7. $match: { 'emails.confirmedAt': { $exists: true, $type: 'string' } },
  8. },
  9. {
  10. $project: {
  11. _id: 1,
  12. 'emails.email': 1,
  13. 'emails.confirmedAt': 1,
  14. },
  15. },
  16. ])
  17. let user
  18. let count = 0
  19. while ((user = await users.next())) {
  20. count += 1
  21. if (count % 10000 === 0) {
  22. console.log(`processed ${count} users`)
  23. }
  24. const confirmedAt = user.emails.confirmedAt
  25. const dateConfirmedAt = new Date(confirmedAt.replace(/ UTC$/, ''))
  26. await db.users.updateOne(
  27. {
  28. _id: user._id,
  29. 'emails.email': user.emails.email,
  30. },
  31. {
  32. $set: {
  33. 'emails.$.confirmedAt': dateConfirmedAt,
  34. },
  35. }
  36. )
  37. }
  38. console.log(`Updated ${count} confirmedAt strings to dates!`)
  39. }
  40. if (!module.parent) {
  41. updateStringDates()
  42. .then(() => {
  43. process.exit(0)
  44. })
  45. .catch(error => {
  46. console.error(error)
  47. process.exit(1)
  48. })
  49. }
  50. module.exports = updateStringDates