akulij/gongbotrs
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

cargo fmt

Browse Source
This commit is contained in:
Akulij 2025-04-08 01:13:49 +09:00
parent 98be2b0f7d
commit cca87da403
2 changed files with 21 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/db/models.rs
View File

@ -5,9 +5,9 @@
use crate::db::schema::*; use crate::db::schema::*;
use chrono::NaiveDateTime;
use chrono::DateTime;
use chrono::offset::Utc; use chrono::offset::Utc;
use chrono::DateTime;
use chrono::NaiveDateTime;
use diesel::prelude::*; use diesel::prelude::*;
#[derive(Queryable, Debug, Identifiable)] #[derive(Queryable, Debug, Identifiable)]
#[diesel(table_name = events)] #[diesel(table_name = events)]
@ -62,4 +62,3 @@ pub struct User {
pub username: Option<String>, pub username: Option<String>,
pub language_code: Option<String>, pub language_code: Option<String>,
} }

30
src/main.rs
View File

@ -72,17 +72,16 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
let db_url2 = config.db_url.clone(); let db_url2 = config.db_url.clone();
let state_mgr = PostgresStorage::open(&db_url2, 8, Json).await?; let state_mgr = PostgresStorage::open(&db_url2, 8, Json).await?;
// TODO: delete this in production // TODO: delete this in production
let events: Vec<DateTime<Utc>> = vec![ let events: Vec<DateTime<Utc>> = vec!["2025-04-09T18:00:00+04:00", "2025-04-11T16:00:00+04:00"]
"2025-04-09T18:00:00+04:00", .iter()
"2025-04-11T16:00:00+04:00", .map(|d| DateTime::parse_from_rfc3339(d).unwrap().into())
].iter().map(|d| DateTime::parse_from_rfc3339(d).unwrap().into()).collect(); .collect();
for event in events { for event in events {
match db.clone().create_event(event).await { match db.clone().create_event(event).await {
Ok(e) => println!("Created event {}", e.id), Ok(e) => println!("Created event {}", e.id),
Err(err) => println!("Failed to create event, error: {}", err) Err(err) => println!("Failed to create event, error: {}", err),
} }
} }
// //
@ -250,12 +249,21 @@ async fn user_command_handler(
} }
async fn make_start_buttons(db: &mut DB) -> InlineKeyboardMarkup { async fn make_start_buttons(db: &mut DB) -> InlineKeyboardMarkup {
let mut buttons: Vec<Vec<InlineKeyboardButton>> = db.get_all_events().await.iter() let mut buttons: Vec<Vec<InlineKeyboardButton>> = db
.map(|e| vec![InlineKeyboardButton::callback( .get_all_events()
.await
.iter()
.map(|e| {
vec![InlineKeyboardButton::callback(
e.time.with_timezone(&Asia::Dubai).to_string(), e.time.with_timezone(&Asia::Dubai).to_string(),
format!("event:{}", e.id) format!("event:{}", e.id),
)]).collect(); )]
buttons.push(vec![InlineKeyboardButton::callback("More info", "more_info")]); })
.collect();
buttons.push(vec![InlineKeyboardButton::callback(
"More info",
"more_info",
)]);
InlineKeyboardMarkup::new(buttons) InlineKeyboardMarkup::new(buttons)
} }