feat: add list_organization_skills tool to fetch skill taxonomy

- Implements fetching all skills from /v1/skill endpoint
- Optimizes context by grouping skills by category
- Prevents N+1 LLM calls when user asks 'what skills do we have'

Author: failattu

src/agileday_server.py

@@ -57,6 +57,15 @@ async def list_tools() -> list[Tool]:
                 },
                 "required": ["name_query"]
             }
+        ),
+        # NEW TOOL ADDED HERE
+        Tool(
+            name="list_organization_skills",
+            description="Retrieves a full list of all available skills/competences defined in the organization.",
+            inputSchema={
+                "type": "object",
+                "properties": {}, # No arguments needed
+            }
         )
     ]
 
@@ -66,6 +75,11 @@ async def call_tool(name: str, arguments: dict) -> list[TextContent | ImageConte
         return [TextContent(type="text", text=find_experts_logic(arguments["skill_name"]))]
     if name == "get_employee_competence_profile":
         return [TextContent(type="text", text=profile_logic(arguments["name_query"]))]
+    
+    # NEW LOGIC HANDLER
+    if name == "list_organization_skills":
+        return [TextContent(type="text", text=list_skills_logic())]
+        
     raise ValueError(f"Unknown tool: {name}")
 
 # --- Helper Functions ---
@@ -124,42 +138,66 @@ def profile_logic(name_query: str) -> str:
 
     return "\n\n".join(results) if results else f"No employee found for '{name_query}'."
 
+# NEW LOGIC FUNCTION
+def list_skills_logic() -> str:
+    try:
+        url = f"{BASE_URL}/v1/skill"
+        response = requests.get(url, headers=get_headers(), timeout=15)
+        response.raise_for_status()
+        skills = response.json()
+    except Exception as e:
+        return f"Error fetching skills: {str(e)}"
+
+    if not skills:
+        return "No skills defined in the library."
+
+    # Group skills by category for better readability
+    categories = {}
+    for s in skills:
+        # Default to "Other" if category is missing/null
+        cat = s.get('category') or "Uncategorized"
+        if cat not in categories: 
+            categories[cat] = []
+        categories[cat].append(s.get('name', 'Unnamed Skill'))
+
+    output = ["**Organization Skill Library**\n"]
+    
+    # Sort categories alphabetically
+    for cat in sorted(categories.keys()):
+        skill_names = sorted(categories[cat])
+        # Format: "### Category Name \n - Skill 1, Skill 2..."
+        output.append(f"### {cat}")
+        output.append(", ".join(skill_names))
+        output.append("") # Empty line for spacing
+
+    return "\n".join(output)
+
 # --- 3. Transport Layer (Raw ASGI) ---
 
 sse_transport = SseServerTransport("/mcp")
 
 class MCPHandler:
-    """
-    A Raw ASGI Handler.
-    This class bypasses Starlette's Request/Response lifecycle entirely.
-    It passes the raw 'send' channel to the MCP SDK, allowing the SDK
-    to write the response headers and body directly without conflict.
-    """
     async def __call__(self, scope, receive, send):
         if scope["type"] != "http":
             return
 
         if scope["method"] == "POST":
-            # The SDK handles reading the body and sending the '202 Accepted' response.
             await sse_transport.handle_post_message(scope, receive, send)
 
         elif scope["method"] == "GET":
-            # The SDK handles the SSE handshake and streaming.
             async with sse_transport.connect_sse(scope, receive, send) as streams:
                 await server.run(streams[0], streams[1], server.create_initialization_options())
 
         else:
-            # Manual 405 Method Not Allowed
             response = Response("Method Not Allowed", status_code=405)
             await response(scope, receive, send)
 
 mcp_asgi_app = MCPHandler()
 
 routes = [
-    # Starlette detects `mcp_asgi_app` is an ASGI app (has __call__) and treats it as a raw endpoint.
     Route("/mcp", endpoint=mcp_asgi_app, methods=["GET", "POST"]),
-    Route("/sse", endpoint=mcp_asgi_app, methods=["GET"]), # Deprecated alias
-    Route("/messages", endpoint=mcp_asgi_app, methods=["POST"]), # Alias
+    Route("/sse", endpoint=mcp_asgi_app, methods=["GET"]), 
+    Route("/messages", endpoint=mcp_asgi_app, methods=["POST"]),
     Route("/health", endpoint=lambda r: Response("OK"))
 ]
 

tests/test_agileday_server.py

@@ -10,8 +10,8 @@
 # Add src to path so we can import the server
 sys.path.append(os.path.join(os.path.dirname(__file__), '../src'))
 
-# IMPORTS UPDATED: We now import the specific logic functions
-from agileday_server import find_experts_logic, profile_logic, BASE_URL
+# Add list_skills_logic to imports
+from agileday_server import find_experts_logic, profile_logic, list_skills_logic, BASE_URL
 
 # --- Fixtures ---
 
@@ -111,4 +111,24 @@ def test_api_failure_handling(mock_api_response):
 
     # Note: In the new implementation we return "Error: ..."
     assert "Error" in result
-    assert "API Connection Failed" in result
+    assert "API Connection Failed" in result
+
+def test_list_skills_grouping(mock_api_response):
+    """Test that skills are fetched and grouped by category."""
+    mock_data = [
+        {"name": "Python", "category": "Backend"},
+        {"name": "Java", "category": "Backend"},
+        {"name": "React", "category": "Frontend"},
+        {"name": "Figma", "category": None} # Should be 'Uncategorized'
+    ]
+    mock_api_response.return_value.json.return_value = mock_data
+
+    result = list_skills_logic()
+
+    # Verify Output Formatting
+    assert "### Backend" in result
+    assert "Python, Java" in result or "Java, Python" in result
+    assert "### Frontend" in result
+    assert "React" in result
+    assert "### Uncategorized" in result
+    assert "Figma" in result