fix(general): cleanup

Author: dineshpinto

src/flare_ai_kit/a2a/README.md docs/a2a_readme.mdsrc/flare_ai_kit/a2a/README.md renamed to docs/a2a_readme.md

@@ -1,6 +1,6 @@
 # Flare AI Kit A2A Package
 
-This package builds A2A (Agent-to-Agent) functionality into the Flare AI Kit. It consists of two main modules, a client and a server, that enable agents to communicate with each other over HTTP JSON-RPC 2.0. The package exposes A2A schemas following the v0.2.3 protocol spec. 
+This package builds A2A (Agent-to-Agent) functionality into the Flare AI Kit. It consists of two main modules, a client and a server, that enable agents to communicate with each other over HTTP JSON-RPC 2.0. The package exposes A2A schemas following the v0.2.3 protocol spec.
 
 ## Using the client
 
@@ -63,24 +63,24 @@ Below is an example response body from the agent:
 
 ```json
 {
-    "jsonrpc": "2.0",
-    "id": "0dacbeeed6a842d0ad6d2d31ce3150f4",
-    "result": {
-        "kind": "message",
-        "role": "agent",
-        "parts": [
-            {
-                "kind": "text",
-                "text": "The price of BTC/USD is 111184.22.",
-                "metadata": null
-            }
-        ],
-        "metadata": null,
-        "messageId": "98698e9607444cd0a4d26f52c11feec5",
-        "contextId": null,
-        "taskId": null
-    },
-    "error": null
+  "jsonrpc": "2.0",
+  "id": "0dacbeeed6a842d0ad6d2d31ce3150f4",
+  "result": {
+    "kind": "message",
+    "role": "agent",
+    "parts": [
+      {
+        "kind": "text",
+        "text": "The price of BTC/USD is 111184.22.",
+        "metadata": null
+      }
+    ],
+    "metadata": null,
+    "messageId": "98698e9607444cd0a4d26f52c11feec5",
+    "contextId": null,
+    "taskId": null
+  },
+  "error": null
 }
 ```
 
@@ -182,10 +182,10 @@ server = A2AServer(card, host="localhost", port=4500)
 async def handle_message(request: SendMessageRequest):
     # Process the message
     user_text = "".join(
-        part.text for part in request.params.message.parts 
+        part.text for part in request.params.message.parts
         if part.kind == "text"
     )
