migrate script

console-api/src/app.service.ts

@@ -371,23 +371,18 @@ export class AppService extends ConsoleLogger {
     return new BlankReturnMessageDto(200, 'success');
   }
 
-  /*
   async migrateFilesField() {
-    const archives = await this.db.getRepository(Archive).find({ select: ['id', 'files'] });
+    const archives = await this.db.getRepository(Archive).find({ select: ['id', 'files'], where: { files: IsNull() } });
     await this.db.transaction(async (edb) => {
       for (const a of archives) {
-        this.log(`Processing archive ${a.id} with ${a.files.length} files.`);
-        const files = a.files.map((f) => {
-          const fileEnt = ArchiveFile.fromPath(f);
-          fileEnt.archive = a;
-          return fileEnt;
-        });
-        await edb.getRepository(ArchiveFile).save(files);
+        this.log(`Processing archive ${a.id}.`);
+        const fileEnts = await this.db.getRepository(ArchiveFile).find({ select: ['path'], where: { archive: a } });
+        this.log(`${fileEnts.length} files found for archive ${a.id}`);
+        a.files = fileEnts.map((f) => f.path);
+        await edb.getRepository(Archive).save(a);
       }
     });
     this.log(`Done.`);
     return new BlankReturnMessageDto(200, 'success');
   }
-
-   */
 }

console-api/src/entities/Archive.entity.ts

@@ -15,8 +15,8 @@ export class Archive extends TimeBase {
   @PrimaryGeneratedColumn({ type: 'int8' })
   id: number;
 
-  //@Column('varchar', { length: 256, array: true })
-  //files: string[];
+  @Column('varchar', { length: 256, array: true, nullable: true })
+  files: string[];
 
   @OneToMany(() => ArchiveFile, (file) => file.archive, { cascade: true })
   containingFiles: ArchiveFile[];