wip: refresh every hour

Cargo.toml

@@ -27,6 +27,7 @@ tempfile = "3.10.1"
 rust-embed = { version = "8.4.0", features = ["axum", "debug-embed"] }
 mime_guess = "2.0.4"
 chrono = "0.4.38"
+tokio_schedule = "0.3.1"
 
 [features]
 monero = ["dep:monero-rpc"]

src/cli.rs

@@ -1,17 +1,18 @@
+use crate::repo::TurbineRepo;
 use anyhow::Result;
 use axum::{
     extract::FromRef,
     routing::{get, post},
     Router,
 };
+use chrono::Utc;
 use clap::{Args, Parser};
 use std::{env, process::ExitCode, sync::Arc};
 use tokio::spawn;
 use tokio::{net::TcpListener, sync::Mutex};
+use tokio_schedule::{every, Job};
 use tracing::info;
 
-use crate::repo::TurbineRepo;
-
 #[derive(clap::Subcommand, Debug, Clone)]
 pub enum Commands {
     Serve(ServeArgs),
@@ -73,6 +74,20 @@ pub async fn serve(args: &ServeArgs) -> Result<ExitCode> {
         .route("/refresh", post(crate::api::refresh))
         .route("/assets/*file", get(crate::api::assets));
 
+    // Refresh every hour
+    let every_hour = every(1)
+        .hour()
+        .at(10, 30)
+        .in_timezone(&Utc)
+        .perform(|| async {
+            reqwest::Client::new()
+                .post("http://127.0.0.1:3000/refresh")
+                .send()
+                .await
+                .unwrap();
+        });
+    tokio::spawn(every_hour);
+
     info!("Starting listener");
     let listener =
         TcpListener::bind(args.bind.as_ref().unwrap_or(&"0.0.0.0:3000".to_string())).await?;

src/repo.rs

@@ -19,7 +19,8 @@ pub struct Contributor {
 
 impl Contributor {
     pub fn compute_payout(&self, commit_id: Oid) -> u64 {
-        todo!()
+        // TODO
+        1
     }
 }
 
@@ -88,7 +89,10 @@ impl TurbineRepo {
 
     pub fn refresh(&mut self) -> Result<()> {
         // Always fetch the repo first
-        // TODO
+        debug!("Fetching upstream repo");
+        self.container
+            .find_remote("origin")?
+            .fetch(&[self.branch.clone()], None, None)?;
 
         let mut revwalk = self.container.revwalk()?;
         revwalk.set_sorting(Sort::REVERSE)?;