Implement reduce and dependency task logic

CHANGELOG.md

@@ -21,6 +21,7 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 - GraphQL endpoint for publishing entries [#123](https://github.com/p2panda/aquadoggo/pull/132)
 - Implement SQL `DocumentStore` [#118](https://github.com/p2panda/aquadoggo/pull/118)
 - Implement SQL `SchemaStore` [#130](https://github.com/p2panda/aquadoggo/pull/130)
+- Reduce and dependency tasks [#144](https://github.com/p2panda/aquadoggo/pull/144)
 - GraphQL endpoints for replication [#100](https://github.com/p2panda/aquadoggo/pull/100)
 
 ### Changed

aquadoggo/src/db/provider.rs

@@ -1,4 +1,5 @@
 // SPDX-License-Identifier: AGPL-3.0-or-later
+
 use async_trait::async_trait;
 use sqlx::query_scalar;
 
@@ -14,20 +15,21 @@ use crate::graphql::client::{
     EntryArgsRequest, EntryArgsResponse, PublishEntryRequest, PublishEntryResponse,
 };
 
-#[derive(Debug, Clone)]
-/// Sql based storage that implements `StorageProvider`
+/// Sql based storage that implements `StorageProvider`.
+#[derive(Clone, Debug)]
 pub struct SqlStorage {
     pub(crate) pool: Pool,
 }
 
 impl SqlStorage {
-    /// Create a new `SqlStorage` using the provided db `Pool`
+    /// Create a new `SqlStorage` using the provided db `Pool`.
     pub fn new(pool: Pool) -> Self {
         Self { pool }
     }
 }
 
-/// A `StorageProvider` implementation based on `sqlx` that supports SQLite and PostgreSQL databases.
+/// A `StorageProvider` implementation based on `sqlx` that supports SQLite and PostgreSQL
+/// databases.
 #[async_trait]
 impl StorageProvider<StorageEntry, StorageLog> for SqlStorage {
     type EntryArgsResponse = EntryArgsResponse;

aquadoggo/src/db/stores/document.rs

@@ -233,8 +233,6 @@ impl DocumentStore for SqlStorage {
         .await
         .map_err(|e| DocumentStorageError::FatalStorageError(e.to_string()))?;
 
-        println!("{:#?}", document_view_field_rows);
-
         if document_view_field_rows.is_empty() {
             return Ok(None);
         }

aquadoggo/src/materializer/input.rs

@@ -4,8 +4,8 @@ use p2panda_rs::document::{DocumentId, DocumentViewId};
 
 #[derive(Clone, Eq, PartialEq, Debug, Hash)]
 pub struct TaskInput {
-    document_id: Option<DocumentId>,
-    document_view_id: Option<DocumentViewId>,
+    pub document_id: Option<DocumentId>,
+    pub document_view_id: Option<DocumentViewId>,
 }
 
 impl TaskInput {