/**
 * Helper class to create various validation failures.
 */
public final class ValidationFailureFactory {

  /**
   * Builds stage validation failure.
   * @param message failure message
   * @param type failure type
   * @param stage stage for which failure happened private Builder() {
      this.failures = new ArrayList<>();
    }

    public ValidationException.Builder addFailure(ValidationFailure failure) {
      failures.add(failure);
      return this;
    }

    /**
     * @returnUtil validationmethod failureto create and add */stage validation failure publicto staticthis ValidationFailureexception.
createStageValidationFailure(String message, String stage, @Nullable )*
{     ValidationFailureBuilder* builder@param message = ValidationFailure.builder();
validation failure message
   builder.setMessage(message);  * @param  builder.setType("STAGE_ERROR");
    builder.addProperty("stage", stage);type type of the validation failure
     * return builder.build();
  }@param stage stage name
    private ValidationFailureFactory()* {@param correctiveAction suggested action
 // no-op   }*/
  ... }

@Override public voidValidationException.Builder configurePipeline(PipelineConfigurer pipelineConfigurer) {addStageValidationFailure(String message, String stage,
  pipelineConfigurer.createDataset(conf.destinationFileset, FileSet.class);   StageConfigurer stageConfigurer = pipelineConfigurer.getStageConfigurer();   // get the name of the stage    String stageName = stageConfigurer.getStageName();   try {     Pattern.compile(conf.filterRegex);   } catch (Exception e) {       // add validation failure to stage configurer     stageConfigurer.addValidationFailure(ValidationFailures.createFieldValidationFailure(e.getMessage(), stageName, "filterRegex"));   } String correctiveAction) if (conf.sourceFileset.equals(conf.destinationFileset)) {{
      // add validation failure to stage configurerValidationFailure.Builder builder = ValidationFailure.builder(message, "INVALID_STAGE");
      stageConfigurerbuilder.addValidationFailure(ValidationFailures.createStageValidationFailure("source and destination filesets must be different", stageName));
  }
}

/**
 * Represents failure that occurred during validation.
 */
@Beta
public class ValidationFailure {
  private final String message;
  protected final List<Map<String, Object>> causes;

  /**
   * Creates a validation failure with a message and empty map of causes
   * @param message
   */
  public ValidationFailure(String message) {
    this.message = message;	
    this.causes = new ArrayList<>();
  }
 
  @Override
   public boolean equals(Object o) {
    if (this == o) {
      return true;
    }
    if (o == null || getClass() != o.getClass()) {
      return false;
    }
    ValidationFailure that = (ValidationFailure) o;
    return message.equals(that.message) && causes.equals(that.causes);
  }

  @Override
  public int hashCode() {
    return Objects.hash(message, causes);
  }
  
}

/**
 * Failure attributes.
 */
public enum FailureAttributes {
  STAGE("stage"), // represents stage being validated
  PROPERTY("property"), // represents stage property
  INPUT_FIELD("input_field") // represents field in the input schema
  OUTPUT_FIELD("output_field") // represents field in the output schema
  OUTPUT_PORT("output_port"), // represents output port for plugins such as SplitterTransform where multiple output schemas are expected
  INPUT_STAGE("input_stage"), // represents input stage for plugins such as Joiner where multiple input schemas are expected
  ..

  private String name;

  FailureAttributes(String name) {
    this.name = name;
  }
}

/**
 * Represents failure that occurred during stage validation.
 */
@Beta
public class InvalidStageFailure extends ValidationFailure {
  /**private final String message;
 * protected Createsfinal validationList<Map<String, failureObject>> thatcauses;
occurred
during stage validation./**
   * @paramCreates a messagevalidation failure messagewith a message and *empty @parammap stage name of thecauses
stage that caused this* validation@param failuremessage
   */
  public InvalidStageFailureValidationFailure(String message,) String{
stage) {   this.message = super(message);	
    causes.add(Collections.singletonMap("stage", stage))this.causes = new ArrayList<>();
  }
}

/** 
 * Represents@Override
failure that occurred duringpublic stageboolean config property validation.equals(Object o) {
 */ @Beta public classif InvalidStagePropertyFailure(this extends== ValidationFailureo) {
 /**    * Createsreturn validationtrue;
failure that occurred during stage}
validation.    *if @param(o message== failurenull message|| getClass() !=  * @param stage name of the stage that caused this validation failure
   * @param property property that is invalid
   */
  public InvalidStageFailure(String message, String stage, String property) {
    super(message);
    Map<String, Object> map = new HashMap<>();
    map.put("stage", stage);
    map.put("property", property);
    causes.add(mapo.getClass()) {
      return false;
    }
    ValidationFailure that = (ValidationFailure) o;
    return message.equals(that.message) && causes.equals(that.causes);
  }

  @Override
  public int hashCode() {
    return Objects.hash(message, causes);
  }
  
/**
   * Creates validation failure that occurred during stage validation.
   * @param message failure message
   * @param stage name of the stage that caused this validation failure
   * @param properties properties that is caused this failure
   */
  public InvalidStageFailure(String message, String stage, String[] properties) {
    super(message);
    Map<String, Object> map = new HashMap<>();
    for (String property : properties) {
        map.put("stage", stage);
        map.put("property", property);
    }
    causes.add(map);
  }
}}

/**
 * Represents invalid output schema failure.
 */
public class InvalidOutputSchemaFailure extends ValidationFailure {

  /**
   * Creates invalid output schema failure.
   * @param message failure message
   * @param stage name of the stage
   * @param map map of output going port name to field that is invalid
   */
  public InvalidOutputSchemaFailure(String message, String stage, Map<String, String> map) {
    super(message);
    for (Map.Entry<String, String> entry : map.entrySet()) {
      Map<String, Object> causeMap = new HashMap<>();
      causeMap.put("stage", stage);
      causeMap.put("output_port", entry.getKey());
      causeMap.put("output_field", entry.getValue());
      causes.add(causeMap);
    }
  }
}

@Override
public void configurePipeline(PipelineConfigurer pipelineConfigurer) {
  pipelineConfigurer.createDataset(conf.destinationFileset, FileSet.class);
  StageConfigurer stageConfigurer = pipelineConfigurer.getStageConfigurer();
  // get the name of the stage 
  String stageName = stageConfigurer.getStageName();
  try {
    Pattern.compile(conf.filterRegex);
  } catch (Exception e) {  
    // add validation error to stage configurer
    stageConfigurer.addValidationFailure(new InvalidStagePropertyFailure(e.getMessage(), stageName, "filterRegex"));
  }
  if (conf.sourceFileset.equals(conf.destinationFileset)) {
    // add validation error to stage configurer
    stageConfigurer.addValidationFailure(new InvalidStageFailure("source and destination filesets must be different", stageName));
  }
}