aboutsummaryrefslogtreecommitdiffstats
path: root/src/main.rs
diff options
context:
space:
mode:
authorTeddy Wing2021-05-30 03:25:59 +0200
committerTeddy Wing2021-05-30 03:25:59 +0200
commitf2f05bdba3bbcedbbc643d8d3f1122fe0b4a3ab2 (patch)
tree626735e18611882cf287297cf59905dffa226b80 /src/main.rs
parent1c191a68165c70a6d0d8f4d5b9e01412266c8c25 (diff)
downloadreflectub-f2f05bdba3bbcedbbc643d8d3f1122fe0b4a3ab2.tar.bz2
Check if repo was updated based on `updated_at` timestamp
Find out if the latest copy is more recent than the cached value in our database.
Diffstat (limited to 'src/main.rs')
-rw-r--r--src/main.rs17
1 files changed, 14 insertions, 3 deletions
diff --git a/src/main.rs b/src/main.rs
index 1b68b61..e7be108 100644
--- a/src/main.rs
+++ b/src/main.rs
@@ -56,11 +56,22 @@ async fn main() {
// fetch
for repo in test_repos {
- match db.repo_get(repo.id).await {
- Ok(_r) => (),
+ let id = repo.id;
+ let db_repo = database::Repo::from(repo);
+
+ match db.repo_get(id).await {
+ Ok(r) => {
+ // TODO: fetch
+
+ if db.repo_is_updated(&db_repo).await.unwrap() {
+ dbg!("UPDATED", &db_repo);
+ }
+ },
+
Err(database::Error::Db(sqlx::Error::RowNotFound)) => {
- db.repo_insert(repo.into()).await.unwrap();
+ db.repo_insert(db_repo).await.unwrap();
},
+
e => panic!("{:?}", e),
}
}