summaryrefslogtreecommitdiff
path: root/src/updater.rs
diff options
context:
space:
mode:
Diffstat (limited to 'src/updater.rs')
-rw-r--r--src/updater.rs7
1 files changed, 3 insertions, 4 deletions
diff --git a/src/updater.rs b/src/updater.rs
index 38c666c..c90f1e6 100644
--- a/src/updater.rs
+++ b/src/updater.rs
@@ -107,12 +107,11 @@ pub fn update_images(now: &DateTime<Utc>, db: &dyn Db, reg: &dyn Registries, fil
.unwrap_or("registry.hub.docker.com");
let mut tag = img.tag.as_ref().map(|x| file.content[x.clone()].to_string());
let image_record = &images[i];
- let image_id = image_record.id;
println!("Checking image {}", &file.content[image_ranges[i].clone()]);
metrics::get().images_checked.with_label_values(&[registry]).inc();
- let tags = db.get_tags_sorted(image_id);
+ let tags = db.get_tags_sorted(image_record.id);
if image_record.expires_at <= *now && tags.is_empty() {
file_errors[file_idx] = Some(format!("{}/{} was not refreshed", image_record.registry, image_record.image));
@@ -123,7 +122,7 @@ pub fn update_images(now: &DateTime<Utc>, db: &dyn Db, reg: &dyn Registries, fil
let cached_digest = if image_record.expires_at <= *now {
None // Cache was stale, ignore cached digest
} else {
- db.get_tag_digest(image_id, tag_for_digest)
+ db.get_tag_digest(image_record.id, tag_for_digest)
};
if let Some(ref tag_str) = tag {
@@ -161,7 +160,7 @@ pub fn update_images(now: &DateTime<Utc>, db: &dyn Db, reg: &dyn Registries, fil
None => {
match reg.get_digest(registry, &image_record.image, tag_for_digest) {
Some(fetched) => {
- db.update_tag_digest(image_id, tag_for_digest, &fetched, now);
+ db.update_tag_digest(image_record.id, tag_for_digest, &fetched, now);
Ok(fetched)
}
None => Err(format!("digest not found for {}:{}", image_record.image, tag_for_digest)),