Hotfix/cache

packages/core/lib/cache/drivers/inMemory.ts

@@ -11,8 +11,13 @@ export class InMemoryDriver implements CacheDriver {
 
   async get<T>(key: string): Promise<T> {
     await this.initialiseModules();
-    const cacheKey = `${this.options.prefix}:::${key}`;
-    return this.client.get(cacheKey);
+    const value = await this.client.get(`${this.options.prefix}:::${key}`);
+    if (!value) return null;
+    try {
+      return JSON.parse(value);
+    } catch (e) {
+      return value;
+    }
   }
 
   async set(

packages/core/lib/console/inquirer.ts

@@ -11,7 +11,6 @@ export class Inquirer {
     const answers = await prompt([
       { name: 'question', message: question, type: 'input' },
     ]);
-    console.log(answers);
     return answers['question'];
   }
 

packages/core/lib/mailer/providers/mailgun.ts

@@ -41,8 +41,6 @@ export class MailgunProvider implements BaseProvider {
       })),
     });
 
-    console.log(report);
-
     return;
   }
 

packages/core/lib/rest/http-server/route-explorer.ts

@@ -99,9 +99,6 @@ export class RouteExplorer {
 
     if (!pathMethod) return;
 
-    console.log(instance.constructor);
-    console.log(controllerKey, methodPath, pathMethod, key);
-
     const fullHttpPath = joinRoute(controllerKey, methodPath);
     return { method: pathMethod, path: fullHttpPath };
   }

packages/core/lib/scheduler/index.ts

@@ -1,5 +1,4 @@
 export * from './metadata.js';
-export * from './worker.js';
 export * from './decorator.js';
 export * from './schedule.js';
 export * from './frequency.js';

packages/core/lib/scheduler/metadata.ts

@@ -18,7 +18,6 @@ export class SchedulerRegistry {
 
     options?.name && schedule.name(options.name);
     schedule.cron(cronExpression);
-    console.log(this.schedules);
   }
 
   static register(name: string, schedule: Schedule): void {

packages/core/lib/storage/drivers/s3Storage.ts

@@ -29,12 +29,10 @@ export class S3Storage implements StorageDriver {
   }
 
   getStream(filePath: string): ReadStream {
-    console.log('file path ===> ', filePath);
     throw new Error('Method not implemented.');
   }
 
   listDir(path: string): Promise<Record<string, any>> {
-    console.log(path);
     throw new Error('Method not implemented.');
   }
 
@@ -293,7 +291,6 @@ export class S3Storage implements StorageDriver {
     params?: Record<string, any>,
   ): Promise<string> {
     this.initialiseModules();
-    console.log(path, ttlInMins, params);
     throw new Error('Method not implemented.');
   }
 

packages/core/lib/utils/object.ts

@@ -149,9 +149,7 @@ export class Obj {
 
   static hash(obj: Record<string, any>): string {
     const sortedObj = this.sort(obj);
-    console.log(sortedObj);
     const jsonString = JSON.stringify(sortedObj);
-    console.log(jsonString);
     return '';
   }
 

packages/core/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@intentjs/core",
-  "version": "0.1.59",
+  "version": "0.1.60",
   "description": "Core module for Intent",
   "repository": {
     "type": "git",