Workflows

wf = app.workflow(
    "Research Company",
    icon="search",
    description="Collect context and draft a brief.",
    scope="user",
)

@wf.start()
async def start(session: cpsl.Session, input: cpsl.WorkflowInput):
    await session.reply("What company should I research?")


@wf.message()
async def continue_research(session: cpsl.Session, msg: cpsl.Message):
    await session.reply(f"Researching {msg.text}...")

@wf.ui()
def research_form():
    return cpsl.ui.WorkflowShell(
        "Research Company",
        children=[
            cpsl.ui.FormSection(
                "Input",
                children=[
                    cpsl.ui.TextInput("Company", name="company", required=True),
                    cpsl.ui.TextInput("Notes", name="notes", multiline=True),
                ],
            ),
            cpsl.ui.ActionBar(
                children=[cpsl.ui.SubmitButton("Start research", primary=True)]
            ),
        ],
    )

@wf.start()
async def start(session: cpsl.Session, input: cpsl.WorkflowInput):
    await session.reply(f"Starting research for {input.company}.")

@wf.action("approve")
async def approve(session: cpsl.Session, input: cpsl.WorkflowInput):
    await session.reply(f"Approved: {input.get('id')}")