package zio.redis.options

import java.net.InetAddress

import zio.duration.Duration

trait Connection {

  sealed abstract class ClientType(val name: String)

  object ClientType {

    case object Master extends ClientType("master")

    case object Normal extends ClientType("normal")

    case object PubSub extends ClientType("pubsub")

    case object Replica extends ClientType("replica")

  }

  sealed trait ClientKillFilter

  object ClientKillFilter {

    sealed case class Address(ip: InetAddress, port: Int) extends ClientKillFilter

    sealed case class LocalAddress(ip: InetAddress, port: Int) extends ClientKillFilter

    sealed case class Id(id: Long) extends ClientKillFilter

    sealed case class Type(clientType: ClientType) extends ClientKillFilter

    sealed case class User(username: String) extends ClientKillFilter

    sealed case class SkipMe(skip: Boolean) extends ClientKillFilter

  }

  sealed trait ClientFlag

  object ClientFlag {
    case object ToBeClosedAsap              extends ClientFlag
    case object Blocked                     extends ClientFlag
    case object ToBeClosedAfterReply        extends ClientFlag
    case object WatchedKeysModified         extends ClientFlag
    case object IsMaster                    extends ClientFlag
    case object MonitorMode                 extends ClientFlag
    case object PubSub                      extends ClientFlag
    case object ReadOnlyMode                extends ClientFlag
    case object Replica                     extends ClientFlag
    case object Unblocked                   extends ClientFlag
    case object UnixDomainSocket            extends ClientFlag
    case object MultiExecContext            extends ClientFlag
    case object KeysTrackingEnabled         extends ClientFlag
    case object TrackingTargetClientInvalid extends ClientFlag
    case object BroadcastTrackingMode       extends ClientFlag
  }

  sealed case class ClientEvents(readable: Boolean = false, writable: Boolean = false)

  sealed case class ClientInfo(
    id: Long,
    name: Option[String] = None,
    address: Option[InetAddress] = None,
    localAddress: Option[InetAddress] = None,
    fileDescriptor: Option[Long] = None,
    age: Option[Duration] = None,
    idle: Option[Duration] = None,
    flags: Set[ClientFlag] = Set.empty,
    databaseId: Option[Long] = None,
    subscriptions: Int = 0,
    patternSubscriptions: Int = 0,
    multiCommands: Int = 0,
    queryBufferLength: Option[Int] = None,
    queryBufferFree: Option[Int] = None,
    outputBufferLength: Option[Int] = None,
    outputListLength: Option[Int] = None,
    outputBufferMem: Option[Long] = None,
    events: ClientEvents = ClientEvents(),
    lastCommand: Option[String] = None,
    argvMemory: Option[Long] = None,
    totalMemory: Option[Long] = None,
    redirectionClientId: Option[Long] = None,
    user: Option[String] = None
  )

  sealed abstract class ClientTrackingRedirect

  object ClientTrackingRedirect {
    case object NotEnabled                         extends ClientTrackingRedirect
    case object NotRedirected                      extends ClientTrackingRedirect
    sealed case class RedirectedTo(clientId: Long) extends ClientTrackingRedirect
  }

  sealed abstract class ClientTrackingMode

  object ClientTrackingMode {
    case object OptIn     extends ClientTrackingMode
    case object OptOut    extends ClientTrackingMode
    case object Broadcast extends ClientTrackingMode
  }

}