johan/FoundKey
1
0
Fork 0
forked from FoundKeyGang/FoundKey
Code Issues Pull requests Projects Releases Packages Wiki Activity

Update migrate.ts

Browse source
This commit is contained in:
syuilo 2019-04-11 22:44:04 +09:00
parent d2b75f3501
commit 4d688be3df
No known key found for this signature in database
GPG key ID: BDC4C49D06AB9D69
1 changed files with 14 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

20
src/migrate.ts
View file

@ -324,10 +324,14 @@ async function main() {
}); });
} }
let allUsersCount = await _User.count(); let allUsersCount = await _User.count({
deletedAt: { $exists: false }
});
if (test && allUsersCount > limit) allUsersCount = limit; if (test && allUsersCount > limit) allUsersCount = limit;
for (let i = 0; i < allUsersCount; i++) { for (let i = 0; i < allUsersCount; i++) {
const user = await _User.findOne({}, { const user = await _User.findOne({
deletedAt: { $exists: false }
}, {
skip: i skip: i
}); });
try { try {
@ -370,12 +374,14 @@ async function main() {
} }
let allDriveFilesCount = await _DriveFile.count({ let allDriveFilesCount = await _DriveFile.count({
'metadata._user.host': null 'metadata._user.host': null,
'metadata.deletedAt': { $exists: false }
}); });
if (test && allDriveFilesCount > limit) allDriveFilesCount = limit; if (test && allDriveFilesCount > limit) allDriveFilesCount = limit;
for (let i = 0; i < allDriveFilesCount; i++) { for (let i = 0; i < allDriveFilesCount; i++) {
const file = await _DriveFile.findOne({ const file = await _DriveFile.findOne({
'metadata._user.host': null 'metadata._user.host': null,
'metadata.deletedAt': { $exists: false }
}, { }, {
skip: i skip: i
}); });
@ -394,12 +400,14 @@ async function main() {
} }
let allNotesCount = await _Note.count({ let allNotesCount = await _Note.count({
'_user.host': null '_user.host': null,
'metadata.deletedAt': { $exists: false }
}); });
if (test && allNotesCount > limit) allNotesCount = limit; if (test && allNotesCount > limit) allNotesCount = limit;
for (let i = 0; i < allNotesCount; i++) { for (let i = 0; i < allNotesCount; i++) {
const note = await _Note.findOne({ const note = await _Note.findOne({
'_user.host': null '_user.host': null,
'metadata.deletedAt': { $exists: false }
}, { }, {
skip: i skip: i
}); });