extern crate postgres;
use std::error::Error;
use teloxide::{
payloads::SendMessageSetters,
prelude::*,
types::{
InlineKeyboardButton, InlineKeyboardMarkup, InlineQueryResultArticle, InputMessageContent,
InputMessageContentText, Me, User,
},
utils::command::BotCommands,
};
use std::env;
use dotenvy::dotenv;
use postgres::{Client, NoTls};
use std::thread;
mod database;
const PRIVATE_CHAT_ID : &str = "-832535905";
const HELLO_MESSAGE : &str ="Приветствую тебя юнный падаван! Я протокольный дроид C-3PO, меня создали чтобы помочь тебе стать джедаем, а пока я могу добавить тебя в тренировочный лагерь.
Для этого тебе нужно выбрать команду Регистрация, в списке ниже.";
const MESSAGE_FOR_REGISTERING : &str = "Вы зарегистрированы в боте, для того чтобы попасть в закрытый чат - пополните баланс
Как пополнить баланс:";
const MESSAGE_FOR_BALANCE : &str ="Ваша подписка действует до: ";
const MESSAGE_FOR_INSTRUCTION : &str ="Здесь будут инструкции по пополнению баланса...";
const MESSAGE_FOR_SUPPORT : &str ="По всем возникающим вопросам нажмите на ссылку: @Vitovt21 и затем на кнопку \"Отправить сообщение\"";
const MESSAGE_WALLET : &str = "fsavipchat21";
#[derive(BotCommands)]
#[command(rename_rule = "lowercase", description = "Я протокольный дроид C-3PO, в настоящий момент я не уменю разговаривать, но мой создатель обещает что я скоро научусь поддерживать разговор.
Вот список команд, которые я сейчас понимаю:")]
enum Command {
#[command(description = "Отобразить этот текст")]
Help,
#[command(description = "Подписка на приватный канал")]
Start,
}
#[tokio::main]
async fn main() -> Result<(), Box<dyn Error>> {
pretty_env_logger::init();
log::info!("Starting FSA Subscriptions bot (version 0ρ0103)");
let bot = Bot::from_env();
let handler = dptree::entry()
.branch(Update::filter_message().endpoint(message_handler))
.branch(Update::filter_callback_query().endpoint(callback_handler))
.branch(Update::filter_inline_query().endpoint(inline_query_handler));
thread::spawn(move || pg_listen__expire_soon(&bot));
thread::spawn(move || pg_listen__expired());
thread::spawn(move || pg_listen__replenishment());
Dispatcher::builder(&bot, handler).enable_ctrlc_handler().build().dispatch().await;
Ok(())
}
Text paste