Bump diesel from 2.2.8 to 2.2.9

Bumps [diesel](https://github.com/diesel-rs/diesel) from 2.2.8 to 2.2.9.
- [Release notes](https://github.com/diesel-rs/diesel/releases)
- [Changelog](https://github.com/diesel-rs/diesel/blob/v2.2.9/CHANGELOG.md)
- [Commits](https://github.com/diesel-rs/diesel/compare/v2.2.8...v2.2.9)

---
updated-dependencies:
- dependency-name: diesel
  dependency-version: 2.2.9
  dependency-type: direct:production
  update-type: version-update:semver-patch
...

Signed-off-by: dependabot[bot] <support@github.com>

.github/workflows/test.yml

@@ -28,3 +28,5 @@ jobs:
         env:
           DATABASE_URL: ${{ secrets.TEST_DATABASE_URL }}
           JWT_SECRET: "test-secret-at-least-256-bits-used"
+          VKID_CLIENT_ID: 0
+          VKID_REDIRECT_URI: "vk0://vk.com/blank.html"

.gitignore

@@ -4,3 +4,4 @@ schedule.json
 teachers.json
 
 .env*
+/*-firebase-adminsdk-*.json

.idea/schedule-parser-rusted.iml

@@ -10,6 +10,7 @@
       <excludeFolder url="file://$MODULE_DIR$/actix-macros/target" />
       <excludeFolder url="file://$MODULE_DIR$/actix-test/target" />
       <excludeFolder url="file://$MODULE_DIR$/target" />
+      <excludeFolder url="file://$MODULE_DIR$/.idea/dataSources" />
     </content>
     <orderEntry type="inheritedJdk" />
     <orderEntry type="sourceFolder" forTests="false" />

Cargo.toml

@@ -18,6 +18,7 @@ diesel = { version = "2.2.9", features = ["postgres"] }
 diesel-derive-enum = { git = "https://github.com/Havunen/diesel-derive-enum.git", features = ["postgres"] }
 dotenvy = "0.15.7"
 env_logger = "0.11.7"
+firebase-messaging-rs = { git = "ssh://git@github.com/i10416/firebase-messaging-rs.git" }
 futures-util = "0.3.31"
 fuzzy-matcher = "0.3.7"
 jsonwebtoken = { version = "9.3.1", features = ["use_pem"] }
@@ -25,7 +26,7 @@ hex = "0.4.3"
 mime = "0.3.17"
 objectid = "0.2.0"
 regex = "1.11.1"
-reqwest = "0.12.15"
+reqwest = { version = "0.12.15", features = ["json"] }
 serde = { version = "1.0.219", features = ["derive"] }
 serde_json = "1.0.140"
 serde_with = "3.12.0"
@@ -36,6 +37,7 @@ rand = "0.9.0"
 utoipa = { version = "5", features = ["actix_extras", "chrono"] }
 utoipa-rapidoc = { version = "6.0.0", features = ["actix-web"] }
 utoipa-actix-web = "0.1"
+uuid = { version = "1.16.0", features = ["v4"] }
 
 [dev-dependencies]
 actix-test = { path = "actix-test" }

migrations/00000000000000_diesel_initial_setup/down.sql

@@ -1,4 +1,4 @@
--- This file was automatically created by Diesel to setup helper functions
+-- This file was automatically created by Diesel to set up helper functions
 -- and other internal bookkeeping. This file is safe to edit, any future
 -- changes will be added to existing projects as new migrations.
 

migrations/00000000000000_diesel_initial_setup/up.sql

@@ -1,4 +1,4 @@
--- This file was automatically created by Diesel to setup helper functions
+-- This file was automatically created by Diesel to set up helper functions
 -- and other internal bookkeeping. This file is safe to edit, any future
 -- changes will be added to existing projects as new migrations.
 

migrations/2025-03-21-212111_create_users/up.sql

@@ -2,7 +2,7 @@ CREATE TABLE users
 (
     id           text PRIMARY KEY NOT NULL,
     username     text UNIQUE      NOT NULL,
-    "password"   text             NOT NULL,
+    password     text             NOT NULL,
     vk_id        int4             NULL,
     access_token text UNIQUE      NOT NULL,
     "group"      text             NOT NULL,

migrations/2025-03-21-212723_create_fcm/up.sql

@@ -1,11 +1,6 @@
 CREATE TABLE fcm
 (
-    user_id text PRIMARY KEY NOT NULL,
+    user_id text PRIMARY KEY NOT NULL REFERENCES users (id),
     token   text             NOT NULL,
-    topics  text[]           NULL
+    topics  text[]           NOT NULL CHECK ( array_position(topics, null) is null )
 );
-
-CREATE UNIQUE INDEX fcm_user_id_key ON fcm USING btree (user_id);
-
-ALTER TABLE fcm
-    ADD CONSTRAINT fcm_user_id_fkey FOREIGN KEY (user_id) REFERENCES users (id) ON DELETE RESTRICT ON UPDATE CASCADE;

src/app_state.rs

@@ -4,10 +4,11 @@ use crate::xls_downloader::basic_impl::BasicXlsDownloader;
 use actix_web::web;
 use chrono::{DateTime, Utc};
 use diesel::{Connection, PgConnection};
+use firebase_messaging_rs::FCMClient;
 use sha1::{Digest, Sha1};
 use std::env;
 use std::hash::Hash;
-use std::sync::{Mutex, MutexGuard};
+use std::sync::Mutex;
 
 #[derive(Clone)]
 pub struct Schedule {
@@ -18,6 +19,24 @@ pub struct Schedule {
     pub data: ParseResult,
 }
 
+#[derive(Clone)]
+pub struct VkId {
+    pub client_id: i32,
+    pub redirect_url: String,
+}
+
+impl VkId {
+    pub fn new() -> Self {
+        Self {
+            client_id: env::var("VKID_CLIENT_ID")
+                .expect("VKID_CLIENT_ID must be set")
+                .parse()
+                .expect("VKID_CLIENT_ID must be integer"),
+            redirect_url: env::var("VKID_REDIRECT_URI").expect("VKID_REDIRECT_URI must be set"),
+        }
+    }
+}
+
 impl Schedule {
     pub fn hash(&self) -> String {
         let mut hasher = DigestHasher::from(Sha1::new());
@@ -31,30 +50,39 @@ impl Schedule {
     }
 }
 
-/// Общие данные передаваемые в эндпоинты
+/// Common data provided to endpoints.
 pub struct AppState {
     pub downloader: Mutex<BasicXlsDownloader>,
     pub schedule: Mutex<Option<Schedule>>,
     pub database: Mutex<PgConnection>,
+    pub vk_id: VkId,
+    pub fcm_client: Option<Mutex<FCMClient>>, // в рантайме не меняется, так что опционален мьютекс, а не данные в нём.
 }
 
 impl AppState {
-    /// Получение объекта соединения с базой данных PostgreSQL
+    pub async fn new() -> Self {
-    pub fn connection(&self) -> MutexGuard<PgConnection> {
+        let database_url = env::var("DATABASE_URL").expect("DATABASE_URL must be set");
-        self.database.lock().unwrap()
+
+        Self {
+            downloader: Mutex::new(BasicXlsDownloader::new()),
+            schedule: Mutex::new(None),
+            database: Mutex::new(
+                PgConnection::establish(&database_url)
+                    .unwrap_or_else(|_| panic!("Error connecting to {}", database_url)),
+            ),
+            vk_id: VkId::new(),
+            fcm_client: if env::var("GOOGLE_APPLICATION_CREDENTIALS").is_ok() {
+                Some(Mutex::new(
+                    FCMClient::new().await.expect("FCM client must be created"),
+                ))
+            } else {
+                None
+            },
+        }
     }
 }
 
-/// Создание нового объекта web::Data<AppState>
+/// Create a new object web::Data<AppState>.
-pub fn app_state() -> web::Data<AppState> {
+pub async fn app_state() -> web::Data<AppState> {
-    let database_url = env::var("DATABASE_URL").expect("DATABASE_URL must be set");
+    web::Data::new(AppState::new().await)
-
-    web::Data::new(AppState {
-        downloader: Mutex::new(BasicXlsDownloader::new()),
-        schedule: Mutex::new(None),
-        database: Mutex::new(
-            PgConnection::establish(&database_url)
-                .unwrap_or_else(|_| panic!("Error connecting to {}", database_url)),
-        ),
-    })
 }

src/database/driver.rs

@@ -1,103 +1,163 @@
 pub mod users {
+    use crate::app_state::AppState;
     use crate::database::models::User;
     use crate::database::schema::users::dsl::users;
     use crate::database::schema::users::dsl::*;
+    use crate::utility::mutex::MutexScope;
+    use actix_web::web;
     use diesel::{ExpressionMethods, QueryResult, insert_into};
-    use diesel::{PgConnection, SelectableHelper};
     use diesel::{QueryDsl, RunQueryDsl};
-    use std::ops::DerefMut;
+    use diesel::{SaveChangesDsl, SelectableHelper};
-    use std::sync::Mutex;
 
-    pub fn get(connection: &Mutex<PgConnection>, _id: &String) -> QueryResult<User> {
+    pub fn get(state: &web::Data<AppState>, _id: &String) -> QueryResult<User> {
-        let mut lock = connection.lock().unwrap();
+        state.database.scope(|conn| {
-        let con = lock.deref_mut();
+            users
-
+                .filter(id.eq(_id))
-        users
+                .select(User::as_select())
-            .filter(id.eq(_id))
+                .first(conn)
-            .select(User::as_select())
+        })
-            .first(con)
     }
 
-    pub fn get_by_username(
+    pub fn get_by_username(state: &web::Data<AppState>, _username: &String) -> QueryResult<User> {
-        connection: &Mutex<PgConnection>,
+        state.database.scope(|conn| {
-        _username: &String,
+            users
-    ) -> QueryResult<User> {
+                .filter(username.eq(_username))
-        let mut lock = connection.lock().unwrap();
+                .select(User::as_select())
-        let con = lock.deref_mut();
+                .first(conn)
-
+        })
-        users
-            .filter(username.eq(_username))
-            .select(User::as_select())
-            .first(con)
     }
 
-    pub fn get_by_vk_id(
+    //noinspection RsTraitObligations
-        connection: &Mutex<PgConnection>,
+    pub fn get_by_vk_id(state: &web::Data<AppState>, _vk_id: i32) -> QueryResult<User> {
-        _vk_id: i32,
+        state.database.scope(|conn| {
-    ) -> QueryResult<User> {
+            users
-        let mut lock = connection.lock().unwrap();
+                .filter(vk_id.eq(_vk_id))
-        let con = lock.deref_mut();
+                .select(User::as_select())
-
+                .first(conn)
-        users
+        })
-            .filter(vk_id.eq(_vk_id))
-            .select(User::as_select())
-            .first(con)
     }
 
-    pub fn contains_by_username(connection: &Mutex<PgConnection>, _username: &String) -> bool {
+    //noinspection DuplicatedCode
-        let mut lock = connection.lock().unwrap();
+    pub fn contains_by_username(state: &web::Data<AppState>, _username: &String) -> bool {
-        let con = lock.deref_mut();
+        // и как это нахуй сократить блять примеров нихуя нет, нихуя не работает
-
+        // как меня этот раст заебал уже
-        match users
+        state.database.scope(|conn| {
-            .filter(username.eq(_username))
+            match users
-            .count()
+                .filter(username.eq(_username))
-            .get_result::<i64>(con)
+                .count()
-        {
+                .get_result::<i64>(conn)
-            Ok(count) => count > 0,
+            {
-            Err(_) => false,
+                Ok(count) => count > 0,
-        }
+                Err(_) => false,
+            }
+        })
     }
 
-    pub fn contains_by_vk_id(connection: &Mutex<PgConnection>, _vk_id: i32) -> bool {
+    //noinspection DuplicatedCode
-        let mut lock = connection.lock().unwrap();
+    //noinspection RsTraitObligations
-        let con = lock.deref_mut();
+    pub fn contains_by_vk_id(state: &web::Data<AppState>, _vk_id: i32) -> bool {
-
+        state.database.scope(|conn| {
-        match users
+            match users
-            .filter(vk_id.eq(_vk_id))
+                .filter(vk_id.eq(_vk_id))
-            .count()
+                .count()
-            .get_result::<i64>(con)
+                .get_result::<i64>(conn)
-        {
+            {
-            Ok(count) => count > 0,
+                Ok(count) => count > 0,
-            Err(_) => false,
+                Err(_) => false,
-        }
+            }
+        })
     }
 
-    pub fn insert(connection: &Mutex<PgConnection>, user: &User) -> QueryResult<usize> {
+    pub fn insert(state: &web::Data<AppState>, user: &User) -> QueryResult<usize> {
-        let mut lock = connection.lock().unwrap();
+        state
-        let con = lock.deref_mut();
+            .database
-
+            .scope(|conn| insert_into(users).values(user).execute(conn))
-        insert_into(users).values(user).execute(con)
     }
 
-    #[cfg(test)]
+    /// Function declaration [User::save][UserSave::save].
-    pub fn delete_by_username(connection: &Mutex<PgConnection>, _username: &String) -> bool {
+    pub trait UserSave {
-        let mut lock = connection.lock().unwrap();
+        /// Saves the user's changes to the database.
-        let con = lock.deref_mut();
+        ///
+        /// # Arguments
+        ///
+        /// * `state`: The state of the actix-web application that stores the mutex of the [connection][diesel::PgConnection].
+        ///
+        /// returns: `QueryResult<User>`
+        ///
+        /// # Examples
+        ///
+        /// ```
+        /// use crate::database::driver::users;
+        ///
+        /// #[derive(Deserialize)]
+        /// struct Params {
+        ///     pub username: String,
+        /// }
+        ///
+        /// #[patch("/")]
+        /// async fn patch_user(
+        ///     app_state: web::Data<AppState>,
+        ///     user: SyncExtractor<User>,
+        ///     web::Query(params): web::Query<Params>,
+        /// ) -> web::Json<User> {
+        ///     let mut user = user.into_inner();
+        ///
+        ///     user.username = params.username;
+        ///
+        ///     match user.save(&app_state) {
+        ///         Ok(user) => web::Json(user),
+        ///         Err(e) => {
+        ///             eprintln!("Failed to save user: {e}");
+        ///             panic!();
+        ///         }
+        ///     }
+        /// }
+        /// ```
+        fn save(&self, state: &web::Data<AppState>) -> QueryResult<User>;
+    }
 
-        match diesel::delete(users.filter(username.eq(_username))).execute(con) {
+    /// Implementation of [UserSave][UserSave] trait.
-            Ok(count) => count > 0,
+    impl UserSave for User {
-            Err(_) => false,
+        fn save(&self, state: &web::Data<AppState>) -> QueryResult<User> {
+            state.database.scope(|conn| self.save_changes::<Self>(conn))
         }
     }
 
     #[cfg(test)]
-    pub fn insert_or_ignore(connection: &Mutex<PgConnection>, user: &User) -> QueryResult<usize> {
+    pub fn delete_by_username(state: &web::Data<AppState>, _username: &String) -> bool {
-        let mut lock = connection.lock().unwrap();
+        state.database.scope(|conn| {
-        let con = lock.deref_mut();
+            match diesel::delete(users.filter(username.eq(_username))).execute(conn) {
+                Ok(count) => count > 0,
+                Err(_) => false,
+            }
+        })
+    }
 
-        insert_into(users)
+    #[cfg(test)]
-            .values(user)
+    pub fn insert_or_ignore(state: &web::Data<AppState>, user: &User) -> QueryResult<usize> {
-            .on_conflict_do_nothing()
+        state.database.scope(|conn| {
-            .execute(con)
+            insert_into(users)
+                .values(user)
+                .on_conflict_do_nothing()
+                .execute(conn)
+        })
+    }
+}
+
+pub mod fcm {
+    use crate::app_state::AppState;
+    use crate::database::models::{FCM, User};
+    use crate::utility::mutex::MutexScope;
+    use actix_web::web;
+    use diesel::QueryDsl;
+    use diesel::RunQueryDsl;
+    use diesel::{BelongingToDsl, QueryResult, SelectableHelper};
+
+    pub fn from_user(state: &web::Data<AppState>, user: &User) -> QueryResult<FCM> {
+        state.database.scope(|conn| {
+            FCM::belonging_to(&user)
+                .select(FCM::as_select())
+                .get_result(conn)
+        })
     }
 }

src/database/models.rs

@@ -1,16 +1,11 @@
 use actix_macros::ResponderJson;
+use diesel::QueryId;
 use diesel::prelude::*;
 use serde::{Deserialize, Serialize};
+use utoipa::ToSchema;
 
 #[derive(
-    diesel_derive_enum::DbEnum,
+    Copy, Clone, PartialEq, Debug, Serialize, Deserialize, diesel_derive_enum::DbEnum, ToSchema,
-    Serialize,
-    Deserialize,
-    Debug,
-    Clone,
-    Copy,
-    PartialEq,
-    utoipa::ToSchema,
 )]
 #[ExistingTypePath = "crate::database::schema::sql_types::UserRole"]
 #[DbValueStyle = "UPPERCASE"]
@@ -25,37 +20,65 @@ pub enum UserRole {
     Identifiable,
     AsChangeset,
     Queryable,
+    QueryId,
     Selectable,
     Serialize,
     Insertable,
     Debug,
-    utoipa::ToSchema,
+    ToSchema,
     ResponderJson,
 )]
 #[diesel(table_name = crate::database::schema::users)]
 #[diesel(treat_none_as_null = true)]
 pub struct User {
-    /// UUID аккаунта
+    /// Account UUID.
     pub id: String,
 
-    /// Имя пользователя
+    /// User name.
     pub username: String,
 
-    /// BCrypt хеш пароля
+    /// BCrypt password hash.
     pub password: String,
 
-    /// Идентификатор привязанного аккаунта VK
+    /// ID of the linked VK account.
     pub vk_id: Option<i32>,
 
-    /// JWT токен доступа
+    /// JWT access token.
     pub access_token: String,
 
-    /// Группа
+    /// Group.
     pub group: String,
 
-    /// Роль
+    /// Role.
     pub role: UserRole,
 
-    /// Версия установленного приложения Polytechnic+
+    /// Version of the installed Polytechnic+ application.
     pub version: String,
 }
+
+#[derive(
+    Debug,
+    Clone,
+    Serialize,
+    Identifiable,
+    Queryable,
+    Selectable,
+    Insertable,
+    AsChangeset,
+    Associations,
+    ToSchema,
+    ResponderJson,
+)]
+#[diesel(belongs_to(User))]
+#[diesel(table_name = crate::database::schema::fcm)]
+#[diesel(primary_key(user_id))]
+pub struct FCM {
+    /// Account UUID.
+    pub user_id: String,
+
+    /// FCM token.
+    pub token: String,
+
+    /// List of topics subscribed to by the user.
+    pub topics: Vec<Option<String>>,
+}

src/database/schema.rs

@@ -10,7 +10,7 @@ diesel::table! {
     fcm (user_id) {
         user_id -> Text,
         token -> Text,
-        topics -> Nullable<Array<Nullable<Text>>>,
+        topics -> Array<Nullable<Text>>,
     }
 }
 

src/extractors/authorized_user.rs

@@ -1,13 +1,13 @@
 use crate::app_state::AppState;
 use crate::database::driver;
-use crate::database::models::User;
+use crate::database::models::{FCM, User};
-use crate::extractors::base::FromRequestSync;
+use crate::extractors::base::{FromRequestSync, SyncExtractor};
 use crate::utility::jwt;
 use actix_macros::ResponseErrorMessage;
 use actix_web::body::BoxBody;
 use actix_web::dev::Payload;
 use actix_web::http::header;
-use actix_web::{HttpRequest, web};
+use actix_web::{FromRequest, HttpRequest, web};
 use derive_more::Display;
 use serde::{Deserialize, Serialize};
 use std::fmt::Debug;
@@ -16,19 +16,19 @@ use std::fmt::Debug;
 #[status_code = "actix_web::http::StatusCode::UNAUTHORIZED"]
 #[serde(rename_all = "SCREAMING_SNAKE_CASE")]
 pub enum Error {
-    /// В запросе отсутствует заголовок Authorization
+    /// There is no Authorization header in the request.
     #[display("No Authorization header found")]
     NoHeader,
 
-    /// Неизвестный тип авторизации, отличающийся от Bearer
+    /// Unknown authorization type other than Bearer.
     #[display("Bearer token is required")]
     UnknownAuthorizationType,
 
-    /// Токен не действителен
+    /// Invalid or expired access token.
     #[display("Invalid or expired access token")]
     InvalidAccessToken,
 
-    /// Пользователь привязанный к токену не найден в базе данных
+    /// The user bound to the token is not found in the database.
     #[display("No user associated with access token")]
     NoUser,
 }
@@ -39,7 +39,7 @@ impl Error {
     }
 }
 
-/// Экстрактор пользователя из запроса с токеном
+/// User extractor from request with Bearer access token.
 impl FromRequestSync for User {
     type Error = actix_web::Error;
 
@@ -63,6 +63,48 @@ impl FromRequestSync for User {
 
         let app_state = req.app_data::<web::Data<AppState>>().unwrap();
 
-        driver::users::get(&app_state.database, &user_id).map_err(|_| Error::NoUser.into())
+        driver::users::get(&app_state, &user_id).map_err(|_| Error::NoUser.into())
+    }
+}
+
+pub struct UserExtractor<const FCM: bool> {
+    user: User,
+
+    fcm: Option<FCM>,
+}
+
+impl<const FCM: bool> UserExtractor<{ FCM }> {
+    pub fn user(&self) -> &User {
+        &self.user
+    }
+
+    pub fn fcm(&self) -> &Option<FCM> {
+        if !FCM {
+            panic!("FCM marked as not required, but it has been requested")
+        }
+
+        &self.fcm
+    }
+}
+
+/// Extractor of user and additional parameters from request with Bearer token.
+impl<const FCM: bool> FromRequestSync for UserExtractor<{ FCM }> {
+    type Error = actix_web::Error;
+
+    fn from_request_sync(req: &HttpRequest, payload: &mut Payload) -> Result<Self, Self::Error> {
+        let user = SyncExtractor::<User>::from_request(req, payload)
+            .into_inner()?
+            .into_inner();
+
+        let app_state = req.app_data::<web::Data<AppState>>().unwrap();
+
+        Ok(Self {
+            fcm: if FCM {
+                driver::fcm::from_user(&app_state, &user).ok()
+            } else {
+                None
+            },
+            user,
+        })
     }
 }

src/extractors/base.rs

@@ -2,26 +2,64 @@ use actix_web::dev::Payload;
 use actix_web::{FromRequest, HttpRequest};
 use futures_util::future::LocalBoxFuture;
 use std::future::{Ready, ready};
+use std::ops;
 
-/// Асинхронный экстрактор объектов из запроса
+/// # Async extractor.
+
+/// Asynchronous object extractor from a query.
 pub struct AsyncExtractor<T>(T);
 
 impl<T> AsyncExtractor<T> {
     #[allow(dead_code)]
-    /// Получение объекта, извлечённого с помощью экстрактора
+    /// Retrieve the object extracted with the extractor.
     pub fn into_inner(self) -> T {
         self.0
     }
 }
 
+impl<T> ops::Deref for AsyncExtractor<T> {
+    type Target = T;
+
+    fn deref(&self) -> &Self::Target {
+        &self.0
+    }
+}
+
+impl<T> ops::DerefMut for AsyncExtractor<T> {
+    fn deref_mut(&mut self) -> &mut Self::Target {
+        &mut self.0
+    }
+}
+
 pub trait FromRequestAsync: Sized {
     type Error: Into<actix_web::Error>;
 
-    /// Асинхронная функция для извлечения данных из запроса
+    /// Asynchronous function for extracting data from a query.
+    ///
+    /// returns: Result<Self, Self::Error>
+    ///
+    /// # Examples
+    ///
+    /// ```
+    /// struct User {
+    ///     pub id: String,
+    ///     pub username: String,
+    /// }
+    ///
+    /// // TODO: Я вообще этот экстрактор не использую, нахуя мне тогда писать пример, если я не ебу как его использовать. Я забыл.
+    ///
+    /// #[get("/")]
+    /// fn get_user_async(
+    ///     user: web::AsyncExtractor<User>,
+    /// ) -> web::Json<User> {
+    ///     let user = user.into_inner();    
+    ///
+    ///     web::Json(user)
+    /// }
+    /// ```
     async fn from_request_async(req: HttpRequest, payload: Payload) -> Result<Self, Self::Error>;
 }
 
-/// Реализация треита FromRequest для всех асинхронных экстракторов
 impl<T: FromRequestAsync> FromRequest for AsyncExtractor<T> {
     type Error = T::Error;
     type Future = LocalBoxFuture<'static, Result<Self, Self::Error>>;
@@ -37,24 +75,72 @@ impl<T: FromRequestAsync> FromRequest for AsyncExtractor<T> {
     }
 }
 
-/// Синхронный экстрактор объектов из запроса
+/// # Sync extractor.
+
+/// Synchronous object extractor from a query.
 pub struct SyncExtractor<T>(T);
 
 impl<T> SyncExtractor<T> {
-    /// Получение объекта, извлечённого с помощью экстрактора
+    /// Retrieving an object extracted with the extractor.
     pub fn into_inner(self) -> T {
         self.0
     }
 }
 
+impl<T> ops::Deref for SyncExtractor<T> {
+    type Target = T;
+
+    fn deref(&self) -> &Self::Target {
+        &self.0
+    }
+}
+
+impl<T> ops::DerefMut for SyncExtractor<T> {
+    fn deref_mut(&mut self) -> &mut Self::Target {
+        &mut self.0
+    }
+}
+
 pub trait FromRequestSync: Sized {
     type Error: Into<actix_web::Error>;
 
-    /// Синхронная функция для извлечения данных из запроса
+    /// Synchronous function for extracting data from a query.
+    ///
+    /// returns: Result<Self, Self::Error>
+    ///
+    /// # Examples
+    ///
+    /// ```
+    /// struct User {
+    ///     pub id: String,
+    ///     pub username: String,
+    /// }
+    ///
+    /// impl FromRequestSync for User {
+    ///     type Error = actix_web::Error;
+    ///
+    ///     fn from_request_sync(req: &HttpRequest, _: &mut Payload) -> Result<Self, Self::Error> {
+    ///         // do magic here.
+    ///
+    ///         Ok(User {
+    ///             id: "qwerty".to_string(),
+    ///             username: "n08i40k".to_string()
+    ///         })
+    ///     }
+    /// }
+    ///
+    /// #[get("/")]
+    /// fn get_user_sync(
+    ///     user: web::SyncExtractor<User>,
+    /// ) -> web::Json<User> {
+    ///     let user = user.into_inner();    
+    ///
+    ///     web::Json(user)
+    /// }
+    /// ```
     fn from_request_sync(req: &HttpRequest, payload: &mut Payload) -> Result<Self, Self::Error>;
 }
 
-/// Реализация треита FromRequest для всех синхронных экстракторов
 impl<T: FromRequestSync> FromRequest for SyncExtractor<T> {
     type Error = T::Error;
     type Future = Ready<Result<Self, Self::Error>>;

src/main.rs

@@ -1,18 +1,11 @@
 use crate::app_state::{AppState, app_state};
 use crate::middlewares::authorization::JWTAuthorization;
-use crate::routes::auth::sign_in::{sign_in_default, sign_in_vk};
+use crate::middlewares::content_type::ContentTypeBootstrap;
-use crate::routes::auth::sign_up::{sign_up_default, sign_up_vk};
+use actix_web::dev::{ServiceFactory, ServiceRequest};
-use crate::routes::schedule::get_cache_status::get_cache_status;
+use actix_web::{App, Error, HttpServer};
-use crate::routes::schedule::get_group::get_group;
-use crate::routes::schedule::get_group_names::get_group_names;
-use crate::routes::schedule::get_schedule::get_schedule;
-use crate::routes::schedule::get_teacher::get_teacher;
-use crate::routes::schedule::get_teacher_names::get_teacher_names;
-use crate::routes::schedule::update_download_url::update_download_url;
-use crate::routes::users::me::me;
-use actix_web::{App, HttpServer};
 use dotenvy::dotenv;
 use utoipa_actix_web::AppExt;
+use utoipa_actix_web::scope::Scope;
 use utoipa_rapidoc::RapiDoc;
 
 mod app_state;
@@ -30,6 +23,52 @@ mod utility;
 
 mod test_env;
 
+pub fn get_api_scope<
+    I: Into<Scope<T>>,
+    T: ServiceFactory<ServiceRequest, Config = (), Error = Error, InitError = ()>,
+>(
+    scope: I,
+) -> Scope<T> {
+    let auth_scope = utoipa_actix_web::scope("/auth")
+        .service(routes::auth::sign_in)
+        .service(routes::auth::sign_in_vk)
+        .service(routes::auth::sign_up)
+        .service(routes::auth::sign_up_vk);
+
+    let users_scope = utoipa_actix_web::scope("/users")
+        .wrap(JWTAuthorization::default())
+        .service(routes::users::change_group)
+        .service(routes::users::change_username)
+        .service(routes::users::me);
+
+    let schedule_scope = utoipa_actix_web::scope("/schedule")
+        .wrap(JWTAuthorization {
+            ignore: &["/group-names", "/teacher-names"],
+        })
+        .service(routes::schedule::schedule)
+        .service(routes::schedule::update_download_url)
+        .service(routes::schedule::cache_status)
+        .service(routes::schedule::group)
+        .service(routes::schedule::group_names)
+        .service(routes::schedule::teacher)
+        .service(routes::schedule::teacher_names);
+
+    let fcm_scope = utoipa_actix_web::scope("/fcm")
+        .wrap(JWTAuthorization::default())
+        .service(routes::fcm::update_callback)
+        .service(routes::fcm::set_token);
+
+    let vk_id_scope = utoipa_actix_web::scope("/vkid") //
+        .service(routes::vk_id::oauth);
+
+    utoipa_actix_web::scope(scope)
+        .service(auth_scope)
+        .service(users_scope)
+        .service(schedule_scope)
+        .service(fcm_scope)
+        .service(vk_id_scope)
+}
+
 #[actix_web::main]
 async fn main() {
     dotenv().ok();
@@ -37,38 +76,13 @@ async fn main() {
     unsafe { std::env::set_var("RUST_LOG", "debug") };
     env_logger::init();
 
-    let app_state = app_state();
+    let app_state = app_state().await;
 
     HttpServer::new(move || {
-        let auth_scope = utoipa_actix_web::scope("/auth")
-            .service(sign_in_default)
-            .service(sign_in_vk)
-            .service(sign_up_default)
-            .service(sign_up_vk);
-
-        let users_scope = utoipa_actix_web::scope("/users")
-            .wrap(JWTAuthorization)
-            .service(me);
-
-        let schedule_scope = utoipa_actix_web::scope("/schedule")
-            .wrap(JWTAuthorization)
-            .service(get_schedule)
-            .service(update_download_url)
-            .service(get_cache_status)
-            .service(get_group)
-            .service(get_group_names)
-            .service(get_teacher)
-            .service(get_teacher_names);
-
-        let api_scope = utoipa_actix_web::scope("/api/v1")
-            .service(auth_scope)
-            .service(users_scope)
-            .service(schedule_scope);
-
         let (app, api) = App::new()
             .into_utoipa_app()
             .app_data(app_state.clone())
-            .service(api_scope)
+            .service(get_api_scope("/api/v1").wrap(ContentTypeBootstrap))
             .split_for_parts();
 
         let rapidoc_service = RapiDoc::with_openapi("/api-docs-json", api).path("/api-docs");
@@ -82,7 +96,7 @@ async fn main() {
         app.service(rapidoc_service.custom_html(patched_rapidoc_html))
     })
     .workers(4)
-    .bind(("0.0.0.0", 8080))
+    .bind(("0.0.0.0", 5050))
     .unwrap()
     .run()
     .await

src/middlewares/authorization.rs

@@ -7,8 +7,17 @@ use actix_web::{Error, HttpRequest, ResponseError};
 use futures_util::future::LocalBoxFuture;
 use std::future::{Ready, ready};
 
-/// Middleware guard работающий с токенами JWT
+/// Middleware guard working with JWT tokens.
-pub struct JWTAuthorization;
+pub struct JWTAuthorization {
+    /// List of ignored endpoints.
+    pub ignore: &'static [&'static str],
+}
+
+impl Default for JWTAuthorization {
+    fn default() -> Self {
+        Self { ignore: &[] }
+    }
+}
 
 impl<S, B> Transform<S, ServiceRequest> for JWTAuthorization
 where
@@ -23,22 +32,27 @@ where
     type Future = Ready<Result<Self::Transform, Self::InitError>>;
 
     fn new_transform(&self, service: S) -> Self::Future {
-        ready(Ok(JWTAuthorizationMiddleware { service }))
+        ready(Ok(JWTAuthorizationMiddleware {
+            service,
+            ignore: self.ignore,
+        }))
     }
 }
 
 pub struct JWTAuthorizationMiddleware<S> {
     service: S,
+    /// List of ignored endpoints.
+    ignore: &'static [&'static str],
 }
 
-/// Функция для проверки наличия и действительности токена в запросе, а так же существования пользователя к которому он привязан
 impl<S, B> JWTAuthorizationMiddleware<S>
 where
     S: Service<ServiceRequest, Response = ServiceResponse<B>, Error = Error>,
     S::Future: 'static,
     B: 'static,
 {
-    pub fn check_authorization(
+    /// Checking the validity of the token.
+    fn check_authorization(
         &self,
         req: &HttpRequest,
         payload: &mut Payload,
@@ -47,9 +61,25 @@ where
             .map(|_| ())
             .map_err(|e| e.as_error::<authorized_user::Error>().unwrap().clone())
     }
+
+    fn should_skip(&self, req: &ServiceRequest) -> bool {
+        let path = req.match_info().unprocessed();
+
+        self.ignore.iter().any(|ignore| {
+            if !path.starts_with(ignore) {
+                return false;
+            }
+
+            if let Some(other) = path.as_bytes().iter().nth(ignore.len()) {
+                return ['?' as u8, '/' as u8].contains(other);
+            }
+
+            true
+        })
+    }
 }
 
-impl<S, B> Service<ServiceRequest> for JWTAuthorizationMiddleware<S>
+impl<'a, S, B> Service<ServiceRequest> for JWTAuthorizationMiddleware<S>
 where
     S: Service<ServiceRequest, Response = ServiceResponse<B>, Error = Error>,
     S::Future: 'static,
@@ -62,6 +92,11 @@ where
     forward_ready!(service);
 
     fn call(&self, req: ServiceRequest) -> Self::Future {
+        if self.should_skip(&req) {
+            let fut = self.service.call(req);
+            return Box::pin(async move { Ok(fut.await?.map_into_left_body()) });
+        }
+
         let (http_req, mut payload) = req.into_parts();
 
         if let Err(err) = self.check_authorization(&http_req, &mut payload) {

src/middlewares/content_type.rs

@@ -0,0 +1,64 @@
+use actix_web::Error;
+use actix_web::body::{BoxBody, EitherBody};
+use actix_web::dev::{Service, ServiceRequest, ServiceResponse, Transform, forward_ready};
+use actix_web::http::header;
+use actix_web::http::header::HeaderValue;
+use futures_util::future::LocalBoxFuture;
+use std::future::{Ready, ready};
+
+/// Middleware to specify the encoding in the Content-Type header.
+pub struct ContentTypeBootstrap;
+
+impl<S, B> Transform<S, ServiceRequest> for ContentTypeBootstrap
+where
+    S: Service<ServiceRequest, Response = ServiceResponse<B>, Error = Error>,
+    S::Future: 'static,
+    B: 'static,
+{
+    type Response = ServiceResponse<EitherBody<B, BoxBody>>;
+    type Error = Error;
+    type Transform = ContentTypeMiddleware<S>;
+    type InitError = ();
+    type Future = Ready<Result<Self::Transform, Self::InitError>>;
+
+    fn new_transform(&self, service: S) -> Self::Future {
+        ready(Ok(ContentTypeMiddleware { service }))
+    }
+}
+
+pub struct ContentTypeMiddleware<S> {
+    service: S,
+}
+
+impl<'a, S, B> Service<ServiceRequest> for ContentTypeMiddleware<S>
+where
+    S: Service<ServiceRequest, Response = ServiceResponse<B>, Error = Error>,
+    S::Future: 'static,
+    B: 'static,
+{
+    type Response = ServiceResponse<EitherBody<B, BoxBody>>;
+    type Error = Error;
+    type Future = LocalBoxFuture<'static, Result<Self::Response, Self::Error>>;
+
+    forward_ready!(service);
+
+    fn call(&self, req: ServiceRequest) -> Self::Future {
+        let fut = self.service.call(req);
+
+        Box::pin(async move {
+            let mut response = fut.await?;
+
+            let headers = response.response_mut().headers_mut();
+            if let Some(content_type) = headers.get("Content-Type") {
+                if content_type == "application/json" {
+                    headers.insert(
+                        header::CONTENT_TYPE,
+                        HeaderValue::from_static("application/json; charset=utf8"),
+                    );
+                }
+            }
+
+            Ok(response.map_into_left_body())
+        })
+    }
+}

src/middlewares/mod.rs

@@ -1 +1,2 @@
 pub mod authorization;
+pub mod content_type;

src/parser/mod.rs

@@ -1,12 +1,12 @@
-use crate::parser::LessonParseResult::{Lessons, Street};
 use crate::parser::schema::LessonType::Break;
 use crate::parser::schema::{
     Day, Lesson, LessonSubGroup, LessonTime, LessonType, ParseError, ParseResult, ScheduleEntry,
 };
-use calamine::{Reader, Xls, open_workbook_from_rs};
+use crate::parser::LessonParseResult::{Lessons, Street};
-use chrono::{Duration, NaiveDateTime};
+use calamine::{open_workbook_from_rs, Reader, Xls};
-use fuzzy_matcher::FuzzyMatcher;
+use chrono::{DateTime, Duration, NaiveDateTime, Utc};
 use fuzzy_matcher::skim::SkimMatcherV2;
+use fuzzy_matcher::FuzzyMatcher;
 use regex::Regex;
 use std::collections::HashMap;
 use std::io::Cursor;
@@ -14,39 +14,37 @@ use std::sync::LazyLock;
 
 pub mod schema;
 
-/// Данные ячейке хранящей строку
+/// Data cell storing the line.
 struct InternalId {
-    /// Индекс строки
+    /// Line index.
     row: u32,
 
-    /// Индекс столбца
+    /// Column index.
     column: u32,
 
-    /**
+    /// Text in the cell.
-     * Текст в ячейке
-     */
     name: String,
 }
 
-/// Данные о времени проведения пар из второй колонки расписания
+/// Data on the time of lessons from the second column of the schedule.
 struct InternalTime {
-    /// Временной отрезок проведения пары
+    /// Temporary segment of the lesson.
     time_range: LessonTime,
 
-    /// Тип пары
+    /// Type of lesson.
     lesson_type: LessonType,
 
-    /// Индекс пары
+    /// The lesson index.
     default_index: Option<u32>,
 
-    /// Рамка ячейки
+    /// The frame of the cell.
     xls_range: ((u32, u32), (u32, u32)),
 }
 
-/// Сокращение типа рабочего листа
+/// Working sheet type alias.
 type WorkSheet = calamine::Range<calamine::Data>;
 
-/// Получение строки из требуемой ячейки
+/// Getting a line from the required cell.
 fn get_string_from_cell(worksheet: &WorkSheet, row: u32, col: u32) -> Option<String> {
     let cell_data = if let Some(data) = worksheet.get((row as usize, col as usize)) {
         data.to_string()
@@ -74,7 +72,7 @@ fn get_string_from_cell(worksheet: &WorkSheet, row: u32, col: u32) -> Option<Str
     }
 }
 
-/// Получение границ ячейки по её верхней левой координате
+/// Obtaining the boundaries of the cell along its upper left coordinate.
 fn get_merge_from_start(worksheet: &WorkSheet, row: u32, column: u32) -> ((u32, u32), (u32, u32)) {
     let worksheet_end = worksheet.end().unwrap();
 
@@ -109,7 +107,7 @@ fn get_merge_from_start(worksheet: &WorkSheet, row: u32, column: u32) -> ((u32,
     ((row, column), (row_end, column_end))
 }
 
-/// Получение "скелета" расписания из рабочего листа
+/// Obtaining a "skeleton" schedule from the working sheet.
 fn parse_skeleton(worksheet: &WorkSheet) -> Result<(Vec<InternalId>, Vec<InternalId>), ParseError> {
     let range = &worksheet;
 
@@ -167,19 +165,20 @@ fn parse_skeleton(worksheet: &WorkSheet) -> Result<(Vec<InternalId>, Vec<Interna
     Ok((days, groups))
 }
 
-/// Результат получения пары из ячейки
+/// The result of obtaining a lesson from the cell.
 enum LessonParseResult {
-    /// Список пар длинной от одного до двух
+    /// List of lessons long from one to two.
     ///
-    /// Количество пар будет равно одному, если пара первая за день, иначе будет возвращен список из шаблона перемены и самой пары
+    /// The number of lessons will be equal to one if the couple is the first in the day,
+    /// otherwise the list from the change template and the lesson itself will be returned.
     Lessons(Vec<Lesson>),
 
-    /// Улица на которой находится корпус политехникума
+    /// Street on which the Polytechnic Corps is located.
     Street(String),
 }
 
 trait StringInnerSlice {
-    /// Получения отрезка строки из строки по начальному и конечному индексу
+    /// Obtaining a line from the line on the initial and final index.
     fn inner_slice(&self, from: usize, to: usize) -> Self;
 }
 
@@ -192,7 +191,8 @@ impl StringInnerSlice for String {
     }
 }
 
-/// Получение нестандартного типа пары по названию
+// noinspection GrazieInspection
+/// Obtaining a non-standard type of lesson by name.
 fn guess_lesson_type(name: &String) -> Option<(String, LessonType)> {
     let map: HashMap<String, LessonType> = HashMap::from([
         ("(консультация)".to_string(), LessonType::Consultation),
@@ -234,7 +234,7 @@ fn guess_lesson_type(name: &String) -> Option<(String, LessonType)> {
     }
 }
 
-/// Получение пары или улицы из ячейки
+/// Getting a pair or street from a cell.
 fn parse_lesson(
     worksheet: &WorkSheet,
     day: &mut Day,
@@ -369,7 +369,7 @@ fn parse_lesson(
     ])))
 }
 
-/// Получение списка кабинетов справа от ячейки пары
+/// Obtaining a list of cabinets to the right of the lesson cell.
 fn parse_cabinets(worksheet: &WorkSheet, row: u32, column: u32) -> Vec<String> {
     let mut cabinets: Vec<String> = Vec::new();
 
@@ -387,7 +387,7 @@ fn parse_cabinets(worksheet: &WorkSheet, row: u32, column: u32) -> Vec<String> {
     cabinets
 }
 
-/// Получение "чистого" названия пары и списка преподавателей из текста ячейки пары
+/// Getting the "pure" name of the lesson and list of teachers from the text of the lesson cell.
 fn parse_name_and_subgroups(name: &String) -> Result<(String, Vec<LessonSubGroup>), ParseError> {
     static LESSON_RE: LazyLock<Regex, fn() -> Regex> =
         LazyLock::new(|| Regex::new(r"(?:[А-Я][а-я]+[А-Я]{2}(?:\([0-9][а-я]+\))?)+$").unwrap());
@@ -479,7 +479,7 @@ fn parse_name_and_subgroups(name: &String) -> Result<(String, Vec<LessonSubGroup
     Ok((lesson_name, subgroups))
 }
 
-/// Конвертация списка пар групп в список пар преподавателей
+/// Conversion of the list of couples of groups in the list of lessons of teachers.
 fn convert_groups_to_teachers(
     groups: &HashMap<String, ScheduleEntry>,
 ) -> HashMap<String, ScheduleEntry> {
@@ -556,7 +556,26 @@ fn convert_groups_to_teachers(
     teachers
 }
 
-/// Чтение XLS документа из буфера и преобразование его в готовые к использованию расписания
+/// Reading XLS Document from the buffer and converting it into the schedule ready to use.
+///
+/// # Arguments
+///
+/// * `buffer`: XLS data containing schedule.
+///
+/// returns: Result<ParseResult, ParseError>
+///
+/// # Examples
+///
+/// ```
+/// use schedule_parser_rusted::parser::parse_xls;
+///
+/// let result = parse_xls(&include_bytes!("../../schedule.xls").to_vec());
+///
+/// assert!(result.is_ok());
+///
+/// assert_ne!(result.as_ref().unwrap().groups.len(), 0);
+/// assert_ne!(result.as_ref().unwrap().teachers.len(), 0);
+/// ```
 pub fn parse_xls(buffer: &Vec<u8>) -> Result<ParseResult, ParseError> {
     let cursor = Cursor::new(&buffer);
     let mut workbook: Xls<_> =
@@ -657,13 +676,15 @@ pub fn parse_xls(buffer: &Vec<u8>) -> Result<ParseResult, ParseError> {
                         let end_match = parse_res.get(2).unwrap().as_str();
                         let end_parts: Vec<&str> = end_match.split(".").collect();
 
+                        static GET_TIME: fn(DateTime<Utc>, &Vec<&str>) -> DateTime<Utc> =
+                            |date, parts| {
+                                date + Duration::hours(parts[0].parse::<i64>().unwrap() - 4)
+                                    + Duration::minutes(parts[1].parse::<i64>().unwrap())
+                            };
+
                         LessonTime {
-                            start: day.date.clone()
+                            start: GET_TIME(day.date.clone(), &start_parts),
-                                + Duration::hours(start_parts[0].parse().unwrap())
+                            end: GET_TIME(day.date.clone(), &end_parts),
-                                + Duration::minutes(start_parts[1].parse().unwrap()),
-                            end: day.date.clone()
-                                + Duration::hours(end_parts[0].parse().unwrap())
-                                + Duration::minutes(end_parts[1].parse().unwrap()),
                         }
                     };
 

src/parser/schema.rs

@@ -6,137 +6,139 @@ use std::collections::HashMap;
 use std::sync::Arc;
 use utoipa::ToSchema;
 
+/// The beginning and end of the lesson.
 #[derive(Clone, Hash, Debug, Serialize, Deserialize, ToSchema)]
 pub struct LessonTime {
-    /// Начало пары
+    /// The beginning of a lesson.
     pub start: DateTime<Utc>,
 
-    /// Конец пары
+    /// The end of the lesson.
     pub end: DateTime<Utc>,
 }
 
+/// Type of lesson.
 #[derive(Clone, Hash, PartialEq, Debug, Serialize_repr, Deserialize_repr, ToSchema)]
 #[serde(rename_all = "SCREAMING_SNAKE_CASE")]
 #[repr(u8)]
 pub enum LessonType {
-    /// Обычная
+    /// Обычная.
     Default = 0,
 
-    /// Допы
+    /// Допы.
     Additional,
 
-    /// Перемена
+    /// Перемена.
     Break,
 
-    /// Консультация
+    /// Консультация.
     Consultation,
 
-    /// Самостоятельная работа
+    /// Самостоятельная работа.
     IndependentWork,
 
-    /// Зачёт
+    /// Зачёт.
     Exam,
 
-    /// Зачет с оценкой
+    /// Зачёт с оценкой.
     ExamWithGrade,
 
-    /// Экзамен
+    /// Экзамен.
     ExamDefault,
 }
 
 #[derive(Clone, Hash, Debug, Serialize, Deserialize, ToSchema)]
 pub struct LessonSubGroup {
-    /// Номер подгруппы
+    /// Index of subgroup.
     pub number: u8,
 
-    /// Кабинет, если присутствует
+    /// Cabinet, if present.
     pub cabinet: Option<String>,
 
-    /// Фио преподавателя
+    /// Full name of the teacher.
     pub teacher: String,
 }
 
 #[derive(Clone, Hash, Debug, Serialize, Deserialize, ToSchema)]
 #[serde(rename_all = "camelCase")]
 pub struct Lesson {
-    /// Тип занятия
+    /// Type.
     #[serde(rename = "type")]
     pub lesson_type: LessonType,
 
-    /// Индексы пар, если присутствуют
+    /// Lesson indexes, if present.
     pub default_range: Option<[u8; 2]>,
 
-    /// Название занятия
+    /// Name.
     pub name: Option<String>,
 
-    /// Начало и конец занятия
+    /// The beginning and end.
     pub time: LessonTime,
 
-    /// Список подгрупп
+    /// List of subgroups.
     #[serde(rename = "subGroups")]
     pub subgroups: Option<Vec<LessonSubGroup>>,
 
-    /// Группа, если это расписание для преподавателей
+    /// Group name, if this is a schedule for teachers.
     pub group: Option<String>,
 }
 
 #[derive(Clone, Hash, Debug, Serialize, Deserialize, ToSchema)]
 pub struct Day {
-    /// День недели
+    /// Day of the week.
     pub name: String,
 
-    /// Адрес другого корпуса
+    /// Address of another corps.
     pub street: Option<String>,
 
-    /// Дата
+    /// Date.
     pub date: DateTime<Utc>,
 
-    /// Список пар в этот день
+    /// List of lessons on this day.
     pub lessons: Vec<Lesson>,
 }
 
 #[derive(Clone, Hash, Debug, Serialize, Deserialize, ToSchema)]
 pub struct ScheduleEntry {
-    /// Название группы или ФИО преподавателя
+    /// The name of the group or name of the teacher.
     pub name: String,
 
-    /// Список из шести дней
+    /// List of six days.
     pub days: Vec<Day>,
 }
 
 #[derive(Clone)]
 pub struct ParseResult {
-    /// Список групп
+    /// List of groups.
     pub groups: HashMap<String, ScheduleEntry>,
 
-    /// Список преподавателей
+    /// List of teachers.
     pub teachers: HashMap<String, ScheduleEntry>,
 }
 
 #[derive(Debug, Display, Clone, ToSchema)]
 pub enum ParseError {
-    /// Ошибки связанные с чтением XLS файла.
+    /// Errors related to reading XLS file.
     #[display("{}: Failed to read XLS file.", "_0")]
     #[schema(value_type = String)]
     BadXLS(Arc<calamine::XlsError>),
 
-    /// Не найдено ни одного листа
+    /// Not a single sheet was found.
     #[display("No work sheets found.")]
     NoWorkSheets,
 
-    /// Отсутствуют данные об границах листа
+    /// There are no data on the boundaries of the sheet.
     #[display("There is no data on work sheet boundaries.")]
     UnknownWorkSheetRange,
 
-    /// Не удалось прочитать начало и конец пары из строки
+    /// Failed to read the beginning and end of the lesson from the line
     #[display("Failed to read lesson start and end times from string.")]
     GlobalTime,
 
-    /// Не найдены начало и конец соответствующее паре
+    /// Not found the beginning and the end corresponding to the lesson.
     #[display("No start and end times matching the lesson was found.")]
     LessonTimeNotFound,
 
-    /// Не удалось прочитать индекс подгруппы
+    /// Failed to read the subgroup index.
     #[display("Failed to read subgroup index.")]
     SubgroupIndexParsingFailed,
 }

src/routes/auth/mod.rs

@@ -1,3 +1,8 @@
-pub mod sign_in;
+mod sign_in;
-pub mod sign_up;
+mod sign_up;
 mod shared;
+
+pub use sign_in::*;
+pub use sign_up::*;
+
+// TODO: change-password

src/routes/auth/sign_in.rs

@@ -5,19 +5,19 @@ use crate::routes::auth::shared::parse_vk_id;
 use crate::routes::auth::sign_in::schema::SignInData::{Default, Vk};
 use crate::routes::schema::user::UserResponse;
 use crate::routes::schema::{IntoResponseAsError, ResponseError};
-use crate::{utility, AppState};
+use crate::utility::mutex::MutexScope;
+use crate::{AppState, utility};
 use actix_web::{post, web};
 use diesel::SaveChangesDsl;
-use std::ops::DerefMut;
 use web::Json;
 
-async fn sign_in(
+async fn sign_in_combined(
     data: SignInData,
     app_state: &web::Data<AppState>,
 ) -> Result<UserResponse, ErrorCode> {
     let user = match &data {
-        Default(data) => driver::users::get_by_username(&app_state.database, &data.username),
+        Default(data) => driver::users::get_by_username(&app_state, &data.username),
-        Vk(id) => driver::users::get_by_vk_id(&app_state.database, *id),
+        Vk(id) => driver::users::get_by_vk_id(&app_state, *id),
     };
 
     match user {
@@ -35,13 +35,12 @@ async fn sign_in(
                 }
             }
 
-            let mut lock = app_state.connection();
-            let conn = lock.deref_mut();
-
             user.access_token = utility::jwt::encode(&user.id);
 
-            user.save_changes::<User>(conn)
+            app_state.database.scope(|conn| {
-                .expect("Failed to update user");
+                user.save_changes::<User>(conn)
+                    .expect("Failed to update user")
+            });
 
             Ok(user.into())
         }
@@ -55,8 +54,10 @@ async fn sign_in(
     (status = NOT_ACCEPTABLE, body = ResponseError<ErrorCode>)
 ))]
 #[post("/sign-in")]
-pub async fn sign_in_default(data: Json<Request>, app_state: web::Data<AppState>) -> ServiceResponse {
+pub async fn sign_in(data: Json<Request>, app_state: web::Data<AppState>) -> ServiceResponse {
-    sign_in(Default(data.into_inner()), &app_state).await.into()
+    sign_in_combined(Default(data.into_inner()), &app_state)
+        .await
+        .into()
 }
 
 #[utoipa::path(responses(
@@ -64,11 +65,14 @@ pub async fn sign_in_default(data: Json<Request>, app_state: web::Data<AppState>
     (status = NOT_ACCEPTABLE, body = ResponseError<ErrorCode>)
 ))]
 #[post("/sign-in-vk")]
-pub async fn sign_in_vk(data_json: Json<vk::Request>, app_state: web::Data<AppState>) -> ServiceResponse {
+pub async fn sign_in_vk(
+    data_json: Json<vk::Request>,
+    app_state: web::Data<AppState>,
+) -> ServiceResponse {
     let data = data_json.into_inner();
 
     match parse_vk_id(&data.access_token) {
-        Ok(id) => sign_in(Vk(id), &app_state).await.into(),
+        Ok(id) => sign_in_combined(Vk(id), &app_state).await.into(),
         Err(_) => ErrorCode::InvalidVkAccessToken.into_response(),
     }
 }
@@ -82,11 +86,11 @@ mod schema {
     #[derive(Deserialize, Serialize, ToSchema)]
     #[schema(as = SignIn::Request)]
     pub struct Request {
-        /// Имя пользователя
+        /// User name.
         #[schema(examples("n08i40k"))]
         pub username: String,
 
-        /// Пароль
+        /// Password.
         pub password: String,
     }
 
@@ -98,7 +102,7 @@ mod schema {
         #[serde(rename_all = "camelCase")]
         #[schema(as = SignInVk::Request)]
         pub struct Request {
-            /// Токен VK ID
+            /// VK ID token.
             pub access_token: String,
         }
     }
@@ -110,21 +114,21 @@ mod schema {
     #[schema(as = SignIn::ErrorCode)]
     #[status_code = "actix_web::http::StatusCode::NOT_ACCEPTABLE"]
     pub enum ErrorCode {
-        /// Некорректное имя пользователя или пароль
+        /// Incorrect username or password.
         IncorrectCredentials,
 
-        /// Недействительный токен VK ID
+        /// Invalid VK ID token.
         InvalidVkAccessToken,
     }
 
     /// Internal
 
-    /// Тип авторизации
+    /// Type of authorization.
     pub enum SignInData {
-        /// Имя пользователя и пароль
+        /// User and password name and password.
         Default(Request),
 
-        /// Идентификатор привязанного аккаунта VK 
+        /// Identifier of the attached account VK.
         Vk(i32),
     }
 }
@@ -134,7 +138,7 @@ mod tests {
     use super::schema::*;
     use crate::database::driver;
     use crate::database::models::{User, UserRole};
-    use crate::routes::auth::sign_in::sign_in_default;
+    use crate::routes::auth::sign_in::sign_in;
     use crate::test_env::tests::{static_app_state, test_app_state, test_env};
     use crate::utility;
     use actix_test::test_app;
@@ -146,7 +150,7 @@ mod tests {
     use std::fmt::Write;
 
     async fn sign_in_client(data: Request) -> ServiceResponse {
-        let app = test_app(test_app_state(), sign_in_default).await;
+        let app = test_app(test_app_state().await, sign_in).await;
 
         let req = test::TestRequest::with_uri("/sign-in")
             .method(Method::POST)
@@ -156,7 +160,7 @@ mod tests {
         test::call_service(&app, req).await
     }
 
-    fn prepare(username: String) {
+    async fn prepare(username: String) {
         let id = {
             let mut sha = Sha1::new();
             sha.update(&username);
@@ -174,9 +178,9 @@ mod tests {
 
         test_env();
 
-        let app_state = static_app_state();
+        let app_state = static_app_state().await;
         driver::users::insert_or_ignore(
-            &app_state.database,
+            &app_state,
             &User {
                 id: id.clone(),
                 username,
@@ -193,7 +197,7 @@ mod tests {
 
     #[actix_web::test]
     async fn sign_in_ok() {
-        prepare("test::sign_in_ok".to_string());
+        prepare("test::sign_in_ok".to_string()).await;
 
         let resp = sign_in_client(Request {
             username: "test::sign_in_ok".to_string(),
@@ -206,7 +210,7 @@ mod tests {
 
     #[actix_web::test]
     async fn sign_in_err() {
-        prepare("test::sign_in_err".to_string());
+        prepare("test::sign_in_err".to_string()).await;
 
         let invalid_username = sign_in_client(Request {
             username: "test::sign_in_err::username".to_string(),

src/routes/auth/sign_up.rs

@@ -9,7 +9,7 @@ use actix_web::{post, web};
 use rand::{Rng, rng};
 use web::Json;
 
-async fn sign_up(
+async fn sign_up_combined(
     data: SignUpData,
     app_state: &web::Data<AppState>,
 ) -> Result<UserResponse, ErrorCode> {
@@ -28,19 +28,19 @@ async fn sign_up(
     }
 
     // If user with specified username already exists.
-    if driver::users::contains_by_username(&app_state.database, &data.username) {
+    if driver::users::contains_by_username(&app_state, &data.username) {
         return Err(ErrorCode::UsernameAlreadyExists);
     }
 
     // If user with specified VKID already exists.
     if let Some(id) = data.vk_id {
-        if driver::users::contains_by_vk_id(&app_state.database, id) {
+        if driver::users::contains_by_vk_id(&app_state, id) {
             return Err(ErrorCode::VkAlreadyExists);
         }
     }
 
     let user = data.into();
-    driver::users::insert(&app_state.database, &user).unwrap();
+    driver::users::insert(&app_state, &user).unwrap();
 
     Ok(UserResponse::from(&user)).into()
 }
@@ -50,13 +50,10 @@ async fn sign_up(
     (status = NOT_ACCEPTABLE, body = ResponseError<ErrorCode>)
 ))]
 #[post("/sign-up")]
-pub async fn sign_up_default(
+pub async fn sign_up(data_json: Json<Request>, app_state: web::Data<AppState>) -> ServiceResponse {
-    data_json: Json<Request>,
-    app_state: web::Data<AppState>,
-) -> ServiceResponse {
     let data = data_json.into_inner();
 
-    sign_up(
+    sign_up_combined(
         SignUpData {
             username: data.username,
             password: data.password,
@@ -83,7 +80,7 @@ pub async fn sign_up_vk(
     let data = data_json.into_inner();
 
     match parse_vk_id(&data.access_token) {
-        Ok(id) => sign_up(
+        Ok(id) => sign_up_combined(
             SignUpData {
                 username: data.username,
                 password: rng()
@@ -124,21 +121,21 @@ mod schema {
     #[derive(Serialize, Deserialize, utoipa::ToSchema)]
     #[schema(as = SignUp::Request)]
     pub struct Request {
-        /// Имя пользователя
+        /// User name.
         #[schema(examples("n08i40k"))]
         pub username: String,
 
-        /// Пароль
+        /// Password.
         pub password: String,
 
-        /// Группа
+        /// Group.
         #[schema(examples("ИС-214/23"))]
         pub group: String,
 
-        /// Роль
+        /// Role.
         pub role: UserRole,
 
-        /// Версия установленного приложения Polytechnic+
+        /// Version of the installed Polytechnic+ application.
         #[schema(examples("3.0.0"))]
         pub version: String,
     }
@@ -151,21 +148,21 @@ mod schema {
         #[serde(rename_all = "camelCase")]
         #[schema(as = SignUpVk::Request)]
         pub struct Request {
-            /// Токен VK ID
+            /// VK ID token.
             pub access_token: String,
 
-            /// Имя пользователя
+            /// User name.
             #[schema(examples("n08i40k"))]
             pub username: String,
 
-            /// Группа
+            /// Group.
             #[schema(examples("ИС-214/23"))]
             pub group: String,
 
-            /// Роль
+            /// Role.
             pub role: UserRole,
 
-            /// Версия установленного приложения Polytechnic+
+            /// Version of the installed Polytechnic+ application.
             #[schema(examples("3.0.0"))]
             pub version: String,
         }
@@ -178,44 +175,44 @@ mod schema {
     #[schema(as = SignUp::ErrorCode)]
     #[status_code = "actix_web::http::StatusCode::NOT_ACCEPTABLE"]
     pub enum ErrorCode {
-        /// Передана роль ADMIN
+        /// Conveyed the role of Admin.
         DisallowedRole,
 
-        /// Неизвестное название группы
+        /// Unknown name of the group.
         InvalidGroupName,
 
-        /// Пользователь с таким именем уже зарегистрирован
+        /// User with this name is already registered.
         UsernameAlreadyExists,
 
-        /// Недействительный токен VK ID
+        /// Invalid VK ID token.
         InvalidVkAccessToken,
 
-        /// Пользователь с таким аккаунтом VK уже зарегистрирован
+        /// User with such an account VK is already registered.
         VkAlreadyExists,
     }
 
     /// Internal
 
-    /// Данные для регистрации
+    /// Data for registration.
     pub struct SignUpData {
-        /// Имя пользователя
+        /// User name.
         pub username: String,
 
-        /// Пароль
+        /// Password.
         ///
-        /// Должен присутствовать даже если регистрация происходит с помощью токена VK ID
+        /// Should be present even if registration occurs using the VK ID token.
         pub password: String,
 
-        /// Идентификатор аккаунта VK
+        /// Account identifier VK.
         pub vk_id: Option<i32>,
 
-        /// Группа
+        /// Group.
         pub group: String,
 
-        /// Роль
+        /// Role.
         pub role: UserRole,
 
-        /// Версия установленного приложения Polytechnic+
+        /// Version of the installed Polytechnic+ application.
         pub version: String,
     }
 
@@ -243,7 +240,7 @@ mod tests {
     use crate::database::driver;
     use crate::database::models::UserRole;
     use crate::routes::auth::sign_up::schema::Request;
-    use crate::routes::auth::sign_up::sign_up_default;
+    use crate::routes::auth::sign_up::sign_up;
     use crate::test_env::tests::{static_app_state, test_app_state, test_env};
     use actix_test::test_app;
     use actix_web::dev::ServiceResponse;
@@ -258,7 +255,7 @@ mod tests {
     }
 
     async fn sign_up_client(data: SignUpPartial) -> ServiceResponse {
-        let app = test_app(test_app_state(), sign_up_default).await;
+        let app = test_app(test_app_state().await, sign_up).await;
 
         let req = test::TestRequest::with_uri("/sign-up")
             .method(Method::POST)
@@ -280,8 +277,8 @@ mod tests {
 
         test_env();
 
-        let app_state = static_app_state();
+        let app_state = static_app_state().await;
-        driver::users::delete_by_username(&app_state.database, &"test::sign_up_valid".to_string());
+        driver::users::delete_by_username(&app_state, &"test::sign_up_valid".to_string());
 
         // test
 
@@ -301,11 +298,8 @@ mod tests {
 
         test_env();
 
-        let app_state = static_app_state();
+        let app_state = static_app_state().await;
-        driver::users::delete_by_username(
+        driver::users::delete_by_username(&app_state, &"test::sign_up_multiple".to_string());
-            &app_state.database,
-            &"test::sign_up_multiple".to_string(),
-        );
 
         let create = sign_up_client(SignUpPartial {
             username: "test::sign_up_multiple".to_string(),

src/routes/fcm/mod.rs

@@ -0,0 +1,5 @@
+mod update_callback;
+mod set_token;
+
+pub use update_callback::*;
+pub use set_token::*;

src/routes/fcm/set_token.rs

@@ -0,0 +1,114 @@
+use crate::app_state::AppState;
+use crate::database;
+use crate::database::models::FCM;
+use crate::extractors::authorized_user::UserExtractor;
+use crate::extractors::base::SyncExtractor;
+use crate::utility::mutex::{MutexScope, MutexScopeAsync};
+use actix_web::{HttpResponse, Responder, patch, web};
+use diesel::{RunQueryDsl, SaveChangesDsl};
+use firebase_messaging_rs::FCMClient;
+use firebase_messaging_rs::topic::{TopicManagementError, TopicManagementSupport};
+use serde::Deserialize;
+
+#[derive(Debug, Deserialize)]
+struct Params {
+    pub token: String,
+}
+
+async fn get_fcm(
+    app_state: &web::Data<AppState>,
+    user_data: &UserExtractor<true>,
+    token: String,
+) -> Result<FCM, diesel::result::Error> {
+    match user_data.fcm() {
+        Some(fcm) => {
+            let mut fcm = fcm.clone();
+            fcm.token = token;
+
+            Ok(fcm)
+        }
+        None => {
+            let fcm = FCM {
+                user_id: user_data.user().id.clone(),
+                token,
+                topics: vec![],
+            };
+
+            match app_state.database.scope(|conn| {
+                diesel::insert_into(database::schema::fcm::table)
+                    .values(&fcm)
+                    .execute(conn)
+            }) {
+                Ok(_) => Ok(fcm),
+                Err(e) => Err(e),
+            }
+        }
+    }
+}
+
+#[utoipa::path(responses((status = OK)))]
+#[patch("/set-token")]
+pub async fn set_token(
+    app_state: web::Data<AppState>,
+    web::Query(params): web::Query<Params>,
+    user_data: SyncExtractor<UserExtractor<true>>,
+) -> impl Responder {
+    let user_data = user_data.into_inner();
+
+    // If token not changes - exit.
+    if let Some(fcm) = user_data.fcm() {
+        if fcm.token == params.token {
+            return HttpResponse::Ok();
+        }
+    }
+
+    let fcm = get_fcm(&app_state, &user_data, params.token.clone()).await;
+    if let Err(e) = fcm {
+        eprintln!("Failed to get FCM: {e}");
+        return HttpResponse::Ok();
+    }
+
+    let mut fcm = fcm.ok().unwrap();
+
+    // Add default topics.
+    if !fcm.topics.contains(&Some("common".to_string())) {
+        fcm.topics.push(Some("common".to_string()));
+    }
+
+    // Subscribe to default topics.
+    if let Some(e) = app_state
+        .fcm_client
+        .as_ref()
+        .unwrap()
+        .async_scope(
+            async |client: &mut FCMClient| -> Result<(), TopicManagementError> {
+                let mut tokens: Vec<String> = Vec::new();
+                tokens.push(fcm.token.clone());
+
+                for topic in fcm.topics.clone() {
+                    if let Some(topic) = topic {
+                        client.register_tokens_to_topic(topic.clone(), tokens.clone()).await?;
+                    }
+                }
+
+                Ok(())
+            },
+        )
+        .await
+        .err()
+    {
+        eprintln!("Failed to subscribe token to topic: {:?}", e);
+        return HttpResponse::Ok();
+    }
+
+    // Write updates to db.
+    if let Some(e) = app_state
+        .database
+        .scope(|conn| fcm.save_changes::<FCM>(conn))
+        .err()
+    {
+        eprintln!("Failed to update FCM object: {e}");
+    }
+
+    HttpResponse::Ok()
+}

src/routes/fcm/update_callback.rs

@@ -0,0 +1,32 @@
+use crate::app_state::AppState;
+use crate::database::models::User;
+use crate::extractors::base::SyncExtractor;
+use crate::utility::mutex::MutexScope;
+use actix_web::{HttpResponse, Responder, post, web};
+use diesel::SaveChangesDsl;
+
+#[utoipa::path(responses(
+    (status = OK),
+    (status = INTERNAL_SERVER_ERROR)
+))]
+#[post("/update-callback/{version}")]
+async fn update_callback(
+    app_state: web::Data<AppState>,
+    version: web::Path<String>,
+    user: SyncExtractor<User>,
+) -> impl Responder {
+    let mut user = user.into_inner();
+
+    user.version = version.into_inner();
+
+    match app_state
+        .database
+        .scope(|conn| user.save_changes::<User>(conn))
+    {
+        Ok(_) => HttpResponse::Ok(),
+        Err(e) => {
+            eprintln!("Failed to update user: {}", e);
+            HttpResponse::InternalServerError()
+        }
+    }
+}

src/routes/mod.rs

@@ -1,4 +1,6 @@
 pub mod auth;
-pub mod users;
+pub mod fcm;
 pub mod schedule;
 mod schema;
+pub mod users;
+pub mod vk_id;

src/routes/schedule/cache_status.rs

@@ -6,7 +6,7 @@ use actix_web::{get, web};
     (status = OK, body = CacheStatus),
 ))]
 #[get("/cache-status")]
-pub async fn get_cache_status(app_state: web::Data<AppState>) -> CacheStatus {
+pub async fn cache_status(app_state: web::Data<AppState>) -> CacheStatus {
     // Prevent thread lock
     let has_schedule = app_state
         .schedule

src/routes/schedule/group.rs

@@ -25,10 +25,7 @@ use actix_web::{get, web};
     ),
 ))]
 #[get("/group")]
-pub async fn get_group(
+pub async fn group(user: SyncExtractor<User>, app_state: web::Data<AppState>) -> ServiceResponse {
-    user: SyncExtractor<User>,
-    app_state: web::Data<AppState>,
-) -> ServiceResponse {
     // Prevent thread lock
     let schedule_lock = app_state.schedule.lock().unwrap();
 
@@ -55,18 +52,18 @@ mod schema {
     #[schema(as = GetGroup::Response)]
     #[serde(rename_all = "camelCase")]
     pub struct Response {
-        /// Расписание группы
+        /// Group schedule.
         pub group: ScheduleEntry,
 
-        /// Устаревшая переменная
+        /// ## Outdated variable.
         ///
-        /// По умолчанию возвращается пустой список
+        /// By default, an empty list is returned.
         #[deprecated = "Will be removed in future versions"]
         pub updated: Vec<i32>,
 
-        /// Устаревшая переменная
+        /// ## Outdated variable.
         ///
-        /// По умолчанию начальная дата по Unix
+        /// By default, the initial date for unix.
         #[deprecated = "Will be removed in future versions"]
         pub updated_at: DateTime<Utc>,
     }
@@ -86,12 +83,12 @@ mod schema {
     #[serde(rename_all = "SCREAMING_SNAKE_CASE")]
     #[schema(as = GroupSchedule::ErrorCode)]
     pub enum ErrorCode {
-        /// Расписания ещё не получены
+        /// Schedules have not yet been parsed.
         #[status_code = "actix_web::http::StatusCode::SERVICE_UNAVAILABLE"]
         #[display("Schedule not parsed yet.")]
         NoSchedule,
 
-        /// Группа не найдена
+        /// Group not found.
         #[status_code = "actix_web::http::StatusCode::NOT_FOUND"]
         #[display("Required group not found.")]
         NotFound,

src/routes/schedule/group_names.rs

@@ -9,7 +9,7 @@ use actix_web::{get, web};
     (status = SERVICE_UNAVAILABLE, body = ResponseError<ErrorCode>),
 ))]
 #[get("/group-names")]
-pub async fn get_group_names(app_state: web::Data<AppState>) -> ServiceResponse {
+pub async fn group_names(app_state: web::Data<AppState>) -> ServiceResponse {
     // Prevent thread lock
     let schedule_lock = app_state.schedule.lock().unwrap();
 
@@ -35,7 +35,7 @@ mod schema {
     #[derive(Serialize, ToSchema)]
     #[schema(as = GetGroupNames::Response)]
     pub struct Response {
-        /// Список названий групп отсортированный в алфавитном порядке
+        /// List of group names sorted in alphabetical order.
         #[schema(examples(json!(["ИС-214/23"])))]
         pub names: Vec<String>,
     }

src/routes/schedule/mod.rs

@@ -1,8 +1,16 @@
-pub mod get_cache_status;
+mod cache_status;
-pub mod get_schedule;
+mod group;
-pub mod get_group;
+mod group_names;
-pub mod get_group_names;
+mod schedule;
-pub mod get_teacher;
+mod teacher;
-pub mod get_teacher_names;
+mod teacher_names;
 mod schema;
-pub mod update_download_url;
+mod update_download_url;
+
+pub use cache_status::*;
+pub use group::*;
+pub use group_names::*;
+pub use schedule::*;
+pub use teacher::*;
+pub use teacher_names::*;
+pub use update_download_url::*;

src/routes/schedule/schedule.rs

@@ -9,7 +9,7 @@ use actix_web::{get, web};
     (status = SERVICE_UNAVAILABLE, body = ResponseError<ErrorCode>)
 ))]
 #[get("/")]
-pub async fn get_schedule(app_state: web::Data<AppState>) -> ServiceResponse {
+pub async fn schedule(app_state: web::Data<AppState>) -> ServiceResponse {
     match ScheduleView::try_from(&app_state) {
         Ok(res) => Ok(res).into(),
         Err(e) => match e {

src/routes/schedule/schema.rs

@@ -8,23 +8,23 @@ use serde::{Deserialize, Serialize};
 use std::collections::HashMap;
 use utoipa::ToSchema;
 
-/// Ответ от сервера с расписаниями
+/// Response from schedule server.
 #[derive(Serialize, ToSchema)]
 #[serde(rename_all = "camelCase")]
 pub struct ScheduleView {
-    /// ETag расписания на сервере политехникума
+    /// ETag schedules on polytechnic server.
     etag: String,
 
-    /// Дата обновления расписания на сайте политехникума
+    /// Schedule update date on polytechnic website.
     uploaded_at: DateTime<Utc>,
 
-    /// Дата последнего скачивания расписания с сервера политехникума
+    /// Date last downloaded from the Polytechnic server.
     downloaded_at: DateTime<Utc>,
 
-    /// Расписание групп
+    /// Groups schedule.
     groups: HashMap<String, ScheduleEntry>,
 
-    /// Расписание преподавателей
+    /// Teachers schedule.
     teachers: HashMap<String, ScheduleEntry>,
 }
 
@@ -33,7 +33,7 @@ pub struct ScheduleView {
 #[serde(rename_all = "SCREAMING_SNAKE_CASE")]
 #[schema(as = ScheduleShared::ErrorCode)]
 pub enum ErrorCode {
-    /// Расписания ещё не получены
+    /// Schedules not yet parsed.
     #[display("Schedule not parsed yet.")]
     NoSchedule,
 }
@@ -56,22 +56,22 @@ impl TryFrom<&web::Data<AppState>> for ScheduleView {
     }
 }
 
-/// Статус кешированного расписаний
+/// Cached schedule status.
 #[derive(Serialize, Deserialize, ToSchema, ResponderJson)]
 #[serde(rename_all = "camelCase")]
 pub struct CacheStatus {
-    /// Хеш расписаний
+    /// Schedule hash.
     pub cache_hash: String,
 
-    /// Требуется ли обновить ссылку на расписание
+    /// Whether the schedule reference needs to be updated.
     pub cache_update_required: bool,
 
-    /// Дата последнего обновления кеша 
+    /// Last cache update date.
     pub last_cache_update: i64,
 
-    /// Дата обновления кешированного расписания
+    /// Cached schedule update date.
     ///
-    /// Определяется сервером политехникума
+    /// Determined by the polytechnic's server.
     pub last_schedule_update: i64,
 }
 

src/routes/schedule/teacher.rs

@@ -23,7 +23,7 @@ use actix_web::{get, web};
     ),
 ))]
 #[get("/teacher/{name}")]
-pub async fn get_teacher(
+pub async fn teacher(
     name: web::Path<String>,
     app_state: web::Data<AppState>,
 ) -> ServiceResponse {
@@ -53,18 +53,18 @@ mod schema {
     #[schema(as = GetTeacher::Response)]
     #[serde(rename_all = "camelCase")]
     pub struct Response {
-        /// Расписание преподавателя
+        /// Teacher's schedule.
         pub teacher: ScheduleEntry,
 
-        /// Устаревшая переменная
+        /// ## Deprecated variable.
         ///
-        /// По умолчанию возвращается пустой список
+        /// By default, an empty list is returned.
         #[deprecated = "Will be removed in future versions"]
         pub updated: Vec<i32>,
 
-        /// Устаревшая переменная
+        /// ## Deprecated variable.
         ///
-        /// По умолчанию начальная дата по Unix
+        /// Defaults to the Unix start date.
         #[deprecated = "Will be removed in future versions"]
         pub updated_at: DateTime<Utc>,
     }
@@ -84,12 +84,12 @@ mod schema {
     #[serde(rename_all = "SCREAMING_SNAKE_CASE")]
     #[schema(as = TeacherSchedule::ErrorCode)]
     pub enum ErrorCode {
-        /// Расписания ещё не получены
+        /// Schedules have not yet been parsed.
         #[status_code = "actix_web::http::StatusCode::SERVICE_UNAVAILABLE"]
         #[display("Schedule not parsed yet.")]
         NoSchedule,
 
-        /// Преподаватель не найден
+        /// Teacher not found.
         #[status_code = "actix_web::http::StatusCode::NOT_FOUND"]
         #[display("Required teacher not found.")]
         NotFound,

src/routes/schedule/teacher_names.rs

@@ -9,7 +9,7 @@ use actix_web::{get, web};
     (status = SERVICE_UNAVAILABLE, body = ResponseError<ErrorCode>),
 ))]
 #[get("/teacher-names")]
-pub async fn get_teacher_names(app_state: web::Data<AppState>) -> ServiceResponse {
+pub async fn teacher_names(app_state: web::Data<AppState>) -> ServiceResponse {
     // Prevent thread lock
     let schedule_lock = app_state.schedule.lock().unwrap();
 
@@ -35,7 +35,7 @@ mod schema {
     #[derive(Serialize, ToSchema)]
     #[schema(as = GetTeacherNames::Response)]
     pub struct Response {
-        /// Список имён преподавателей отсортированный в алфавитном порядке
+        /// List of teacher names sorted alphabetically.
         #[schema(examples(json!(["Хомченко Н.Е."])))]
         pub names: Vec<String>,
     }

src/routes/schedule/update_download_url.rs

@@ -84,7 +84,7 @@ mod schema {
 
     #[derive(Serialize, Deserialize, ToSchema)]
     pub struct Request {
-        /// Ссылка на расписание
+        /// Schedule link.
         pub url: String,
     }
 
@@ -92,25 +92,26 @@ mod schema {
     #[status_code = "actix_web::http::StatusCode::NOT_ACCEPTABLE"]
     #[schema(as = SetDownloadUrl::ErrorCode)]
     pub enum ErrorCode {
-        /// Передана ссылка с хостом отличающимся от politehnikum-eng.ru
+        /// Transferred link with host different from politehnikum-eng.ru.
         #[display("URL with unknown host provided. Provide url with politehnikum-eng.ru host.")]
         NonWhitelistedHost,
 
-        /// Не удалось получить мета-данные файла
+        /// Failed to retrieve file metadata.
         #[display("Unable to retrieve metadata from the specified URL.")]
         FetchFailed,
 
-        /// Не удалось скачать файл
+        /// Failed to download the file.
         #[display("Unable to retrieve data from the specified URL.")]
         DownloadFailed,
 
-        /// Ссылка ведёт на устаревшее расписание
+        /// The link leads to an outdated schedule.
         ///
-        /// Под устаревшим расписанием подразумевается расписание, которое было опубликовано раньше, чем уже имеется на данный момент
+        /// An outdated schedule refers to a schedule that was published earlier
+        /// than is currently available.
         #[display("The schedule is older than it already is.")]
         OutdatedSchedule,
 
-        /// Не удалось преобразовать расписание
+        /// Failed to parse the schedule.
         #[display("{}", "_0.display()")]
         InvalidSchedule(ParseError),
     }

src/routes/schema.rs

@@ -113,6 +113,7 @@ pub mod user {
     use actix_macros::ResponderJson;
     use serde::Serialize;
 
+    //noinspection SpellCheckingInspection
     /// Используется для скрытия чувствительных полей, таких как хеш пароля или FCM
     #[derive(Serialize, utoipa::ToSchema, ResponderJson)]
     #[serde(rename_all = "camelCase")]
@@ -132,7 +133,7 @@ pub mod user {
         /// Роль
         role: UserRole,
 
-        /// Идентификатор прявязанного аккаунта VK
+        /// Идентификатор привязанного аккаунта VK
         #[schema(examples(498094647, json!(null)))]
         vk_id: Option<i32>,
 

src/routes/users/change_group.rs

@@ -0,0 +1,85 @@
+use self::schema::*;
+use crate::app_state::AppState;
+use crate::database::driver::users::UserSave;
+use crate::database::models::User;
+use crate::extractors::base::SyncExtractor;
+use crate::routes::schema::IntoResponseAsError;
+use crate::utility::mutex::MutexScope;
+use actix_web::{post, web};
+
+#[utoipa::path(responses((status = OK)))]
+#[post("/change-group")]
+pub async fn change_group(
+    app_state: web::Data<AppState>,
+    user: SyncExtractor<User>,
+    data: web::Json<Request>,
+) -> ServiceResponse {
+    let mut user = user.into_inner();
+
+    if user.group == data.group {
+        return ErrorCode::SameGroup.into_response();
+    }
+
+    if let Some(e) = app_state.schedule.scope(|schedule| match schedule {
+        Some(schedule) => {
+            if schedule.data.groups.contains_key(&data.group) {
+                None
+            } else {
+                Some(ErrorCode::NotFound)
+            }
+        }
+        None => Some(ErrorCode::NoSchedule),
+    }) {
+        return e.into_response();
+    }
+
+    user.group = data.into_inner().group;
+
+    if let Some(e) = user.save(&app_state).err() {
+        eprintln!("Failed to update user: {e}");
+        return ErrorCode::InternalServerError.into_response();
+    }
+
+    Ok(()).into()
+}
+
+mod schema {
+    use actix_macros::{IntoResponseErrorNamed, StatusCode};
+    use derive_more::Display;
+    use serde::{Deserialize, Serialize};
+    use utoipa::ToSchema;
+
+    pub type ServiceResponse = crate::routes::schema::Response<(), ErrorCode>;
+
+    #[derive(Serialize, Deserialize, ToSchema)]
+    #[schema(as = ChangeGroup::Request)]
+    pub struct Request {
+        /// Group name.
+        pub group: String,
+    }
+
+    #[derive(Clone, Serialize, ToSchema, StatusCode, Display, IntoResponseErrorNamed)]
+    #[serde(rename_all = "SCREAMING_SNAKE_CASE")]
+    #[schema(as = ChangeGroup::ErrorCode)]
+    #[status_code = "actix_web::http::StatusCode::CONFLICT"]
+    pub enum ErrorCode {
+        /// Schedules have not yet been received.
+        #[display("Schedule not parsed yet.")]
+        #[status_code = "actix_web::http::StatusCode::SERVICE_UNAVAILABLE"]
+        NoSchedule,
+
+        /// Passed the same group name that is currently there.
+        #[display("Passed the same group name as it is at the moment.")]
+        SameGroup,
+
+        /// The required group does not exist.
+        #[display("The required group does not exist.")]
+        #[status_code = "actix_web::http::StatusCode::NOT_FOUND"]
+        NotFound,
+
+        /// Server-side error.
+        #[display("Internal server error.")]
+        #[status_code = "actix_web::http::StatusCode::INTERNAL_SERVER_ERROR"]
+        InternalServerError,
+    }
+}

src/routes/users/change_username.rs

@@ -0,0 +1,70 @@
+use self::schema::*;
+use crate::app_state::AppState;
+use crate::database::driver;
+use crate::database::driver::users::UserSave;
+use crate::database::models::User;
+use crate::extractors::base::SyncExtractor;
+use crate::routes::schema::IntoResponseAsError;
+use actix_web::{post, web};
+
+#[utoipa::path(responses((status = OK)))]
+#[post("/change-username")]
+pub async fn change_username(
+    app_state: web::Data<AppState>,
+    user: SyncExtractor<User>,
+    data: web::Json<Request>,
+) -> ServiceResponse {
+    let mut user = user.into_inner();
+
+    if user.username == data.username {
+        return ErrorCode::SameUsername.into_response();
+    }
+
+    if driver::users::get_by_username(&app_state, &data.username).is_ok() {
+        return ErrorCode::AlreadyExists.into_response();
+    }
+
+    user.username = data.into_inner().username;
+
+    if let Some(e) = user.save(&app_state).err() {
+        eprintln!("Failed to update user: {e}");
+        return ErrorCode::InternalServerError.into_response();
+    }
+
+    Ok(()).into()
+}
+
+mod schema {
+    use actix_macros::{IntoResponseErrorNamed, StatusCode};
+    use derive_more::Display;
+    use serde::{Deserialize, Serialize};
+    use utoipa::ToSchema;
+
+    pub type ServiceResponse = crate::routes::schema::Response<(), ErrorCode>;
+
+    #[derive(Serialize, Deserialize, ToSchema)]
+    #[schema(as = ChangeUsername::Request)]
+    pub struct Request {
+        /// User name.
+        pub username: String,
+    }
+
+    #[derive(Clone, Serialize, ToSchema, StatusCode, Display, IntoResponseErrorNamed)]
+    #[serde(rename_all = "SCREAMING_SNAKE_CASE")]
+    #[schema(as = ChangeUsername::ErrorCode)]
+    #[status_code = "actix_web::http::StatusCode::CONFLICT"]
+    pub enum ErrorCode {
+        /// The same name that is currently present is passed.
+        #[display("Passed the same name as it is at the moment.")]
+        SameUsername,
+
+        /// A user with this name already exists.
+        #[display("A user with this name already exists.")]
+        AlreadyExists,
+
+        /// Server-side error.
+        #[display("Internal server error.")]
+        #[status_code = "actix_web::http::StatusCode::INTERNAL_SERVER_ERROR"]
+        InternalServerError,
+    }
+}

src/routes/users/mod.rs

@@ -1 +1,7 @@
-pub mod me;
+mod change_group;
+mod change_username;
+mod me;
+
+pub use change_group::*;
+pub use change_username::*;
+pub use me::*;

src/routes/vk_id/mod.rs

@@ -0,0 +1,3 @@
+mod oauth;
+
+pub use oauth::*;

src/routes/vk_id/oauth.rs

@@ -0,0 +1,114 @@
+use self::schema::*;
+use crate::app_state::AppState;
+use crate::routes::schema::{IntoResponseAsError, ResponseError};
+use actix_web::{post, web};
+use serde::Deserialize;
+use std::collections::HashMap;
+use uuid::Uuid;
+
+#[allow(dead_code)]
+#[derive(Deserialize)]
+struct VkIdAuthResponse {
+    refresh_token: String,
+    access_token: String,
+    id_token: String,
+    token_type: String,
+    expires_in: i32,
+    user_id: i32,
+    state: String,
+    scope: String,
+}
+
+#[utoipa::path(responses(
+    (status = OK, body = Response),
+    (
+        status = NOT_ACCEPTABLE,
+        body = ResponseError<ErrorCode>,
+        example = json!({
+            "code": "VK_ID_ERROR",
+            "message": "VK server returned an error"
+        })
+    ),
+))]
+#[post("/oauth")]
+async fn oauth(data: web::Json<Request>, app_state: web::Data<AppState>) -> ServiceResponse {
+    let data = data.into_inner();
+    let state = Uuid::new_v4().simple().to_string();
+
+    let vk_id = &app_state.vk_id;
+    let client_id = vk_id.client_id.clone().to_string();
+
+    let mut params = HashMap::new();
+    params.insert("grant_type", "authorization_code");
+    params.insert("client_id", client_id.as_str());
+    params.insert("state", state.as_str());
+    params.insert("code_verifier", data.code_verifier.as_str());
+    params.insert("code", data.code.as_str());
+    params.insert("device_id", data.device_id.as_str());
+    params.insert("redirect_uri", vk_id.redirect_url.as_str());
+
+    let client = reqwest::Client::new();
+    match client
+        .post("https://id.vk.com/oauth2/auth")
+        .form(&params)
+        .send()
+        .await
+    {
+        Ok(res) => {
+            if !res.status().is_success() {
+                return ErrorCode::VkIdError.into_response();
+            }
+
+            if let Ok(auth_data) = res.json::<VkIdAuthResponse>().await {
+                Ok(Response {
+                    access_token: auth_data.id_token,
+                })
+                .into()
+            } else {
+                ErrorCode::VkIdError.into_response()
+            }
+        }
+        Err(_) => ErrorCode::VkIdError.into_response(),
+    }
+}
+
+mod schema {
+    use actix_macros::{IntoResponseErrorNamed, StatusCode};
+    use derive_more::Display;
+    use serde::{Deserialize, Serialize};
+    use utoipa::ToSchema;
+
+    pub type ServiceResponse = crate::routes::schema::Response<Response, ErrorCode>;
+
+    #[derive(Deserialize, ToSchema)]
+    #[serde(rename_all = "camelCase")]
+    #[schema(as = VkIdOAuth::Request)]
+    pub struct Request {
+        /// Код подтверждения authorization_code.
+        pub code: String,
+
+        /// Parameter to protect transmitted data.
+        pub code_verifier: String,
+
+        /// Device ID.
+        pub device_id: String,
+    }
+
+    #[derive(Serialize, ToSchema)]
+    #[serde(rename_all = "camelCase")]
+    #[schema(as = VkIdOAuth::Response)]
+    pub struct Response {
+        /// ID token.
+        pub access_token: String,
+    }
+
+    #[derive(Clone, Serialize, ToSchema, IntoResponseErrorNamed, StatusCode, Display)]
+    #[serde(rename_all = "SCREAMING_SNAKE_CASE")]
+    #[schema(as = VkIdOAuth::ErrorCode)]
+    #[status_code = "actix_web::http::StatusCode::NOT_ACCEPTABLE"]
+    pub enum ErrorCode {
+        /// VK server returned an error.
+        #[display("VK server returned an error")]
+        VkIdError,
+    }
+}

src/test_env.rs

@@ -1,16 +1,16 @@
 #[cfg(test)]
 pub(crate) mod tests {
-    use crate::app_state::{app_state, AppState, Schedule};
+    use crate::app_state::{AppState, Schedule, app_state};
     use crate::parser::tests::test_result;
-    use actix_web::{web};
+    use actix_web::web;
-    use std::sync::LazyLock;
+    use tokio::sync::OnceCell;
 
     pub fn test_env() {
         dotenvy::from_path(".env.test").expect("Failed to load test environment file");
     }
 
-    pub fn test_app_state() -> web::Data<AppState> {
+    pub async fn test_app_state() -> web::Data<AppState> {
-        let state = app_state();
+        let state = app_state().await;
         let mut schedule_lock = state.schedule.lock().unwrap();
 
         *schedule_lock = Some(Schedule {
@@ -24,9 +24,9 @@ pub(crate) mod tests {
         state.clone()
     }
 
-    pub fn static_app_state() -> web::Data<AppState> {
+    pub async fn static_app_state() -> web::Data<AppState> {
-        static STATE: LazyLock<web::Data<AppState>> = LazyLock::new(|| test_app_state());
+        static STATE: OnceCell<web::Data<AppState>> = OnceCell::const_new();
 
-        STATE.clone()
+        STATE.get_or_init(|| test_app_state()).await.clone()
     }
 }

src/utility/error.rs

@@ -2,7 +2,7 @@ use std::fmt::{Write};
 use std::fmt::Display;
 use serde::{Deserialize, Serialize};
 
-/// Ответ от сервера при ошибках внутри Middleware
+/// Server response to errors within Middleware.
 #[derive(Serialize, Deserialize)]
 pub struct ResponseErrorMessage<T: Display> {
     code: T,

src/utility/hasher.rs

@@ -1,7 +1,7 @@
 use sha1::Digest;
 use std::hash::Hasher;
 
-/// Хешер возвращающий хеш из алгоритма реализующего Digest
+/// Hesher returning hash from the algorithm implementing Digest
 pub struct DigestHasher<D: Digest> {
     digest: D,
 }
@@ -10,7 +10,7 @@ impl<D> DigestHasher<D>
 where
     D: Digest,
 {
-    /// Получение хеша
+    /// Obtain hash.
     pub fn finalize(self) -> String {
         hex::encode(self.digest.finalize().0)
     }
@@ -20,14 +20,14 @@ impl<D> From<D> for DigestHasher<D>
 where
     D: Digest,
 {
-    /// Создания хешера из алгоритма реализующего Digest
+    /// Creating a hash from an algorithm implementing Digest.
     fn from(digest: D) -> Self {
         DigestHasher { digest }
     }
 }
 
 impl<D: Digest> Hasher for DigestHasher<D> {
-    /// Заглушка для предотвращения вызова стандартного результата Hasher
+    /// Stopper to prevent calling the standard Hasher result.
     fn finish(&self) -> u64 {
         unimplemented!("Do not call finish()");
     }

src/utility/jwt.rs

@@ -9,31 +9,31 @@ use std::env;
 use std::mem::discriminant;
 use std::sync::LazyLock;
 
-/// Ключ для верификации токена
+/// Key for token verification.
 static DECODING_KEY: LazyLock<DecodingKey> = LazyLock::new(|| {
     let secret = env::var("JWT_SECRET").expect("JWT_SECRET must be set");
 
     DecodingKey::from_secret(secret.as_bytes())
 });
 
-/// Ключ для создания подписанного токена
+/// Key for creating a signed token.
 static ENCODING_KEY: LazyLock<EncodingKey> = LazyLock::new(|| {
     let secret = env::var("JWT_SECRET").expect("JWT_SECRET must be set");
 
     EncodingKey::from_secret(secret.as_bytes())
 });
 
-/// Ошибки верификации токена
+/// Token verification errors.
 #[allow(dead_code)]
 #[derive(Debug)]
 pub enum Error {
-    /// Токен имеет другую подпись
+    /// The token has a different signature.
     InvalidSignature,
 
-    /// Ошибка чтения токена
+    /// Token reading error.
     InvalidToken(ErrorKind),
 
-    /// Токен просрочен
+    /// Token expired.
     Expired,
 }
 
@@ -43,26 +43,26 @@ impl PartialEq for Error {
     }
 }
 
-/// Данные, которые хранит в себе токен
+/// The data the token holds.
 #[serde_as]
 #[derive(Debug, Serialize, Deserialize)]
 struct Claims {
-    /// UUID аккаунта пользователя
+    /// User account UUID.
     id: String,
 
-    /// Дата создания токена
+    /// Token creation date.
     #[serde_as(as = "DisplayFromStr")]
     iat: u64,
 
-    /// Дата окончания действия токена
+    /// Token expiry date.
     #[serde_as(as = "DisplayFromStr")]
     exp: u64,
 }
 
-/// Алгоритм подписи токенов
+/// Token signing algorithm.
 pub(crate) const DEFAULT_ALGORITHM: Algorithm = Algorithm::HS256;
 
-/// Проверка токена и извлечение из него UUID аккаунта пользователя 
+/// Checking the token and extracting the UUID of the user account from it.
 pub fn verify_and_decode(token: &String) -> Result<String, Error> {
     let mut validation = Validation::new(DEFAULT_ALGORITHM);
 
@@ -87,7 +87,7 @@ pub fn verify_and_decode(token: &String) -> Result<String, Error> {
     }
 }
 
-/// Создание токена пользователя
+/// Creating a user token.
 pub fn encode(id: &String) -> String {
     let header = Header {
         typ: Some(String::from("JWT")),
@@ -132,6 +132,7 @@ mod tests {
         );
     }
 
+    //noinspection SpellCheckingInspection
     #[test]
     fn test_decode_invalid_signature() {
         test_env();
@@ -143,6 +144,7 @@ mod tests {
         assert_eq!(result.err().unwrap(), Error::InvalidSignature);
     }
 
+    //noinspection SpellCheckingInspection
     #[test]
     fn test_decode_expired() {
         test_env();
@@ -154,6 +156,7 @@ mod tests {
         assert_eq!(result.err().unwrap(), Error::Expired);
     }
 
+    //noinspection SpellCheckingInspection
     #[test]
     fn test_decode_ok() {
         test_env();

src/utility/mod.rs

@@ -1,3 +1,4 @@
 pub mod jwt;
 pub mod error;
 pub mod hasher;
+pub mod mutex;

src/utility/mutex.rs

@@ -0,0 +1,77 @@
+use std::ops::DerefMut;
+use std::sync::Mutex;
+
+pub trait MutexScope<T, ScopeFn, ScopeFnOutput>
+where
+    ScopeFn: FnOnce(&mut T) -> ScopeFnOutput,
+{
+    /// Replaces manually creating a mutex lock to perform operations on the data it manages.
+    ///
+    /// # Arguments
+    ///
+    /// * `f`: Function (mostly lambda) to which a reference to the mutable object stored in the mutex will be passed.
+    ///
+    /// returns: Return value of `f` function.
+    ///
+    /// # Examples
+    ///
+    /// ```
+    /// let mtx: Mutex<i32> = Mutex::new(10);
+    ///
+    /// let res = mtx.scope(|x| { *x = *x * 2; *x });
+    /// assert_eq!(res, *mtx.lock().unwrap());
+    /// ```
+    fn scope(&self, f: ScopeFn) -> ScopeFnOutput;
+}
+
+impl<T, ScopeFn, ScopeFnOutput> MutexScope<T, ScopeFn, ScopeFnOutput> for Mutex<T>
+where
+    ScopeFn: FnOnce(&mut T) -> ScopeFnOutput,
+{
+    fn scope(&self, f: ScopeFn) -> ScopeFnOutput {
+        let mut lock = self.lock().unwrap();
+        let inner = lock.deref_mut();
+
+        f(inner)
+    }
+}
+
+pub trait MutexScopeAsync<T> {
+    /// ## Asynchronous variant of [MutexScope::scope][MutexScope::scope].
+    ///
+    /// Replaces manually creating a mutex lock to perform operations on the data it manages.
+    ///
+    /// # Arguments
+    ///
+    /// * `f`: Asynchronous function (mostly lambda) to which a reference to the mutable object stored in the mutex will be passed.
+    ///
+    /// returns: Return value of `f` function.
+    ///
+    /// # Examples
+    ///
+    /// ```
+    /// let mtx: Mutex<i32> = Mutex::new(10);
+    ///
+    /// let res = mtx.async_scope(async |x| { *x = *x * 2; *x }).await;
+    /// assert_eq!(res, *mtx.lock().unwrap());
+    /// ```
+    async fn async_scope<'a, F, FnFut, FnOut>(&'a self, f: F) -> FnOut
+    where
+        FnFut: Future<Output = FnOut>,
+        F: FnOnce(&'a mut T) -> FnFut,
+        T: 'a;
+}
+
+impl<T> MutexScopeAsync<T> for Mutex<T> {
+    async fn async_scope<'a, F, FnFut, FnOut>(&'a self, f: F) -> FnOut
+    where
+        FnFut: Future<Output = FnOut>,
+        F: FnOnce(&'a mut T) -> FnFut,
+        T: 'a,
+    {
+        let mut guard = self.lock().unwrap();
+
+        let ptr: &'a mut T = unsafe { &mut *(guard.deref_mut() as *mut _) };
+        f(ptr).await
+    }
+}

src/xls_downloader/interface.rs

@@ -1,41 +1,41 @@
 use chrono::{DateTime, Utc};
 
-/// Ошибки получения данных XLS
+/// XLS data retrieval errors.
 #[derive(PartialEq, Debug)]
 pub enum FetchError {
-    /// Не установлена ссылка на файл
+    /// File url is not set.
     NoUrlProvided,
 
-    /// Неизвестная ошибка
+    /// Unknown error.
     Unknown,
 
-    /// Сервер вернул статус код отличающийся от 200
+    /// Server returned a status code different from 200.
     BadStatusCode,
 
-    /// Ссылка ведёт на файл другого типа
+    /// The url leads to a file of a different type.
     BadContentType,
 
-    /// Сервер не вернул ожидаемые заголовки
+    /// Server doesn't return expected headers.
     BadHeaders,
 }
 
-/// Результат получения данных XLS
+/// Result of XLS data retrieval.
 pub struct FetchOk {
-    /// ETag объекта
+    /// ETag object.
     pub etag: String,
 
-    /// Дата загрузки файла
+    /// File upload date.
     pub uploaded_at: DateTime<Utc>,
 
-    /// Дата получения данных
+    /// Date data received.
     pub requested_at: DateTime<Utc>,
 
-    /// Данные файла
+    /// File data.
     pub data: Option<Vec<u8>>,
 }
 
 impl FetchOk {
-    /// Результат без контента файла
+    /// Result without file content.
     pub fn head(etag: String, uploaded_at: DateTime<Utc>) -> Self {
         FetchOk {
             etag,
@@ -45,7 +45,7 @@ impl FetchOk {
         }
     }
 
-    /// Полный результат
+    /// Full result.
     pub fn get(etag: String, uploaded_at: DateTime<Utc>, data: Vec<u8>) -> Self {
         FetchOk {
             etag,
@@ -59,9 +59,9 @@ impl FetchOk {
 pub type FetchResult = Result<FetchOk, FetchError>;
 
 pub trait XLSDownloader {
-    /// Получение данных о файле, и, опционально, его контент
+    /// Get data about the file, and optionally its content.
     async fn fetch(&self, head: bool) -> FetchResult;
 
-    /// Установка ссылки на файл
+    /// Setting the file link.
     async fn set_url(&mut self, url: String) -> FetchResult;
 }