def updateDynamo()

in src/main/scala/com/gu/dynamodbswitches/Switches.scala [36:54]


  def updateDynamo(switches : List[Switch]) = {
    val listWR = switches.map(switch => {
      val putRequest: PutRequest = PutRequest.builder()
        .item(Map("name" -> switch.toStringAttribute(),
          "enabled" -> switch.asAttributeValue(switch.default)).asJava)
        .build()
      val writeRequest: WriteRequest = WriteRequest.builder().putRequest(putRequest).build()
      writeRequest
    }).asJava
    try {
      dynamoDbClient.batchWriteItem(
        BatchWriteItemRequest.builder()
          .requestItems(Map(dynamoDbTableName -> listWR).asJava)
          .build())
    } catch {
      case e: Exception => error(e)
      case _ => warn("Something went wrong")
    }
  }