feat(contract): emit events for primary state changes in creator-earnings

Add InitializedEvent, AuthorizedAddedEvent, and DepositEvent typed event
structs. Emit events at the end of initialize(), add_authorized(), and
deposit() alongside the existing WithdrawEvent in withdraw().
Add unit tests verifying each new event is emitted with correct data.

Also applies cargo fmt fixes to pre-existing formatting violations in
content-access, content-likes, creator-earnings, subscription,
test-consumer, and treasury.

Closes #942

Author: Xaxxoo

contract/contracts/content-access/src/lib.rs

@@ -127,7 +127,10 @@ impl ContentAccess {
 
         // Check if already unlocked (idempotent) – but re-check expiry.
         let access_key = DataKey::Access(buyer.clone(), creator.clone(), content_id);
-        if let Some(existing) = env.storage().instance().get::<DataKey, Purchase>(&access_key)
+        if let Some(existing) = env
+            .storage()
+            .instance()
+            .get::<DataKey, Purchase>(&access_key)
         {
             // If the existing purchase is still valid, treat as no-op.
             if existing.expiry > current_seq {
@@ -166,7 +169,11 @@ impl ContentAccess {
     /// Check if buyer has valid (non-expired) access to content.
     pub fn has_access(env: Env, buyer: Address, creator: Address, content_id: u64) -> bool {
         let access_key = DataKey::Access(buyer, creator, content_id);
-        if let Some(purchase) = env.storage().instance().get::<DataKey, Purchase>(&access_key) {
+        if let Some(purchase) = env
+            .storage()
+            .instance()
+            .get::<DataKey, Purchase>(&access_key)
+        {
             let current_seq: u64 = env.ledger().sequence() as u64;
             purchase.expiry > current_seq
         } else {
@@ -853,7 +860,10 @@ mod test {
         assert!(client.has_access(&buyer, &creator, &1));
         // verify_access should not panic (we test this by not expecting an error)
         let verify_result = client.try_verify_access(&buyer, &creator, &1);
-        assert!(verify_result.is_ok(), "verify_access should succeed when has_access is true");
+        assert!(
+            verify_result.is_ok(),
+            "verify_access should succeed when has_access is true"
+        );
     }
 
     /// Invariant: If verify_access succeeds, has_access should return true.
@@ -879,7 +889,10 @@ mod test {
         client.unlock_content(&buyer, &creator, &1, &NO_EXPIRY);
         assert!(client.has_access(&buyer, &creator, &1));
         let verify_result = client.try_verify_access(&buyer, &creator, &1);
-        assert!(verify_result.is_ok(), "verify_access should succeed after unlock");
+        assert!(
+            verify_result.is_ok(),
+            "verify_access should succeed after unlock"
+        );
     }
 
     /// Invariant: Price set by creator should be retrievable.

contract/contracts/content-access/src/tests/event_tests.rs

@@ -1,7 +1,5 @@
 use crate::{
-    events::{
-        AdminTransferredEvent, ContentPriceSetEvent, MaxPriceClearedEvent, MaxPriceSetEvent,
-    },
+    events::{AdminTransferredEvent, ContentPriceSetEvent, MaxPriceClearedEvent, MaxPriceSetEvent},
     ContentAccess, ContentAccessClient,
 };
 use soroban_sdk::{

contract/contracts/content-access/src/tests/init_admin_tests.rs

@@ -13,9 +13,7 @@
 
 use crate::{ContentAccess, ContentAccessClient, Error};
 use soroban_sdk::{
-    testutils::Address as _,
-    xdr::SorobanAuthorizationEntry,
-    Address, Env, Error as SorobanError,
+    testutils::Address as _, xdr::SorobanAuthorizationEntry, Address, Env, Error as SorobanError,
 };
 
 const EMPTY_AUTHS: &[SorobanAuthorizationEntry] = &[];
@@ -62,7 +60,11 @@ fn initialize_stores_admin() {
 
     client.initialize(&admin, &token_id);
 
-    assert_eq!(client.admin(), admin, "admin() must return the initialized admin");
+    assert_eq!(
+        client.admin(),
+        admin,
+        "admin() must return the initialized admin"
+    );
 }
 
 /// initialize stores the token address; set_content_price succeeds after init.
@@ -136,7 +138,10 @@ fn admin_view_panics_when_uninitialized() {
     let client = ContentAccessClient::new(&env, &contract_id);
 
     let result = client.try_admin();
-    assert!(result.is_err(), "admin() must fail on uninitialized contract");
+    assert!(
+        result.is_err(),
+        "admin() must fail on uninitialized contract"
+    );
 }
 
 // ── set_admin ─────────────────────────────────────────────────────────────────
@@ -152,7 +157,8 @@ fn set_admin_transfers_admin_role() {
     client.set_admin(&new_admin);
 
     assert_eq!(
-        client.admin(), new_admin,
+        client.admin(),
+        new_admin,
         "admin() must return new admin after set_admin"
     );
 }
@@ -246,7 +252,11 @@ fn set_max_price_zero_clears_cap() {
     assert_eq!(client.get_max_price(), Some(500_000));
 
     client.set_max_price(&0);
-    assert_eq!(client.get_max_price(), None, "cap must be removed after set_max_price(0)");
+    assert_eq!(
+        client.get_max_price(),
+        None,
+        "cap must be removed after set_max_price(0)"
+    );
 }
 
 /// Non-admin cannot call set_max_price.
@@ -264,7 +274,10 @@ fn set_max_price_rejected_for_non_admin() {
 
     env.set_auths(EMPTY_AUTHS);
     let result = client.try_set_max_price(&500_000);
-    assert!(result.is_err(), "set_max_price must fail without admin auth");
+    assert!(
+        result.is_err(),
+        "set_max_price must fail without admin auth"
+    );
 }
 
 /// Prices above max_price are rejected when cap is configured.

contract/contracts/content-access/src/tests/unauthorized_tests.rs

@@ -30,7 +30,13 @@ fn setup(env: &Env) -> (ContentAccessClient<'_>, Address, Address) {
     (client, admin, token_address)
 }
 
-fn mock_rogue_auth(env: &Env, rogue: &Address, contract: &Address, fn_name: &'static str, args: soroban_sdk::Vec<Val>) {
+fn mock_rogue_auth(
+    env: &Env,
+    rogue: &Address,
+    contract: &Address,
+    fn_name: &'static str,
+    args: soroban_sdk::Vec<Val>,
+) {
     env.mock_auths(&[MockAuth {
         address: rogue,
         invoke: &MockAuthInvoke {
@@ -163,7 +169,9 @@ fn initialize_reverts_if_already_initialized() {
     let second_admin = Address::generate(&env);
 
     env.mock_all_auths();
-    assert!(client.try_initialize(&second_admin, &token_address).is_err());
+    assert!(client
+        .try_initialize(&second_admin, &token_address)
+        .is_err());
 }
 
 #[test]

contract/contracts/content-likes/src/lib.rs

@@ -584,7 +584,10 @@ mod test {
 
         // Verify events were published
         let events = env.events().all();
-        assert!(events.len() >= 2, "Expected at least 2 events (like and unlike)");
+        assert!(
+            events.len() >= 2,
+            "Expected at least 2 events (like and unlike)"
+        );
     }
 
     #[test]

contract/contracts/content-likes/tests/contract_integration.rs

@@ -63,7 +63,10 @@ fn test_error_unlike_without_like() {
 
     // Try to unlike without ever liking — should fail with NotLiked error (code 1)
     let result = client.try_unlike(&user, &content_id);
-    assert!(result.is_err(), "Expected unlike without prior like to fail with NotLiked error");
+    assert!(
+        result.is_err(),
+        "Expected unlike without prior like to fail with NotLiked error"
+    );
 }
 
 /// Test multiple users liking the same content.

contract/contracts/creator-earnings/src/lib.rs

@@ -40,7 +40,30 @@ pub enum Error {
     InvalidAmount = 5,
 }
 
-/// -------- Events (INLINE) --------
+/// -------- Events --------
+
+#[contracttype]
+#[derive(Clone, Debug, Eq, PartialEq)]
+pub struct InitializedEvent {
+    pub admin: Address,
+    pub token: Address,
+}
+
+#[contracttype]
+#[derive(Clone, Debug, Eq, PartialEq)]
+pub struct AuthorizedAddedEvent {
+    pub depositor: Address,
+}
+
+#[contracttype]
+#[derive(Clone, Debug, Eq, PartialEq)]
+pub struct DepositEvent {
+    pub from: Address,
+    pub creator: Address,
+    pub amount: i128,
+    pub token: Address,
+}
+
 #[contracttype]
 #[derive(Clone, Debug, Eq, PartialEq)]
 pub struct WithdrawEvent {
@@ -50,6 +73,9 @@ pub struct WithdrawEvent {
 }
 
 /// Avoid magic strings
+const INITIALIZED_EVENT: &str = "initialized";
+const AUTHORIZED_ADDED_EVENT: &str = "authorized_added";
+const DEPOSIT_EVENT: &str = "deposit";
 const WITHDRAW_EVENT: &str = "withdraw";
 
 #[contract]
@@ -69,6 +95,14 @@ impl CreatorEarnings {
         env.storage()
             .instance()
             .set(&DataKey::Token, &token_address);
+
+        env.events().publish(
+            (Symbol::new(&env, INITIALIZED_EVENT),),
+            InitializedEvent {
+                admin,
+                token: token_address,
+            },
+        );
     }
 
     /// Add authorized depositor contract (admin only)
@@ -78,7 +112,14 @@ impl CreatorEarnings {
 
         env.storage()
             .instance()
-            .set(&DataKey::AuthorizedDepositor(contract), &true);
+            .set(&DataKey::AuthorizedDepositor(contract.clone()), &true);
+
+        env.events().publish(
+            (Symbol::new(&env, AUTHORIZED_ADDED_EVENT),),
+            AuthorizedAddedEvent {
+                depositor: contract,
+            },
+        );
     }
 
     /// Deposit earnings for creator
@@ -102,6 +143,16 @@ impl CreatorEarnings {
         env.storage()
             .instance()
             .set(&DataKey::Balance(creator.clone()), &new_balance);
+
+        env.events().publish(
+            (Symbol::new(&env, DEPOSIT_EVENT),),
+            DepositEvent {
+                from,
+                creator,
+                amount,
+                token: token_address,
+            },
+        );
     }
 
     /// Get creator balance
@@ -112,7 +163,7 @@ impl CreatorEarnings {
             .unwrap_or(0)
     }
 
-    /// Withdraw earnings (WITH EVENT)
+    /// Withdraw earnings
     pub fn withdraw(env: Env, creator: Address, amount: i128) {
         if amount <= 0 {
             panic_with_error!(&env, Error::InvalidAmount);
@@ -141,7 +192,6 @@ impl CreatorEarnings {
             .instance()
             .set(&DataKey::Balance(creator.clone()), &new_balance);
 
-        // ✅ Typed event emission
         env.events().publish(
             (Symbol::new(&env, WITHDRAW_EVENT),),
             WithdrawEvent {