Completed structure change

Author: charlykeyko

fplus-http-server/src/router/allocator.rs

@@ -45,14 +45,12 @@ pub async fn create_from_json(file: web::Json<ChangedAllocator>) -> actix_web::R
             } else {
                 Some(model.application.verifiers_gh_handles.join(", ")) // Join verifiers in a string if exists
             };
-
-            let owner_repo_parts: Vec<&str> = model.application.allocation_bookkeeping.split('/').collect();
-            let owner = parts[owner_repo_parts.len() - 2];
-            let repo = parts[owner_repo_parts.len() - 1];
+            let owner = model.owner.clone().unwrap_or_default().to_string();
+            let repo = model.repo.clone().unwrap_or_default().to_string();
 
             let allocator_model = match allocators_db::create_or_update_allocator(
-                owner.to_string(),
-                repo.to_string(),
+                owner.clone(),
+                repo.clone(),
                 None,
                 Some(model.pathway_addresses.msig),      
                 verifiers_gh_handles,
@@ -62,11 +60,11 @@ pub async fn create_from_json(file: web::Json<ChangedAllocator>) -> actix_web::R
                 Err(e) => return Ok(HttpResponse::BadRequest().body(e.to_string())),
             };
 
-            match is_allocator_repo_created(&model.owner, &model.repo).await {
+            match is_allocator_repo_created(&owner, &repo).await {
                 Ok(true) => Ok(HttpResponse::Ok().json(allocator_model)),
                 Ok(false) => {
                     //Create allocator repo. If it fails, return http error
-                    match create_allocator_repo(&model.owner, &model.repo).await {
+                    match create_allocator_repo(&owner, &repo).await {
                         Ok(files_list) => {
                             log::info!("Allocator repo created successfully: {:?}", files_list);
                             Ok(HttpResponse::Ok().json(allocator_model))

fplus-lib/src/core/allocator/file.rs

@@ -3,14 +3,16 @@ use serde::{Serialize, Deserialize};
 #[derive(Serialize, Deserialize, Debug)]
 pub struct AllocatorModel {
     pub application: Application,
-    #[serde(rename = "multisig_threshold")]
     pub multisig_threshold: Option<i32>,
-    pub pathway_addresses: AllocatorModelPathwayAddresses
+    pub pathway_addresses: AllocatorModelPathwayAddresses,
+    pub owner: Option<String>,
+    pub repo: Option<String>,
 }
 
 #[derive(Serialize, Deserialize, Debug)]
 pub struct AllocatorModelPathwayAddresses {
     pub msig: String,
+    pub signer: Vec<String>,
 }
 
 #[derive(Serialize, Deserialize, Debug)]

fplus-lib/src/core/allocator/mod.rs

@@ -29,7 +29,7 @@ pub async fn process_allocator_file(file_name: &str) -> Result<AllocatorModel, L
     let mut model = content_items_to_allocator_model(content_items).map_err(|e| LDNError::Load(e.to_string()))?;
 
     // Get multisig threshold from the blockchain if multisig address is available
-    if let Ok(blockchain_threshold) = get_multisig_threshold_for_actor(&model.multisig_address).await {
+    if let Ok(blockchain_threshold) = get_multisig_threshold_for_actor(&model.pathway_addresses.msig).await {
         model.multisig_threshold = Some(blockchain_threshold as i32);
     } else {
         log::warn!("Blockchain multisig threshold not found, using default or provided value");
@@ -55,7 +55,16 @@ fn content_items_to_allocator_model(file: ContentItems) -> Result<AllocatorModel
     log::info!("Cleaned content: {:?}", cleaned_content);
 
     match decode_allocator_model(&cleaned_content) {
-        Some(model) => {
+        Some(mut model) => {
+            let owner_repo_parts: Vec<&str> = model.application.allocation_bookkeeping.split('/').collect();
+            if owner_repo_parts.len() < 2 {
+                log::error!("Failed to parse allocator model");
+                return Err(LDNError::Load("Failed to parse allocator model".to_string()));
+            }
+            
+            model.owner = Some(owner_repo_parts[owner_repo_parts.len() - 2].to_string());
+            model.repo = Some(owner_repo_parts[owner_repo_parts.len() - 1].to_string());
+            
             log::info!("Parsed allocator model successfully");
             Ok(model)
         }