Method process

processor/generators.py:236–262

(self, ctx: PipelineContext)

class MultiRichTextGenerator(Generator):
    def process(self, ctx: PipelineContext):
        text_segments: List[TextSegment] = TextSegment.from_dicts(ctx.get("text_segments"))
        text_alignment = ctx.get("text_alignment")
        text_spacing = ctx.getint("text_spacing")
        height = ctx.get("height", 100)

        text_images = []
        for segment in text_segments:
            segment.height = height
            context = PipelineContext(asdict(segment))
            context.set("save_buffer", False)
            RichTextGenerator().process(context)
            text_images.extend(context.get_buffer())

        # 使用 start_process 替代直接调用 ConcatMerger，解耦对 Merger 的直接依赖
        from processor.core import start_process
        pipeline = [
            {
                "processor_name": "concat",
                "alignment": text_alignment,
                "spacing": text_spacing,
                "save_buffer": False,
            }
        ]
        result = start_process(pipeline, initial_buffer=text_images)

        ctx.update_buffer([result]).save_buffer(self.name()).success()

    def name(self) -> str:
        return "multi_rich_text"