-    
+
     # Generate response
     return SendMessageResponse(
         result=Message(
@@ -231,6 +231,7 @@ The A2A package includes robust task management with SQLite-based persistence th
 ### Task States
 
 Tasks can be in one of several states:
+
 - `submitted`: Task has been submitted
 - `working`: Task is being processed
 - `input_required`: Task needs additional input
@@ -284,6 +285,7 @@ Streaming support is planned for future releases. The infrastructure is in place
 - Agent capabilities can declare `streaming: true`
 
 When implemented, streaming will allow:
+
 - Real-time message streaming
 - Progressive task updates
 - Artifact streaming for large responses
@@ -298,6 +300,7 @@ Push notification support is planned for future releases. The foundation include
 - Authentication schemes for secure webhook delivery
 
 When implemented, push notifications will enable:
+
 - Webhook-based task status updates
 - Asynchronous result delivery
 - Real-time event notifications
@@ -324,4 +327,3 @@ See the examples in the `examples/a2a/a2a_collaboration/` directory for a comple
 ### Simple Ping-Pong Example
 
 See `examples/a2a/messaging/ping_pong.py` for a basic client-server interaction example.
-

…t/ecosystem/protocols/DA_LAYER_README.md docs/da_layer_readme.mdsrc/flare_ai_kit/ecosystem/protocols/DA_LAYER_README.md renamed to docs/da_layer_readme.md src/flare_ai_kit/ecosystem/protocols/DA_LAYER_README.md renamed to docs/da_layer_readme.md

@@ -9,7 +9,7 @@ This implementation provides a comprehensive connector for interacting with the
 ### ✅ Core Requirements Fulfilled
 
 1. **Data Retrieval from FSP**: Retrieve data that has been submitted to the Flare DA Layer via the Flare State Protocol
-2. **Merkle Proof Support**: Fetch and verify Merkle proofs associated with data on the DA Layer  
+2. **Merkle Proof Support**: Fetch and verify Merkle proofs associated with data on the DA Layer
 3. **Historical Data Access**: Support for historical data retrieval as permitted by the layer's design
 4. **Data Integrity Verification**: Confirm integrity and provenance of attestation data
 
@@ -104,7 +104,7 @@ async with await DataAvailabilityLayer.create(settings) as da_layer:
         end_timestamp=end_time,
         attestation_types=["Payment", "EVMTransaction"]
     )
-    
+
     # Process attestations...
     for attestation in historical_data:
         # Verify each attestation
@@ -216,7 +216,7 @@ evm_attestations = await da_layer.get_attestations_by_type(
 for attestation in evm_attestations:
     response = attestation.response
     proof = attestation.proof
-    
+
     # Submit to smart contract for verification
     # contract.verify_attestation(response_data, proof_data)
 ```
@@ -302,10 +302,10 @@ async def process_attestations_batch(da_layer, attestations):
         da_layer.verify_merkle_proof(attestation)
         for attestation in attestations
     ]
-    
+
     # Verify all proofs concurrently
     verification_results = await asyncio.gather(*verification_tasks)
-    
+
     # Process verified attestations
     for attestation, is_valid in zip(attestations, verification_results):
         if is_valid:

examples/docs/FASSETS_TESTING_GUIDE.md docs/fassets_testing_guide.mdexamples/docs/FASSETS_TESTING_GUIDE.md renamed to docs/fassets_testing_guide.md

@@ -3,11 +3,14 @@
 ## Prerequisites
 
 ### Python Version
+
 This project requires **Python 3.12+**. The current environment has Python 3.9, which causes compatibility issues with:
+
 - Union operator `|` (requires Python 3.10+)
 - `typing.override` (requires Python 3.12+)
 
 ### Install Dependencies
+
 ```bash
 # Using uv (recommended)
 uv sync
@@ -19,6 +22,7 @@ pip install -e .
 ## Testing the Implementation
 
 ### 1. Import Testing
+
 ```python
 # Test basic imports
 from flare_ai_kit import FlareAIKit
@@ -31,22 +35,23 @@ print("✅ All imports successful!")
 ```
 
 ### 2. Basic Functionality Test
+
 ```python
 import asyncio
 from flare_ai_kit import FlareAIKit
 
 async def test_fassets_basic():
     # Initialize FlareAIKit
     kit = FlareAIKit()
-    
+
     # Get FAssets connector
     fassets = await kit.fassets
     print("✅ FAssets connector initialized")
-    
+
     # Test network detection
     supported = await fassets.get_supported_fassets()
     print(f"✅ Supported FAssets: {list(supported.keys())}")
-    
+
     # Test chain ID detection
     chain_id = await fassets.w3.eth.chain_id
     print(f"✅ Connected to network: {chain_id}")
@@ -57,6 +62,7 @@ asyncio.run(test_fassets_basic())
 ### 3. Network-Specific Testing
 
 #### Songbird Network (Chain ID: 19)
+
 ```python
 # FXRP should be available and active
 if chain_id == 19:
@@ -66,6 +72,7 @@ if chain_id == 19:
 ```
 
 #### Flare Mainnet (Chain ID: 14)
+
 ```python
 # FBTC and FDOGE should be configured but not active yet
 if chain_id == 14:
@@ -76,6 +83,7 @@ if chain_id == 14:
 ```
 
 ### 4. Contract Integration Testing
+
 **Note: Requires real contract addresses**
 
 ```python
@@ -84,19 +92,20 @@ async def test_contract_integration():
     try:
         agents = await fassets.get_all_agents(FAssetType.FXRP)
         print(f"✅ Found {len(agents)} agents")
-        
+
         if agents:
             agent_info = await fassets.get_agent_info(FAssetType.FXRP, agents[0])
             print(f"✅ Agent info retrieved: {agent_info.name}")
-            
+
             available_lots = await fassets.get_available_lots(FAssetType.FXRP, agents[0])
             print(f"✅ Available lots: {available_lots}")
-            
+
     except Exception as e:
         print(f"⚠️  Contract calls failed (expected with placeholder addresses): {e}")
 ```
 
 ### 5. Minting Flow Testing
+
 ```python
 async def test_minting_flow():
     """Test the complete minting workflow"""
@@ -111,18 +120,19 @@ async def test_minting_flow():
             executor_fee_nat=100000000000000000  # 0.1 NAT
         )
         print(f"✅ Collateral reserved: {reservation_id}")
-        
+
         # Step 2: Get reservation details
         reservation_data = await fassets.get_collateral_reservation_data(
             FAssetType.FXRP, reservation_id
         )
         print(f"✅ Reservation data: {reservation_data}")
-        
+
     except Exception as e:
         print(f"⚠️  Minting test failed (expected without real contracts): {e}")
 ```
 
 ### 6. Redemption Flow Testing
+
 ```python
 async def test_redemption_flow():
     """Test the redemption workflow"""
@@ -136,14 +146,15 @@ async def test_redemption_flow():
             executor_fee_nat=100000000000000000
         )
         print(f"✅ Redemption requested: {redemption_id}")
