From 6770f6f32ec72b2140d6f5696ca92d9296393589 Mon Sep 17 00:00:00 2001
From: lunaticbum <lunaticbum@gmail.com>
Date: Thu, 6 Mar 2025 18:32:56 +0900
Subject: [PATCH] ...

---
 .../kr/lunaticbum/back/lun/service/Lama.kt    | 30 ++++++++++++++++++-
 1 file changed, 29 insertions(+), 1 deletion(-)

diff --git a/src/main/kotlin/kr/lunaticbum/back/lun/service/Lama.kt b/src/main/kotlin/kr/lunaticbum/back/lun/service/Lama.kt
index f37294c..c3efd0b 100644
--- a/src/main/kotlin/kr/lunaticbum/back/lun/service/Lama.kt
+++ b/src/main/kotlin/kr/lunaticbum/back/lun/service/Lama.kt
@@ -5,7 +5,13 @@ package kr.lunaticbum.back.lun.service
 import com.google.gson.Gson
 import com.knuddels.jtokkit.api.IntArrayList
 import io.micrometer.observation.ObservationRegistry
+import kotlinx.coroutines.CoroutineScope
+import kotlinx.coroutines.Dispatchers
+import kotlinx.coroutines.launch
 import kr.lunaticbum.back.lun.configs.GlobalEnvironment
+import kr.lunaticbum.back.lun.controllers.BumlamaResp
+import kr.lunaticbum.back.lun.controllers.TelegramSendMsg
+import kr.lunaticbum.back.lun.controllers.lamaGenerated
 import kr.lunaticbum.back.lun.model.*
 import org.jsoup.Jsoup
 import org.springframework.ai.embedding.EmbeddingRequest
@@ -88,7 +94,7 @@ class Lama {
                     it.originQuery = query
                     val data = Gson().toJson(it)
                     println(it.title)
-                    Jsoup.connect(it.url).get().body().text()?.let { text ->
+                    Jsoup.connect(it.url).get().html().let { text ->
                         try {
                             println("text >>>>> $text")
                             it.pageData = chatClient.chat(OllamaApi.ChatRequest.Builder("phi4:14b").stream(false).format("json").messages(
@@ -214,6 +220,28 @@ class Lama {
                 ).build())
             }
             println(response.message.content)
+//            val fullUrl = "https://api.telegram.org/${globalEvv.telegramBotKey}/sendMessage?chat_id=${globalEvv.telegramMyId}&text=${query}의 대답이 도착했어요.\n\n${response.message.content}"
+            CoroutineScope(Dispatchers.IO).launch {
+                var toalmsg = "${query}의 대답이 도착했어요.\n" + "${response.message.content}"
+                val fullUrl = "https://api.telegram.org/${globalEvv.telegramBotKey}/sendMessage"
+                toalmsg.chunked(2048).forEach { chunkedMsg ->
+                    println("fullUrl >>> ${fullUrl}")
+                    (targetId ?: globalEvv.telegramMyId)?.let {
+                        var tlgSend = TelegramSendMsg(it, chunkedMsg)
+                        WebClient
+                            .create()
+                            .post()
+                            .uri(fullUrl)
+                            .body(BodyInserters.fromValue(Gson().toJson(tlgSend)))
+                            .retrieve().bodyToMono(String::class.java).timeout(Duration.ofMinutes(20L))
+                            .block()?.let { result ->
+
+                            }
+                    }
+                }
+            }
+
+
             println("On generateResponse :: END OF Answer")
         }
     }