clean slide uris

gistfile1.scala

package migrations

import global.{ComponentRegistry, DaoRegistry}

import com.amazonaws.services.dynamodbv2.model.AttributeValue
import java.net.URI
import scala.concurrent.Await
import scala.concurrent.duration._

object SlideUriMigration extends DatabaseMigration with DaoRegistry {

  val TableName = "slide"
  private val embedlyUrlCol = "embedlyUrl"

  def execute =
    modifyRows(TableName)(cleanUris)

  private def cleanUris(attributes: Map[String, AttributeValue]): Map[String, AttributeValue] = {
    val uri = attributes.get(embedlyUrlCol).map(_.getS)
    uri map { u =>

      try {
        val url = new URI(u)
        attributes
      } catch {
        case e: Exception => attributes - embedlyUrlCol
      }
    } getOrElse attributes
  }
}