Method scanAndSave

src/core/SpecService.ts:150–240

(folderPath: string)

  }

  async scanAndSave(folderPath: string): Promise<void> {
    this.logger.debug({ folderPath }, "Starting scan and persist operation");
    const tempCatalog: SpecCatalogEntry[] = [];
    const pendingOperations: Array<{
      spec: OpenAPIV3.Document;
      entry: SpecCatalogEntry;
    }> = [];

    try {
      for await (const scanResult of this.scanner.scan(folderPath)) {
        const { filename, spec, specId, error } = scanResult;

        if (error) {
          this.logger.warn({ filename, error }, "Error scanning file");
          continue;
        }

        try {
          const operations: SpecOperationEntry[] = [];
          const schemas: SpecSchemaEntry[] = [];

          // Extract operations
          for (const path in spec.paths) {
            const pathItem = spec.paths[path];
            for (const method in pathItem) {
              if (method === "parameters" || method === "$ref") continue;
              const operation = pathItem[method] as OpenAPIV3.OperationObject;
              operations.push({
                path,
                method,
                description: operation.description,
                operationId: operation.operationId,
              });
            }
          }

          // Extract schemas
          if (spec.components?.schemas) {
            for (const [name, schema] of Object.entries(
              spec.components.schemas
            )) {
              schemas.push({
                name,
                description: (schema as OpenAPIV3.SchemaObject).description,
              });
            }
          }

          const entry: SpecCatalogEntry = {
            uri: {
              specId,
              type: "specification",
              identifier: specId,
            },
            description: spec.info.description,
            operations,
            schemas,
          };