summaryrefslogtreecommitdiff
path: root/crates/discord-bot/src/jobs.rs
diff options
context:
space:
mode:
authorseth <[email protected]>2024-08-16 22:14:16 -0400
committerGitHub <[email protected]>2024-08-17 02:14:16 +0000
commitbbc00edc6508ea1910c4d9e6a272f7859900950d (patch)
tree538fe23940cb6bca8afa48059e502bfa7d5608cd /crates/discord-bot/src/jobs.rs
parent66ea6f8c225cc2273cfbfb1b948604c170a78e8c (diff)
end of summer refactor (#31)
* crates: `bot-*` -> `discord-bot` I didn't really need all these crates to be split :/ * discord-bot: revamp http impl also handles the new errors reported by teawieAPI * crates: split http backend this can be reused easily * git-tracker: short-circuit boolean logic We don't need to check if the commit is a descendant of the HEAD of the branch if it *is* the HEAD * nix: fenix -> nixpkgs * treefmt: add actionlint * nix: use docker arch names for containers * ci: use actions-rust-lang actions * nix: drop ci dev shell * git-tracker: init ManagedRepository this logic can be shared * ci: use nix for clippy scan * discord-bot: better handle unmerged PRs * ci: fix treefmt check * nix: fix clippy check * .env.template: update crate names * git-tracker: use remote name for remote name i was half asleep * discord-bot: handle merged PRs that aren't found in any tracked branches * git-tracker: make collect_statuses_in() return a Vec * discord-bot: add more PR info with response fixes #18
Diffstat (limited to 'crates/discord-bot/src/jobs.rs')
-rw-r--r--crates/discord-bot/src/jobs.rs36
1 files changed, 36 insertions, 0 deletions
diff --git a/crates/discord-bot/src/jobs.rs b/crates/discord-bot/src/jobs.rs
new file mode 100644
index 0000000..40d34cc
--- /dev/null
+++ b/crates/discord-bot/src/jobs.rs
@@ -0,0 +1,36 @@
+use crate::{config::Config, consts::NIXPKGS_REMOTE, consts::NIXPKGS_URL};
+
+use std::{path::Path, time::Duration};
+
+use eyre::Result;
+use git_tracker::ManagedRepository;
+use log::error;
+
+const TTL_SECS: u64 = 60 * 5; // 5 minutes
+
+/// Run our jobs an initial time, then loop them on a separate thread
+///
+/// # Errors
+///
+/// Will return [`Err`] if any jobs fail
+pub fn dispatch(config: Config) -> Result<()> {
+ let managed_repository = ManagedRepository {
+ path: Path::new(&config.nixpkgs_path).to_path_buf(),
+ tracked_branches: config.nixpkgs_branches,
+ upstream_remote_url: NIXPKGS_URL.to_string(),
+ upstream_remote_name: NIXPKGS_REMOTE.to_string(),
+ };
+
+ managed_repository.fetch_or_update()?;
+
+ tokio::spawn(async move {
+ loop {
+ tokio::time::sleep(Duration::from_secs(TTL_SECS)).await;
+ if let Err(why) = managed_repository.fetch_or_update() {
+ error!("Could not fetch or update repository!\n{why:?}");
+ };
+ }
+ });
+
+ Ok(())
+}