Method process_file

ms_agent/tools/filesystem_tool.py:661–692

(path)

        results = {}

        def process_file(path):
            try:
                target_path_real = self.get_real_path(path)
                if target_path_real is None:
                    return path, f'Access denied: Reading file <{path}> outside output directory is not allowed.'

                index_file = os.path.join(self.index_dir, path.strip(os.sep))
                if os.path.exists(index_file):
                    with open(index_file, 'r', encoding='utf-8') as f:
                        return path, f.read()

                # Read file content
                with open(target_path_real, 'r', encoding='utf-8') as f:
                    content = f.read()

                # Use LLM to generate abbreviation
                messages = [
                    Message(role='system', content=self.system),
                    Message(
                        role='user',
                        content='The content to be abbreviated:\n\n'
                        + content),
                ]
                response = self.llm.generate(messages=messages, stream=False)
                os.makedirs(os.path.dirname(index_file), exist_ok=True)
                with open(index_file, 'w', encoding='utf-8') as f:
                    f.write(response.content)
                return path, response.content
            except FileNotFoundError:
                return path, f'Read file <{path}> failed: FileNotFound'
            except Exception as e:
                return path, f'Process file <{path}> failed, error: ' + str(e)

        # Use thread pool for parallel LLM API calls
        with ThreadPoolExecutor(max_workers=4) as executor: