workflow.h

#pragma once
 
#include <agents-cpp/types.h>
#include <agents-cpp/agent_context.h>
#include <functional>
#include <memory>
 
namespace agents {
namespace workflows {

class Workflow {
public:
    Workflow(std::shared_ptr<AgentContext> context);

    ~Workflow() = default;

    virtual JsonObject run(const String& input) = 0;

    virtual void runAsync(
        const String& input,
        std::function<void(const JsonObject&)> callback
    );

    std::shared_ptr<AgentContext> getContext() const;

    void setStepCallback(std::function<void(const String&, const JsonObject&)> callback);

    void setMaxSteps(int max_steps);

    int getMaxSteps() const;

protected:
    std::shared_ptr<AgentContext> context_;

    std::function<void(const String&, const JsonObject&)> step_callback_;

    int max_steps_ = 10;

    void logStep(const String& description, const JsonObject& result);
};
 
} // namespace workflows
} // namespace agents