Method _run_loop

src/codegraphcontext/server.py:705–791

(self, loop)

                warning_logger(f"Error during server shutdown: {exc}")

    async def _run_loop(self, loop):
        request_count = 0
        while True:
            try:
                if request_count and request_count % 50 == 0:
                    self.job_manager.cleanup_old_jobs(max_age_hours=24)
                # Read a request from the standard input.
                line = await loop.run_in_executor(None, sys.stdin.readline)
                if not line:
                    debug_logger("Client disconnected (EOF received). Shutting down.")
                    break
                
                request = json.loads(line.strip())
                method = request.get('method')
                params = request.get('params', {})
                request_id = request.get('id')
                request_count += 1
                
                response = {}
                # Route the request based on the JSON-RPC method.
                if method == 'initialize':
                    response = {
                        "jsonrpc": "2.0", "id": request_id,
                        "result": {
                            "protocolVersion": "2025-03-26",
                            "serverInfo": {
                                "name": "CodeGraphContext", "version": self._get_version(),
                                "instructionsAvailable": True
                            },
                            "capabilities": {"tools": {"listTools": True}},
                            "instructions": LLM_SYSTEM_PROMPT,
                        }
                    }
                elif method == 'tools/list':
                    # Return the list of tools defined in _init_tools.
                    response = {
                        "jsonrpc": "2.0", "id": request_id,
                        "result": {"tools": list(self.tools.values())}
                    }
                elif method == 'tools/call':
                    # Execute a tool call and return the result.
                    tool_name = params.get('name')
                    args = params.get('arguments', {})
                    result = await self.handle_tool_call(tool_name, args)
                    result = _strip_workspace_prefix(result)

                    if "error" in result:
                        response = {
                            "jsonrpc": "2.0", "id": request_id,
                            "error": {"code": -32000, "message": "Tool execution error", "data": result}
                        }
                    else:
                        response_text = encode_response(result)
                        response_text = _apply_response_token_limit(tool_name, response_text)
                        response = {
                            "jsonrpc": "2.0", "id": request_id,
                            "result": {"content": [{"type": "text", "text": response_text}]}
                        }