fix: exclusive content detail on comment

src/application.ts

@@ -86,6 +86,7 @@ import {getFilePathFromSeedData, upload} from './utils/upload';
 import fs, {existsSync} from 'fs';
 import {FriendStatusType} from './enums';
 import {UpdatePeopleProfileJob} from './jobs';
+import {Asset} from './interfaces';
 
 const jwt = require('jsonwebtoken');
 
@@ -238,10 +239,13 @@ export class MyriadApiApplication extends BootMixin(
   }
 
   async migrateSchema(options?: SchemaMigrationOptions): Promise<void> {
-    await super.migrateSchema(options);
-
+    if (!this.options?.skipMigrateSchema) await super.migrateSchema(options);
     if (options?.existingSchema === 'drop') return this.databaseSeeding();
-    await Promise.allSettled([this.doMigrateUser()]);
+    await Promise.allSettled([
+      this.doMigrateComment(),
+      this.doMigratePost(),
+      this.doMigrateUser(),
+    ]);
   }
 
   async databaseSeeding(): Promise<void> {
@@ -510,8 +514,12 @@ export class MyriadApiApplication extends BootMixin(
   }
 
   async doMigrateUser(): Promise<void> {
+    if (!this.doCollectionExists('user')) return;
+
     const {userRepository} = await this.repositories();
-    const {count: totalUser} = await userRepository.count();
+    const {count: totalUser} = await userRepository.count({
+      email: {exists: true},
+    });
     const bar = this.initializeProgressBar('Start Migrate User');
     const promises = [];
 
@@ -520,6 +528,11 @@ export class MyriadApiApplication extends BootMixin(
       const [user] = await userRepository.find({
         limit: 1,
         skip: i,
+        where: {
+          email: {
+            exists: true,
+          },
+        },
       });
 
       if (!user) continue;
@@ -536,6 +549,98 @@ export class MyriadApiApplication extends BootMixin(
     bar.stop();
   }
 
+  async doMigratePost(): Promise<void> {
+    if (!this.doCollectionExists('post')) return;
+
+    const {postRepository} = await this.repositories();
+    const {count: totalPost} = await postRepository.count(<AnyObject>{
+      'asset.exclusiveContents': {exists: true},
+    });
+    const bar = this.initializeProgressBar('Start Migrate Post');
+    const promises = [];
+
+    bar.start(totalPost - 1, 0);
+    for (let i = 0; i < totalPost; i++) {
+      const [post] = await postRepository.find(<AnyObject>{
+        limit: 1,
+        skip: i,
+        where: {
+          'asset.exclusiveContents': {
+            $exists: true,
+          },
+        },
+      });
+
+      if (!post) continue;
+      if (!post?.asset?.exclusiveContents) continue;
+      if (post.asset.exclusiveContents.length <= 0) continue;
+
+      const exclusiveContents = [];
+
+      for (const content of post.asset.exclusiveContents) {
+        const contentId = content.split('/').at(-1);
+        if (!contentId) continue;
+        exclusiveContents.push(contentId);
+      }
+
+      const asset: Asset = {...post.asset, exclusiveContents};
+
+      promises.push(postRepository.updateById(post.id, {asset}));
+
+      bar.update(i);
+    }
+
+    await Promise.allSettled(promises);
+
+    bar.stop();
+  }
+
+  async doMigrateComment(): Promise<void> {
+    if (!this.doCollectionExists('comment')) return;
+
+    const {commentRepository} = await this.repositories();
+    const {count: totalComments} = await commentRepository.count(<AnyObject>{
+      'asset.exclusiveContents': {exists: true},
+    });
+    const bar = this.initializeProgressBar('Start Migrate Post');
+    const promises = [];
+
+    bar.start(totalComments - 1, 0);
+    for (let i = 0; i < totalComments; i++) {
+      const [comment] = await commentRepository.find(<AnyObject>{
+        limit: 1,
+        skip: i,
+        where: {
+          'asset.exclusiveContents': {
+            $exists: true,
+          },
+        },
+      });
+
+      if (!comment) continue;
+      if (!comment?.asset?.exclusiveContents) continue;
+      if (comment.asset.exclusiveContents.length <= 0) continue;
+
+      const exclusiveContents = [];
+
+      for (const content of comment.asset.exclusiveContents) {
+        const contentId = content.split('/').at(-1);
+        if (!contentId) continue;
+        exclusiveContents.push(contentId);
+      }
+
+      const asset: Asset = {...comment.asset, exclusiveContents};
+
+      promises.push(commentRepository.updateById(comment.id, {asset}));
+
+      bar.update(i);
+    }
+
+    await Promise.allSettled(promises);
+
+    bar.stop();
+  }
+
   async repositories(): Promise<Repositories> {
     const accountSettingRepository = await this.getRepository(
       AccountSettingRepository,
@@ -612,6 +717,10 @@ export class MyriadApiApplication extends BootMixin(
     };
   }
 
+  doCollectionExists(name: string) {
+    return this.options.alter.length > 0 && this.options.alter.includes(name);
+  }
+
   initializeProgressBar(title: string) {
     const cliProgress = require('cli-progress');
     const colors = require('ansi-colors');

src/interceptors/pagination.interceptor.ts

@@ -371,19 +371,17 @@ export class PaginationInterceptor implements Provider<Interceptor> {
               const exclusiveContents = comment?.asset?.exclusiveContents ?? [];
               if (exclusiveContents.length > 0) {
                 const updatedContents: AnyObject[] = [];
-                for (const url of exclusiveContents) {
-                  const id = String(url).split('/').at(-1);
-                  if (!id) continue;
+                for (const contentId of exclusiveContents) {
                   const prices = await this.contentPriceRepository.find({
                     include: ['currency'],
                     where: {
-                      unlockableContentId: id,
+                      unlockableContentId: contentId,
                     },
                   });
                   if (prices.length === 0) continue;
                   const updatedPrices = prices.map(price => {
                     return {
-                      id,
+                      id: contentId,
                       price: price.amount,
                       decimal: price?.currency?.decimal ?? 0,
                       symbol: price?.currency?.symbol ?? 'UNKNOWN',

src/migrate.ts

@@ -2,19 +2,27 @@ import {MyriadApiApplication} from './application';
 
 export async function migrate(args: string[]) {
   const existingSchema = args.includes('--rebuild') ? 'drop' : 'alter';
+  const skipMigrateSchema = args.includes('--skip-migrate-schema')
+    ? true
+    : false;
   const envIndex = args.indexOf('--environment');
   const environment = args.includes('--environment')
     ? args[envIndex + 1]
       ? args[envIndex + 1]
       : 'development'
     : undefined;
   const alterIndex = args.indexOf('--alter');
-  const alter = args.includes('--alter') ? args[alterIndex + 1].split(',') : [];
+  const alter = args.includes('--alter')
+    ? args[alterIndex + 1]?.split(',') ?? []
+    : [];
   const dropIndex = args.indexOf('--drop');
-  const drop = args.includes('--drop') ? args[dropIndex + 1].split(',') : [];
+  const drop = args.includes('--drop')
+    ? args[dropIndex + 1]?.split(',') ?? []
+    : [];
   console.log('Migrating schemas (%s existing schema)', existingSchema);
 
   const app = new MyriadApiApplication({
+    skipMigrateSchema,
     environment,
     alter,
     drop,