Skip to content
Snippets Groups Projects
Commit ac67dbf7 authored by Jozsef Barcza's avatar Jozsef Barcza
Browse files

datetime validation

parent 302785b4
No related branches found
No related tags found
6 merge requests!130integer data type,!120integer data type,!119Develop to main M25,!117Develop to main M25,!110Feature/date time typo,!109Feature/fix datetime validation
Pipeline #289980 failed
......@@ -129,13 +129,13 @@ object ValidationUtil extends LogF {
} else {
logger.info(s"received data points1: ${timeSeries.timeSeriesDateTime}")
logger.info(s"received data points2: ${timeSeries.timeSeriesDateTime.get.points}")
val isIsoDateTime = timeSeries.timeSeriesDateTime.get.points.foldLeft(true) { (valid, point) =>
val p = point.value.asInstanceOf[String]
valid & Try(ZonedDateTime.parse(p)).isSuccess
val inValidDateTimes = timeSeries.timeSeriesDateTime.get.points.foldLeft(List.empty[String]) { (inValid, point) =>
val pValue = point.value.asInstanceOf[String]
if Try(ZonedDateTime.parse(pValue)).isSuccess then inValid else pValue :: inValid
}
if (!isIsoDateTime) {
Future(Bad(ErrorMessageResponse(StatusCodes.BadRequest.intValue, StatusCodes.BadRequest.reason, WriteBackServiceMessages.createMessage(WriteBackServiceMessages.invalidDataTypeISODateTime, timeSeries.timeSeriesDateTime.get.points.map(_.value).mkString(", "), "timeSeriesDateTime"))))
if (!inValidDateTimes.isEmpty) {
Future(Bad(ErrorMessageResponse(StatusCodes.BadRequest.intValue, StatusCodes.BadRequest.reason, WriteBackServiceMessages.createMessage(WriteBackServiceMessages.invalidDataTypeISODateTime, inValidDateTimes.mkString(", "), "timeSeriesDateTime"))))
} else {
// val invalidDataPoints = validateDataFormat("timeSeriesDateTime", timeSeries.timeSeriesDateTime.get.points)
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment