keith/barkey
1
0
Fork 0
mirror of https://codeberg.org/yeentown/barkey synced 2024-11-23 02:35:10 +00:00
Code Issues Projects Releases Packages Wiki Activity

fix

Browse source
This commit is contained in:
otofune 2017-11-07 22:39:17 +09:00
parent bf7601fa8d
commit 36a95c003a
1 changed files with 11 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
tools/migration/use-gridfs.js
View file

@ -48,16 +48,24 @@ const migrateToGridFS = async (doc) => {
async function main() { async function main() {
const count = await DriveFile.count({}); const count = await DriveFile.count({});
console.log(`there are ${count} files.`)
const dop = Number.parseInt(process.argv[2]) || 5 const dop = Number.parseInt(process.argv[2]) || 5
const idop = ((count - (count % dop)) / dop) + 1
return zip( return zip(
1, 1,
async (time) => { async (time) => {
const doc = await DriveFile.find({}, { limit: dop, skip: time * dop }) console.log(`${time} / ${idop}`)
const doc = await db.get('drive_files').find({}, { limit: dop, skip: time * dop })
return Promise.all(doc.map(migrateToGridFS)) return Promise.all(doc.map(migrateToGridFS))
}, },
((count - (count % dop)) / dop) + 1 idop
) ).then(a => {
const rv = []
a.forEach(e => rv.push(...e))
return rv
})
} }
main().then(console.dir).catch(console.error) main().then(console.dir).catch(console.error)