feat(mcp): implement remaining MCP resources for inventory and orders

Implement 4 additional MCP resources to complete v0.1.0 resource coverage:

**Inventory Resources:**
- katana://inventory/stock-movements - Unified view of stock transfers and adjustments
  - Fetches recent transfers and adjustments via generated API
  - Aggregates into chronological movement feed
  - Provides summary statistics by movement type

**Order Resources (all 3):**
- katana://sales-orders - Customer orders with status and delivery info
- katana://purchase-orders - Supplier orders with expected delivery
- katana://manufacturing-orders - Production orders with progress tracking

**Implementation Details:**
- All resources use generated Katana API (no helpers needed)
- Consistent pattern: fetch → parse → aggregate → summarize
- Pydantic models for type-safe response structures
- Comprehensive error handling and logging
- Next-actions suggestions for each resource

**Key Technical Notes:**
- Use generated API directly: get_all_sales_orders, find_purchase_orders, get_all_manufacturing_orders
- No `from __future__ import annotations` (FastMCP Context requirement)
- Response parsing: response.parsed for list data
- Status aggregation via dict counters

**Resources Implemented (5 total):**
1. ✅ katana://inventory/items (previous commit)
2. ✅ katana://inventory/stock-movements (new)
3. ✅ katana://sales-orders (new)
4. ✅ katana://purchase-orders (new)
5. ✅ katana://manufacturing-orders (new)

**Deferred:** katana://inventory/stock-adjustments (redundant with stock-movements for v0.1.0)

