hebbian-mind-enterprise

Instructions

Implementation Reference

• src/hebbian_mind/server.py:1485-1519 (handler)

  The handler logic for the 'faiss_status' tool, which uses the FaissTetherBridge to query the status of an external FAISS service.

  elif name == "faiss_status":
      if not tether.is_available():
          return [
              types.TextContent(
                  type="text",
                  text=json.dumps(
                      {
                          "success": False,
                          "status": "offline",
                          "enabled": Config.FAISS_TETHER_ENABLED,
                          "host": Config.FAISS_TETHER_HOST,
                          "port": Config.FAISS_TETHER_PORT,
                      },
                      indent=2,
                  ),
              )
          ]
  
      status = tether.status()
  
      return [
          types.TextContent(
              type="text",
              text=json.dumps(
                  {
                      "success": True,
                      "status": "connected",
                      "host": Config.FAISS_TETHER_HOST,
                      "port": Config.FAISS_TETHER_PORT,
                      "tether_info": status,
                  },
                  indent=2,
              ),
          )
      ]

• src/hebbian_mind/server.py:1110-1113 (registration)

  The registration of the 'faiss_status' tool in the list_tools() function.

      name="faiss_status",
      description="Check external FAISS tether status (if enabled).",
      inputSchema={"type": "object", "properties": {}},
  ),

• src/hebbian_mind/server.py:975-988 (helper)

  The status method of the FaissTetherBridge class that executes the status command against the FAISS service.

  def status(self) -> Dict:
      if not self.enabled:
          return {"status": "error", "message": "FAISS tether not enabled"}
      try:
          sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
          sock.settimeout(5)
          sock.connect((self.host, self.port))
          request = json.dumps({"cmd": "status"})
          sock.sendall(request.encode("utf-8"))
          response = sock.recv(16384).decode("utf-8")
          sock.close()
          return json.loads(response)
      except Exception as e:
          return {"status": "error", "message": str(e)}