diff options
| -rw-r--r-- | src/database.rs | 16 | ||||
| -rw-r--r-- | src/main.rs | 6 |
2 files changed, 18 insertions, 4 deletions
diff --git a/src/database.rs b/src/database.rs index e735df9..2a53f0b 100644 --- a/src/database.rs +++ b/src/database.rs @@ -139,7 +139,21 @@ impl Db { is_updated } - pub fn repo_update(repo: &Repo) -> Result<(), Error> { + pub async fn repo_update(&mut self, repo: &Repo) -> Result<(), Error> { + let mut tx = self.connection.begin().await?; + + sqlx::query(r#" + UPDATE repositories + SET updated_at = ? + WHERE id = ? + "#) + .bind(&repo.updated_at) + .bind(repo.id) + .execute(&mut tx) + .await?; + + tx.commit().await?; + Ok(()) } } diff --git a/src/main.rs b/src/main.rs index e7be108..cbaec61 100644 --- a/src/main.rs +++ b/src/main.rs @@ -61,10 +61,10 @@ async fn main() { match db.repo_get(id).await { Ok(r) => { - // TODO: fetch - if db.repo_is_updated(&db_repo).await.unwrap() { - dbg!("UPDATED", &db_repo); + // TODO: fetch + + db.repo_update(&db_repo).await.unwrap(); } }, |