refactor: add extra logging

Author: lucien martijn

src/worker.ts

@@ -18,6 +18,7 @@ import {
 } from './util'
 import { DateTimeFormatSettings, SerializeableUri } from './types'
 import * as constants from './constants'
+import { getLogger } from './logger'
 
 if (!parentPort) {
     throw new Error('InvalidWorker')
@@ -44,6 +45,7 @@ class QueryHelper {
     }
 
     async getPage(message: any) {
+        getLogger().info(`QueryHelper.getPage()`)
         let query: QueryObject = {
             pageSize: message.pageSize,
             pageNumber: message.pageNumber,
@@ -77,6 +79,7 @@ class QueryHelper {
     }
 
     async query(queryObject: QueryObject) {
+        getLogger().info(`QueryHelper.query()`)
         let query = this.formatQueryString(queryObject.queryString)
 
         await this.backend.query(
@@ -122,6 +125,7 @@ class QueryHelper {
     }
 
     async search(message: any) {
+        getLogger().info(`QueryHelper.search()`)
         let schemaQuery = `
         SELECT * FROM ${this.tableName}
         `
@@ -184,6 +188,7 @@ class QueryHelper {
     }
 
     private async createEmptyExcelFile(filePath: string) {
+        getLogger().info(`QueryHelper.createEmptyExcelFile()`)
         const workbook = new exceljs.Workbook()
         workbook.addWorksheet('Sheet1')
 
@@ -207,6 +212,7 @@ class QueryHelper {
     }
 
     async export(message: any) {
+        getLogger().info(`QueryHelper.export()`)
         const exportType = message.exportType
         const savedPath = message.savedPath
 
@@ -341,6 +347,7 @@ export class BackendWorker {
         serializeableUri: SerializeableUri,
         dateTimeFormatSettings: DateTimeFormatSettings
     ) {
+        getLogger().info(`BackendWorker.create()`)
         const path = `${serializeableUri.scheme}://${serializeableUri.path}`
         const uri = URI.parse(path, true)
         const backend = await DuckDBBackend.createAsync(
@@ -353,6 +360,7 @@ export class BackendWorker {
     }
 
     public exit(): void {
+        getLogger().info(`BackendWorker.exit()`)
         return process.exit()
     }
 
@@ -384,6 +392,7 @@ export class BackendWorker {
     }
 
     async search(message: any) {
+        getLogger().info(`BackendWorker.search()`)
         const { headers, result, rowCount } =
             await this.queryHelper.search(message)
 
@@ -406,6 +415,7 @@ export class BackendWorker {
     }
 
     async getPage(message: any) {
+        getLogger().info(`BackendWorker.getPage()`)
         const { headers, result, rowCount } =
             await this.queryHelper.getPage(message)
 
@@ -422,6 +432,7 @@ export class BackendWorker {
     }
 
     async export(message: any) {
+        getLogger().info(`BackendWorker.export()`)
         const exportPath = await this.queryHelper.export(message)
         return {
             type: 'exportQueryResults',