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")
}
}