Reorganizing files before splitting out API

17 files changed, 65 insertions, 66 deletions

diff --git a/server/src/apub.rs b/server/src/apub.rs
index 4fc0ba33..3d9595c8 100644
--- a/server/src/apub.rs
+++ b/server/src/apub.rs
@@ -1,6 +1,6 @@
 extern crate activitypub;
 use self::activitypub::{context, actor::Person};
-use actions::user::User_;
+use db::user::User_;
 
 impl User_ {
   pub fn person(&self) -> Person {
diff --git a/server/src/actions/category.rs b/server/src/db/category.rs
index 8491f1ec..8491f1ec 100644
--- a/server/src/actions/category.rs
+++ b/server/src/db/category.rs
diff --git a/server/src/actions/comment.rs b/server/src/db/comment.rs
index 4bbc7c04..d63837a0 100644
--- a/server/src/actions/comment.rs
+++ b/server/src/db/comment.rs
@@ -4,7 +4,7 @@ use diesel::*;
 use diesel::result::Error;
 use serde::{Deserialize, Serialize};
 use {Crud, Likeable, Saveable};
-use actions::post::Post;
+use super::post::Post;
 
 // WITH RECURSIVE MyTree AS (
 //     SELECT * FROM comment WHERE parent_id IS NULL
@@ -160,9 +160,9 @@ impl Saveable <CommentSavedForm> for CommentSaved {
 mod tests {
   use establish_connection;
   use super::*;
-  use actions::post::*;
-  use actions::community::*;
-  use actions::user::*;
+  use super::super::post::*;
+  use super::super::community::*;
+  use super::super::user::*;
   use Crud;
  #[test]
   fn test_crud() {
diff --git a/server/src/actions/comment_view.rs b/server/src/db/comment_view.rs
index eb6276cc..903c4839 100644
--- a/server/src/actions/comment_view.rs
+++ b/server/src/db/comment_view.rs
@@ -68,7 +68,7 @@ impl CommentView {
               page: Option<i64>,
               limit: Option<i64>,
               ) -> Result<Vec<Self>, Error> {
-    use actions::comment_view::comment_view::dsl::*;
+    use super::comment_view::comment_view::dsl::*;
 
     let (limit, offset) = limit_and_offset(page, limit);
 
@@ -125,7 +125,7 @@ impl CommentView {
   }
 
   pub fn read(conn: &PgConnection, from_comment_id: i32, my_user_id: Option<i32>) -> Result<Self, Error> {
-    use actions::comment_view::comment_view::dsl::*;
+    use super::comment_view::comment_view::dsl::*;
 
     let mut query = comment_view.into_boxed();
 
@@ -206,7 +206,7 @@ impl ReplyView {
               page: Option<i64>,
               limit: Option<i64>,
               ) -> Result<Vec<Self>, Error> {
-    use actions::comment_view::reply_view::dsl::*;
+    use super::comment_view::reply_view::dsl::*;
 
     let (limit, offset) = limit_and_offset(page, limit);
 
@@ -251,10 +251,10 @@ impl ReplyView {
 mod tests {
   use establish_connection;
   use super::*;
-  use actions::post::*;
-  use actions::community::*;
-  use actions::user::*;
-  use actions::comment::*;
+  use super::super::post::*;
+  use super::super::community::*;
+  use super::super::user::*;
+  use super::super::comment::*;
   use {Crud,Likeable};
  #[test]
   fn test_crud() {
diff --git a/server/src/actions/community.rs b/server/src/db/community.rs
index db53ceb9..2e75828f 100644
--- a/server/src/actions/community.rs
+++ b/server/src/db/community.rs
@@ -221,7 +221,7 @@ impl Crud<SiteForm> for Site {
 mod tests {
   use establish_connection;
   use super::*;
-  use actions::user::*;
+  use super::super::user::*;
   use Crud;
  #[test]
   fn test_crud() {
diff --git a/server/src/actions/community_view.rs b/server/src/db/community_view.rs
index 9a162746..5ec22f4e 100644
--- a/server/src/actions/community_view.rs
+++ b/server/src/db/community_view.rs
@@ -100,7 +100,7 @@ pub struct CommunityView {
 
 impl CommunityView {
   pub fn read(conn: &PgConnection, from_community_id: i32, from_user_id: Option<i32>) -> Result<Self, Error> {
-    use actions::community_view::community_view::dsl::*;
+    use super::community_view::community_view::dsl::*;
 
     let mut query = community_view.into_boxed();
 
@@ -122,7 +122,7 @@ impl CommunityView {
               page: Option<i64>,
               limit: Option<i64>,
               ) -> Result<Vec<Self>, Error> {
-    use actions::community_view::community_view::dsl::*;
+    use super::community_view::community_view::dsl::*;
     let mut query = community_view.into_boxed();
 
     let (limit, offset) = limit_and_offset(page, limit);
@@ -163,12 +163,12 @@ pub struct CommunityModeratorView {
 
 impl CommunityModeratorView {
   pub fn for_community(conn: &PgConnection, from_community_id: i32) -> Result<Vec<Self>, Error> {
-    use actions::community_view::community_moderator_view::dsl::*;
+    use super::community_view::community_moderator_view::dsl::*;
     community_moderator_view.filter(community_id.eq(from_community_id)).load::<Self>(conn)
   }
 
   pub fn for_user(conn: &PgConnection, from_user_id: i32) -> Result<Vec<Self>, Error> {
-    use actions::community_view::community_moderator_view::dsl::*;
+    use super::community_view::community_moderator_view::dsl::*;
     community_moderator_view.filter(user_id.eq(from_user_id)).load::<Self>(conn)
   }
 }
@@ -186,12 +186,12 @@ pub struct CommunityFollowerView {
 
 impl CommunityFollowerView {
   pub fn for_community(conn: &PgConnection, from_community_id: i32) -> Result<Vec<Self>, Error> {
-    use actions::community_view::community_follower_view::dsl::*;
+    use super::community_view::community_follower_view::dsl::*;
     community_follower_view.filter(community_id.eq(from_community_id)).load::<Self>(conn)
   }
 
   pub fn for_user(conn: &PgConnection, from_user_id: i32) -> Result<Vec<Self>, Error> {
-    use actions::community_view::community_follower_view::dsl::*;
+    use super::community_view::community_follower_view::dsl::*;
     community_follower_view.filter(user_id.eq(from_user_id)).load::<Self>(conn)
   }
 }
@@ -210,17 +210,17 @@ pub struct CommunityUserBanView {
 
 impl CommunityUserBanView {
   pub fn for_community(conn: &PgConnection, from_community_id: i32) -> Result<Vec<Self>, Error> {
-    use actions::community_view::community_user_ban_view::dsl::*;
+    use super::community_view::community_user_ban_view::dsl::*;
     community_user_ban_view.filter(community_id.eq(from_community_id)).load::<Self>(conn)
   }
 
   pub fn for_user(conn: &PgConnection, from_user_id: i32) -> Result<Vec<Self>, Error> {
-    use actions::community_view::community_user_ban_view::dsl::*;
+    use super::community_view::community_user_ban_view::dsl::*;
     community_user_ban_view.filter(user_id.eq(from_user_id)).load::<Self>(conn)
   }
 
   pub fn get(conn: &PgConnection, from_user_id: i32, from_community_id: i32) -> Result<Self, Error> {
-    use actions::community_view::community_user_ban_view::dsl::*;
+    use super::community_view::community_user_ban_view::dsl::*;
     community_user_ban_view
       .filter(user_id.eq(from_user_id))
       .filter(community_id.eq(from_community_id))
@@ -246,7 +246,7 @@ pub struct SiteView {
 
 impl SiteView {
   pub fn read(conn: &PgConnection) -> Result<Self, Error> {
-    use actions::community_view::site_view::dsl::*;
+    use super::community_view::site_view::dsl::*;
     site_view.first::<Self>(conn)
   }
 }
diff --git a/server/src/actions/mod.rs b/server/src/db/mod.rs
index ece1e885..ece1e885 100644
--- a/server/src/actions/mod.rs
+++ b/server/src/db/mod.rs
diff --git a/server/src/actions/moderator.rs b/server/src/db/moderator.rs
index 794d91e7..74068e0a 100644
--- a/server/src/actions/moderator.rs
+++ b/server/src/db/moderator.rs
@@ -400,10 +400,10 @@ impl Crud<ModAddForm> for ModAdd {
 mod tests {
   use establish_connection;
   use super::*;
-  use actions::user::*;
-  use actions::post::*;
-  use actions::community::*;
-  use actions::comment::*;
+  use super::super::user::*;
+  use super::super::post::*;
+  use super::super::community::*;
+  use super::super::comment::*;
   // use Crud;
  #[test]
   fn test_crud() {
diff --git a/server/src/actions/moderator_views.rs b/server/src/db/moderator_views.rs
index 89418277..56881ef5 100644
--- a/server/src/actions/moderator_views.rs
+++ b/server/src/db/moderator_views.rs
@@ -41,7 +41,7 @@ impl ModRemovePostView {
               page: Option<i64>,
               limit: Option<i64>, 
               ) -> Result<Vec<Self>, Error> {
-    use actions::moderator_views::mod_remove_post_view::dsl::*;
+    use super::moderator_views::mod_remove_post_view::dsl::*;
     let mut query = mod_remove_post_view.into_boxed();
 
     let (limit, offset) = limit_and_offset(page, limit);
@@ -94,7 +94,7 @@ impl ModLockPostView {
               page: Option<i64>,
               limit: Option<i64>, 
               ) -> Result<Vec<Self>, Error> {
-    use actions::moderator_views::mod_lock_post_view::dsl::*;
+    use super::moderator_views::mod_lock_post_view::dsl::*;
     let mut query = mod_lock_post_view.into_boxed();
 
     let (limit, offset) = limit_and_offset(page, limit);
@@ -156,7 +156,7 @@ impl ModRemoveCommentView {
               page: Option<i64>,
               limit: Option<i64>, 
              ) -> Result<Vec<Self>, Error> {
-    use actions::moderator_views::mod_remove_comment_view::dsl::*;
+    use super::moderator_views::mod_remove_comment_view::dsl::*;
     let mut query = mod_remove_comment_view.into_boxed();
 
     let (limit, offset) = limit_and_offset(page, limit);
@@ -207,7 +207,7 @@ impl ModRemoveCommunityView {
               page: Option<i64>,
               limit: Option<i64>, 
               ) -> Result<Vec<Self>, Error> {
-    use actions::moderator_views::mod_remove_community_view::dsl::*;
+    use super::moderator_views::mod_remove_community_view::dsl::*;
     let mut query = mod_remove_community_view.into_boxed();
 
     let (limit, offset) = limit_and_offset(page, limit);
@@ -260,7 +260,7 @@ impl ModBanFromCommunityView {
               page: Option<i64>,
               limit: Option<i64>, 
               ) -> Result<Vec<Self>, Error> {
-    use actions::moderator_views::mod_ban_from_community_view::dsl::*;
+    use super::moderator_views::mod_ban_from_community_view::dsl::*;
     let mut query = mod_ban_from_community_view.into_boxed();
 
     let (limit, offset) = limit_and_offset(page, limit);
@@ -311,7 +311,7 @@ impl ModBanView {
               page: Option<i64>,
               limit: Option<i64>, 
               ) -> Result<Vec<Self>, Error> {
-    use actions::moderator_views::mod_ban_view::dsl::*;
+    use super::moderator_views::mod_ban_view::dsl::*;
     let mut query = mod_ban_view.into_boxed();
 
     let (limit, offset) = limit_and_offset(page, limit);
@@ -359,7 +359,7 @@ impl ModAddCommunityView {
               page: Option<i64>,
               limit: Option<i64>, 
               ) -> Result<Vec<Self>, Error> {
-    use actions::moderator_views::mod_add_community_view::dsl::*;
+    use super::moderator_views::mod_add_community_view::dsl::*;
     let mut query = mod_add_community_view.into_boxed();
 
     let (limit, offset) = limit_and_offset(page, limit);
@@ -406,7 +406,7 @@ impl ModAddView {
               page: Option<i64>,
               limit: Option<i64>, 
               ) -> Result<Vec<Self>, Error> {
-    use actions::moderator_views::mod_add_view::dsl::*;
+    use super::moderator_views::mod_add_view::dsl::*;
     let mut query = mod_add_view.into_boxed();
 
     let (limit, offset) = limit_and_offset(page, limit);
diff --git a/server/src/actions/post.rs b/server/src/db/post.rs
index 495a8b09..59a7a1d4 100644
--- a/server/src/actions/post.rs
+++ b/server/src/db/post.rs
@@ -173,10 +173,10 @@ impl Readable <PostReadForm> for PostRead {
 #[cfg(test)]
 mod tests {
   use establish_connection;
-  use super::*;
   use Crud;
-  use actions::community::*;
-  use actions::user::*;
+  use super::*;
+  use super::super::community::*;
+  use super::super::user::*;
  #[test]
   fn test_crud() {
     let conn = establish_connection();
diff --git a/server/src/actions/post_view.rs b/server/src/db/post_view.rs
index 18287651..6dc6b6ef 100644
--- a/server/src/actions/post_view.rs
+++ b/server/src/db/post_view.rs
@@ -85,7 +85,7 @@ impl PostView {
               page: Option<i64>,
               limit: Option<i64>,
               ) -> Result<Vec<Self>, Error> {
-    use actions::post_view::post_view::dsl::*;
+    use super::post_view::post_view::dsl::*;
 
     let (limit, offset) = limit_and_offset(page, limit);
 
@@ -158,7 +158,7 @@ impl PostView {
 
   pub fn read(conn: &PgConnection, from_post_id: i32, my_user_id: Option<i32>) -> Result<Self, Error> {
 
-    use actions::post_view::post_view::dsl::*;
+    use super::post_view::post_view::dsl::*;
     use diesel::prelude::*;
 
     let mut query = post_view.into_boxed();
@@ -181,9 +181,9 @@ impl PostView {
 mod tests {
   use {establish_connection, Crud, Likeable};
   use super::*;
-  use actions::community::*;
-  use actions::user::*;
-  use actions::post::*;
+  use super::super::community::*;
+  use super::super::user::*;
+  use super::super::post::*;
   #[test]
   fn test_crud() {
     let conn = establish_connection();
diff --git a/server/src/actions/user.rs b/server/src/db/user.rs
index 9c9e0a52..9c9e0a52 100644
--- a/server/src/actions/user.rs
+++ b/server/src/db/user.rs
diff --git a/server/src/actions/user_view.rs b/server/src/db/user_view.rs
index a5187aee..f17fd8c9 100644
--- a/server/src/actions/user_view.rs
+++ b/server/src/db/user_view.rs
@@ -35,20 +35,20 @@ pub struct UserView {
 
 impl UserView {
   pub fn read(conn: &PgConnection, from_user_id: i32) -> Result<Self, Error> {
-    use actions::user_view::user_view::dsl::*;
+    use super::user_view::user_view::dsl::*;
 
     user_view.find(from_user_id)
     .first::<Self>(conn)
   }
 
   pub fn admins(conn: &PgConnection) -> Result<Vec<Self>, Error> {
-    use actions::user_view::user_view::dsl::*;
+    use super::user_view::user_view::dsl::*;
     user_view.filter(admin.eq(true))
     .load::<Self>(conn)
   }
 
   pub fn banned(conn: &PgConnection) -> Result<Vec<Self>, Error> {
-    use actions::user_view::user_view::dsl::*;
+    use super::user_view::user_view::dsl::*;
     user_view.filter(banned.eq(true))
     .load::<Self>(conn)
   }
diff --git a/server/src/lib.rs b/server/src/lib.rs
index 71b72ac3..a453633e 100644
--- a/server/src/lib.rs
+++ b/server/src/lib.rs
@@ -17,8 +17,8 @@ pub extern crate regex;
 
 pub mod schema;
 pub mod apub;
-pub mod actions;
-pub mod websocket_server;
+pub mod db;
+pub mod websocket;
 
 use diesel::*;
 use diesel::pg::PgConnection;
diff --git a/server/src/bin/main.rs b/server/src/main.rs
index c2fde341..3e51785b 100644
--- a/server/src/bin/main.rs
+++ b/server/src/main.rs
@@ -1,14 +1,13 @@
-extern crate server;
+extern crate lemmy_server;
 #[macro_use] extern crate diesel_migrations;
 
 use std::time::{Instant, Duration};
 use std::env;
-use server::actix::*;
-use server::actix_web::server::HttpServer;
-use server::actix_web::{ws, App, Error, HttpRequest, HttpResponse, fs::NamedFile, fs};
-
-use server::websocket_server::server::*;
-use server::establish_connection;
+use lemmy_server::actix::*;
+use lemmy_server::actix_web::server::HttpServer;
+use lemmy_server::actix_web::{ws, App, Error, HttpRequest, HttpResponse, fs::NamedFile, fs};
+use lemmy_server::websocket::server::*;
+use lemmy_server::establish_connection;
 
 embed_migrations!();
 
diff --git a/server/src/websocket_server/mod.rs b/server/src/websocket/mod.rs
index 74f47ad3..74f47ad3 100644
--- a/server/src/websocket_server/mod.rs
+++ b/server/src/websocket/mod.rs
diff --git a/server/src/websocket_server/server.rs b/server/src/websocket/server.rs
index 82c4007d..a530b9a6 100644
--- a/server/src/websocket_server/server.rs
+++ b/server/src/websocket/server.rs
@@ -14,17 +14,17 @@ use failure::Error;
 use std::time::{SystemTime};
 
 use {Crud, Joinable, Likeable, Followable, Bannable, Saveable, establish_connection, naive_now, naive_from_unix, SortType, SearchType, has_slurs, remove_slurs, Settings};
-use actions::community::*;
-use actions::user::*;
-use actions::post::*;
-use actions::comment::*;
-use actions::post_view::*;
-use actions::comment_view::*;
-use actions::category::*;
-use actions::community_view::*;
-use actions::user_view::*;
-use actions::moderator_views::*;
-use actions::moderator::*;
+use db::community::*;
+use db::user::*;
+use db::post::*;
+use db::comment::*;
+use db::post_view::*;
+use db::comment_view::*;
+use db::category::*;
+use db::community_view::*;
+use db::user_view::*;
+use db::moderator_views::*;
+use db::moderator::*;
 
 const RATE_LIMIT_MESSAGES: i32 = 30;
 const RATE_LIMIT_PER_SECOND: i32 = 60;