feat: analysis에 logger 메시지 추가

Author: izure1

package.json

@@ -1,6 +1,6 @@
 {
   "name": "document-dataply",
-  "version": "0.0.14-alpha.3",
+  "version": "0.0.14-alpha.4",
   "description": "Simple and powerful JSON document database supporting complex queries and flexible indexing policies.",
   "license": "MIT",
   "author": "izure <admin@izure.org>",

src/core/AnalysisManager.ts

@@ -6,7 +6,7 @@ import type {
 import type { DocumentDataplyAPI } from './documentAPI'
 import type { AnalysisProvider } from './AnalysisProvider'
 import { Cron } from 'croner'
-import { Transaction, Logger } from 'dataply'
+import { Transaction, Logger, LoggerManager } from 'dataply'
 import { RealtimeAnalysisProvider } from './RealtimeAnalysisProvider'
 import { IntervalAnalysisProvider } from './IntervalAnalysisProvider'
 import { BuiltinAnalysisProviders } from './analysis'
@@ -16,15 +16,20 @@ export class AnalysisManager<T extends DocumentJSON> {
   private cron: Cron | null = null
   private flushing: boolean = false
 
+  private logger: Logger
+
   constructor(
     private api: DocumentDataplyAPI<T>,
     schedule: string,
     public readonly sampleSize: number,
-    private logger: Logger
+    private loggerManager: LoggerManager
   ) {
+    this.logger = loggerManager.create('document-dataply:analysis')
     this.cron = new Cron(schedule, async () => {
       if (this.flushing) return
       await this.api.flushAnalysis()
+    }, {
+      paused: true
     })
   }
 
@@ -44,7 +49,7 @@ export class AnalysisManager<T extends DocumentJSON> {
    */
   registerBuiltinProviders(): void {
     for (const Provider of BuiltinAnalysisProviders) {
-      const instance = new Provider(this.api)
+      const instance = new Provider(this.api, this.loggerManager)
       this.registerProvider(instance)
     }
   }

src/core/AnalysisProvider.ts

@@ -1,6 +1,6 @@
 import type { DocumentJSON } from '../types'
 import type { DocumentDataplyAPI } from './documentAPI'
-import type { Transaction } from 'dataply'
+import type { Transaction, Logger, LoggerManager } from 'dataply'
 
 /**
  * Abstract base class for analysis providers.
@@ -10,7 +10,15 @@ export abstract class AnalysisProvider<T extends DocumentJSON = DocumentJSON> {
   /** Overflow row PK assigned by AnalysisManager during initialization. */
   storageKey: number = -1
 
-  constructor(protected api: DocumentDataplyAPI<T>) { }
+  private _logger?: Logger
+  protected get logger(): Logger {
+    if (!this._logger) {
+      this._logger = this.loggerManager.create(`document-dataply:analysis:${this.name}`)
+    }
+    return this._logger
+  }
+
+  constructor(protected api: DocumentDataplyAPI<T>, protected loggerManager: LoggerManager) { }
 
   /**
    * Unique name of this analysis type (e.g. 'ftsTermCount').

src/core/analysis/FTSTermCount.ts

@@ -13,6 +13,7 @@ export class FTSTermCount<T extends DocumentJSON = DocumentJSON> extends Interva
   private sampleSize: number = 0
 
   async serialize(tx: Transaction): Promise<string> {
+    this.logger.debug(`Starting serialize`)
     const docs = await this.sample({ count: this.api.analysisManager.sampleSize }, tx)
 
     this.termCount = {}
@@ -78,13 +79,16 @@ export class FTSTermCount<T extends DocumentJSON = DocumentJSON> extends Interva
 
     this.termCount = optimizedTermCount
 
+    this.logger.debug(`Serialize complete, sampleSize: ${this.sampleSize}`)
     return JSON.stringify({ _sampleSize: this.sampleSize, ...this.termCount })
   }
 
   async load(data: string | null, tx: Transaction): Promise<void> {
+    this.logger.debug(`Loading data`)
     this.termCount = {}
     this.sampleSize = 0
     if (!data) {
+      this.logger.debug(`No existing data found, initialized as empty`)
       return
     }
     try {
@@ -94,7 +98,9 @@ export class FTSTermCount<T extends DocumentJSON = DocumentJSON> extends Interva
         this.sampleSize = typeof _sampleSize === 'number' ? _sampleSize : 0
         this.termCount = rest
       }
+      this.logger.debug(`Successfully parsed existing data (sampleSize: ${this.sampleSize})`)
     } catch (e) {
+      this.logger.warn(`Failed to parse existing data`, e)
       // Ignore parse error
     }
   }

src/core/documentAPI.ts

@@ -47,7 +47,7 @@ export class DocumentDataplyAPI<T extends DocumentJSON> extends DataplyAPI {
       this,
       options.analysisSchedule ?? '* */1 * * *',
       options.analysisSampleSize ?? 1000,
-      this.loggerManager.create('document-dataply:analysis')
+      this.loggerManager
     )
 
     this.hook.onceAfter('close', async () => {