add: paginate notifications/requests pages

crates/core/src/database/notifications.rs

@@ -53,6 +53,32 @@ impl DataManager {
         Ok(res.unwrap())
     }
 
+    /// Get all notifications by `owner` (paginated).
+    pub async fn get_notifications_by_owner_paginated(
+        &self,
+        owner: usize,
+        batch: usize,
+        page: usize,
+    ) -> Result<Vec<Notification>> {
+        let conn = match self.connect().await {
+            Ok(c) => c,
+            Err(e) => return Err(Error::DatabaseConnection(e.to_string())),
+        };
+
+        let res = query_rows!(
+            &conn,
+            "SELECT * FROM notifications WHERE owner = $1 ORDER BY created DESC LIMIT $2 OFFSET $3",
+            &[&(owner as i64), &(batch as i64), &((page * batch) as i64)],
+            |x| { Self::get_notification_from_row(x) }
+        );
+
+        if res.is_err() {
+            return Err(Error::GeneralNotFound("notification".to_string()));
+        }
+
+        Ok(res.unwrap())
+    }
+
     /// Get all notifications by `tag`.
     pub async fn get_notifications_by_tag(&self, tag: &str) -> Result<Vec<Notification>> {
         let conn = match self.connect().await {

crates/core/src/database/requests.rs

@@ -86,6 +86,32 @@ impl DataManager {
         Ok(res.unwrap())
     }
 
+    /// Get all action requests by `owner` (paginated).
+    pub async fn get_requests_by_owner_paginated(
+        &self,
+        owner: usize,
+        batch: usize,
+        page: usize,
+    ) -> Result<Vec<ActionRequest>> {
+        let conn = match self.connect().await {
+            Ok(c) => c,
+            Err(e) => return Err(Error::DatabaseConnection(e.to_string())),
+        };
+
+        let res = query_rows!(
+            &conn,
+            "SELECT * FROM requests WHERE owner = $1 ORDER BY created DESC LIMIT $2 OFFSET $3",
+            &[&(owner as i64), &(batch as i64), &((page * batch) as i64)],
+            |x| { Self::get_request_from_row(x) }
+        );
+
+        if res.is_err() {
+            return Err(Error::GeneralNotFound("request".to_string()));
+        }
+
+        Ok(res.unwrap())
+    }
+
     /// Create a new request in the database.
     ///
     /// # Arguments