🤖 Generated with [Claude Code](https://claude.com/claude-code)

Co-Authored-By: Claude <noreply@anthropic.com>

Author: Doug Borg

katana_mcp_server/src/katana_mcp/resources/inventory.py

@@ -243,6 +243,253 @@ async def get_inventory_items(context: Context) -> dict:
     return response.model_dump()
 
 
+# ============================================================================
+# Resource 2: katana://inventory/stock-movements
+# ============================================================================
+
+
+class StockMovementsSummary(BaseModel):
+    """Summary statistics for stock movements."""
+
+    total_movements: int = Field(..., description="Total number of movements")
+    movements_in_response: int = Field(
+        ..., description="Number of movements in this response"
+    )
+    movement_types: dict[str, int] = Field(
+        ..., description="Count of movements by type (transfer, adjustment)"
+    )
+
+
+class StockMovementsResource(BaseModel):
+    """Response structure for stock movements resource."""
+
+    generated_at: str = Field(
+        ..., description="ISO timestamp when resource was generated"
+    )
+    summary: StockMovementsSummary = Field(..., description="Summary statistics")
+    movements: list[dict] = Field(
+        ..., description="List of recent stock movements (transfers and adjustments)"
+    )
+    next_actions: list[str] = Field(
+        default_factory=list, description="Suggested next actions"
+    )
+
+
+async def _get_stock_movements_impl(context: Context) -> StockMovementsResource:
+    """Implementation of stock movements resource.
+
+    Fetches recent stock transfers and adjustments from Katana and aggregates
+    them into a unified view of inventory movements.
+
+    Args:
+        context: FastMCP context for accessing the Katana client
+
+    Returns:
+        Structured stock movements data with summary and movements list
+
+    Raises:
+        Exception: If API calls fail
+    """
+    logger.info("stock_movements_resource_started")
+    start_time = time.monotonic()
+
+    try:
+        services = get_services(context)
+
+        # Import the generated API functions
+        from katana_public_api_client.api.stock_adjustment import (
+            get_all_stock_adjustments,
+        )
+        from katana_public_api_client.api.stock_transfer import (
+            get_all_stock_transfers,
+        )
+
+        # Fetch recent stock transfers and adjustments
+        # TODO: Consider parallelizing with asyncio.gather() for better performance
+        transfers_response = await get_all_stock_transfers.asyncio_detailed(
+            client=services.client, limit=50
+        )
+        adjustments_response = await get_all_stock_adjustments.asyncio_detailed(
+            client=services.client, limit=50
+        )
+
+        # Parse responses - extract data from Response objects
+        transfers = transfers_response.parsed if transfers_response.parsed else []
+        adjustments = adjustments_response.parsed if adjustments_response.parsed else []
+
+        # Aggregate into unified movements list
+        movements = []
+
+        # Add transfers
+        for transfer in transfers:
+            movements.append(
+                {
+                    "id": transfer.id if hasattr(transfer, "id") else None,
+                    "timestamp": (
+                        transfer.transfer_date.isoformat()
+                        if hasattr(transfer, "transfer_date") and transfer.transfer_date
+                        else (
+                            transfer.updated_at.isoformat()
+                            if hasattr(transfer, "updated_at") and transfer.updated_at
+                            else None
+                        )
+                    ),
+                    "type": "transfer",
+                    "number": (
+                        transfer.stock_transfer_number
+                        if hasattr(transfer, "stock_transfer_number")
+                        else None
+                    ),
+                    "source_location_id": (
+                        transfer.source_location_id
+                        if hasattr(transfer, "source_location_id")
+                        else None
+                    ),
+                    "target_location_id": (
+                        transfer.target_location_id
+                        if hasattr(transfer, "target_location_id")
+                        else None
+                    ),
+                    "status": (
+                        transfer.status.value
+                        if hasattr(transfer, "status") and transfer.status
+                        else None
+                    ),
+                    "notes": (
+                        transfer.additional_info
+                        if hasattr(transfer, "additional_info")
+                        else None
+                    ),
+                }
+            )
+
+        # Add adjustments
+        for adjustment in adjustments:
+            movements.append(
+                {
+                    "id": adjustment.id if hasattr(adjustment, "id") else None,
+                    "timestamp": (
+                        adjustment.adjustment_date.isoformat()
+                        if hasattr(adjustment, "adjustment_date")
+                        and adjustment.adjustment_date
+                        else (
+                            adjustment.updated_at.isoformat()
+                            if hasattr(adjustment, "updated_at")
+                            and adjustment.updated_at
+                            else None
+                        )
+                    ),
+                    "type": "adjustment",
+                    "number": (
+                        adjustment.stock_adjustment_number
+                        if hasattr(adjustment, "stock_adjustment_number")
+                        else None
+                    ),
+                    "location_id": (
+                        adjustment.location_id
+                        if hasattr(adjustment, "location_id")
+                        else None
+                    ),
+                    "reference_no": (
+                        adjustment.reference_no
+                        if hasattr(adjustment, "reference_no")
+                        else None
+                    ),
+                    "status": (
+                        adjustment.status.value
+                        if hasattr(adjustment, "status") and adjustment.status
+                        else None
+                    ),
+                    "notes": (
+                        adjustment.additional_info
+                        if hasattr(adjustment, "additional_info")
+                        else None
+                    ),
+                }
+            )
+
+        # Sort by timestamp (most recent first)
+        movements.sort(key=lambda m: m.get("timestamp") or "", reverse=True)
+
+        # Count movement types
+        movement_types = {"transfer": len(transfers), "adjustment": len(adjustments)}
+
+        # Build summary
+        summary = StockMovementsSummary(
+            total_movements=len(transfers) + len(adjustments),
+            movements_in_response=len(movements),
+            movement_types=movement_types,
+        )
+
+        duration_ms = round((time.monotonic() - start_time) * 1000, 2)
+        logger.info(
+            "stock_movements_resource_completed",
+            total_movements=summary.total_movements,
+            duration_ms=duration_ms,
+        )
+
+        return StockMovementsResource(
+            generated_at=datetime.now(UTC).isoformat(),
+            summary=summary,
+            movements=movements,
+            next_actions=[
+                "Review recent adjustments for accuracy",
+                "Check transfer statuses for pending movements",
+                "Audit patterns in stock movements",
+            ],
+        )
+
+    except Exception as e:
+        duration_ms = round((time.monotonic() - start_time) * 1000, 2)
+        logger.error(
+            "stock_movements_resource_failed",
+            error=str(e),
+            error_type=type(e).__name__,
+            duration_ms=duration_ms,
+            exc_info=True,
+        )
+        raise
+
+
+async def get_stock_movements(context: Context) -> dict:
+    """Get stock movements resource.
+
+    Provides unified view of recent inventory movements including stock transfers
+    between locations and manual stock adjustments.
+
+    **Resource URI:** `katana://inventory/stock-movements`
+
+    **Purpose:** Track inventory changes and audit trail
+
+    **Refresh Rate:** On-demand (no caching in v0.1.0)
+
+    **Data Includes:**
+    - Recent stock transfers between locations
+    - Manual stock adjustments
+    - Movement timestamps and statuses
+    - Location information
+    - Reference numbers and notes
+
+    **Use Cases:**
+    - Monitor recent inventory activity
+    - Audit stock changes
+    - Track transfer status
+    - Investigate discrepancies
+
+    **Related Tools:**
+    - `check_inventory` - Get current stock levels
+    - `create_purchase_order` - Order more stock
+
+    Args:
+        context: FastMCP context providing access to Katana client
+
+    Returns:
+        Dictionary containing stock movements data with summary and movements list
+    """
+    response = await _get_stock_movements_impl(context)
+    return response.model_dump()
+
+
 def register_resources(mcp: FastMCP) -> None:
     """Register all inventory resources with the FastMCP instance.
 
@@ -257,5 +504,13 @@ def register_resources(mcp: FastMCP) -> None:
         mime_type="application/json",
     )(get_inventory_items)
 
+    # Register katana://inventory/stock-movements resource
+    mcp.resource(
+        uri="katana://inventory/stock-movements",
+        name="Stock Movements",
+        description="Recent inventory movements (transfers and adjustments)",
+        mime_type="application/json",
+    )(get_stock_movements)
+
 
 __all__ = ["register_resources"]