6838 add prefs repo layer

server/repository/src/db_diesel/preference.rs

@@ -14,7 +14,6 @@ use super::{
 #[derive(PartialEq, Debug, Clone, Default)]
 pub struct Preference {
     pub preference_row: PreferenceRow,
-    pub store_row: StoreRow,
 }
 
 #[derive(Clone, Default)]
@@ -77,10 +76,7 @@ impl<'a> PreferenceRepository<'a> {
         let result = final_query
             .load::<PreferenceJoin>(self.connection.lock().connection())?
             .into_iter()
-            .map(|(preference_row, store_row)| Preference {
-                preference_row,
-                store_row,
-            })
+            .map(|(preference_row, _store_row)| Preference { preference_row })
             .collect();
 
         Ok(result)

server/repository/src/db_diesel/preference_row.rs

@@ -78,10 +78,29 @@ impl<'a> PreferenceRowRepository<'a> {
         Ok(result)
     }
 
-    pub fn delete(&self, preference_id: &str) -> Result<(), RepositoryError> {
+    pub fn find_one_by_id(
+        &self,
+        preference_id: &str,
+    ) -> Result<Option<PreferenceRow>, RepositoryError> {
+        let result = preference::table
+            .filter(preference::id.eq(preference_id))
+            .first(self.connection.lock().connection())
+            .optional()?;
+        Ok(result)
+    }
+
+    pub fn delete(&self, preference_id: &str) -> Result<Option<i64>, RepositoryError> {
+        let old_row = self.find_one_by_id(preference_id)?;
+        let change_log_id = match old_row {
+            Some(old_row) => self.insert_changelog(old_row, RowActionType::Delete)?,
+            None => {
+                return Ok(None);
+            }
+        };
+
         diesel::delete(preference.filter(preference::id.eq(preference_id)))
             .execute(self.connection.lock().connection())?;
-        Ok(())
+        Ok(Some(change_log_id))
     }
 }