Bump tokio from 1.44.1 to 1.44.2

Bumps [tokio](https://github.com/tokio-rs/tokio) from 1.44.1 to 1.44.2. - [Release notes](https://github.com/tokio-rs/tokio/releases) - [Commits](https://github.com/tokio-rs/tokio/compare/tokio-1.44.1...tokio-1.44.2) --- updated-dependencies: - dependency-name: tokio dependency-version: 1.44.2 dependency-type: direct:production update-type: version-update:semver-patch ... Signed-off-by: dependabot[bot] <support@github.com>
2025-12-06 17:57:47 +03:00 · 2025-04-16 21:16:18 +00:00
13 changed files with 110 additions and 293 deletions
--- a/.github/workflows/release.yml
+++ b/.github/workflows/release.yml
@@ -1,169 +0,0 @@
-name: release
-
-on:
-  push:
-    tags: [ "release/v*" ]
-
-permissions:
-  contents: write
-
-env:
-  CARGO_TERM_COLOR: always
-
-  BINARY_NAME: schedule-parser-rusted
-
-  TEST_DB: ${{ secrets.TEST_DATABASE_URL }}
-
-  SENTRY_AUTH_TOKEN: ${{ secrets.SENTRY_AUTH_TOKEN }}
-  SENTRY_ORG: ${{ secrets.SENTRY_ORG }}
-  SENTRY_PROJECT: ${{ secrets.SENTRY_PROJECT }}
-
-  DOCKER_IMAGE_NAME: ${{ github.repository }}
-
-  DOCKER_REGISTRY_HOST: registry.n08i40k.ru
-  DOCKER_REGISTRY_USERNAME: ${{ github.repository_owner }}
-  DOCKER_REGISTRY_PASSWORD: ${{ secrets.DOCKER_REGISTRY_PASSWORD }}
-
-jobs:
-  test:
-    name: Test
-    runs-on: ubuntu-latest
-    steps:
-      - uses: actions/checkout@v4
-        with:
-          fetch-depth: 0
-
-      - name: Setup Rust
-        uses: actions-rust-lang/setup-rust-toolchain@v1.11.0
-        with:
-          toolchain: stable
-
-      - name: Test
-        run: |
-          touch .env.test
-          cargo test --verbose
-        env:
-          DATABASE_URL: ${{ env.TEST_DB }}
-          JWT_SECRET: "test-secret-at-least-256-bits-used"
-          VKID_CLIENT_ID: 0
-          VKID_REDIRECT_URI: "vk0://vk.com/blank.html"
-          REQWEST_USER_AGENT: "Dalvik/2.1.0 (Linux; U; Android 6.0.1; OPPO R9s Build/MMB29M)"
-  build:
-    name: Build
-    runs-on: ubuntu-latest
-    needs: test
-    steps:
-      - uses: actions/checkout@v4
-        with:
-          fetch-depth: 0
-
-      - name: Setup Rust
-        uses: actions-rust-lang/setup-rust-toolchain@v1.11.0
-        with:
-          toolchain: stable
-
-      - name: Build
-        run: cargo build --release --verbose
-
-      - name: Extract debug symbols
-        run: |
-          objcopy --only-keep-debug target/release/${{ env.BINARY_NAME }}{,.d}
-          objcopy --strip-debug --strip-unneeded target/release/${{ env.BINARY_NAME }}
-          objcopy --add-gnu-debuglink target/release/${{ env.BINARY_NAME }}{.d,}
-
-      - name: Setup sentry-cli
-        uses: matbour/setup-sentry-cli@v2.0.0
-        with:
-          version: latest
-          token: ${{ env.SENTRY_AUTH_TOKEN }}
-          organization: ${{ env.SENTRY_ORG }}
-          project: ${{ env.SENTRY_PROJECT }}
-
-      - name: Upload debug symbols to Sentry
-        run: |
-          sentry-cli debug-files upload --include-sources .
-
-      - name: Upload build binary artifact
-        uses: actions/upload-artifact@v4
-        with:
-          name: release-binary
-          path: target/release/${{ env.BINARY_NAME }}
-
-      - name: Upload build debug symbols artifact
-        uses: actions/upload-artifact@v4
-        with:
-          name: release-symbols
-          path: target/release/${{ env.BINARY_NAME }}.d
-
-  docker:
-    name: Build & Push Docker Image
-    runs-on: ubuntu-latest
-    needs: build
-    steps:
-      - uses: actions/checkout@v4
-
-      - name: Download build artifacts
-        uses: actions/download-artifact@v4
-        with:
-          name: release-binary
-
-      - name: Setup Docker Buildx
-        uses: docker/setup-buildx-action@v3.10.0
-
-      - name: Login to Registry
-        uses: docker/login-action@v3.4.0
-        with:
-          registry: ${{ env.DOCKER_REGISTRY_HOST }}
-          username: ${{ env.DOCKER_REGISTRY_USERNAME }}
-          password: ${{ env.DOCKER_REGISTRY_PASSWORD }}
-
-      - name: Extract Docker metadata
-        id: meta
-        uses: docker/metadata-action@v5.7.0
-        with:
-          images: ${{ env.DOCKER_REGISTRY_HOST }}/${{ env.DOCKER_IMAGE_NAME }}
-
-      - name: Build and push Docker image
-        id: build-and-push
-        uses: docker/build-push-action@v6.15.0
-        with:
-          context: .
-          push: true
-          tags: ${{ steps.meta.outputs.tags }}
-          labels: ${{ steps.meta.outputs.labels }}
-          cache-from: type=gha
-          cache-to: type=gha,mode=max
-          build-args: |
-            "BINARY_NAME=${{ env.BINARY_NAME }}"
-  release:
-    name: Create GitHub Release
-    runs-on: ubuntu-latest
-    needs:
-      - build
-      - docker
-    # noinspection GrazieInspection,SpellCheckingInspection
-    steps:
-      - uses: actions/checkout@v4
-        with:
-          fetch-depth: 0
-
-      - name: Generate changelog
-        run: |
-          LAST_TAG=$(git describe --tags --abbrev=0 HEAD^)
-          echo "## Коммиты с прошлого релиза $LAST_TAG" > CHANGELOG.md
-          git log $LAST_TAG..HEAD --oneline >> CHANGELOG.md
-
-      - name: Download build artifacts
-        uses: actions/download-artifact@v4
-        with:
-          pattern: release-*
-          merge-multiple: true
-
-      - name: Create Release
-        id: create_release
-        uses: ncipollo/release-action@v1.16.0
-        env:
-          GITHUB_TOKEN: ${{ secrets.GITHUB_TOKEN }}
-        with:
-          artifacts: "${{ env.BINARY_NAME }},${{ env.BINARY_NAME }}.d"
-          bodyFile: CHANGELOG.md
--- a/.github/workflows/test.yml
+++ b/.github/workflows/test.yml
@@ -1,9 +1,10 @@
-name: cargo test
+name: Tests

 on:
  push:
    branches: [ "master" ]
-    tags-ignore: [ "release/v*" ]
+  pull_request:
+    branches: [ "master" ]

 permissions:
  contents: read
@@ -29,4 +30,3 @@ jobs:
          JWT_SECRET: "test-secret-at-least-256-bits-used"
          VKID_CLIENT_ID: 0
          VKID_REDIRECT_URI: "vk0://vk.com/blank.html"
-          REQWEST_USER_AGENT: "Dalvik/2.1.0 (Linux; U; Android 6.0.1; OPPO R9s Build/MMB29M)"
--- a/.idea/sqldialects.xml
+++ b/.idea/sqldialects.xml
@@ -0,0 +1,9 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="SqlDialectMappings">
+    <file url="file://$PROJECT_DIR$/migrations/2025-03-21-211822_create_user_role/down.sql" dialect="PostgreSQL" />
+    <file url="file://$PROJECT_DIR$/migrations/2025-03-21-212111_create_users/up.sql" dialect="PostgreSQL" />
+    <file url="file://$PROJECT_DIR$/migrations/2025-03-21-212723_create_fcm/down.sql" dialect="PostgreSQL" />
+    <file url="file://$PROJECT_DIR$/migrations/2025-03-21-212723_create_fcm/up.sql" dialect="PostgreSQL" />
+  </component>
+</project>
--- a/Cargo.lock
+++ b/Cargo.lock
@@ -2876,7 +2876,7 @@ dependencies = [

 [[package]]
 name = "schedule-parser-rusted"
-version = "1.0.2"
+version = "0.8.0"
 dependencies = [
 "actix-macros 0.1.0",
 "actix-test",
@@ -3484,9 +3484,9 @@ checksum = "1f3ccbac311fea05f86f61904b462b55fb3df8837a366dfc601a0161d0532f20"

 [[package]]
 name = "tokio"
-version = "1.44.1"
+version = "1.44.2"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "f382da615b842244d4b8738c82ed1275e6c5dd90c459a30941cd07080b06c91a"
+checksum = "e6b88822cbe49de4185e3a4cbf8321dd487cf5fe0c5c65695fef6346371e9c48"
 dependencies = [
 "backtrace",
 "bytes",
--- a/Cargo.toml
+++ b/Cargo.toml
@@ -3,13 +3,10 @@ members = ["actix-macros", "actix-test"]

 [package]
 name = "schedule-parser-rusted"
-version = "1.0.2"
+version = "0.8.0"
 edition = "2024"
 publish = false

-[profile.release]
-debug = true
-
 [dependencies]
 actix-web = "4.10.2"
 actix-macros = { path = "actix-macros" }
@@ -37,7 +34,7 @@ serde_json = "1.0.140"
 serde_with = "3.12.0"
 serde_repr = "0.1.20"
 sha1 = "0.11.0-pre.5"
-tokio = { version = "1.44.1", features = ["macros", "rt-multi-thread"] }
+tokio = { version = "1.44.2", features = ["macros", "rt-multi-thread"] }
 rand = "0.9.0"
 utoipa = { version = "5", features = ["actix_extras", "chrono"] }
 utoipa-rapidoc = { version = "6.0.0", features = ["actix-web"] }
--- a/14
+++ b/14
@@ -1,14 +0,0 @@
-FROM debian:stable-slim
-LABEL authors="n08i40k"
-
-ARG BINARY_NAME
-
-WORKDIR /app/
-
-RUN apt update && \
-    apt install -y libpq5
-
-COPY ./${BINARY_NAME} /bin/main
-RUN chmod +x /bin/main
-
-ENTRYPOINT ["main"]
--- a/src/routes/auth/shared.rs
+++ b/src/routes/auth/shared.rs
@@ -1,6 +1,9 @@
+use crate::utility::jwt::DEFAULT_ALGORITHM;
 use jsonwebtoken::errors::ErrorKind;
-use jsonwebtoken::{decode, Algorithm, DecodingKey, Validation};
+use jsonwebtoken::{decode, DecodingKey, Validation};
 use serde::{Deserialize, Serialize};
+use std::env;
+use std::sync::LazyLock;

 #[derive(Deserialize, Serialize)]
 struct TokenData {
@@ -14,7 +17,7 @@ struct TokenData {

 #[derive(Debug, Serialize, Deserialize)]
 struct Claims {
-    sub: i32,
+    sub: String,
    iis: String,
    jti: i32,
    app: i32,
@@ -49,10 +52,17 @@ const VK_PUBLIC_KEY: &str = concat!(
    "-----END PUBLIC KEY-----"
 );

-pub fn parse_vk_id(token_str: &String, client_id: i32) -> Result<i32, Error> {
+static VK_ID_CLIENT_ID: LazyLock<i32> = LazyLock::new(|| {
+    env::var("VK_ID_CLIENT_ID")
+        .expect("VK_ID_CLIENT_ID must be set")
+        .parse::<i32>()
+        .expect("VK_ID_CLIENT_ID must be i32")
+});
+
+pub fn parse_vk_id(token_str: &String) -> Result<i32, Error> {
    let dkey = DecodingKey::from_rsa_pem(VK_PUBLIC_KEY.as_bytes()).unwrap();

-    match decode::<Claims>(&token_str, &dkey, &Validation::new(Algorithm::RS256)) {
+    match decode::<Claims>(&token_str, &dkey, &Validation::new(DEFAULT_ALGORITHM)) {
        Ok(token_data) => {
            let claims = token_data.claims;

@@ -60,10 +70,13 @@ pub fn parse_vk_id(token_str: &String, client_id: i32) -> Result<i32, Error> {
                Err(Error::UnknownIssuer(claims.iis))
            } else if claims.jti != 21 {
                Err(Error::UnknownType(claims.jti))
-            } else if claims.app != client_id {
+            } else if claims.app != *VK_ID_CLIENT_ID {
                Err(Error::UnknownClientId(claims.app))
            } else {
-                Ok(claims.sub)
+                match claims.sub.parse::<i32>() {
+                    Ok(sub) => Ok(sub),
+                    Err(_) => Err(Error::InvalidToken),
+                }
            }
        }
        Err(err) => Err(match err.into_kind() {
--- a/src/routes/auth/sign_in.rs
+++ b/src/routes/auth/sign_in.rs
@@ -71,7 +71,7 @@ pub async fn sign_in_vk(
 ) -> ServiceResponse {
    let data = data_json.into_inner();

-    match parse_vk_id(&data.access_token, app_state.vk_id.client_id) {
+    match parse_vk_id(&data.access_token) {
        Ok(id) => sign_in_combined(Vk(id), &app_state).await.into(),
        Err(_) => ErrorCode::InvalidVkAccessToken.into_response(),
    }
--- a/src/routes/auth/sign_up.rs
+++ b/src/routes/auth/sign_up.rs
@@ -79,7 +79,7 @@ pub async fn sign_up_vk(
 ) -> ServiceResponse {
    let data = data_json.into_inner();

-    match parse_vk_id(&data.access_token, app_state.vk_id.client_id) {
+    match parse_vk_id(&data.access_token) {
        Ok(id) => sign_up_combined(
            SignUpData {
                username: data.username,
--- a/src/routes/schedule/update_download_url.rs
+++ b/src/routes/schedule/update_download_url.rs
@@ -4,7 +4,7 @@ use crate::app_state::Schedule;
 use crate::parser::parse_xls;
 use crate::routes::schedule::schema::CacheStatus;
 use crate::routes::schema::{IntoResponseAsError, ResponseError};
-use crate::xls_downloader::interface::{FetchError, XLSDownloader};
+use crate::xls_downloader::interface::XLSDownloader;
 use actix_web::web::Json;
 use actix_web::{patch, web};
 use chrono::Utc;
@@ -60,20 +60,18 @@ pub async fn update_download_url(
                    }
                },
                Err(error) => {
-                    if let FetchError::Unknown(error) = &error {
-                        sentry::capture_error(&error);
-                    }
+                    eprintln!("Unknown url provided {}", data.url);
+                    eprintln!("{:?}", error);

-                    ErrorCode::DownloadFailed(error).into_response()
+                    ErrorCode::DownloadFailed.into_response()
                }
            }
        }
        Err(error) => {
-            if let FetchError::Unknown(error) = &error {
-                sentry::capture_error(&error);
-            }
+            eprintln!("Unknown url provided {}", data.url);
+            eprintln!("{:?}", error);

-            ErrorCode::FetchFailed(error).into_response()
+            ErrorCode::FetchFailed.into_response()
        }
    }
 }
@@ -85,7 +83,6 @@ mod schema {
    use derive_more::Display;
    use serde::{Deserialize, Serialize, Serializer};
    use utoipa::ToSchema;
-    use crate::xls_downloader::interface::FetchError;

    pub type ServiceResponse = crate::routes::schema::Response<CacheStatus, ErrorCode>;

@@ -104,12 +101,12 @@ mod schema {
        NonWhitelistedHost,

        /// Failed to retrieve file metadata.
-        #[display("Unable to retrieve metadata from the specified URL: {_0}")]
-        FetchFailed(FetchError),
+        #[display("Unable to retrieve metadata from the specified URL.")]
+        FetchFailed,

        /// Failed to download the file.
-        #[display("Unable to retrieve data from the specified URL: {_0}")]
-        DownloadFailed(FetchError),
+        #[display("Unable to retrieve data from the specified URL.")]
+        DownloadFailed,

        /// The link leads to an outdated schedule.
        ///
@@ -130,8 +127,8 @@ mod schema {
        {
            match self {
                ErrorCode::NonWhitelistedHost => serializer.serialize_str("NON_WHITELISTED_HOST"),
-                ErrorCode::FetchFailed(_) => serializer.serialize_str("FETCH_FAILED"),
-                ErrorCode::DownloadFailed(_) => serializer.serialize_str("DOWNLOAD_FAILED"),
+                ErrorCode::FetchFailed => serializer.serialize_str("FETCH_FAILED"),
+                ErrorCode::DownloadFailed => serializer.serialize_str("DOWNLOAD_FAILED"),
                ErrorCode::OutdatedSchedule => serializer.serialize_str("OUTDATED_SCHEDULE"),
                ErrorCode::InvalidSchedule(_) => serializer.serialize_str("INVALID_SCHEDULE"),
            }
--- a/src/routes/vk_id/oauth.rs
+++ b/src/routes/vk_id/oauth.rs
@@ -59,16 +59,13 @@ async fn oauth(data: web::Json<Request>, app_state: web::Data<AppState>) -> Serv
                return ErrorCode::VkIdError.into_response();
            }

-            match res.json::<VkIdAuthResponse>().await {
-                Ok(auth_data) =>
-                    Ok(Response {
-                        access_token: auth_data.id_token,
-                    }).into(),
-                Err(error) => {
-                    sentry::capture_error(&error);
-                    
-                    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(),
--- a/src/xls_downloader/basic_impl.rs
+++ b/src/xls_downloader/basic_impl.rs
@@ -1,14 +1,11 @@
 use crate::xls_downloader::interface::{FetchError, FetchOk, FetchResult, XLSDownloader};
 use chrono::{DateTime, Utc};
-use std::env;
-use std::sync::Arc;

 pub struct BasicXlsDownloader {
    pub url: Option<String>,
-    user_agent: String,
 }

-async fn fetch_specified(url: &String, user_agent: &String, head: bool) -> FetchResult {
+async fn fetch_specified(url: &String, user_agent: String, head: bool) -> FetchResult {
    let client = reqwest::Client::new();

    let response = if head {
@@ -16,14 +13,14 @@ async fn fetch_specified(url: &String, user_agent: &String, head: bool) -> Fetch
    } else {
        client.get(url)
    }
-    .header("User-Agent", user_agent.clone())
+    .header("User-Agent", user_agent)
    .send()
    .await;

    match response {
        Ok(r) => {
            if r.status().as_u16() != 200 {
-                return Err(FetchError::BadStatusCode(r.status().as_u16()));
+                return Err(FetchError::BadStatusCode);
            }

            let headers = r.headers();
@@ -33,18 +30,11 @@ async fn fetch_specified(url: &String, user_agent: &String, head: bool) -> Fetch
            let last_modified = headers.get("last-modified");
            let date = headers.get("date");

-            if content_type.is_none() {
-                Err(FetchError::BadHeaders("Content-Type".to_string()))
-            } else if etag.is_none() {
-                Err(FetchError::BadHeaders("ETag".to_string()))
-            } else if last_modified.is_none() {
-                Err(FetchError::BadHeaders("Last-Modified".to_string()))
-            } else if date.is_none() {
-                Err(FetchError::BadHeaders("Date".to_string()))
+            if content_type.is_none() || etag.is_none() || last_modified.is_none() || date.is_none()
+            {
+                Err(FetchError::BadHeaders)
            } else if content_type.unwrap() != "application/vnd.ms-excel" {
-                Err(FetchError::BadContentType(
-                    content_type.unwrap().to_str().unwrap().to_string(),
-                ))
+                Err(FetchError::BadContentType)
            } else {
                let etag = etag.unwrap().to_str().unwrap().to_string();
                let last_modified =
@@ -59,16 +49,13 @@ async fn fetch_specified(url: &String, user_agent: &String, head: bool) -> Fetch
                })
            }
        }
-        Err(error) => Err(FetchError::Unknown(Arc::new(error))),
+        Err(_) => Err(FetchError::Unknown),
    }
 }

 impl BasicXlsDownloader {
    pub fn new() -> Self {
-        BasicXlsDownloader {
-            url: None,
-            user_agent: env::var("REQWEST_USER_AGENT").expect("USER_AGENT must be set"),
-        }
+        BasicXlsDownloader { url: None }
    }
 }

@@ -77,12 +64,17 @@ impl XLSDownloader for BasicXlsDownloader {
        if self.url.is_none() {
            Err(FetchError::NoUrlProvided)
        } else {
-            fetch_specified(self.url.as_ref().unwrap(), &self.user_agent, head).await
+            fetch_specified(
+                self.url.as_ref().unwrap(),
+                "t.me/polytechnic_next".to_string(),
+                head,
+            )
+            .await
        }
    }

    async fn set_url(&mut self, url: String) -> FetchResult {
-        let result = fetch_specified(&url, &self.user_agent, true).await;
+        let result = fetch_specified(&url, "t.me/polytechnic_next".to_string(), true).await;

        if let Ok(_) = result {
            self.url = Some(url);
@@ -94,7 +86,7 @@ impl XLSDownloader for BasicXlsDownloader {

 #[cfg(test)]
 mod tests {
-    use crate::xls_downloader::basic_impl::{fetch_specified, BasicXlsDownloader};
+    use crate::xls_downloader::basic_impl::{BasicXlsDownloader, fetch_specified};
    use crate::xls_downloader::interface::{FetchError, XLSDownloader};

    #[tokio::test]
@@ -103,8 +95,8 @@ mod tests {
        let user_agent = String::new();

        let results = [
-            fetch_specified(&url, &user_agent, true).await,
-            fetch_specified(&url, &user_agent, false).await,
+            fetch_specified(&url, user_agent.clone(), true).await,
+            fetch_specified(&url, user_agent.clone(), false).await,
        ];

        assert!(results[0].is_err());
@@ -117,17 +109,21 @@ mod tests {
        let user_agent = String::new();

        let results = [
-            fetch_specified(&url, &user_agent, true).await,
-            fetch_specified(&url, &user_agent, false).await,
+            fetch_specified(&url, user_agent.clone(), true).await,
+            fetch_specified(&url, user_agent.clone(), false).await,
        ];

        assert!(results[0].is_err());
        assert!(results[1].is_err());

-        let expected_error = FetchError::BadStatusCode(404);
-
-        assert_eq!(*results[0].as_ref().err().unwrap(), expected_error);
-        assert_eq!(*results[1].as_ref().err().unwrap(), expected_error);
+        assert_eq!(
+            *results[0].as_ref().err().unwrap(),
+            FetchError::BadStatusCode
+        );
+        assert_eq!(
+            *results[1].as_ref().err().unwrap(),
+            FetchError::BadStatusCode
+        );
    }

    #[tokio::test]
@@ -136,17 +132,15 @@ mod tests {
        let user_agent = String::new();

        let results = [
-            fetch_specified(&url, &user_agent, true).await,
-            fetch_specified(&url, &user_agent, false).await,
+            fetch_specified(&url, user_agent.clone(), true).await,
+            fetch_specified(&url, user_agent.clone(), false).await,
        ];

        assert!(results[0].is_err());
        assert!(results[1].is_err());

-        let expected_error = FetchError::BadHeaders("ETag".to_string());
-
-        assert_eq!(*results[0].as_ref().err().unwrap(), expected_error);
-        assert_eq!(*results[1].as_ref().err().unwrap(), expected_error);
+        assert_eq!(*results[0].as_ref().err().unwrap(), FetchError::BadHeaders);
+        assert_eq!(*results[1].as_ref().err().unwrap(), FetchError::BadHeaders);
    }

    #[tokio::test]
@@ -155,12 +149,21 @@ mod tests {
        let user_agent = String::new();

        let results = [
-            fetch_specified(&url, &user_agent, true).await,
-            fetch_specified(&url, &user_agent, false).await,
+            fetch_specified(&url, user_agent.clone(), true).await,
+            fetch_specified(&url, user_agent.clone(), false).await,
        ];

        assert!(results[0].is_err());
        assert!(results[1].is_err());
+
+        assert_eq!(
+            *results[0].as_ref().err().unwrap(),
+            FetchError::BadContentType
+        );
+        assert_eq!(
+            *results[1].as_ref().err().unwrap(),
+            FetchError::BadContentType
+        );
    }

    #[tokio::test]
@@ -169,8 +172,8 @@ mod tests {
        let user_agent = String::new();

        let results = [
-            fetch_specified(&url, &user_agent, true).await,
-            fetch_specified(&url, &user_agent, false).await,
+            fetch_specified(&url, user_agent.clone(), true).await,
+            fetch_specified(&url, user_agent.clone(), false).await,
        ];

        assert!(results[0].is_ok());
--- a/src/xls_downloader/interface.rs
+++ b/src/xls_downloader/interface.rs
@@ -1,38 +1,22 @@
 use chrono::{DateTime, Utc};
-use derive_more::Display;
-use std::mem::discriminant;
-use std::sync::Arc;
-use utoipa::ToSchema;

 /// XLS data retrieval errors.
-#[derive(Clone, Debug, ToSchema, Display)]
+#[derive(PartialEq, Debug)]
 pub enum FetchError {
    /// File url is not set.
-    #[display("The link to the timetable was not provided earlier.")]
    NoUrlProvided,

    /// Unknown error.
-    #[display("An unknown error occurred while downloading the file.")]
-    #[schema(value_type = String)]
-    Unknown(Arc<reqwest::Error>),
+    Unknown,

    /// Server returned a status code different from 200.
-    #[display("Server returned a status code {_0}.")]
-    BadStatusCode(u16),
+    BadStatusCode,

    /// The url leads to a file of a different type.
-    #[display("The link leads to a file of type '{_0}'.")]
-    BadContentType(String),
+    BadContentType,

    /// Server doesn't return expected headers.
-    #[display("Server doesn't return expected header(s) '{_0}'.")]
-    BadHeaders(String),
-}
-
-impl PartialEq for FetchError {
-    fn eq(&self, other: &Self) -> bool {
-        discriminant(self) == discriminant(other)
-    }
+    BadHeaders,
 }

 /// Result of XLS data retrieval.