fix: The memory generation job does not work correctly

Author: ExceptionsOccur

server/src/repositories/memory.repository.ts

@@ -12,21 +12,16 @@ import { IBulkAsset } from 'src/types';
 
 @Injectable()
 export class MemoryRepository implements IBulkAsset {
-  constructor(@InjectKysely() private db: Kysely<DB>) {}
+  constructor(@InjectKysely() private db: Kysely<DB>) { }
 
   async cleanup() {
-    await this.db
-      .deleteFrom('memory_asset')
-      .using('asset')
-      .whereRef('memory_asset.assetId', '=', 'asset.id')
-      .where('asset.visibility', '!=', AssetVisibility.Timeline)
-      .execute();
+    await this.db.transaction().execute(async (trx) => {
+      await trx.deleteFrom('memory_asset').execute();
+    });
 
-    return this.db
-      .deleteFrom('memory')
-      .where('createdAt', '<', DateTime.now().minus({ days: 30 }).toJSDate())
-      .where('isSaved', '=', false)
-      .execute();
+    return await this.db.transaction().execute(async (trx) => {
+      await trx.deleteFrom('memory').execute();
+    });
   }
 
   searchBuilder(ownerId: string, dto: MemorySearchDto) {

server/src/services/memory.service.ts

@@ -19,6 +19,13 @@ export class MemoryService extends BaseService {
     await this.databaseRepository.withLock(DatabaseLock.MemoryCreation, async () => {
       const state = await this.systemMetadataRepository.get(SystemMetadataKey.MemoriesState);
       const start = DateTime.utc().startOf('day').minus({ days: DAYS });
+      const systemConfig = await this.systemMetadataRepository.get(SystemMetadataKey.SystemConfig)
+      const isManualGenerate = DateTime.now().toFormat('HH:mm') !== systemConfig?.nightlyTasks?.startTime
+      if (isManualGenerate && state) {
+        state["lastOnThisDayDate"] = start.toISO();
+        // if not cleanup, record will duplicates
+        this.onMemoriesCleanup();
+      }
       const lastOnThisDayDate = state?.lastOnThisDayDate ? DateTime.fromISO(state.lastOnThisDayDate) : start;
 
       // generate a memory +/- X days from today