JSON Schema Validation

validate.scala

def getSchemaRef(event: JSONObject): String = {
  JsonObjectFields.getSchemaRef(event, defaultSchema)
} 
 
def validateEvent(schema: Schema, event: JSONObject): ValidationResult[JSONObject] = {
  val validationListener: SchemaValidationListener = SchemaValidationListener()
  val validator: Validator = Validator
    .builder
    .withListener(validationListener)
    .build()
 
  validator.performValidation(schema, event)
 
  val schemasReferenced: Seq[SchemaReferenced] = validationListener
    .schemasReferencedMatching
    .distinct
 
  ValidationResult(event, schemasReferenced)
}
 
def validateEvent(event: JSONObject): ValidationResult[JSONObject] = {
  val schemaRef = getSchemaRef(event)
  val schema: Schema = Try(schemaCache.get(schemaRef)).recover {
    case _: Exception =>
      logger.error(s"Error loading schema [$schemaRef]")
      throw SchemaNotFoundException(schemaRef)
  }.get
  validateEvent(schema, event)
}