aboutsummaryrefslogtreecommitdiff
path: root/src/app/init.rs
diff options
context:
space:
mode:
authorOxbian <oxbian@mailbox.org>2025-03-02 21:55:42 -0500
committerOxbian <oxbian@mailbox.org>2025-03-02 21:55:42 -0500
commitb9061a3e652cb7594397c38cd0078a47ddab960a (patch)
tree7c98344ea6cf8d35aa1ebdd586d6dd4dd9e4d7ad /src/app/init.rs
parente4eaecc8ce7fb3e84977c41597eff80edd4d73c7 (diff)
downloadNAI-b9061a3e652cb7594397c38cd0078a47ddab960a.tar.gz
NAI-b9061a3e652cb7594397c38cd0078a47ddab960a.zip
fix: readme, screenshot...
Diffstat (limited to 'src/app/init.rs')
-rw-r--r--src/app/init.rs33
1 files changed, 14 insertions, 19 deletions
diff --git a/src/app/init.rs b/src/app/init.rs
index f62b2d0..201e79e 100644
--- a/src/app/init.rs
+++ b/src/app/init.rs
@@ -1,7 +1,7 @@
use crate::app::llm::{Message, MessageType, LLM};
use crate::helper::init::warn;
use uuid::Uuid;
-use tokio;
+use tokio::runtime::Builder;
pub struct App {
pub messages: Vec<Message>, // History of recorded message
@@ -30,14 +30,16 @@ impl App {
self.messages.push(message);
}
- pub fn send_message(&mut self, content: String) {
- self.append_message(content, MessageType::USER);
-
- let runtime = tokio::runtime::Builder::new_current_thread()
+ fn ask(&mut self, mode: &str) {
+ let runtime = Builder::new_current_thread()
.enable_all()
.build().unwrap();
let result = runtime.block_on(async {
- self.chat_llm.ask(&self.messages).await
+ if mode == "resume" {
+ self.resume_llm.ask(&self.messages).await
+ } else {
+ self.chat_llm.ask(&self.messages).await
+ }
});
match result {
@@ -46,20 +48,13 @@ impl App {
}
}
+ pub fn send_message(&mut self, content: String) {
+ self.append_message(content, MessageType::USER);
+ self.ask("chat");
+ }
+
pub fn resume_conv(&mut self) {
self.append_message(self.resume_llm.system_prompt.to_string(), MessageType::USER);
-
- let runtime = tokio::runtime::Builder::new_current_thread()
- .enable_all()
- .build().unwrap();
-
- let result = runtime.block_on(async {
- self.resume_llm.ask(&self.messages).await
- });
-
- match result {
- Ok(msg) => self.append_message(msg, MessageType::ASSISTANT),
- Err(e) => self.append_message(e.to_string(), MessageType::ASSISTANT),
- }
+ self.ask("resume");
}
}
ArKa projects. All rights to me, and your next child right arm.