Method installModel

core/llm/llms/Docker.ts:164–215

(
    modelName: string,
    signal: AbortSignal,
    progressReporter?: (task: string, increment: number, total: number) => void,
  )

  }

  async installModel(
    modelName: string,
    signal: AbortSignal,
    progressReporter?: (task: string, increment: number, total: number) => void,
  ): Promise<any> {
    const targetModel = this.modelMap[modelName] || modelName;

    const release = await Docker.modelsBeingInstalledMutex.acquire();
    try {
      if (Docker.modelsBeingInstalled.has(modelName)) {
        throw new Error(`Model '${modelName}' is already being installed.`);
      }
      Docker.modelsBeingInstalled.add(modelName);
    } finally {
      release();
    }

    try {
      // Report starting the installation
      progressReporter?.(`Installing Docker model ${targetModel}`, 0, 100);

      // Pull the model
      const { stdout, stderr } = await this.executeDockerCommand(
        ["model", "pull", targetModel],
        signal,
      );

      // Report completion
      progressReporter?.(
        `Docker model ${targetModel} installed successfully`,
        100,
        100,
      );

      return { success: true, stdout, stderr };
    } catch (error) {
      console.error(`Failed to install Docker model ${targetModel}:`, error);
      // Fix: Type check the error before accessing message property
      const errorMessage =
        error instanceof Error ? error.message : String(error);
      throw new Error(
        `Failed to install Docker model ${targetModel}: ${errorMessage}`,
      );
    } finally {
      const release = await Docker.modelsBeingInstalledMutex.acquire();
      try {
        Docker.modelsBeingInstalled.delete(modelName);
      } finally {
        release();
      }
    }
  }

  public async isInstallingModel(modelName: string): Promise<boolean> {
    const release = await Docker.modelsBeingInstalledMutex.acquire();