Feed system, user/organization following [MOD-535]

Cargo.toml

@@ -109,3 +109,4 @@ derive-new = "0.5.9"
 
 [dev-dependencies]
 actix-http = "3.4.0"
+assert_matches = "1.5.0"

Dockerfile

@@ -1,4 +1,4 @@
-FROM rust:1.68.0 as build
+FROM rust:1.70.0 as build
 ENV PKG_CONFIG_ALLOW_CROSS=1
 
 WORKDIR /usr/src/labrinth

migrations/20231020223602_user_and_organization_follows.sql

@@ -0,0 +1,12 @@
+CREATE TABLE user_follows(
+    follower_id bigint NOT NULL REFERENCES users ON DELETE CASCADE,
+    target_id bigint NOT NULL REFERENCES users (id) ON DELETE CASCADE,
+    created timestamptz DEFAULT CURRENT_TIMESTAMP NOT NULL,
+    PRIMARY KEY (follower_id, target_id)
+);
+CREATE TABLE organization_follows(
+    follower_id bigint NOT NULL REFERENCES users ON DELETE CASCADE,
+    target_id bigint NOT NULL REFERENCES organizations (id) ON DELETE CASCADE,
+    created timestamptz DEFAULT CURRENT_TIMESTAMP NOT NULL,
+    PRIMARY KEY (follower_id, target_id)
+);

migrations/20231023212957_feeds.sql

@@ -0,0 +1,20 @@
+CREATE TABLE events(
+    id bigint NOT NULL PRIMARY KEY,
+    target_id bigint NOT NULL,
+    target_id_type text NOT NULL,
+    triggerer_id bigint NULL,
+    triggerer_id_type text NULL,
+    event_type text NOT NULL,
+    metadata jsonb NULL,
+    created timestamptz NOT NULL DEFAULT CURRENT_TIMESTAMP
+);
+CREATE INDEX events_targets ON events (
+    target_id,
+    target_id_type,
+    event_type
+);
+CREATE INDEX events_triggerers ON events (
+    triggerer_id,
+    triggerer_id_type,
+    event_type
+);

src/auth/checks.rs

@@ -79,18 +79,15 @@ pub async fn is_authorized(
 
 pub async fn filter_authorized_projects(
     projects: Vec<QueryProject>,
-    user_option: &Option<User>,
+    user_option: Option<&User>,
     pool: &web::Data<PgPool>,
 ) -> Result<Vec<crate::models::projects::Project>, ApiError> {
     let mut return_projects = Vec::new();
     let mut check_projects = Vec::new();
 
     for project in projects {
         if !project.inner.status.is_hidden()
-            || user_option
-                .as_ref()
-                .map(|x| x.role.is_mod())
-                .unwrap_or(false)
+            || user_option.map(|x| x.role.is_mod()).unwrap_or(false)
         {
             return_projects.push(project.into());
         } else if user_option.is_some() {
@@ -194,7 +191,7 @@ impl ValidateAuthorized for crate::database::models::OAuthClient {
 
 pub async fn filter_authorized_versions(
     versions: Vec<QueryVersion>,
-    user_option: &Option<User>,
+    user_option: Option<&User>,
     pool: &web::Data<PgPool>,
 ) -> Result<Vec<crate::models::projects::Version>, ApiError> {
     let mut return_versions = Vec::new();