Merge pull request #153 from filecoin-project/update-threshold-from-blockchain

Updating threshold db inside propose and approve

Author: clriesco

fplus-database/src/database/allocators.rs

@@ -151,6 +151,36 @@ pub async fn create_or_update_allocator(
     }
 }
 
+/**
+ * Update the multisig threshold of an allocator in the database
+ * 
+ * This function specifically targets and updates only the multisig threshold of an existing allocator.
+ * 
+ * # Arguments
+ * @param owner: &str - The owner of the repository.
+ * @param repo: &str - The name of the repository.
+ * @param multisig_threshold: i32 - The new multisig threshold to be updated in the allocator.
+ * 
+ * # Returns
+ * @return Result<AllocatorModel, sea_orm::DbErr> - The result of the operation.
+ * On successful update, it returns the updated AllocatorModel.
+ * On failure, it returns an error of type DbErr.
+ */
+pub async fn update_allocator_threshold(
+    owner: &str,
+    repo: &str,
+    multisig_threshold: i32,
+) -> Result<AllocatorModel, sea_orm::DbErr> {
+    let conn = get_database_connection().await?;
+    let mut existing_allocator = get_allocator(owner, repo).await?
+        .ok_or_else(|| DbErr::Custom("Allocator not found".into()))?
+        .into_active_model();
+
+    existing_allocator.multisig_threshold = Set(Some(multisig_threshold));
+
+    existing_allocator.update(&conn).await
+}
+
 /**
  * Delete an allocator from the database
  * 

fplus-lib/src/core/mod.rs

@@ -21,7 +21,7 @@ use crate::{
     }},
     parsers::ParsedIssue,
 };
-use fplus_database::database::{self, allocators::get_allocator};
+use fplus_database::database::{self, allocators::{get_allocator, update_allocator_threshold}};
 use fplus_database::models::applications::Model as ApplicationModel;
 
 use self::application::file::{
@@ -677,7 +677,10 @@ impl LDNApplication {
         // If blockchain threshold is available and different from DB, update DB (placeholder for update logic)
         if let Some(blockchain_threshold) = blockchain_threshold {
             if blockchain_threshold != db_threshold {
-                // TODO: Update the database with the new threshold from the blockchain
+                match update_allocator_threshold(&owner, &repo, blockchain_threshold as i32).await {
+                    Ok(_) => log::info!("Database updated with new multisig threshold"),
+                    Err(e) => log::error!("Failed to update database: {}", e),
+                };
             }
         }
         // Use the blockchain threshold if available; otherwise, fall back to the database value
@@ -788,7 +791,10 @@ impl LDNApplication {
         // If blockchain threshold is available and different from DB, update DB (placeholder for update logic)
         if let Some(blockchain_threshold) = blockchain_threshold {
             if blockchain_threshold != db_threshold {
-                // TODO: Update the database with the new threshold from the blockchain
+                match update_allocator_threshold(&owner, &repo, blockchain_threshold as i32).await {
+                    Ok(_) => log::info!("Database updated with new multisig threshold"),
+                    Err(e) => log::error!("Failed to update database: {}", e),
+                };
             }
         }