deliciousinsights/mongoose-pii

const mongoose = require('mongoose')
const { Schema } = require('mongoose')
const { markFieldsAsPII } = require('../index')

mongoose.connect('mongodb://localhost:27017/demos', {
  connectTimeoutMS: 1000,
  useNewUrlParser: true,
})

demoScenario()

const email = 'christophe@delicious-insights.com'

async function demoFinders(User) {
  const id = (await User.find().limit(1))[0].id

  // 7. findById / findOne, including a ciphered query
  let fetchedUser = await User.findById(id)
  console.log('Fetched user (findById):', fetchedUser.toJSON())
  fetchedUser = await User.where({ firstName: 'Chris' }).findOne()
  console.log('Fetched user (findOne, ciphered query):', fetchedUser.toJSON())

  // 8. multi-fetch using find()
  const fetchedUsers = await User.where({ lastName: 'Roberts', email })
    .limit(2)
    .find()
  console.log(
    '2 fetched users (find, ciphered query):',
    fetchedUsers.map((u) => u.toJSON())
  )
  // 9. findOneAndDelete, with a ciphered query
  const deletedUser = await User.where({ email }).findOneAndDelete()
  console.log('Deleted user (ciphered query):', deletedUser)
}

async function demoInsertions(User) {
  const attrs = {
    address: '83 av. Philippe-Auguste 75011 Paris',
    email,
    firstName: 'Christophe',
    lastName: 'Porteneuve',
    password: 'foobar42',
  }

  // 1. Single-step create
  const user = await User.create(attrs)
  console.log('Created user:', user.toJSON())
  // 2. Two-step init-and-save
  const user2 = new User(attrs)
  await user2.save()
  console.log('Saved user:', user2.toJSON())
  // 3. insertMany
  const users = await User.insertMany([attrs, attrs])
  console.log(
    'insertMany users:',
    users.map((u) => u.toJSON())
  )
}

async function demoScenario() {
  const User = await setup()

  try {
    await demoInsertions(User)
    await demoUpdates(User)
    await demoFinders(User)
  } finally {
    mongoose.disconnect()
  }
}

async function demoUpdates(User) {
  const user = await User.findOne()

  // 4. updateOne (update would work too but is deprecated)
  await user.updateOne({ firstName: 'Chris' })
  // 5. updateMany with both query and update ciphering
  const { nModified, n: nMatched } = await User.updateMany(
    { email: user.email },
    { address: '19 rue François Mauriac 92700 Colombes', lastName: 'Roberts' }
  )
  console.log(
    `updateMany with ciphered queries and updates: ${nMatched} matched, ${nModified} updated`
  )
}

function prepareModel() {
  const schema = new Schema({
    address: String,
    email: String,
    firstName: String,
    lastName: String,
    password: String,
  })
  schema.plugin(markFieldsAsPII, {
    fields: ['email', 'firstName', 'lastName'],
    key: '59aad44db330ad2bf34f6730e50c0058',
  })

  return mongoose.model('User', schema)
}

async function setup() {
  const User = prepareModel()

  if (process.stdout.isTTY) {
    process.stdout.write('\x1b[2J\x1b[H')
  }
  await User.deleteMany({})

  return User
}