class ChatHub[F[_]] private(
                             val topic: Topic[F, WebSocketFrame],
                             private val ref: Ref[F, Int]
                           )
                           (
                             implicit concurrent: Concurrent[F],
                             timer: Timer[F]
                           ) extends Http4sDsl[F] {
  val endpointWs: ServerEndpoint[String, Unit, String, Stream[IO, WebSocketFrame], IO] = endpoint
    .get
    .in("chat")
    .tag("WebSockets")
    .summary("Подключится к общему чату. Например по такому адресу: ws://localhost:8080/chat")
    .description("Подключает к общему чату")
    .in(
      stringBody
        .description("Сообщение которое будет отправлено пользователям в чате")
        .example("Привет!")
    )
    .out(
      stringBody
        .description("Сообщение которое кто-то написал в чат")
        .example("6 : Сообщение от клиента с Id подключения f518a53d: Привет!")
    )
    //Заглушка которая всегда отвечает ошибкой.
    .serverLogic(_ => IO(Left(()): Either[Unit, String]))
  def routeWs: HttpRoutes[F] = {
    HttpRoutes.of[F] {
      case GET -> Root / "chat" => logic()
    }
  }
  private def logic(): F[Response[F]] = {
    val toClient: Stream[F, WebSocketFrame] =
      topic.subscribe(1000)
    val fromClient: Pipe[F, WebSocketFrame, Unit] =
      handle
    WebSocketBuilder[F].build(toClient, fromClient)
  }
  private def handle(s: Stream[F, WebSocketFrame]): Stream[F, Unit] = s
    .collect({
      case WebSocketFrame.Text(text, _) => text
    })
    .evalMap(text => ref.modify(count => (count + 1, WebSocketFrame.Text(s"${count + 1} : $text"))))
    .through(topic.publish)
}
object ChatHub {
  def apply[F[_]]()(implicit concurrent: Concurrent[F], timer: Timer[F]): F[ChatHub[F]] = for {
    ref <- Ref.of[F, Int](0)
    topic <- Topic[F, WebSocketFrame](WebSocketFrame.Text("==="))
  } yield new ChatHub(topic, ref)
}

val topic: Topic[F, WebSocketFrame],

private val ref: Ref[F, Int]

private def handle(stream: Stream[F, WebSocketFrame]): Stream[F, Unit] =
    stream
//Достаем из фрейма текстовое сообщение и фильтруем фреймы.
    .collect({
      case WebSocketFrame.Text(text, _) => text
    })
//Атомарно увеличиваем наш счетчик с сохранением нового значения и добавления его значения к тексту сообщения пользователя.
    .evalMap(text => ref.modify(count => (count + 1, WebSocketFrame.Text(s"${count + 1} : $text"))))
//Каждое пришедшее сообщение отправляем в топик
    .through(topic.publish)

private def logic(): F[Response[F]] = {
//Откуда получать данные для клиента.
    val toClient: Stream[F, WebSocketFrame] =
//Просто подписываемся на данные которые будут приходить в топик
      topic.subscribe(1000)
//Что будем делать с данными которые приходить от клиента
    val fromClient: Pipe[F, WebSocketFrame, Unit] =
//Просто отправляем данные в топик после обработки
      handle
//Создаем веб сокет с созданными ранее генератором и потребителем данных.
    WebSocketBuilder[F].build(toClient, fromClient)
  }

def routeWs: HttpRoutes[F] = {
    HttpRoutes.of[F] {
      case GET -> Root / "chat" => logic()
    }
  }

val endpointWs: Endpoint[String, Unit, String, fs2.Stream[F, Byte]] = endpoint
    .get
    .in("chat")
    .tag("WebSockets")
    .summary("Подключится к общему чату. Например по такому адресу: ws://localhost:8080/chat")
    .description("Подключает к общему чату")
    .in(
      stringBody
        .description("Сообщение которое будет отправлено пользователям в чате")
        .example("Привет!")
    )
    .out(
      stringBody
        .description("Сообщение которое кто-то написал в чат")
        .example("6 : Сообщение от клиента с Id подключения f518a53d: Привет!")
    )

todosController = new TodosController()
    imagesController = new ImagesController()
//Создаем объект нашего чата
    chatHub <- Resource.liftF(ChatHub[IO]())
    endpoints = todosController.endpoints ::: imagesController.endpoints
//Добавляем его эндпойнт в документацию Swagger
    docs = (chatHub.endpointWs :: endpoints).toOpenAPI("The Scala Todo List", "0.0.1")
    yml: String = docs.toYaml
//Добавляем его маршрут в список маршрутов приложения
    routes = chatHub.routeWs <+>
      endpoints.toRoutes <+>
      new SwaggerHttp4s(yml, "swagger").routes[IO]
    httpApp = Router(
      "/" -> routes
    ).orNotFound
    blazeServer <- BlazeServerBuilder[IO](serverEc)
      .bindHttp(settings.host.port, settings.host.host)
      .withHttpApp(httpApp)
      .resource

<script>
        const id = `f${(~~(Math.random() * 1e8)).toString(16)}`;
        const webSocket = new WebSocket('ws://localhost:8080/chat');
        webSocket.onopen = event => {
            alert('onopen ');
        };
        webSocket.onmessage = event => {
            console.log(event);
            receive(event.data);
        };
        webSocket.onclose = event => {
            alert('onclose ');
        };
        function send() {
            let text = document.getElementById("message");
            webSocket.send(`Сообщение от клиента с Id подключения ${id}: ${text.value}`);
            text.value = '';
        }
        function receive(m) {
            let text = document.getElementById("chat");
            text.value = text.value + '\n\r' + m;
        }
    </script>