tbelway/immich
1
0
Fork 0
mirror of https://github.com/immich-app/immich.git synced 2025-07-09 03:06:56 -04:00
Code Issues Packages Projects Releases Wiki Activity

- send only one request for checkBulkUpload

Browse Source
This commit is contained in:
tiefseetauchner 2024-08-15 20:02:11 +02:00
parent 32dfc3ddcb
commit 5c9ef5c6fd
1 changed files with 18 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

31
cli/src/commands/asset.ts
View File

@ -97,22 +97,14 @@ export const checkForDuplicates = async (files: string[], { concurrency, skipHas
progressBar.start(files.length, 0);
const newFiles: string[] = [];
const duplicates: Asset[] = [];
const results: { id: string; checksum: string }[] = [];
const queue = new Queue<string, AssetBulkUploadCheckResults>(
async (filepath: string) => {
const dto = [{ id: filepath, checksum: await sha1(filepath) }];
const response = await checkBulkUpload({ assetBulkUploadCheckDto: { assets: dto } });
const results = response.results as AssetBulkUploadCheckResults;
for (const { id: filepath, assetId, action } of results) {
if (action === Action.Accept) {
newFiles.push(filepath);
} else {
// rejects are always duplicates
duplicates.push({ id: assetId as string, filepath });
}
}
const dto = { id: filepath, checksum: await sha1(filepath) };
results.push(dto);
progressBar.increment();
return results;
},
@ -127,6 +119,19 @@ export const checkForDuplicates = async (files: string[], { concurrency, skipHas
await queue.drained();
const newFiles: string[] = [];
const duplicates: Asset[] = [];
const response = await checkBulkUpload({ assetBulkUploadCheckDto: { assets: results } });
for (const { id: filepath, assetId, action } of response.results) {
if (action === Action.Accept) {
newFiles.push(filepath);
} else {
// rejects are always duplicates
duplicates.push({ id: assetId as string, filepath });
}
}
progressBar.stop();
console.log(`Found ${newFiles.length} new files and ${duplicates.length} duplicate${s(duplicates.length)}`);