Add a dashboard

src/activity_pub/inbox.rs

@@ -1,6 +1,5 @@
 use activitypub::{
     Actor,
-    actor::Person,
     activity::{Accept, Announce, Create, Follow, Like, Undo},
     object::Note
 };

src/main.rs

@@ -104,6 +104,8 @@ fn main() {
 
             routes::user::me,
             routes::user::details,
+            routes::user::dashboard,
+            routes::user::dashboard_auth,
             routes::user::followers,            
             routes::user::edit,
             routes::user::edit_auth,

src/models/blogs.rs

@@ -7,7 +7,7 @@ use reqwest::{
 use serde_json;
 use url::Url;
 use chrono::NaiveDateTime;
-use diesel::{self, QueryDsl, RunQueryDsl, ExpressionMethods, PgConnection};
+use diesel::{self, QueryDsl, RunQueryDsl, ExpressionMethods, PgConnection, dsl::any};
 use openssl::{
     hash::MessageDigest,
     pkey::{PKey, Private},
@@ -71,6 +71,14 @@ impl Blog {
             .into_iter().nth(0)
     }
 
+    pub fn find_for_author(conn: &PgConnection, author_id: i32) -> Vec<Blog> {
+        use schema::blog_authors;
+        let author_ids = blog_authors::table.filter(blog_authors::author_id.eq(author_id)).select(blog_authors::blog_id);
+        blogs::table.filter(blogs::id.eq(any(author_ids)))
+            .load::<Blog>(conn)
+            .expect("Couldn't load blogs ")
+    }
+
     pub fn find_by_name(conn: &PgConnection, name: String, instance_id: i32) -> Option<Blog> {
         blogs::table.filter(blogs::actor_id.eq(name))
             .filter(blogs::instance_id.eq(instance_id))

src/routes/user.rs

@@ -15,6 +15,7 @@ use activity_pub::{
 };
 use db_conn::DbConn;
 use models::{
+    blogs::Blog,
     follows,
     instance::Instance,
     posts::Post,
@@ -74,6 +75,20 @@ fn details(name: String, conn: DbConn, account: Option<User>) -> Template {
     }))
 }
 
+#[get("/dashboard")]
+fn dashboard(user: User, conn: DbConn) -> Template {
+    let blogs = Blog::find_for_author(&*conn, user.id);
+    Template::render("users/dashboard", json!({
+        "account": user,
+        "blogs": blogs
+    }))
+}
+
+#[get("/dashboard", rank = 2)]
+fn dashboard_auth() -> Flash<Redirect> {
+    utils::requires_login("You need to be logged in order to access your dashboard", "/dashboard")
+}
+
 #[get("/@/<name>/follow")]
 fn follow(name: String, conn: DbConn, user: User) -> Redirect {
     let target = User::find_by_fqn(&*conn, name.clone()).unwrap();
@@ -91,7 +106,7 @@ fn follow(name: String, conn: DbConn, user: User) -> Redirect {
 
 #[get("/@/<name>/follow", rank = 2)]
 fn follow_auth(name: String) -> Flash<Redirect> {
-    utils::requires_login("You need to belogged in order to follow someone", &format!("/@/{}/follow", name))
+    utils::requires_login("You need to be logged in order to follow someone", &format!("/@/{}/follow", name))
 }
 
 #[get("/@/<name>/followers", rank = 2)]