worker/jobs/downloads/update_metadata: Read downloads from crate_downloads table

Author: Turbo87

src/worker/jobs/downloads/update_metadata.rs

@@ -176,8 +176,9 @@ mod tests {
     use super::*;
     use crate::email::Emails;
     use crate::models::{Crate, NewCrate, NewUser, NewVersion, User, Version};
-    use crate::schema::{crates, versions};
+    use crate::schema::{crate_downloads, crates, versions};
     use crate::test_util::test_db_connection;
+    use chrono::NaiveDateTime;
     use std::collections::BTreeMap;
 
     fn user(conn: &mut PgConnection) -> User {
@@ -235,9 +236,9 @@ mod tests {
             .select(versions::downloads)
             .first(conn);
         assert_eq!(version_downloads, Ok(1));
-        let crate_downloads = crates::table
+        let crate_downloads = crate_downloads::table
             .find(krate.id)
-            .select(crates::downloads)
+            .select(crate_downloads::downloads)
             .first(conn);
         assert_eq!(crate_downloads, Ok(1));
         super::update(conn).unwrap();
@@ -332,17 +333,19 @@ mod tests {
             .unwrap();
 
         let version_before: Version = versions::table.find(version.id).first(conn).unwrap();
-        let krate_before: (NaiveDateTime, i32) = crates::table
-            .select((crates::updated_at, crates::downloads))
+        let krate_before: (NaiveDateTime, i64) = crates::table
+            .inner_join(crate_downloads::table)
+            .select((crates::updated_at, crate_downloads::downloads))
             .filter(crates::id.eq(krate.id))
             .first(conn)
             .unwrap();
         super::update(conn).unwrap();
         let version2: Version = versions::table.find(version.id).first(conn).unwrap();
         assert_eq!(version2.downloads, 2);
         assert_eq!(version2.updated_at, version_before.updated_at);
-        let krate2: (NaiveDateTime, i32) = crates::table
-            .select((crates::updated_at, crates::downloads))
+        let krate2: (NaiveDateTime, i64) = crates::table
+            .inner_join(crate_downloads::table)
+            .select((crates::updated_at, crate_downloads::downloads))
             .filter(crates::id.eq(krate.id))
             .first(conn)
             .unwrap();