fix: persists engine version on init

Author: louis-jan

cortex-js/src/infrastructure/providers/cortex/cortex.provider.ts

@@ -13,6 +13,7 @@ import { readdirSync } from 'node:fs';
 import { normalizeModelId } from '@/utils/normalize-model-id';
 import { firstValueFrom } from 'rxjs';
 import { FileManagerService } from '@/infrastructure/services/file-manager/file-manager.service';
+import { existsSync, readFileSync } from 'fs';
 
 export interface ModelStatResponse {
   object: string;
@@ -37,6 +38,7 @@ export default class CortexProvider extends OAIEngineExtension {
     protected readonly fileManagerService: FileManagerService,
   ) {
     super(httpService);
+    this.persistEngineVersion();
   }
 
   // Override the inference method to make an inference request to the engine
@@ -165,4 +167,14 @@ export default class CortexProvider extends OAIEngineExtension {
     // Return an error if none of the conditions are met
     return { error: 'Cannot split prompt template' };
   };
+
+  private persistEngineVersion = async () => {
+    const versionFilePath = join(
+      await this.fileManagerService.getCortexCppEnginePath(),
+      this.name,
+      'version.txt',
+    );
+    if (existsSync(versionFilePath))
+      this.version = readFileSync(versionFilePath, 'utf-8');
+  };
 }

cortex-js/src/infrastructure/repositories/extensions/extension.repository.ts

@@ -31,7 +31,7 @@ export class ExtensionRepositoryImpl implements ExtensionRepository {
     // Watch engine folder only for now
     fileService.getCortexCppEnginePath().then((path) => {
       if (!existsSync(path)) mkdirSync(path);
-      watch(path, (eventType, filename) => {
+      watch(path, () => {
         this.extensions.clear();
         this.loadCoreExtensions();
         this.loadExternalExtensions();

cortex-js/src/usecases/engines/engines.usecase.ts

@@ -1,7 +1,7 @@
 import { ForbiddenException, Injectable } from '@nestjs/common';
 import { ExtensionRepository } from '@/domain/repositories/extension.interface';
 
-import { cpSync, existsSync, mkdirSync, readdirSync } from 'fs';
+import { cpSync, existsSync, mkdirSync, readdirSync, writeFileSync } from 'fs';
 import { join } from 'path';
 import { HttpService } from '@nestjs/axios';
 import decompress from 'decompress';
@@ -23,7 +23,7 @@ import { CommonResponseDto } from '@/infrastructure/dtos/common/common-response.
 import { EngineStatus } from '@/domain/abstracts/engine.abstract';
 import { ConfigsUsecases } from '../configs/configs.usecase';
 import { defaultInstallationOptions } from '@/utils/init';
-import { isEmpty } from "lodash"
+import { isEmpty } from 'lodash';
 @Injectable()
 export class EnginesUsecases {
   constructor(
@@ -276,6 +276,7 @@ export class EnginesUsecases {
       engine,
       DownloadType.Engine,
       { [toDownloadAsset.browser_download_url]: destination },
+      // On completed - post processing
       async () => {
         try {
           await decompress(destination, engineDir);
@@ -288,9 +289,15 @@ export class EnginesUsecases {
         // Copy the additional files to the cortex-cpp directory
         for (const file of readdirSync(join(engineDir, engine))) {
           if (!file.includes('engine')) {
-            await cpSync(join(engineDir, engine, file), join(engineDir, file));
+            cpSync(join(engineDir, engine, file), join(engineDir, file));
           }
         }
+
+        writeFileSync(
+          join(engineDir, engine, 'version.txt'),
+          release.tag_name.replace(/^v/, ''),
+          'utf-8',
+        );
       },
     );
   }