libraryDependencies += "com.twitter" %% "finagle-http" % "21.12.0"

import com.twitter.finagle.Http
import com.twitter.finagle.http.{Request, Response}
import com.twitter.util.{Await, Future}

object TelegramBotClient {
  // 创建HTTP客户端
  private val client = Http.client
    .withTls("api.telegram.org") // 启用TLS并指定目标主机名
    .newService("api.telegram.org:443") // Telegram API的HTTPS端点

  def sendRequest(token: String, method: String, params: Map[String, String]): Future[Response] = {
    // 构建请求URL
    val url = s"/bot$token/$method"
    
    // 创建HTTP GET请求
    val request = Request(url)
    request.method = Method.Get
    
    // 添加查询参数
    val queryParams = params.map { case (k, v) => s"$k=$v" }.mkString("&")
    if (queryParams.nonEmpty) {
      request.uri = s"$url?$queryParams"
    }
    
    // 发送请求
    client(request)
  }
}

import com.twitter.util.Await

object Main extends App {
  val botToken = "YOUR_BOT_TOKEN"
  val chatId = "TARGET_CHAT_ID"
  val text = "Hello from Finagle!"
  
  val response = Await.result(
    TelegramBotClient.sendRequest(
      token = botToken,
      method = "sendMessage",
      params = Map(
        "chat_id" -> chatId,
        "text" -> text
      )
    )
  )
  
  println(response.contentString)
}

import io.circe.parser._
import io.circe.generic.auto._

case class TelegramResponse(ok: Boolean, result: Option[Any], description: Option[String])

def parseResponse(response: Response): Either[Error, TelegramResponse] = {
  parse(response.contentString).flatMap(_.as[TelegramResponse])
}

TelegramBotClient.sendRequest(...)
  .map { response =>
    if (response.status == Status.Ok) {
      println("Request succeeded")
    } else {
      println(s"Request failed: ${response.status}")
    }
  }
  .handle { case ex: Exception =>
    println(s"Request failed with exception: ${ex.getMessage}")
  }

val customizedClient = Http.client
  .withTls("api.telegram.org")
  .withRequestTimeout(5.seconds) // 设置请求超时
  .withSessionPool.maxSize(10)  // 设置连接池大小
  .newService("api.telegram.org:443")