package lila.socket

import play.api.libs.json._
import scala.concurrent.Promise
import ornicar.scalalib.Zero

object Socket extends Socket {

  case class Sri(value: String) extends AnyVal with StringValue

  val sriIso             = lila.common.Iso.string[Sri](Sri.apply, _.value)
  implicit val sriFormat = lila.common.Json.stringIsoFormat(sriIso)

  case class Sris(sris: Set[Sri])

  case class SocketVersion(value: Int) extends AnyVal with IntValue with Ordered[SocketVersion] {
    def compare(other: SocketVersion) = Integer.compare(value, other.value)
    def inc                           = SocketVersion(value + 1)
  }

  val socketVersionIso             = lila.common.Iso.int[SocketVersion](SocketVersion.apply, _.value)
  implicit val socketVersionFormat = lila.common.Json.intIsoFormat(socketVersionIso)
  implicit val socketVersionZero   = Zero.instance[SocketVersion](SocketVersion(0))

  case class GetVersion(promise: Promise[SocketVersion])

  case class SendToFlag(flag: String, message: JsObject)
}

private[socket] trait Socket {

  def makeMessage[A](t: String, data: A)(implicit writes: Writes[A]): JsObject =
    JsObject(new Map.Map2("t", JsString(t), "d", writes.writes(data)))

  def makeMessage(t: String): JsObject = JsObject(new Map.Map1("t", JsString(t)))
}