Show total crate downloads count in user dashboard

Author: PritiKumr

app/adapters/user.js

@@ -0,0 +1,11 @@
+import ApplicationAdapter from './application';
+
+export default ApplicationAdapter.extend({
+    stats(id) {
+        return this.ajax(this.urlForStatsAction(id), 'GET');
+    },
+
+    urlForStatsAction(id) {
+        return `${this.buildURL('user', id)}/stats`;
+    },
+});

app/controllers/dashboard.js

@@ -14,6 +14,7 @@ export default Ember.Controller.extend({
         this.myCrates = [];
         this.myFollowing = [];
         this.myFeed = [];
+        this.myStats = 0;
     },
 
     visibleCrates: computed('myCreates', function() {
@@ -24,6 +25,10 @@ export default Ember.Controller.extend({
         return this.get('myFollowing').slice(0, TO_SHOW);
     }),
 
+    visibleStats: computed('myStats', function() {
+        return this.get('myStats');
+    }),
+
     hasMoreCrates: computed('myCreates', function() {
         return this.get('myCrates.length') > TO_SHOW;
     }),

app/models/user.js

@@ -7,4 +7,8 @@ export default DS.Model.extend({
     api_token: DS.attr('string'),
     avatar: DS.attr('string'),
     url: DS.attr('string'),
+
+    stats() {
+        return this.store.adapterFor('user').stats(this.get('id'));
+    },
 });

app/routes/dashboard.js

@@ -10,6 +10,7 @@ export default Ember.Route.extend(AuthenticatedRoute, {
         controller.set('fetchingFeed', true);
         controller.set('myCrates', this.get('data.myCrates'));
         controller.set('myFollowing', this.get('data.myFollowing'));
+        controller.set('myStats', this.get('data.myStats'));
 
         if (!controller.get('loadingMore')) {
             controller.set('myFeed', []);
@@ -30,9 +31,14 @@ export default Ember.Route.extend(AuthenticatedRoute, {
             following: 1
         });
 
+        let myStats = user.stats();
+
         return Ember.RSVP.hash({
             myCrates,
-            myFollowing
-        }).then((hash) => this.set('data', hash));
+            myFollowing,
+            myStats
+        }).then((hash) => {
+            this.set('data', hash);
+        });
     }
 });

app/styles/me.scss

@@ -86,3 +86,18 @@
         &:hover { background-color: darken($bg, 10%); }
     }
 }
+
+#stats{
+    margin-left: auto;
+    padding: 10px;
+
+    span { margin-left: 10px; }
+    .num {
+        font-size: 30px;
+        font-weight: bold;
+    }
+    .downloads {
+        @include display-flex;
+        @include align-items(center);
+    }
+}

app/templates/dashboard.hbs

@@ -3,8 +3,16 @@
 <div id='crates-heading'>
     <img class='logo dashboard' src="/assets/dashboard.png"/>
     <h1>My Dashboard</h1>
+    <div id="stats">
+        <div class='downloads'>
+            <img class="download" src="/assets/download.png"/>
+            <span class='num'>{{visibleStats.total_downloads}}</span>
+            <span class='desc small'>Total Downloads</span>
+        </div>
+    </div>
 </div>
 
+
 <div id='my-info'>
     <div id='my-crate-lists' class='crate-lists'>
         <div id='my-crates'>

src/lib.rs

@@ -131,6 +131,7 @@ pub fn middleware(app: Arc<App>) -> MiddlewareBuilder {
     api_router.get("/categories/:category_id", C(category::show));
     api_router.get("/category_slugs", C(category::slugs));
     api_router.get("/users/:user_id", C(user::show));
+    api_router.get("/users/:user_id/stats", C(user::stats));
     let api_router = Arc::new(R404(api_router));
 
     let mut router = RouteBuilder::new();

src/tests/user.rs

@@ -199,3 +199,43 @@ fn following() {
 
     bad_resp!(middle.call(req.with_query("page=0")));
 }
+
+#[test]
+fn user_total_downloads() {
+    use diesel::update;
+
+    let (_b, app, middle) = ::app();
+    let u;
+    {
+        let conn = app.diesel_database.get().unwrap();
+        
+        u = ::new_user("foo").create_or_update(&conn).unwrap();
+
+        let mut krate = ::new_crate("foo_krate1")
+            .create_or_update(&conn, None, u.id).unwrap();
+        krate.downloads = 10;
+        update(&krate).set(&krate).execute(&*conn).unwrap();
+
+
+        let mut krate2 = ::new_crate("foo_krate2")
+            .create_or_update(&conn, None, u.id).unwrap();
+        krate2.downloads = 20;
+        update(&krate2).set(&krate2).execute(&*conn).unwrap();
+
+        let another_user = ::new_user("bar").create_or_update(&conn).unwrap();
+        
+        let mut another_krate = ::new_crate("bar_krate1")
+            .create_or_update(&conn, None, another_user.id).unwrap();
+        another_krate.downloads = 2;
+        update(&another_krate).set(&another_krate).execute(&*conn).unwrap();
+    }
+
+    let mut req = ::req(app, Method::Get, &format!("/api/v1/users/{}/stats", u.id));
+    let mut response = ok_resp!(middle.call(&mut req));
+
+    #[derive(RustcDecodable)]
+    struct Response { total_downloads: i64 }
+    let response: Response = ::json(&mut response);
+    assert_eq!(response.total_downloads, 30);
+    assert!(response.total_downloads != 32);
+}

src/user/mod.rs

@@ -378,6 +378,25 @@ pub fn updates(req: &mut Request) -> CargoResult<Response> {
     Ok(req.json(&R{ versions: versions, meta: Meta { more: more } }))
 }
 
+/// Handles the `GET /users/:user_id/stats` route.
+pub fn stats(req: &mut Request) -> CargoResult<Response> {
+    use  diesel::expression::dsl::sum;
+    use owner::OwnerKind;
+
+    let user_id = &req.params()["user_id"].parse::<i32>().ok().unwrap();
+    let conn = req.db_conn()?;
+    
+    let data = crate_owners::table.inner_join(crates::table)
+        .filter(crate_owners::owner_id.eq(user_id).and(crate_owners::owner_kind.eq(OwnerKind::User as i32)))
+        .select(sum(crates::downloads)).first::<i64>(&*conn)?; 
+    
+    #[derive(RustcEncodable)]
+    struct R {
+        total_downloads: i64
+    }
+    Ok(req.json(&R { total_downloads: data }))
+}
+
 #[cfg(test)]
 mod tests {
     use super::*;