Commit 802fe5d8 authored by nanahira's avatar nanahira

query ent directly

parent 05e16f82
Pipeline #5430 passed with stages
in 4 minutes and 9 seconds
......@@ -75,7 +75,7 @@ export class MirrorService extends ConsoleLogger {
}
}
private async saveMirrorFromPath(archive: Partial<Archive>) {
private async saveMirrorFromPath(archive: Archive) {
const uploadInfo: UploadInfo = {
url: this.packageS3.getCdnUrl(`${archive.path}.tar.zst`),
size: archive.size,
......@@ -124,9 +124,8 @@ export class MirrorService extends ConsoleLogger {
private async runMirror() {
const query = this.db
.createQueryBuilder()
.select('archive.path', 'path')
.select(['archive.path', 'archive.size'])
.distinctOn(['archive.path'])
.addSelect('archive.size', 'size')
.from(Archive, 'archive')
.where('archive.size <= :maximumMirroredSize', { maximumMirroredSize: this.maximumMirroredSize });
query
......@@ -135,7 +134,7 @@ export class MirrorService extends ConsoleLogger {
)
.take(10);
this.log(`Searching for archives to mirror`);
const archives = await query.getRawMany<Partial<Archive>>();
const archives = await query.getMany();
if (!archives.length) {
return false;
}
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment