⬇️ Support for multiple bundles in comic model

models/comic.model.ts

@@ -46,7 +46,7 @@ const ComicSchema = mongoose.Schema({
 	acquisition: {
 		wanted: Boolean,
 		release: {},
-		directconnect: {},
+		directconnect: Array,
 		torrent: {
 			sourceApplication: String,
 			magnet: String,

services/import.service.ts

@@ -70,10 +70,10 @@ export default class ProductsService extends Service {
 									};
 								}>
 							) {
-								console.log("ASDASD", ctx.params);
 								let volumeDetails;
 								const comicMetadata = ctx.params;
-								if (comicMetadata.sourcedMetadata.comicvine && 
+								if (
+									comicMetadata.sourcedMetadata.comicvine &&
 									!isNil(
 										comicMetadata.sourcedMetadata.comicvine
 											.volume
@@ -161,7 +161,8 @@ export default class ProductsService extends Service {
 								ctx: Context<{
 									comicObjectId: string;
 									resultId: string;
-									downloadResult: {};
+									bundleId: string;
+									directoryIds: [];
 									searchInstanceId: string;
 								}>
 							) {
@@ -169,21 +170,30 @@ export default class ProductsService extends Service {
 									ctx.params.comicObjectId
 								);
 								return new Promise((resolve, reject) => {
-									Comic.findByIdAndUpdate(comicObjectId, {
+									Comic.findByIdAndUpdate(
-										acquisition: {
+										comicObjectId,
-											directconnect: {
+										{
-												resultId: ctx.params.resultId,
+											$push: {
-												downloadResult: ctx.params.downloadResult,
+												"acquisition.directconnect": {
-												searchInstanceId: ctx.params.searchInstanceId,
+													resultId:
-											}
+														ctx.params.resultId,
-										}
+													bundleId: ctx.params.bundleId,
-									}, { new: true}, (err, result) =>{
+													directoryIds: ctx.params.directoryIds,
-										if(err) {
+													searchInstanceId:
+														ctx.params
+															.searchInstanceId,
+												},
+											},
+										},
+										{ new: true, safe: true, upsert: true },
+										(err, result) => {
+											if (err) {
 												reject(err);
 											} else {
 												resolve(result);
 											}
-									});
+										}
+									);
 								});
 							},
 						},