FCCS MCP Agentic Server

Instructions

Implementation Reference

• fccs_agent/tools/journals.py:153-165 (handler)

  The main handler function for the 'import_journals' MCP tool. It calls the underlying FCCS client to submit an import journals job and wraps the result in a success response.

  async def import_journals(
      parameters: Optional[dict[str, Any]] = None
  ) -> dict[str, Any]:
      """Import consolidation journals / Importar diarios de consolidacao.
  
      Args:
          parameters: Import parameters.
  
      Returns:
          dict: Job submission result.
      """
      result = await _client.import_journals(_app_name, parameters)
      return {"status": "success", "data": result}

• fccs_agent/tools/journals.py:238-247 (schema)

  The input schema definition for the 'import_journals' tool, specifying an optional 'parameters' object.

  {
      "name": "import_journals",
      "description": "Import consolidation journals / Importar diarios de consolidacao",
      "inputSchema": {
          "type": "object",
          "properties": {
              "parameters": {"type": "object", "description": "Import parameters"},
          },
      },
  },

• fccs_agent/agent.py:157-157 (registration)

  Registration of the 'import_journals' handler in the central TOOL_HANDLERS dictionary used by the agent to dispatch tool calls.

  "import_journals": journals.import_journals,

• fccs_agent/agent.py:192-192 (registration)

  Inclusion of journals.TOOL_DEFINITIONS (containing the schema) into the aggregated ALL_TOOL_DEFINITIONS list exposed to MCP.

  journals.TOOL_DEFINITIONS +

• fccs_agent/client/fccs_client.py:511-526 (helper)

  Underlying client method that performs the actual HTTP POST to FCCS /jobs endpoint with jobType 'IMPORTJOURNALS', called by the tool handler.

  async def import_journals(
      self,
      app_name: str,
      parameters: Optional[dict[str, Any]] = None
  ) -> dict[str, Any]:
      """Import journals / Importar lancamentos."""
      if self.config.fccs_mock_mode:
          return {"jobId": "602", "status": "Submitted", "jobType": "ImportJournals"}
  
      payload = {"jobType": "IMPORTJOURNALS", **(parameters or {})}
      response = await self._client.post(
          f"/{app_name}/jobs{self._get_query_params()}",
          json=payload
      )
      response.raise_for_status()
      return response.json()