feat: add applications as providers

Signed-off-by: vsoch <vsoch@users.noreply.github.com>

Author: vsoch

mcpserver/core/base.py

@@ -2,6 +2,7 @@
 import json
 import time
 
+from resource_secretary.apps import discover_applications
 from resource_secretary.providers import discover_providers
 from resource_secretary.providers.mock import discover_mock_providers
 
@@ -15,19 +16,20 @@ class WorkerBase:
     ask secretary. We provide it here so that a hub can use it to generate
     its dual mode (acting as worker AND hub.)
     """
+
     def jsonify_response(self, result):
         """
         Ensure we get the text, and separate and parse tool calls,
         which the agent will return in a verbose mode.
         """
-        print('result')
+        print("result")
         print(result)
         print(type(result))
         if isinstance(result, dict):
             return result
         if not isinstance(result, str) and hasattr(result, "content"):
             result = result.content[0].text
-     
+
         # Audit the tool calls (Did the agent just get lucky?)
         calls = []
         if "CALLS" in result:
@@ -47,11 +49,14 @@ def init_providers(self, mock=False):
         Probe the local system on startup. E.g., "we found spack, flux, etc."
         These can be faux (mock) or real discovered providers
         """
+        # We can use apps in mock or regular
+        apps = discover_applications()
         logger.info("📡 Probing local system for resource providers...")
         if mock:
             self.catalog = discover_mock_providers(self.worker_id, choice=mock)
         else:
             self.catalog = discover_providers()
+        self.catalog.update(apps)
 
     def register_agent_tools(self):
         """

mcpserver/core/hub.py

@@ -209,9 +209,6 @@ async def dispatch_job(worker_id: str, prompt: str) -> dict:
 
             async with info["client"] as sess:
                 result = await sess.call_tool("submit", {"request": prompt})
-                print('response in hub')
-                print(type(result))
-                print(result)
                 return self.jsonify_response(result)
 
         @self.mcp.tool(name="negotiate_job")

mcpserver/core/worker.py

@@ -3,8 +3,6 @@
 from typing import Any, Dict, Optional
 
 import httpx
-from resource_secretary.providers import discover_providers
-from resource_secretary.providers.mock import discover_mock_providers
 from rich import print
 
 from mcpserver.logger import logger

mcpserver/utils/text.py

@@ -1,4 +1,3 @@
-import json
 import re
 
 
@@ -21,14 +20,11 @@ def format_calls(calls_block):
     """
     calls = []
     try:
-        print(calls_block)
-        print(type(calls_block))
         calls = extract_code_block(calls_block)
-        print('success to extract calls')
         return calls
     except Exception as e:
-        print(f'Issue in format calls: {e}')
-        return calls
+        print(f"Issue in format calls: {e}")
+        return calls_block
 
 
 def extract_code_block(text):