def getAuditsForChannelTest()

in app/services/DynamoChannelTestsAudit.scala [103:118]


  def getAuditsForChannelTest(channel: String, name: String): ZIO[ZEnv, DynamoError, List[ChannelTestAudit[ChannelTest[_]]]] = {
    val channelAndName = s"${channel}_$name"

    getAuditsFromDynamo(channelAndName).map { results =>
      results.asScala
        .map(item => dynamoMapToJson(item).as[ChannelTestAudit[ChannelTest[_]]])
        .flatMap {
          case Right(audit) => Some(audit)
          case Left(error) =>
            logger.error(s"Failed to decode audit item from Dynamo: ${error.getMessage}")
            None
        }
        .toList
        .sortBy(_.timestamp)
    }
  }