-        
+
     except Exception as e:
         print(f"⚠️  Redemption test failed (expected without real contracts): {e}")
 ```
 
 ## Running the Tests
 
 ### Unit Tests
+
 ```bash
 # Run the FAssets-specific tests
 python -m pytest tests/integration/ecosystem/protocols/test_fassets.py -v
@@ -153,6 +164,7 @@ python examples/02_fassets_basic.py
 ```
 
 ### Integration Tests
+
 ```bash
 # Run all ecosystem tests
 python -m pytest tests/integration/ecosystem/ -v
@@ -161,40 +173,50 @@ python -m pytest tests/integration/ecosystem/ -v
 ## Expected Results
 
 ### ✅ Working Components
+
 1. **Data Models**: All FAssets schemas, enums, and exceptions
 2. **Network Detection**: Automatic FAsset configuration based on chain ID
 3. **API Structure**: Complete method signatures and error handling
 4. **Integration**: Proper integration with FlareAIKit main class
 
 ### ⚠️ Requires Real Contract Addresses
+
 1. **Contract Calls**: Currently using placeholder addresses
 2. **Event Parsing**: Needs implementation for reservation/redemption IDs
 3. **Transaction Execution**: Needs real agent addresses and sufficient funds
 
 ## Next Steps for Production
 
 ### 1. Contract Addresses
+
 Update placeholder addresses in `_initialize_supported_fassets()`:
+
 ```python
 # Replace these with real deployed addresses
 asset_manager_address="0x0000000000000000000000000000000000000000"  # ❌ Placeholder
 f_asset_address="0x0000000000000000000000000000000000000000"      # ❌ Placeholder
 ```
 
 ### 2. Event Parsing
+
 Implement proper event log parsing for:
+
 - `CollateralReserved` events (to get reservation ID)
 - `MintingExecuted` events
 - `RedemptionRequested` events
 
 ### 3. Enhanced Error Handling
+
 Add specific error handling for:
+
 - Insufficient collateral
-- Invalid agent addresses  
+- Invalid agent addresses
 - Failed underlying transactions
 
 ### 4. Testing with Real Networks
+
 Test on:
+
 - Songbird testnet (Coston)
 - Flare testnet (Coston2)
 - Songbird mainnet (FXRP live)
@@ -216,6 +238,7 @@ Test on:
 - [ ] End-to-end redemption flow tested
 
 ## Current Status
+
 ✅ **Implementation Complete**: Core functionality, data models, and integration
 ⚠️ **Needs Real Contracts**: Placeholder addresses prevent live testing
-🔄 **Ready for Integration**: Can be used immediately with proper contract addresses 
+🔄 **Ready for Integration**: Can be used immediately with proper contract addresses