| 1234567891011121314151617181920212223242526272829303132333435363738394041424344 |
- const mongojs = require('../../app/src/infrastructure/mongojs')
- const { db } = mongojs
- const Async = require('async')
- db.projects.find(
- {
- 'tokens.readAndWrite': { $exists: true },
- 'tokens.readAndWritePrefix': { $exists: false }
- },
- { tokens: 1 },
- (err, projects) => {
- if (err) {
- throw err
- }
- console.log(`>> Updating ${projects.length} projects`)
- Async.eachLimit(
- projects,
- 5,
- (project, cb) => {
- const rwToken = project.tokens.readAndWrite
- const prefixMatch = rwToken.match(/^(\d+).*$/)
- if (!prefixMatch) {
- const err = new Error(
- `no prefix on token: ${project._id}, ${rwToken}`
- )
- console.log(`>> Error, ${err.message}`)
- return cb(err)
- }
- db.projects.update(
- { _id: project._id },
- { $set: { 'tokens.readAndWritePrefix': prefixMatch[1] } },
- cb
- )
- },
- err => {
- if (err) {
- throw err
- }
- console.log('>> done')
- process.exit(0)
- }
- )
- }
- )
|