All files / src/models/inspect csv-inspection.model.ts

90.91% Statements 60/66
78.38% Branches 29/37
100% Functions 8/8
88.24% Lines 45/51

Press n or j to go to the next uncovered block, b, p or k for the previous block.

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129                              9x         9x 9x                 9x     11x 11x   9x 1x                       1x     9x 8x 6x     2x 2x               9x     6x             6x     9x 8x 5x   8x 5x   8x 8x           8x 6x       9x       24x 24x     24x 24x 18x   6x 6x 18x 18x       9x   11x 11x 11x 9x   11x 11x 11x 9x  
/*
    Copyright (C) 2017 Red Hat, Inc.
 
    Licensed under the Apache License, Version 2.0 (the "License");
    you may not use this file except in compliance with the License.
    You may obtain a copy of the License at
 
            http://www.apache.org/licenses/LICENSE-2.0
 
    Unless required by applicable law or agreed to in writing, software
    distributed under the License is distributed on an "AS IS" BASIS,
    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
    See the License for the specific language governing permissions and
    limitations under the License.
*/
import {
  DocumentInspectionModel,
  DocumentInspectionRequestModel,
  DocumentInspectionRequestOptions,
} from './document-inspection.model';
import { ErrorInfo, ErrorLevel, ErrorScope, ErrorType } from '../error.model';
import { FieldType, IDocument } from '../../contracts/common';
import {
  ICsvComplexType,
  ICsvDocumentContainer,
  ICsvField,
  ICsvInspectionResponse,
  ICsvInspectionResponseContainer,
} from '../../contracts/documents/csv';
 
import { CommonUtil } from '../../utils/common-util';
import { Field } from '../field.model';
 
export class CsvInspectionModel extends DocumentInspectionModel {
  request = new CsvInspectionRequestModel(this.cfg, this.doc);
 
  isOnlineInspectionCapable(): boolean {
    Iif (this.cfg.initCfg.baseCSVInspectionServiceUrl == null) {
      this.cfg.errorService.addError(
        new ErrorInfo({
          message: `CSV inspection service is not configured. Document will not be loaded: ${this.doc.name}`,
          level: ErrorLevel.WARN,
          scope: ErrorScope.APPLICATION,
          type: ErrorType.INTERNAL,
          object: this.doc,
        })
      );
      return false;
    }
    return true;
  }
 
  parseResponse(responseJson: any): void {
    if (typeof responseJson.CsvInspectionResponse !== 'undefined') {
      this.extractCSVDocumentDefinitionFromInspectionResponse(
        (responseJson as ICsvInspectionResponseContainer).CsvInspectionResponse
      );
    } else Eif (typeof responseJson.CsvDocument !== 'undefined') {
      this.extractCSVDocumentDefinition(
        (responseJson as ICsvDocumentContainer).CsvDocument
      );
    } else {
      throw new Error(`Unknown CSV inspection result format: ${responseJson}`);
    }
  }
 
  private extractCSVDocumentDefinitionFromInspectionResponse(
    body: ICsvInspectionResponse
  ): void {
    Iif (body.errorMessage) {
      this.doc.errorOccurred = true;
      throw new Error(
        `Could not load JSON document, error: ${body.errorMessage}`
      );
    }
 
    this.extractCSVDocumentDefinition(body.csvDocument);
  }
 
  private extractCSVDocumentDefinition(csvDocument: IDocument): void {
    if (!this.doc.description) {
      this.doc.description = this.doc.id;
    }
    if (!this.doc.name) {
      this.doc.name = this.doc.id;
    }
    Eif (this.doc.inspectionParameters) {
      this.doc.uri = CommonUtil.urlWithParameters(
        this.doc.uri,
        this.doc.inspectionParameters
      );
    }
 
    for (const field of csvDocument.fields.field) {
      this.parseCSVFieldFromDocument(field as ICsvField, null);
    }
  }
 
  private parseCSVFieldFromDocument(
    field: ICsvField,
    parentField: Field | null
  ): void {
    const parsedField = this.parseFieldFromDocument(field, parentField);
    Iif (parsedField == null) {
      return;
    }
    parsedField.column = field.column;
    if (field.fieldType !== FieldType.COMPLEX) {
      return;
    }
    const csvComplexType = field as ICsvComplexType;
    Eif (csvComplexType.csvFields?.csvField?.length) {
      for (const childField of csvComplexType.csvFields.csvField) {
        this.parseCSVFieldFromDocument(childField, parsedField);
      }
    }
  }
}
 
export class CsvInspectionRequestModel extends DocumentInspectionRequestModel {
  url = this.cfg.initCfg.baseCSVInspectionServiceUrl + 'inspect';
  options = new CsvInspectionRequestOptions(this.cfg, this.doc);
}
 
export class CsvInspectionRequestOptions extends DocumentInspectionRequestOptions {
  body = this.doc.inspectionSource;
  searchParams: { [key: string]: string } = this.doc.inspectionParameters;
}