Class FileSystemSpecService

src/core/SpecService.ts:39–490

}

export class FileSystemSpecService implements ISpecStore, ISpecExplorer {
  private readonly config: Required<SpecServiceConfig>;
  private readonly logger: Logger;
  private readonly specCache: SimpleCache<string, OpenAPIV3.Document>;
  private readonly folderPath: string;
  private readonly catalogPath: string;
  private readonly dereferencedPath: string;
  private specs: { [specId: string]: OpenAPIV3.Document } = {};
  private catalog: SpecCatalogEntry[] = [];

  constructor(
    private readonly scanner: ISpecScanner,
    config: SpecServiceConfig,
    logger?: Logger
  ) {
    this.config = {
      basePath: config.basePath,
      catalogDir: config.catalogDir || "_catalog",
      dereferencedDir: config.dereferencedDir || "_dereferenced",
      retryAttempts: config.retryAttempts || 3,
      retryDelay: config.retryDelay || 1000,
      cache: {
        maxSize: config.cache?.maxSize || 500,
        ttl: config.cache?.ttl || 60 * 60 * 1000, // 1 hour
      },
    };

    this.logger = logger || new ConsoleLogger();
    this.folderPath = this.config.basePath;
    this.catalogPath = path.join(this.folderPath, this.config.catalogDir);
    this.dereferencedPath = path.join(
      this.folderPath,
      this.config.dereferencedDir
    );

    this.specCache = new SimpleCache<string, OpenAPIV3.Document>({
      maxSize: this.config.cache.maxSize,
      ttl: this.config.cache.ttl,
    });
  }

  private async ensureDirectory(dir: string) {
    try {
      await fs.mkdir(dir, { recursive: true });
    } catch (error) {
      throw new SpecServiceError(
        `Failed to create directory ${dir}`,
        "INIT_ERROR",
        error instanceof Error ? error : new Error(String(error))
      );
    }
  }

  private async ensureDirectories() {
    this.logger.debug("Ensuring required directories exist");
    await Promise.all([
      this.ensureDirectory(this.folderPath),
      this.ensureDirectory(this.catalogPath),