upstream-rs 1.16.3

Fetch package updates directly from the source.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108

#![allow(async_fn_in_trait)]

use std::path::Path;

use anyhow::{Result, anyhow};
use async_trait::async_trait;
use chrono::{DateTime, Utc};

use crate::models::provider::{Asset, Release, RepositorySearchResult};

#[async_trait(?Send)]
pub trait ReleaseProvider {
    async fn get_latest_release(&self, slug: &str) -> Result<Release>;

    async fn get_releases(
        &self,
        slug: &str,
        per_page: Option<u32>,
        max_total: Option<u32>,
    ) -> Result<Vec<Release>>;

    async fn get_release_by_tag(&self, slug: &str, tag: &str) -> Result<Release>;

    async fn get_branch_head_sha(&self, _slug: &str, _branch: &str) -> Result<String> {
        Err(anyhow!("Branch builds are not supported for this provider"))
    }

    async fn search_repositories(
        &self,
        _query: &str,
        _limit: Option<u32>,
    ) -> Result<Vec<RepositorySearchResult>> {
        Err(anyhow!(
            "Repository search is not supported for this provider"
        ))
    }

    async fn get_latest_release_if_modified_since(
        &self,
        slug: &str,
        _last_upgraded: Option<DateTime<Utc>>,
    ) -> Result<Option<Release>> {
        Ok(Some(self.get_latest_release(slug).await?))
    }

    async fn download_asset(
        &self,
        asset: &Asset,
        destination_path: &Path,
        dl_callback: Option<&mut (dyn FnMut(u64, u64) + '_)>,
    ) -> Result<()>;
}

#[async_trait(?Send)]
impl<T> ReleaseProvider for &T
where
    T: ReleaseProvider + ?Sized,
{
    async fn get_latest_release(&self, slug: &str) -> Result<Release> {
        (*self).get_latest_release(slug).await
    }

    async fn get_releases(
        &self,
        slug: &str,
        per_page: Option<u32>,
        max_total: Option<u32>,
    ) -> Result<Vec<Release>> {
        (*self).get_releases(slug, per_page, max_total).await
    }

    async fn get_release_by_tag(&self, slug: &str, tag: &str) -> Result<Release> {
        (*self).get_release_by_tag(slug, tag).await
    }

    async fn get_branch_head_sha(&self, slug: &str, branch: &str) -> Result<String> {
        (*self).get_branch_head_sha(slug, branch).await
    }

    async fn search_repositories(
        &self,
        query: &str,
        limit: Option<u32>,
    ) -> Result<Vec<RepositorySearchResult>> {
        (*self).search_repositories(query, limit).await
    }

    async fn get_latest_release_if_modified_since(
        &self,
        slug: &str,
        last_upgraded: Option<DateTime<Utc>>,
    ) -> Result<Option<Release>> {
        (*self)
            .get_latest_release_if_modified_since(slug, last_upgraded)
            .await
    }

    async fn download_asset(
        &self,
        asset: &Asset,
        destination_path: &Path,
        dl_callback: Option<&mut (dyn FnMut(u64, u64) + '_)>,
    ) -> Result<()> {
        (*self)
            .download_asset(asset, destination_path, dl_callback)
            .await
    }
}