0.13.0

.env.example

@@ -1,5 +1,10 @@
 BOT_TOKEN=
 GEMINI_API_KEY=
-OWNERS=701733705, 6452350296
-MONGODB_URL=
-RUST_LOG=info
+COBALT_API_KEY=
+OWNERS=701733705,6452350296
+LOG_CHAT_ID=
+ERROR_CHAT_THREAD_ID=0
+WARN_CHAT_THREAD_ID=0
+MONGODB_URL=mongodb://localhost:27017
+RUST_LOG=info
+REDIS_URL=redis://127.0.0.1:6379

Cargo.toml

@@ -22,3 +22,12 @@ async-trait = "0.1.88"
 log = "0.4.27"
 pretty_env_logger = "0.5.0"
 uuid = { version = "1.17.0", features = ["v4"] }
+ccobalt = { git = "https://github.com/fulturate/ccobalt.git" }
+translators = { version = "0.1.5", features = ["google", "tokio-async"] }
+redis = { version = "0.32.5", features = ["tokio-comp"] }
+redis-macros = { version = "0.5.6" }
+url = "2.5.4"
+base64 = "0.22.1"
+mime = "0.3.17"
+md5 = "0.7.0"
+futures = "0.3.31"

LICENSE

@@ -1,4 +1,4 @@
-Copyright (c) 2012-2025 Weever (Weever1337)
+Copyright (c) 2012-2025 Fulturate
 
 Permission is hereby granted, free of charge, to any person obtaining
 a copy of this software and associated documentation files (the

README.md

@@ -1,29 +1,19 @@
 <div align="center">
   <img src="https://weever.my/_next/image?url=https%3A%2F%2Fcamo.githubusercontent.com%2Fa3662ea2d6a9a0b4ba2bfc2501db31c0815afd2c4d25ec3d29ad3b7aaac464ce%2F68747470733a2f2f63646e2e646973636f72646170702e636f6d2f6174746163686d656e74732f3732343938333636393131343134323735312f313336303330383531303737363336353230382f6368616e6e656c73345f70726f66696c652e6a70673f65783d36376661613538362669733d363766393534303626686d3d6366616562303939656438333961313932333735663863316134636636313134363037303165623231343137383965313438336534366434373830643661323626&w=640&q=75" width="150">
-  <h1>Fulturate-rs - Telegram Utility Bot 🤖</h1>
-  (Currently, the bot is in Russian. The next version**s** will include a 100% language switcher.)
+  <h1>Fulturate-rs - Best utility bot for Telegram on Rust 🤖</h1>
 </div>
 
 ## ✨ Features:
 - **Speech Recognition** 🎤: Convert spoken words into text for a more interactive experience.
 - **Currency Conversion** 💰: Convert between different currencies easily.
-
-## 🔹 Todo:
-- **Download Videos/Music from URLs** 🎥🎶: Seamlessly download multimedia content.
-- **Download Images from URLs** 🖼️: Fetch images directly from URLs.
-- **Download Files from URLs** 📂: Download various types of files from provided URLs.
-- **Download Audios from URLs** 🎧: Grab audio files from URLs for easy access.
-- **Settings** ⚙️: Manage and adjust bot settings to your preferences.
-- **Model Switcher (Speech Recognition)** 🧠: Switch between different speech recognition models for better accuracy.
-- **Language Switcher** 🌍: Switch between multiple languages with ease.
-- **Message Translation** 🌐: Translate messages into your preferred language.
+- **Summarization** ✨: Summarize audio files.
 
 ## 🚀 Getting Started:
 To get started with Fulturate-rs, follow these steps:  
 *(If you don't have Rust installed, visit: [Rust Install](https://www.rust-lang.org/tools/install))*
 
 1. Clone the repository:  
-   `git clone https://github.com/Weever1337/fulturate-rs.git`
+   `git clone https://github.com/Fulturate/bot.git`
 2. Run the bot:  
    `cargo run`  
    OR run with Docker:  
@@ -33,10 +23,9 @@ To get started with Fulturate-rs, follow these steps:
 - **News Channel**: [Fulturate News](https://t.me/FulturateNews)
 - **Bot**: [Fulturate Bot](https://t.me/FulturateBot)
 - **Owner's Bio-Channel in Telegram**: [Weever](https://t.me/Weever)
-- **Owner's Shitpost Channel (RUS) in Telegram**: [WeeverDev](https://t.me/WeeverDev)
 
 ## 💖 Credits:
-- **Nixxoq**: [GitHub](https://github.com/nixxoq), [Telegram](https://t.me/nixxoq)
+- **Nixxoq (did a LOT of work)**: [GitHub](https://github.com/nixxoq), [Telegram](https://t.me/nixxoq)
 
 ## 📄 License:
-- **MIT License**: [MIT License](https://github.com/Weever1337/fulturate-rs/blob/main/LICENSE)
+- **MIT License**: [MIT License](https://github.com/Fulturate/bot/blob/main/LICENSE)

config.json

@@ -1,4 +1,5 @@
 {
   "ai_model": "gemini-2.5-flash",
-  "ai_prompt": "You are a highly specialized audio-to-text transcription service. Your SOLE purpose is to accurately transcribe the spoken words from the audio track of the provided file.\n\n**Crucial Instruction: You MUST completely ignore the visual stream of the file. Your task is NOT to describe the video.**\n\n- **DO:** Listen to the audio and transcribe it word-for-word (verbatim).\n- **DO:** Maintain the original language of the speech.\n\n- **DO NOT:** Describe scenes, people, objects, actions, logos, or the environment.\n- **DO NOT:** Analyze the camera work or shot composition.\n- **DO NOT:** Provide summaries, explanations, or any commentary.\n- **DO NOT:** Add headers, timestamps, or any formatting.\n\nReturn ONLY the raw, plain transcribed text. If no speech is present, return \"[no speech]\"."
+  "ai_prompt": "You are a highly specialized audio-to-text transcription service. Your SOLE purpose is to accurately transcribe the spoken words from the audio track of the provided file.\n\n**Crucial Instruction: You MUST completely ignore the visual stream of the file. Your task is NOT to describe the video.**\n\n- **DO:** Listen to the audio and transcribe it word-for-word (verbatim).\n- **DO:** Maintain the original language of the speech.\n\n- **DO NOT:** Describe scenes, people, objects, actions, logos, or the environment.\n- **DO NOT:** Analyze the camera work or shot composition.\n- **DO NOT:** Provide summaries, explanations, or any commentary.\n- **DO NOT:** Add headers, timestamps, or any formatting.\n\nReturn ONLY the raw, plain transcribed text. If no speech is present, return \"[no speech]\".",
+  "summarize_prompt": "You are an assistant that transcribes and then summarizes spoken content. First, accurately and fully transcribe the voice message, keeping the original language. Then, briefly summarize the transcribed text in the same language. Output only the final summary. Do not include the full transcription, and do not add any extra words like 'Summary' or 'Transcription'. Do not explain or comment. The output must be plain and concise."
 }

src/bot/callbacks/cobalt_pagination.rs

@@ -0,0 +1,120 @@
+use crate::{
+    bot::keyboards::cobalt::make_photo_pagination_keyboard,
+    core::{config::Config, services::cobalt::DownloadResult},
+    errors::MyError,
+};
+use std::sync::Arc;
+use teloxide::{
+    ApiError, RequestError,
+    prelude::*,
+    types::{CallbackQuery, InputFile, InputMedia, InputMediaPhoto},
+};
+
+struct PagingData<'a> {
+    original_user_id: u64,
+    index: usize,
+    total: usize,
+    url_hash: &'a str,
+}
+
+impl<'a> PagingData<'a> {
+    fn from_parts(parts: &'a [&'a str]) -> Option<Self> {
+        if parts.len() < 5 {
+            return None;
+        }
+
+        Some(Self {
+            original_user_id: parts.get(1)?.parse().ok()?,
+            index: parts.get(2)?.parse().ok()?,
+            total: parts.get(3)?.parse().ok()?,
+            url_hash: parts.get(4)?,
+        })
+    }
+}
+
+pub async fn handle_cobalt_pagination(
+    bot: Bot,
+    q: CallbackQuery,
+    config: Arc<Config>,
+) -> Result<(), MyError> {
+    let Some(data) = q.data else { return Ok(()) };
+    let parts: Vec<&str> = data.split(':').collect();
+
+    if parts.get(1) == Some(&"noop") {
+        bot.answer_callback_query(q.id).await?;
+        return Ok(());
+    }
+
+    let Some(paging_data) = PagingData::from_parts(&parts) else {
+        log::error!("Invalid callback data format: {}", data);
+        return Ok(());
+    };
+
+    if q.from.id.0 != paging_data.original_user_id {
+        bot.answer_callback_query(q.id)
+            .text("Вы не можете использовать эти кнопки.")
+            .show_alert(true)
+            .await?;
+        return Ok(());
+    }
+
+    let cache_key = format!("cobalt_cache:{}", paging_data.url_hash);
+    let redis = config.get_redis_client();
+    let Ok(Some(DownloadResult::Photos { urls, original_url })) = redis.get(&cache_key).await
+    else {
+        bot.answer_callback_query(q.id)
+            .text("Извините, срок хранения этих фото истёк.")
+            .show_alert(true)
+            .await?;
+        return Ok(());
+    };
+
+    let Some(photo_url_str) = urls.get(paging_data.index) else {
+        log::error!(
+            "Pagination index {} is out of bounds for len {}",
+            paging_data.index,
+            urls.len()
+        );
+        return Ok(());
+    };
+    let Ok(url) = photo_url_str.parse() else {
+        log::error!("Failed to parse photo URL: {}", photo_url_str);
+        return Ok(());
+    };
+
+    let media = InputMedia::Photo(InputMediaPhoto::new(InputFile::url(url)));
+    let keyboard = make_photo_pagination_keyboard(
+        paging_data.url_hash,
+        paging_data.index,
+        paging_data.total,
+        paging_data.original_user_id,
+        &original_url,
+    );
+
+    let edit_result = if let Some(msg) = q.message {
+        bot.edit_message_media(msg.chat().id, msg.id(), media)
+            .reply_markup(keyboard)
+            .await
+            .map(|_| ())
+    } else if let Some(inline_id) = q.inline_message_id {
+        bot.edit_message_media_inline(inline_id, media)
+            .reply_markup(keyboard)
+            .await
+            .map(|_| ())
+    } else {
+        return Ok(());
+    };
+
+    if let Err(e) = edit_result
+        && !matches!(e, RequestError::Api(ApiError::MessageNotModified))
+    {
+        log::error!("Failed to edit message for pagination: {}", e);
+        bot.answer_callback_query(q.id.clone())
+            .text("Не удалось обновить фото.")
+            .await?;
+    }
+
+    bot.answer_callback_query(q.id).await?;
+
+    Ok(())
+}