//设置package包名称以及导入依赖的类
package bloomfilter.hashing

import java.nio.ByteBuffer

import sandbox.hashing.{YonikMurmurHash3, CassandraMurmurHash, AlgebirdMurmurHash128}
import sandbox.hashing.YonikMurmurHash3.LongPair
import com.yahoo.sketches.hash.{MurmurHash3 => yMurmurHash3}
import com.google.common.hash.Hashing
import org.openjdk.jmh.annotations.{Benchmark, Scope, State}
import scala.util.hashing.{MurmurHash3 => ScalaMurmurHash3}
import com.clearspring.analytics.hash.{MurmurHash => StreamLibMurmurHash}

@State(Scope.Benchmark)
class MurmurHash3Benchmark {

  val key = Range(0, 64).map(_.toByte).toArray

  @Benchmark
  def javaVersion() = {
    YonikMurmurHash3.murmurhash3_x64_128(key, 0, key.length, 0, new LongPair)
  }

  @Benchmark
  def scalaVersion() = {
    MurmurHash3Generic.murmurhash3_x64_128(key, 0, key.length, 0)
  }

  val guavaMurmur = Hashing.murmur3_128()

  @Benchmark
  def guavaVersion() = {
    guavaMurmur.hashBytes(key, 0, key.length)
  }

  @Benchmark
  def cassandraVersion() = {
    CassandraMurmurHash.hash3_x64_128(ByteBuffer.wrap(key), 0, key.length, 0)
  }

  val algebirdMurmur = AlgebirdMurmurHash128(0)

  @Benchmark
  def algebirdVersion() = {
    algebirdMurmur.apply(key)
  }

  @Benchmark
  def yahooVersion() = {
    yMurmurHash3.hash(key, 0)
  }

  @Benchmark
  def scalaStdlibVersion() = {
    ScalaMurmurHash3.arrayHash(key, 0)
  }

  @Benchmark
  def streamLibVersion() = {
    StreamLibMurmurHash.hash(key)
  }
} 

//设置package包名称以及导入依赖的类
package services

import java.nio.charset.StandardCharsets
import javax.inject.Inject

import com.google.common.hash.Hashing
import com.google.inject.ImplementedBy
import daos.LinkDao
import models.Link


@ImplementedBy(classOf[LinkServiceImpl])
trait LinkService {
  def read(shortUrl: String): Option[Link]
  def read(id: Long): Option[Link]
  def incrementViews(link: Link): Link
  def save(link: Link): Link
  def simplify(link: Link): Link
  def checkOrSimplify(link: Link): Link
}

class LinkServiceImpl @Inject()(linkDao: LinkDao) extends LinkService {

  def read(shortUrl: String): Option[Link] =
    Option.apply(linkDao.read(shortUrl))

  def read(id: Long): Option[Link] =
    Option.apply(linkDao.read(id))

  def incrementViews(link: Link): Link = {
    val updatedLink = Link(link.id, link.url, link.shortUrl, link.views + 1)
    linkDao.update(updatedLink)
  }

  def save(link: Link): Link = {
    val simplified: Link = if (link.shortUrl == null) simplify(link) else checkOrSimplify(link)
    val linkFromDb: Option[Link] = read(simplified.shortUrl)
    if (linkFromDb.nonEmpty) linkFromDb.get
    else linkDao.save(simplified)
  }

  def simplify(link: Link): Link = {
    require(link.url != null)
    val builder = new StringBuilder
    builder append Hashing.murmur3_32().hashString(link.url, StandardCharsets.UTF_8).toString
    Link(link.id, link.url, builder.toString, link.views)
  }

  def checkOrSimplify(link: Link): Link = {
    if (linkDao.read(link.shortUrl) != null) simplify(link)
    else link
  }
}