feat: Allow campaign owners to cancel before funding completes

contracts/crowdfund_registry/src/contract.rs

@@ -1,8 +1,8 @@
 use crate::error::CrowdfundError;
 use crate::events::{
-    CampaignApproved, CampaignCancelled, CampaignCreated, CampaignFailed, CampaignFunded,
-    CampaignRejected, CampaignSubmittedForReview, CampaignTerminated, CampaignValidated,
-    CampaignVoteRejected, DisputeResolved, MilestoneApproved, MilestoneDisputed,
+    CampaignApproved, CampaignCancelled, CampaignCancelledByOwner, CampaignCreated, CampaignFailed,
+    CampaignFunded, CampaignRejected, CampaignSubmittedForReview, CampaignTerminated,
+    CampaignValidated, CampaignVoteRejected, DisputeResolved, MilestoneApproved, MilestoneDisputed,
     MilestoneEscalated, MilestoneOverdue, MilestoneRejected, MilestoneRevisionRequested,
     MilestoneSubmitted, PledgeRecorded, RefundBatchProcessed,
 };
@@ -947,6 +947,33 @@ impl CrowdfundRegistry {
         Ok(())
     }
 
+    pub fn owner_cancel_campaign(env: Env, campaign_id: u64) -> Result<(), CrowdfundError> {
+        let key = CrowdfundDataKey::Campaign(campaign_id);
+        let mut campaign: Campaign = env
+            .storage()
+            .persistent()
+            .get(&key)
+            .ok_or(CrowdfundError::CampaignNotFound)?;
+
+        campaign.owner.require_auth();
+
+        // Only allowed before funding completes
+        if campaign.status != CampaignStatus::Draft
+            && campaign.status != CampaignStatus::Submitted
+            && campaign.status != CampaignStatus::Campaigning
+        {
+            return Err(CrowdfundError::InvalidState);
+        }
+
+        campaign.status = CampaignStatus::Cancelled;
+        campaign.refund_progress = 0;
+        campaign.vote_session_id = None;
+        env.storage().persistent().set(&key, &campaign);
+
+        CampaignCancelledByOwner { id: campaign_id }.publish(&env);
+        Ok(())
+    }
+
     // ========================================================================
     // GOVERNANCE: DISPUTE & TERMINATION
     // ========================================================================

contracts/crowdfund_registry/src/events/mod.rs

@@ -65,6 +65,13 @@ pub struct CampaignCancelled {
     pub id: u64,
 }
 
+#[contractevent]
+#[derive(Clone, Debug, Eq, PartialEq)]
+pub struct CampaignCancelledByOwner {
+    #[topic]
+    pub id: u64,
+}
+
 #[contractevent]
 #[derive(Clone, Debug, Eq, PartialEq)]
 pub struct RefundBatchProcessed {

contracts/crowdfund_registry/src/tests/mod.rs

@@ -840,3 +840,95 @@ fn test_overdue_creator_submits_during_grace_period() {
         CampaignStatus::Executing
     );
 }
+
+#[test]
+fn test_owner_cancel_in_draft() {
+    let t = setup();
+    let owner = Address::generate(&t.env);
+
+    let cid = t.client.create_campaign(
+        &owner,
+        &String::from_str(&t.env, "Owner cancel draft"),
+        &10000i128,
+        &t.token_addr,
+        &(t.env.ledger().timestamp() + 86400),
+        &make_milestones(&t.env),
+        &100i128,
+        &false,
+    );
+
+    assert_eq!(t.client.get_campaign(&cid).status, CampaignStatus::Draft);
+
+    t.client.owner_cancel_campaign(&cid);
+    assert_eq!(
+        t.client.get_campaign(&cid).status,
+        CampaignStatus::Cancelled
+    );
+}
+
+#[test]
+fn test_owner_cancel_in_campaigning_with_refunds() {
+    let t = setup();
+    let sac = StellarAssetClient::new(&t.env, &t.token_addr);
+
+    let owner = Address::generate(&t.env);
+    let donor = Address::generate(&t.env);
+    sac.mint(&donor, &10_000);
+
+    let cid = t.client.create_campaign(
+        &owner,
+        &String::from_str(&t.env, "Owner cancel campaigning"),
+        &10000i128,
+        &t.token_addr,
+        &(t.env.ledger().timestamp() + 86400),
+        &make_milestones(&t.env),
+        &100i128,
+        &false,
+    );
+
+    advance_to_campaigning(&t, cid);
+
+    // Backer pledges
+    t.client.pledge(&donor, &cid, &500);
+    let balance_after_pledge = t.token.balance(&donor);
+
+    // Owner cancels
+    t.client.owner_cancel_campaign(&cid);
+    assert_eq!(
+        t.client.get_campaign(&cid).status,
+        CampaignStatus::Cancelled
+    );
+
+    // Refunds work
+    t.client.process_refund_batch(&cid);
+    assert_eq!(t.token.balance(&donor), balance_after_pledge + 500);
+}
+
+#[test]
+fn test_owner_cancel_after_funded_fails() {
+    let t = setup();
+    let sac = StellarAssetClient::new(&t.env, &t.token_addr);
+
+    let owner = Address::generate(&t.env);
+    let donor = Address::generate(&t.env);
+    sac.mint(&donor, &10_000);
+
+    let cid = t.client.create_campaign(
+        &owner,
+        &String::from_str(&t.env, "Owner cancel funded"),
+        &1000i128,
+        &t.token_addr,
+        &(t.env.ledger().timestamp() + 86400),
+        &make_milestones(&t.env),
+        &100i128,
+        &false,
+    );
+
+    advance_to_campaigning(&t, cid);
+    t.client.pledge(&donor, &cid, &1100);
+    assert_eq!(t.client.get_campaign(&cid).status, CampaignStatus::Funded);
+
+    // Owner cannot cancel after funded
+    let result = t.client.try_owner_cancel_campaign(&cid);
+    assert!(result.is_err());
+}