{"id":336797,"date":"2022-08-09T15:00:33","date_gmt":"2022-08-09T15:00:33","guid":{"rendered":"http:\/\/savepearlharbor.com\/?p=336797"},"modified":"-0001-11-30T00:00:00","modified_gmt":"-0001-11-29T21:00:00","slug":"","status":"publish","type":"post","link":"https:\/\/savepearlharbor.com\/?p=336797","title":{"rendered":"\u041a\u0430\u043a \u044f \u043d\u0430\u043f\u0438\u0441\u0430\u043b telegram \u0431\u043e\u0442\u0430 \u043d\u0430 Rust \u0434\u043b\u044f \u043e\u0442\u0441\u043b\u0435\u0436\u0438\u0432\u0430\u043d\u0438\u044f \u0440\u0435\u0439\u0442\u0438\u043d\u0433\u0430 \u043f\u0440\u0438 \u043f\u043e\u0441\u0442\u0443\u043f\u043b\u0435\u043d\u0438\u0438 \u0432 \u0432\u0443\u0437<\/span>"},"content":{"rendered":"
<\/div>\n
\n
\n
\n
\n

\u041f\u0440\u0438\u0432\u0435\u0442, \u043c\u0435\u043d\u044f \u0437\u043e\u0432\u0443\u0442 \u0418\u043b\u044c\u044f, \u044f \u0441\u0435\u0439\u0447\u0430\u0441 \u0441\u0434\u0430\u044e \u0432\u0441\u0442\u0443\u043f\u0438\u0442\u0435\u043b\u044c\u043d\u044b\u0435 \u044d\u043a\u0437\u0430\u043c\u0435\u043d\u044b \u0432 \u043c\u0430\u0433\u0438\u0441\u0442\u0440\u0430\u0442\u0443\u0440\u0443. \u0421\u0442\u043e\u043b\u043a\u043d\u0443\u043b\u0441\u044f \u043f\u0440\u0438 \u043f\u043e\u0441\u0442\u0443\u043f\u043b\u0435\u043d\u0438\u0438 \u0441 \u043f\u0440\u043e\u0431\u043b\u0435\u043c\u043e\u0439, \u0447\u0442\u043e \u0440\u0435\u0437\u0443\u043b\u044c\u0442\u0430\u0442\u044b \u044d\u043a\u0437\u0430\u043c\u0435\u043d\u043e\u0432 \u0432 \u0440\u0435\u0439\u0442\u0438\u043d\u0433\u043e\u0432\u043e\u043c \u0441\u043f\u0438\u0441\u043a\u0435 \u043f\u043e\u044f\u0432\u043b\u044f\u044e\u0442\u0441\u044f \u043d\u0435 \u0441\u0440\u0430\u0437\u0443, \u0430 \u043f\u043e\u0441\u0442\u043e\u044f\u043d\u043d\u043e \u0435\u0433\u043e \u043e\u0442\u043a\u0440\u044b\u0432\u0430\u0442\u044c \u0438 \u043d\u0430\u0445\u043e\u0434\u0438\u0442\u044c \u0441\u0435\u0431\u044f \u043d\u0430 \u0441\u0442\u0440\u0430\u043d\u0438\u0446\u0435 — \u043f\u043e\u0441\u043b\u0435 \u0440\u0430\u0437\u0430 \u0434\u0432\u0430\u0434\u0446\u0430\u0442\u043e\u0433\u043e \u043d\u0430\u0434\u043e\u0435\u043b\u043e. \u041f\u043e\u0441\u043b\u0435 \u0438\u0441\u0441\u043b\u0435\u0434\u043e\u0432\u0430\u043d\u0438\u044f devtools \u044f \u0437\u0430\u0445\u043e\u0442\u0435\u043b \u043d\u0430\u043f\u0438\u0441\u0430\u0442\u044c \u043f\u0440\u0438\u043b\u043e\u0436\u0435\u043d\u0438\u0435 \u0434\u043b\u044f \u043e\u0442\u0441\u043b\u0435\u0436\u0438\u0432\u0430\u043d\u0438\u044f \u0438\u0437\u043c\u0435\u043d\u0435\u043d\u0438\u0439 \u0440\u0435\u0439\u0442\u0438\u043d\u0433\u0430, \u0430 \u0443\u0432\u0435\u0434\u043e\u043c\u043b\u0435\u043d\u0438\u044f \u043e\u0442\u043f\u0440\u0430\u0432\u043b\u044f\u0442\u044c \u0432 \u0442\u0435\u043b\u0435\u0433\u0440\u0430\u043c. \u0410 Rust \u0431\u044b\u043b \u0432\u044b\u0431\u0440\u0430\u043d \u043f\u043e \u043f\u0440\u043e\u0441\u0442\u043e\u0439 \u043f\u0440\u0438\u0447\u0438\u043d\u0435 — \u043e\u043d \u043c\u043d\u0435 \u043f\u043e\u043d\u0440\u0430\u0432\u0438\u043b\u0441\u044f, \u043d\u0443 \u0438 \u0435\u0441\u0442\u044c \u0443\u0434\u043e\u0431\u043d\u044b\u0435 \u0448\u0442\u0443\u043a\u0438 \u0432\u0441\u044f\u043a\u0438\u0435.<\/p>\n

\u041d\u0435 \u0441\u0443\u0434\u0438\u0442\u0435 \u0441\u0442\u0440\u043e\u0433\u043e, \u043c\u043e\u0439 \u043f\u0435\u0440\u0432\u044b\u0439 \u043e\u043f\u044b\u0442 \u043d\u0430\u043f\u0438\u0441\u0430\u043d\u0438\u044f \u0441\u0442\u0430\u0442\u044c\u0438 (\u0438 \u0431\u043e\u0442\u0430). \u0422\u0430\u043a\u0436\u0435 \u043e\u043d\u0430 \u043d\u0435 \u043f\u0440\u0435\u0442\u0435\u043d\u0434\u0443\u0435\u0442 \u043d\u0430 \u0437\u0432\u0430\u043d\u0438\u0435 \u043f\u043e\u043b\u043d\u043e\u0446\u0435\u043d\u043d\u043e\u0433\u043e \u0442\u0443\u0442\u043e\u0440\u0438\u0430\u043b\u0430 \u043f\u043e \u0440\u0430\u0437\u0440\u0430\u0431\u043e\u0442\u043a\u0435 \u0442\u0435\u043b\u0435\u0433\u0440\u0430\u043c \u0431\u043e\u0442\u043e\u0432 \u043d\u0430 Rust, \u043d\u043e \u044f \u0441\u0442\u0430\u0440\u0430\u043b\u0441\u044f. \u0418 \u0442\u0435\u043c \u0431\u043e\u043b\u0435\u0435 \u044d\u0442\u043e \u043d\u0435 \u0442\u0443\u0442\u043e\u0440\u0438\u0430\u043b \u043f\u043e \u0441\u0430\u043c\u043e\u043c\u0443 \u044f\u0437\u044b\u043a\u0443.<\/p>\n

\u0420\u0435\u0430\u043b\u0438\u0437\u0430\u0446\u0438\u044f<\/h3>\n

\u0414\u043b\u044f \u0437\u0430\u043f\u0440\u043e\u0441\u043e\u0432 \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u043b reqwest \u0441 \u0432\u043a\u043b\u044e\u0447\u0435\u043d\u043d\u043e\u0439 \u0444\u0438\u0447\u0435\u0439 json<\/code> \u0434\u043b\u044f \u0434\u0435\u0441\u0435\u0440\u0438\u0430\u043b\u0438\u0437\u0430\u0446\u0438\u0438, \u0434\u043b\u044f \u043f\u043e\u0434\u0434\u0435\u0440\u0436\u043a\u0438 async\/await<\/code> — tokio<\/a>, \u0434\u043b\u044f \u0440\u0430\u0431\u043e\u0442\u044b \u0441 SQLite — rusqlite<\/a>.<\/p>\n

\u041f\u043e\u043a\u0430 \u0447\u0442\u043e \u0435\u0441\u0442\u044c \u0432\u043e\u0437\u043c\u043e\u0436\u043d\u043e\u0441\u0442\u044c \u0441\u043c\u043e\u0442\u0440\u0435\u0442\u044c \u0440\u0435\u0439\u0442\u0438\u043d\u0433 \u0442\u043e\u043b\u044c\u043a\u043e \u0434\u043b\u044f \u043c\u0430\u0433\u0438\u0441\u0442\u0440\u0430\u0442\u0443\u0440\u044b \u0418\u0422\u041c\u041e<\/em><\/p>\n

\u0421\u0445\u0435\u043c\u0430 \u0440\u0430\u0431\u043e\u0442\u044b<\/h4>\n

\u041f\u043e\u043b\u0443\u0447\u0430\u0435\u043c \u0441\u043f\u0438\u0441\u043e\u043a \u043f\u0440\u043e\u0433\u0440\u0430\u043c\u043c \u0438 \u0441\u043e\u0445\u0440\u0430\u043d\u044f\u0435\u043c \u0432 \u0431\u0430\u0437\u0435, \u0434\u0430\u043b\u0435\u0435 \u0437\u0430\u043f\u0443\u0441\u043a\u0430\u0435\u043c \u0446\u0438\u043a\u043b, \u043d\u0430 \u043a\u0430\u0436\u0434\u043e\u043c \u0448\u0430\u0433\u0435 \u0437\u0430\u043f\u0440\u0430\u0448\u0438\u0432\u0430\u0435\u043c \u0438 \u043e\u0431\u0440\u0430\u0431\u0430\u0442\u044b\u0432\u0430\u0435\u043c \u043e\u0431\u043d\u043e\u0432\u043b\u0435\u043d\u0438\u044f \u0441 \u0442\u0435\u043b\u0435\u0433\u0440\u0430\u043c\u0430, \u0438 \u043f\u0440\u0438\u043c\u0435\u0440\u043d\u043e \u043a\u0430\u0436\u0434\u044b\u0435 10 \u043c\u0438\u043d\u0443\u0442 \u043e\u0431\u043d\u043e\u0432\u043b\u044f\u0435\u043c \u0440\u0435\u0439\u0442\u0438\u043d\u0433 \u0441 \u0441\u0430\u0439\u0442\u0430.<\/p>\n

\u041f\u043e\u043b\u0443\u0447\u0435\u043d\u0438\u0435 \u0440\u0435\u0439\u0442\u0438\u043d\u0433\u0430<\/h4>\n

\u041d\u0430\u0447\u0430\u043b \u044f \u0441 \u043f\u043e\u043b\u0443\u0447\u0435\u043d\u0438\u044f \u0434\u0430\u043d\u043d\u044b\u0445 \u043e \u0440\u0435\u0439\u0442\u0438\u043d\u0433\u0435 \u0441 abitlk.itmo.ru<\/code>. \u0417\u0434\u0435\u0441\u044c \u043f\u043e\u043b\u0443\u0447\u0430\u0435\u043c \u0434\u0430\u043d\u043d\u044b\u0435, \u0444\u0443\u043d\u043a\u0446\u0438\u044f find_score<\/code> \u0438\u0449\u0435\u0442 \u0432 \u043d\u0438\u0445 \u043d\u0443\u0436\u043d\u0443\u044e \u0437\u0430\u043f\u0438\u0441\u044c, \u0432 \u0441\u043b\u0443\u0447\u0430\u0435 \u0435\u0441\u043b\u0438 \u043d\u0435 \u043d\u0430\u0445\u043e\u0434\u0438\u0442, \u0432\u043e\u0437\u0432\u0440\u0430\u0449\u0430\u0435\u0442 \u043e\u0448\u0438\u0431\u043a\u0443, \u043a\u043e\u0442\u043e\u0440\u0430\u044f \u0431\u0443\u0434\u0435\u0442 \u043e\u0431\u0440\u0430\u0431\u043e\u0442\u0430\u043d\u0430, \u0438 \u0431\u0443\u0434\u0435\u0442 \u043e\u0442\u043f\u0440\u0430\u0432\u043b\u0435\u043d\u043e \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435, \u0447\u0442\u043e \u043d\u0438\u0447\u0435\u0433\u043e \u043d\u0435 \u043d\u0430\u0439\u0434\u0435\u043d\u043e<\/p>\n

\nget_rating_competition<\/summary>\n
\n
pub async fn get_rating_competition(     degree: &str,     program_id: &str,     case_number: &str, ) -> Result<Option<Competition>, Box<dyn std::error::Error>> {     let rating_response: RatingResponse = reqwest::get(format!(         \"{API_PREFIX}\/{API_KEY}\/rating\/{degree}\/budget?program_id={program_id}\"     ))     .await?     .json()     .await?;      match find_score(rating_response, case_number) {         None => Err(Box::from(\"no matching competition\")),         competition => Ok(competition),     } } <\/code><\/pre>\n<\/p>\n<\/div>\n<\/details>\n
\u041f\u043e\u0438\u0441\u043a \u0437\u0430\u043f\u0438\u0441\u0438 \u0432 \u0434\u0430\u043d\u043d\u044b\u0445. \u0415\u0441\u043b\u0438 \u0432 \u043f\u043e\u043b\u0435 ok<\/code> \u0432\u0435\u0440\u043d\u0443\u043b\u043e\u0441\u044c false<\/code>, \u0441\u0440\u0430\u0437\u0443 \u0432\u043e\u0437\u0432\u0440\u0430\u0449\u0430\u0435\u043c None<\/code>. \u0418\u043d\u0430\u0447\u0435 \u0434\u043e\u0441\u0442\u0430\u0435\u043c \u043c\u0430\u0441\u0441\u0438\u0432 \u0432\u0441\u0435\u0445 \u0437\u0430\u043f\u0438\u0441\u0435\u0439 \u0438\u0437 response.result.general_competition<\/code>, \u0438 \u043d\u0430\u0445\u043e\u0434\u0438\u043c \u0432 \u043d\u0435\u043c \u043f\u043e\u0437\u0438\u0446\u0438\u044e \u043f\u043e \u043d\u043e\u043c\u0435\u0440\u0443 \u0434\u0435\u043b\u0430 \u0438\u0437 \u043b\u0438\u0447\u043d\u043e\u0433\u043e \u043a\u0430\u0431\u0438\u043d\u0435\u0442\u0430 (\u0443 \u043c\u0435\u043d\u044f \u0432\u0438\u0434\u0430 \u041c\u0445-\u0445\u0445\u0445\u0445-2022<\/code>)<\/p>\n
\nfind_score<\/summary>\n
\n
fn find_score(response: RatingResponse, case_number: &str) -> Option<Competition> {     if !response.ok {         return None;     }      response         .result         .general_competition         .iter()         .find(|c| -> bool {             if let Some(c) = &c.case_number {                 c == case_number             } else {                 false             }         })         .cloned() } <\/code><\/pre>\n<\/p>\n<\/div>\n<\/details>\n
\u0421\u0442\u0440\u0443\u043a\u0442\u0443\u0440\u0430 RatingResponse<\/code> \u0432\u044b\u0433\u043b\u044f\u0434\u0438\u0442 \u0442\u0430\u043a. \u0422\u0443\u0442 \u044f \u0437\u0430\u0434\u0430\u043b \u0442\u043e\u043b\u044c\u043a\u043e \u043d\u0443\u0436\u043d\u044b\u0435 \u043f\u043e\u043b\u044f, \u043e\u0441\u0442\u0430\u043b\u044c\u043d\u044b\u0435, \u043a\u043e\u0442\u043e\u0440\u044b\u0435 \u043f\u0440\u0438\u0434\u0443\u0442 \u0432 \u043e\u0442\u0432\u0435\u0442\u0435, \u0431\u0443\u0434\u0443\u0442 \u043f\u0440\u043e\u0438\u0433\u043d\u043e\u0440\u0438\u0440\u043e\u0432\u0430\u043d\u044b \u043f\u0440\u0438 \u043f\u0430\u0440\u0441\u0438\u043d\u0433\u0435.<\/p>\n
\n\u041c\u043e\u0434\u0435\u043b\u0438 \u043e\u0442\u0432\u0435\u0442\u0430<\/summary>\n
\n
pub struct Response<T> {     pub ok: bool,     pub message: String,     pub result: T, }  pub type RatingResponse = Response<RatingResult>;  pub struct RatingResult {     pub general_competition: Vec<Competition>, }  pub struct Competition {     pub position: i32,     pub priority: i32,     pub total_scores: f64,     pub case_number: Option<String>,     pub exam_scores: Option<f64>, } <\/code><\/pre>\n<\/p>\n<\/div>\n<\/details>\n
\u0422\u0430\u043a\u0436\u0435 \u043a\u0430\u0436\u0434\u0430\u044f \u0441\u0442\u0440\u0443\u043a\u0442\u0443\u0440\u0430 \u043d\u0430\u0441\u043b\u0435\u0434\u0443\u0435\u0442 serde::Deserialize<\/code> \u0434\u043b\u044f \u0433\u0435\u043d\u0435\u0440\u0430\u0446\u0438\u0438 \u043d\u0443\u0436\u043d\u044b\u0445 \u043c\u0435\u0442\u043e\u0434\u043e\u0432, \u043a\u043e\u0442\u043e\u0440\u044b\u0435 \u0431\u0443\u0434\u0443\u0442 \u043f\u043e\u0442\u043e\u043c \u043f\u0440\u0435\u043e\u0431\u0440\u0430\u0437\u043e\u0432\u044b\u0432\u0430\u0442\u044c \u0441\u044b\u0440\u044b\u0435 \u0434\u0430\u043d\u043d\u044b\u0435 (\u0432 \u0434\u0430\u043d\u043d\u043e\u043c \u0441\u043b\u0443\u0447\u0430\u0435 json) \u0432 \u0441\u0442\u0440\u0443\u043a\u0442\u0443\u0440\u0443:<\/p>\n
#[derive(Deserialize)] pub struct Response<T> {} <\/code><\/pre>\n
\u041f\u043e\u043b\u0443\u0447\u0435\u043d\u0438\u0435 \u043a\u043e\u043c\u0430\u043d\u0434 \u043e\u0442 \u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u0435\u043b\u0435\u0439<\/h4>\n
\u0414\u043b\u044f \u043f\u043e\u043b\u0443\u0447\u0435\u043d\u0438\u044f \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0439 \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u0443\u0435\u0442\u0441\u044f \u044d\u043d\u0434\u043f\u043e\u0439\u043d\u0442 https:\/\/api.telegram.org\/botTOKEN\/getUpdates?offset=x<\/code> \u0434\u043b\u044f \u043f\u043e\u043b\u0443\u0447\u0435\u043d\u0438\u044f \u043e\u0431\u043d\u043e\u0432\u043b\u0435\u043d\u0438\u0439, \u0433\u0434\u0435 \u0435\u0441\u0442\u044c \u0438 \u043d\u043e\u0432\u044b\u0435 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f. offset<\/code> \u043d\u0435\u043e\u0431\u0445\u043e\u0434\u0438\u043c \u0434\u043b\u044f \u043f\u043e\u043c\u0435\u0442\u043a\u0438 \u043e\u0431\u043d\u043e\u0432\u043b\u0435\u043d\u0438\u0439 \u043a\u0430\u043a \u043f\u0440\u043e\u0447\u0438\u0442\u0430\u043d\u043d\u044b\u0445, \u0447\u0442\u043e\u0431\u044b \u043e\u043d\u0438 \u0431\u043e\u043b\u044c\u0448\u0435 \u043d\u0435 \u0432\u043e\u0437\u0432\u0440\u0430\u0449\u0430\u043b\u0438\u0441\u044c. \u0424\u0443\u043d\u043a\u0446\u0438\u044f \u0434\u043b\u044f \u0438\u0445 \u043f\u043e\u043b\u0443\u0447\u0435\u043d\u0438\u044f:<\/p>\n
\nget_updates<\/summary>\n
\n
async fn get_updates(offset: i32) -> Result<GetUpdatesResponse, Box<dyn std::error::Error>> {     let params = [(\"offset\", &offset.to_string())];     let url =         reqwest::Url::parse_with_params(&format!(\"{TG_API_PREFIX}{TOKEN}\/getUpdates\"), &params)?;      let response = reqwest::get(url).await?;     if !response.status().is_success() {         let error: ErrorResponse = response.json().await?;         let text = format!(             \"cannot get updates\\nerror: `{}`\",             error.description.unwrap_or_default()         );         send_message(&text, LOGS_CHAT_ID).await?;         return Err(Box::from(\"cannot get updates\"));     }      Ok(response.json().await?) } <\/code><\/pre>\n<\/p>\n<\/div>\n<\/details>\n
\u041f\u043e\u043b\u0443\u0447\u0435\u043d\u043d\u044b\u0435 \u0434\u0430\u043d\u043d\u044b\u0435 \u043e\u0431\u0440\u0430\u0431\u0430\u0442\u044b\u0432\u0430\u0435\u043c. \u0417\u0434\u0435\u0441\u044c \u0432\u043e-\u043f\u0435\u0440\u0432\u044b\u0445 \u0441\u043e\u0445\u0440\u0430\u043d\u044f\u0435\u0442\u0441\u044f \u043c\u0430\u043a\u0441\u0438\u043c\u0430\u043b\u044c\u043d\u044b\u0439 update_id<\/code> \u0434\u043b\u044f \u043f\u043e\u0441\u043b\u0435\u0434\u0443\u044e\u0449\u0435\u0433\u043e \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u043d\u0438\u044f \u0432 \u043a\u0430\u0447\u0435\u0441\u0442\u0432\u0435 offset<\/code>, \u0434\u0430\u043b\u0435\u0435 \u0432 MessageRequest::from(text)<\/code> \u043f\u0430\u0440\u0441\u0438\u0442\u0441\u044f \u0442\u0435\u043a\u0441\u0442 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f, \u0435\u0441\u043b\u0438 \u044d\u0442\u043e \u0438\u0437\u0432\u0435\u0441\u0442\u043d\u0430\u044f \u043a\u043e\u043c\u0430\u043d\u0434\u0430, \u043e\u043d\u0430 \u0434\u0430\u043b\u0435\u0435 \u043e\u0431\u0440\u0430\u0431\u0430\u0442\u044b\u0432\u0430\u0435\u0442\u0441\u044f, \u0435\u0441\u043b\u0438 \u043d\u0435\u0442, \u043e\u0442\u043f\u0440\u0430\u0432\u043b\u044f\u0435\u0442\u0441\u044f \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435, \u0447\u0442\u043e \u044d\u0442\u043e \u043d\u0435 \u043a\u043e\u043c\u0430\u043d\u0434\u0430.<\/p>\n
\nhandle_updates<\/summary>\n
\n
pub async fn handle_updates(db: &DB, offset: i32) -> Result<i32, Box<dyn std::error::Error>> {     let data = get_updates(offset).await?;      let mut max_update_id = 0;     for update in data.result {         if update.update_id > max_update_id {             max_update_id = update.update_id;         }          if let Some(message) = update.message {             if let Some(text) = message.text {                 let chat_id = message.from.id.to_string();                 match MessageRequest::from(text) {                     Some(request) => handle_message_request(db, request, &chat_id).await?,                     None => send_message(messages::unknown_message, &chat_id).await?,                 }             }         }     }      Ok(max_update_id + 1) } <\/code><\/pre>\n<\/p>\n<\/div>\n<\/details>\n
\u041f\u0430\u0440\u0441\u0438\u0442\u0441\u044f \u0442\u0430\u043a (\u0444\u0443\u043d\u043a\u0446\u0438\u044f from<\/code>). \u0422\u0435\u043a\u0441\u0442 \u0440\u0430\u0437\u0431\u0438\u0432\u0430\u0435\u0442\u0441\u044f \u043f\u043e \u043f\u0440\u043e\u0431\u0435\u043b\u0430\u043c, \u0434\u0430\u043b\u0435\u0435 \u0432 \u0441\u043b\u0443\u0447\u0430\u0435 \u043e\u0434\u043d\u043e\u0441\u043b\u043e\u0436\u043d\u044b\u0445 \u043a\u043e\u043c\u0430\u043d\u0434 \u043f\u0440\u043e\u0441\u0442\u043e \u0432\u043e\u0437\u0432\u0440\u0430\u0449\u0430\u0435\u0442\u0441\u044f \u0437\u043d\u0430\u0447\u0435\u043d\u0438\u0435 \u043f\u0435\u0440\u0435\u0447\u0438\u0441\u043b\u0435\u043d\u0438\u044f, \u0430 \u0432 \u0441\u043b\u0443\u0447\u0430\u0435 \/watch<\/code> \u0438\u0437 \u0437\u043d\u0430\u0447\u0435\u043d\u0438\u0439 \u043c\u0430\u0441\u0441\u0438\u0432\u0430 \u0441\u043e\u0437\u0434\u0430\u0435\u0442\u0441\u044f \u043e\u0431\u044a\u0435\u043a\u0442 \u0434\u043b\u044f \u0438\u0445 \u043f\u0435\u0440\u0435\u0434\u0430\u0447\u0438. \u041f\u0440\u0438 \u043d\u0435\u043f\u0440\u0430\u0432\u0438\u043b\u044c\u043d\u043e\u0439 \u043a\u043e\u043c\u0430\u043d\u0434\u0435 \u0432\u043e\u0437\u0432\u0440\u0430\u0449\u0430\u0435\u0442\u0441\u044f \u0435\u0451 \u0438\u043c\u044f, \u0434\u0430\u043b\u0435\u0435 \u043e\u043d\u043e \u0431\u0443\u0434\u0435\u0442 \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u043d\u043e \u0434\u043b\u044f \u043e\u0442\u043f\u0440\u0430\u0432\u043a\u0438 \u0441\u0438\u043d\u0442\u0430\u043a\u0441\u0438\u0441\u0430 \u044d\u0442\u043e\u0439 \u043a\u043e\u043c\u0430\u043d\u0434\u044b.<\/p>\n
\nMessageRequest::from<\/summary>\n
\n
impl MessageRequest {     pub fn from(text: String) -> Option<Self> {         let text: Vec<String> = text.split(' ').map(|w| w.to_string()).collect();         if text.is_empty() {             return None;         }          let command = text[0].as_str();         match command {             \"\/watch\" | \"\/unwatch\" => {                 let incorrect_command = Some(Self::IncorrectCommand(command.to_string()));                  if text.len() < 5 {                     if text.len() == 2 && text[1] == \"all\" {                         return Some(Self::UnwatchAll);                     }                     return incorrect_command;                 }                  \/\/ waiting for let-chain                 if let Some(watch) = Watch::new(\"itmo\", &text[2], &text[3], &text[4]) {                     if watch.degree == Degree::Master {                         return match command {                             \"\/watch\" => Some(Self::Watch(watch)),                             \"\/unwatch\" => Some(Self::Unwatch(watch)),                             _ => incorrect_command,                         };                     }                 }                  incorrect_command             }             \"\/about\" => Some(Self::About),             \"\/help\" => Some(Self::Help),             \"\/start\" => Some(Self::Start),             _ => None,         }     } } <\/code><\/pre>\n<\/p>\n<\/div>\n<\/details>\n
\u0421\u0442\u0440\u0443\u043a\u0442\u0443\u0440\u0430 MessageRequest<\/code> \u0438 \u0432\u0441\u043f\u043e\u043c\u043e\u0433\u0430\u0442\u0435\u043b\u044c\u043d\u044b\u0435 Degree<\/code> \u0438 Watch<\/code>:<\/p>\n
\n\u041c\u043e\u0434\u0435\u043b\u0438 \u0437\u0430\u043f\u0440\u043e\u0441\u0430 \u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u0435\u043b\u044f<\/summary>\n
\n
pub enum Degree {     Bachelor,     Master,     Postgraduate, }  pub struct Watch {     pub uni: String,     pub degree: Degree,     pub program_id: String,     pub case_number: String, }  pub enum MessageRequest {     About,     Help,     Start,     Unwatch(Watch),     UnwatchAll,     Watch(Watch),     IncorrectCommand(String), } <\/code><\/pre>\n<\/p>\n<\/div>\n<\/details>\n
MessageRequest<\/code> \u043e\u0431\u0440\u0430\u0431\u0430\u0442\u044b\u0432\u0430\u0435\u0442\u0441\u044f \u0442\u0430\u043a. \u0414\u043b\u044f \u043f\u0440\u043e\u0441\u0442\u044b\u0445 \u043a\u043e\u043c\u0430\u043d\u0434 \u043e\u0442\u043f\u0440\u0430\u0432\u043b\u044f\u0435\u043c \u0441\u043e\u043e\u0442\u0432\u0435\u0442\u0441\u0442\u0432\u0443\u044e\u0449\u0438\u0435 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f, \u043a\u043e\u043c\u0430\u043d\u0434\u044b \/watch<\/code> \u0438 \/unwatch<\/code> \u043e\u0431\u0440\u0430\u0431\u0430\u0442\u044b\u0432\u0430\u0435\u043c (\u0441\u0430\u043c\u0430 \u0444\u0443\u043d\u043a\u0446\u0438\u044f \u043e\u0431\u0440\u0430\u0431\u043e\u0442\u043a\u0438 \u0447\u0443\u0442\u044c \u043d\u0438\u0436\u0435).<\/p>\n
\nhandle_message_request<\/summary>\n
\n
async fn handle_message_request(     db: &DB,     request: MessageRequest,     chat_id: &str, ) -> Result<(), CrateError> {     match request {         MessageRequest::Watch(args) => {             let result = handle_competition(db, chat_id, &args.degree.to_string(), &args.case_number, &args.program_id, true).await;             if let Err(_) = result {                 send_message(messages::rating_not_found, chat_id).await?;             }         }         MessageRequest::Unwatch(args) => {             db.delete_competition(                 &args.case_number,                 chat_id,                 &args.program_id,                 &args.degree.to_string(),             )?;             send_message(messages::done, chat_id).await?;         }         MessageRequest::UnwatchAll => {             db.delete_competition_by_user(chat_id)?;             send_message(messages::done, chat_id).await?;         }         MessageRequest::IncorrectCommand(command) => {             send_incorrect_command_message(&command, chat_id).await?         }         MessageRequest::Help => send_message(messages::help, chat_id).await?,         MessageRequest::Start => send_message(messages::start, chat_id).await?,         MessageRequest::About => send_message(messages::about, chat_id).await?,     };     Ok(()) } <\/code><\/pre>\n<\/p>\n<\/div>\n<\/details>\n
\u041a\u043e\u0434 \u043e\u0431\u0440\u0430\u0431\u043e\u0442\u043a\u0438 \u0434\u043e\u0432\u043e\u043b\u044c\u043d\u043e \u0441\u043a\u0443\u0447\u043d\u044b\u0439, \u043d\u043e \u0434\u043e\u0432\u043e\u043b\u044c\u043d\u043e \u0431\u043e\u043b\u044c\u0448\u043e\u0439. \u0421\u043d\u0430\u0447\u0430\u043b\u0430 \u043f\u043e\u043b\u0443\u0447\u0430\u0435\u0442\u0441\u044f \u043f\u043e\u0437\u0438\u0446\u0438\u044f, \u0434\u043e\u0441\u0442\u0430\u0435\u0442\u0441\u044f \u0443\u0436\u0435 \u0440\u0430\u043d\u0435\u0435 \u0437\u0430\u043f\u0440\u043e\u0448\u0435\u043d\u043d\u0430\u044f \u043f\u043e\u0437\u0438\u0446\u0438\u044f \u0438\u0437 \u0431\u0430\u0437\u044b, \u0435\u0441\u043b\u0438 \u043e\u043d\u0438 \u043d\u0435 \u0441\u043e\u0432\u043f\u0430\u0434\u0430\u044e\u0442, \u0442\u043e \u043e\u0442\u0441\u044b\u043b\u0430\u0435\u0442\u0441\u044f \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 \u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u0435\u043b\u044e, \u0438 \u0437\u043d\u0430\u0447\u0435\u043d\u0438\u0435 \u0432 \u0431\u0430\u0437\u0435 \u043e\u0431\u043d\u043e\u0432\u043b\u044f\u0435\u0442\u0441\u044f. \u0415\u0441\u043b\u0438 \u043d\u0435 \u0440\u0430\u0432\u043d\u044b, \u0442\u043e \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 \u043e\u0442\u0441\u044b\u043b\u0430\u0435\u0442\u0441\u044f \u0442\u043e\u043b\u044c\u043a\u043e \u0432 \u0441\u043b\u0443\u0447\u0430\u0435, \u0435\u0441\u043b\u0438 \u044d\u0442\u0430 \u0444\u0443\u043d\u043a\u0446\u0438\u044f \u0431\u044b\u043b\u0430 \u0432\u044b\u0437\u0432\u0430\u043d\u0430 \u043f\u043e\u0441\u043b\u0435 \u043e\u0431\u0440\u0430\u0431\u043e\u0442\u043a\u0438 \u043a\u043e\u043c\u0430\u043d\u0434\u044b \u043e\u0442 \u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u0442\u0435\u043b\u044f, \u0430 \u043d\u0435 \u043d\u0430 \u044d\u0442\u0430\u043f\u0435 \u0440\u0435\u0433\u0443\u043b\u044f\u0440\u043d\u043e\u0439 \u043f\u0440\u043e\u0432\u0435\u0440\u043a\u0438 \u043e\u0431\u043d\u043e\u0432\u043b\u0435\u043d\u0438\u0439. \u0417\u0430 \u044d\u0442\u043e \u043e\u0442\u0432\u0435\u0447\u0430\u0435\u0442 \u043f\u0430\u0440\u0430\u043c\u0435\u0442\u0440 is_user_request<\/code>:<\/p>\n
\nhandle_competition<\/summary>\n
\n
pub async fn handle_competition(     db: &DB,     chat_id: &str,     degree: &str,     case_number: &str,     program_id: &str,     is_user_request: bool, ) -> Result<(), Box<dyn std::error::Error>> {     let competition = get_rating_competition(db, degree, program_id, case_number).await?;      match db.select_competition(chat_id, case_number, degree, program_id) {         Ok(old_competition) => {             if let Some(competition) = competition {                 let program = db.select_program(\"itmo\", program_id)?;                 let program_name = if let Some(program) = program {                     program.title_ru                 } else {                     \"\u041d\u0430\u0437\u0432\u0430\u043d\u0438\u044f \u043d\u0435\u0442\".to_string()                 };                  let mut should_send_message = false;                  \/\/ update if competition is old (competition != old_competition)                 \/\/ insert if is new (when old == None, on first user request)                 if let Some(old_competition) = old_competition {                     if competition != old_competition {                         db.update_competition(&competition, chat_id, program_id, degree)?;                         should_send_message = true;                     }                 } else {                     db.insert_competition(&competition, chat_id, program_id, degree)?;                 }                  \/\/ send if it's user request or record in db was updated                 if is_user_request || should_send_message {                     send_competition_message(&competition, chat_id, &program_name).await?;                 }             }         }         Err(e) => {             eprintln!(\"cannot select competition: {e}\")         }     };     Ok(()) } <\/code><\/pre>\n<\/p>\n<\/div>\n<\/details>\n
\u041e\u0442\u043f\u0440\u0430\u0432\u043a\u0430 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f \u0432\u044b\u0433\u043b\u044f\u0434\u0438\u0442 \u0442\u0430\u043a. \u042d\u043a\u0440\u0430\u043d\u0438\u0440\u0443\u0435\u043c \u043d\u0435\u043a\u043e\u0442\u043e\u0440\u044b\u0435 \u0441\u0438\u043c\u0432\u043e\u043b\u044b, \u043e\u0442\u043f\u0440\u0430\u0432\u043b\u044f\u0435\u043c \u0437\u0430\u043f\u0440\u043e\u0441, \u043f\u0440\u043e\u0432\u0435\u0440\u044f\u0435\u043c \u0440\u0435\u0437\u0443\u043b\u044c\u0442\u0430\u0442.<\/p>\n
\nsend_message<\/summary>\n
\n
pub async fn send_message(text: &str, chat_id: &str) -> Result<(), Box<dyn std::error::Error>> {     let text = &text.replace('-', \"\\\\-\").replace('.', \"\\\\.\");      let params = [         (\"chat_id\", chat_id),         (\"text\", text),         (\"parse_mode\", \"MarkdownV2\"),     ];      let url =         reqwest::Url::parse_with_params(&format!(\"{TG_API_PREFIX}{TOKEN}\/sendMessage\"), &params)?;     let response = reqwest::get(url).await?;     if !response.status().is_success() {         let error: ErrorResponse = response.json().await?;         let msg = \"Cannot send message request\";         if let Some(description) = error.description {             eprintln!(\"{msg}: {description}\");         }         return Err(Box::from(msg));     }      let data: SendMessageResponse = response.json().await?;      if !data.ok {         eprintln!(             \"Cannot send message: {}\",             data.description                 .unwrap_or_else(|| \"error has no description\".to_string())         )     }      Ok(()) } <\/code><\/pre>\n<\/p>\n<\/div>\n<\/details>\n
\u041e\u0431\u044a\u0435\u0434\u0438\u043d\u044f\u0435\u043c<\/h4>\n
\u0412 \u0444\u0443\u043d\u043a\u0446\u0438\u0438 main<\/code> \u0441\u043d\u0430\u0447\u0430\u043b\u0430 \u0437\u0430\u043f\u0440\u0430\u0448\u0438\u0432\u0430\u0435\u0442\u0441\u044f \u0441\u043f\u0438\u0441\u043e\u043a \u0432\u0441\u0435\u0445 \u043f\u0440\u043e\u0433\u0440\u0430\u043c\u043c (\u0434\u043b\u044f \u0441\u043e\u0445\u0440\u0430\u043d\u0435\u043d\u0438\u044f \u0438\u0445 \u043d\u0430\u0437\u0432\u0430\u043d\u0438\u0439), \u0434\u0430\u043b\u0435\u0435 \u0437\u0430\u043f\u0443\u0441\u043a\u0430\u0435\u0442\u0441\u044f \u0431\u0435\u0441\u043a\u043e\u043d\u0435\u0447\u043d\u044b\u0439 \u0446\u0438\u043a\u043b, \u043a\u043e\u0442\u043e\u0440\u044b\u0439 \u043a\u0430\u0436\u0434\u0443\u044e \u0441\u0435\u043a\u0443\u043d\u0434\u0443 \u043f\u0440\u043e\u0432\u0435\u0440\u044f\u0435\u0442 \u043e\u0431\u043d\u043e\u0432\u043b\u0435\u043d\u0438\u044f \u0441\u043e \u0441\u0442\u043e\u0440\u043e\u043d\u044b \u0442\u0435\u043b\u0435\u0433\u0440\u0430\u043c\u0430, \u0432\u044b\u0437\u044b\u0432\u0430\u044f \u0444\u0443\u043d\u043a\u0446\u0438\u044e handle_updates<\/code>, \u0430 \u0442\u0430\u043a\u0436\u0435 \u0440\u0430\u0437 \u0432 \u043f\u0440\u0438\u043c\u0435\u0440\u043d\u043e 10 \u043c\u0438\u043d\u0443\u0442 \u043f\u0440\u043e\u0432\u0435\u0440\u044f\u0435\u0442 \u043e\u0431\u043d\u043e\u0432\u043b\u0435\u043d\u0438\u044f \u0440\u0435\u0439\u0442\u0438\u043d\u0433\u043e\u0432 \u0438 \u0440\u0430\u0441\u0441\u044b\u043b\u0430\u0435\u0442 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f \u043e\u0431 \u043e\u0431\u043d\u043e\u0432\u043b\u0435\u043d\u0438\u0438. #[tokio::main]<\/code> \u043d\u0443\u0436\u043d\u043e \u0434\u043b\u044f \u0441\u0442\u0430\u0440\u0442\u0430 main \u0441\u0440\u0430\u0437\u0443 \u043a\u0430\u043a \u0430\u0441\u0438\u043d\u0445\u0440\u043e\u043d\u043d\u043e\u0439 \u0444\u0443\u043d\u043a\u0446\u0438\u0438, \u0431\u0435\u0437 \u043d\u0435\u043e\u0431\u0445\u043e\u0434\u0438\u043c\u043e\u0441\u0442\u0438 \u0440\u0443\u0447\u043d\u043e\u0433\u043e \u0441\u043e\u0437\u0434\u0430\u043d\u0438\u044f loop-\u0430.<\/p>\n
\nmain<\/summary>\n
\n
const TEN_MIN_IN_SEC: i32 = 10 * 60;  #[tokio::main] async fn main() -> Result<(), Box<dyn std::error::Error>> {     let db = init_db()?;      load_programs(&db).await.unwrap();      let mut offset = 0;     let mut sec_counter = 0;     loop {         offset = handle_updates(&db, offset).await.unwrap();          if sec_counter == 0 {             check_rating_updates(&db).await?;         }         sec_counter = (sec_counter + 1) % TEN_MIN_IN_SEC;          time::sleep(time::Duration::from_secs(1)).await;     } } <\/code><\/pre>\n<\/p>\n<\/div>\n<\/details>\n
\ncheck_rating_updates<\/summary>\n
\n
async fn check_rating_updates(db: &DB) -> Result<(), Box<dyn std::error::Error>> {     \/\/ select registered watchers from 'results'     for c in db.select_all_competitions()? {         if let Some(case_number) = c.competition.case_number {             handle_competition(db, &c.tg_chat_id, &c.degree, &case_number, &c.program_id, false)             .await?;         }     }     Ok(()) }<\/code><\/pre>\n<\/p>\n<\/div>\n<\/details>\n
\u0418\u0442\u043e\u0433\u0438<\/h3>\n
\u041d\u0430\u0434\u0435\u044e\u0441\u044c, \u044d\u0442\u043e\u0442 \u0431\u043e\u0442 \u043f\u043e\u043c\u043e\u0436\u0435\u0442 \u043a\u043e\u043c\u0443-\u043d\u0438\u0431\u0443\u0434\u044c \u0435\u0449\u0451 \u043a\u0440\u043e\u043c\u0435 \u043c\u0435\u043d\u044f. \u0421\u0441\u044b\u043b\u043a\u0430 \u043d\u0430 \u0431\u043e\u0442\u0430 @uni_rating_checker_bot<\/a> \u0438 \u043d\u0430 \u0438\u0441\u0445\u043e\u0434\u043d\u044b\u0439 \u043a\u043e\u0434<\/a><\/p>\n
P.S.<\/h4>\n