Compare commits
2 Commits
779b68f053
...
5b670ed775
Author | SHA1 | Date | |
---|---|---|---|
|
5b670ed775 | ||
e4d5d5302e |
24
CHANGELOG.md
24
CHANGELOG.md
@ -6,6 +6,30 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
|
||||
|
||||
## [Unreleased]
|
||||
|
||||
## [0.2.0] - 2024-09-14
|
||||
|
||||
### Added
|
||||
- add cache get
|
||||
- send out wait
|
||||
- add cache
|
||||
- add settings config
|
||||
- add github fetch prs refactoring
|
||||
- gitea able to pull repositories
|
||||
- add config
|
||||
|
||||
### Docs
|
||||
- add readme
|
||||
|
||||
### Fixed
|
||||
- don't have to use user for basic auth
|
||||
|
||||
### Other
|
||||
- removed unused code
|
||||
- move projects list into separate file
|
||||
- separate files
|
||||
- move config out
|
||||
- remove unused libraries
|
||||
|
||||
## [0.1.0] - 2024-09-12
|
||||
|
||||
### Added
|
||||
|
@ -3,7 +3,7 @@ members = ["crates/*"]
|
||||
resolver = "2"
|
||||
|
||||
[workspace.package]
|
||||
version = "0.1.0"
|
||||
version = "0.2.0"
|
||||
|
||||
[workspace.dependencies]
|
||||
gitnow = { path = "crates/gitnow" }
|
||||
|
@ -52,7 +52,37 @@ impl Cache {
|
||||
return Ok(None);
|
||||
}
|
||||
|
||||
let file = tokio::fs::read(location).await?;
|
||||
if let Some(cache_duration) = self.app.config.settings.cache.duration.get_duration() {
|
||||
let metadata = tokio::fs::metadata(&location).await?;
|
||||
|
||||
if let Ok(file_modified_last) = metadata
|
||||
.modified()
|
||||
.context("failed to get modified date")
|
||||
.inspect_err(|e| {
|
||||
tracing::warn!(
|
||||
"could not get valid metadata from file, cache will be reused: {}",
|
||||
e
|
||||
);
|
||||
})
|
||||
.and_then(|m| {
|
||||
m.elapsed()
|
||||
.context("failed to get elapsed from file")
|
||||
.inspect_err(|e| tracing::warn!("failed to get elapsed from system: {}", e))
|
||||
})
|
||||
{
|
||||
tracing::trace!(
|
||||
cache = file_modified_last.as_secs(),
|
||||
expiry = cache_duration.as_secs(),
|
||||
"checking if cache is valid"
|
||||
);
|
||||
if file_modified_last > cache_duration {
|
||||
tracing::debug!("cache has expired");
|
||||
return Ok(None);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
let file = tokio::fs::read(&location).await?;
|
||||
if file.is_empty() {
|
||||
tracing::debug!("cache file appears to be empty");
|
||||
return Ok(None);
|
||||
@ -87,7 +117,7 @@ pub trait CacheConfig {
|
||||
|
||||
impl CacheConfig for Config {
|
||||
fn get_cache_location(&self) -> anyhow::Result<PathBuf> {
|
||||
Ok(self.settings.cache.location.clone())
|
||||
Ok(self.settings.cache.location.clone().into())
|
||||
}
|
||||
|
||||
fn get_cache_file_location(&self) -> anyhow::Result<PathBuf> {
|
||||
|
@ -27,7 +27,7 @@ impl RootCommand {
|
||||
};
|
||||
|
||||
for repo in &repositories {
|
||||
tracing::info!("repo: {}", repo.to_rel_path().display());
|
||||
//tracing::info!("repo: {}", repo.to_rel_path().display());
|
||||
}
|
||||
|
||||
tracing::info!("amount of repos fetched {}", repositories.len());
|
||||
|
@ -18,17 +18,76 @@ pub struct Settings {
|
||||
pub cache: Cache,
|
||||
}
|
||||
|
||||
#[derive(Debug, Serialize, Deserialize, PartialEq)]
|
||||
#[derive(Debug, Default, Serialize, Deserialize, PartialEq)]
|
||||
pub struct Cache {
|
||||
pub location: PathBuf,
|
||||
#[serde(default)]
|
||||
pub location: CacheLocation,
|
||||
|
||||
#[serde(default)]
|
||||
pub duration: CacheDuration,
|
||||
}
|
||||
|
||||
impl Default for Cache {
|
||||
#[derive(Debug, Clone, Serialize, Deserialize, PartialEq)]
|
||||
pub struct CacheLocation(PathBuf);
|
||||
|
||||
impl From<PathBuf> for CacheLocation {
|
||||
fn from(value: PathBuf) -> Self {
|
||||
Self(value)
|
||||
}
|
||||
}
|
||||
|
||||
impl From<CacheLocation> for PathBuf {
|
||||
fn from(value: CacheLocation) -> Self {
|
||||
value.0
|
||||
}
|
||||
}
|
||||
|
||||
impl Default for CacheLocation {
|
||||
fn default() -> Self {
|
||||
let home = dirs::home_dir().unwrap_or_default();
|
||||
|
||||
Self {
|
||||
location: home.join(".cache/gitnow"),
|
||||
Self(home.join(".cache/gitnow"))
|
||||
}
|
||||
}
|
||||
|
||||
#[derive(Debug, Serialize, Deserialize, PartialEq)]
|
||||
#[serde(untagged)]
|
||||
pub enum CacheDuration {
|
||||
Enabled(bool),
|
||||
Precise {
|
||||
#[serde(default)]
|
||||
days: u64,
|
||||
#[serde(default)]
|
||||
hours: u64,
|
||||
#[serde(default)]
|
||||
minutes: u64,
|
||||
},
|
||||
}
|
||||
|
||||
impl CacheDuration {
|
||||
pub fn get_duration(&self) -> Option<std::time::Duration> {
|
||||
match self {
|
||||
CacheDuration::Enabled(true) => CacheDuration::default().get_duration(),
|
||||
CacheDuration::Enabled(false) => None,
|
||||
CacheDuration::Precise {
|
||||
days,
|
||||
hours,
|
||||
minutes,
|
||||
} => Some(
|
||||
std::time::Duration::from_days(*days)
|
||||
+ std::time::Duration::from_hours(*hours)
|
||||
+ std::time::Duration::from_mins(*minutes),
|
||||
),
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
impl Default for CacheDuration {
|
||||
fn default() -> Self {
|
||||
Self::Precise {
|
||||
days: 1,
|
||||
hours: 0,
|
||||
minutes: 0,
|
||||
}
|
||||
}
|
||||
}
|
||||
@ -174,6 +233,7 @@ mod test {
|
||||
let content = r#"
|
||||
[settings.cache]
|
||||
location = ".cache/gitnow"
|
||||
duration = { days = 2 }
|
||||
|
||||
[[providers.github]]
|
||||
current_user = "kjuulh"
|
||||
@ -250,7 +310,12 @@ mod test {
|
||||
},
|
||||
settings: Settings {
|
||||
cache: Cache {
|
||||
location: PathBuf::from(".cache/gitnow/")
|
||||
location: PathBuf::from(".cache/gitnow").into(),
|
||||
duration: CacheDuration::Precise {
|
||||
days: 2,
|
||||
hours: 0,
|
||||
minutes: 0
|
||||
}
|
||||
}
|
||||
}
|
||||
},
|
||||
|
@ -120,7 +120,6 @@ impl GiteaProvider {
|
||||
.collect())
|
||||
}
|
||||
|
||||
#[tracing::instrument(skip(self))]
|
||||
pub async fn list_repositories_for_user_with_page(
|
||||
&self,
|
||||
user: &str,
|
||||
@ -135,7 +134,6 @@ impl GiteaProvider {
|
||||
Ok(repos)
|
||||
}
|
||||
|
||||
#[tracing::instrument]
|
||||
pub async fn list_repositories_for_organisation(
|
||||
&self,
|
||||
organisation: &str,
|
||||
@ -181,7 +179,6 @@ impl GiteaProvider {
|
||||
.collect())
|
||||
}
|
||||
|
||||
#[tracing::instrument(skip(self))]
|
||||
pub async fn list_repositories_for_organisation_with_page(
|
||||
&self,
|
||||
organisation: &str,
|
||||
|
@ -1,3 +1,5 @@
|
||||
#![feature(duration_constructors)]
|
||||
|
||||
use std::path::PathBuf;
|
||||
|
||||
use anyhow::Context;
|
||||
|
Loading…
Reference in New Issue
Block a user