flow

type BranchGenerator struct{}

type ConversationFlow struct {
	// contains filtered or unexported fields

} // NewConversationFlow creates a new conversation flow with dependencies.

type ConversationFlowRecovery struct{}

type ConversationHistory struct {
	Messages []ConversationMessage `json:"messages"`
}

type ConversationMessage struct {
	Role      string    `json:"role"`      // "user", "assistant", or "system"
	Content   string    `json:"content"`   // message content
	Timestamp time.Time `json:"timestamp"` // when the message was sent
}

type Coordinator interface {
	// LoadSystemPrompt loads any system prompt or configuration needed.
	LoadSystemPrompt() error

	// ProcessMessageWithHistory handles a user message and may update the provided
	// conversation history in-place. Returns the assistant's reply to send.
	ProcessMessageWithHistory(ctx context.Context, participantID, userMessage string, chatHistory []openai.ChatCompletionMessageParamUnion, conversationHistory *ConversationHistory) (string, error)
}

type CoordinatorChoice string

type CoordinatorModule struct {
	// contains filtered or unexported fields
}

type Dependencies struct {
	StateManager StateManager
	Timer        models.Timer
}

type FeedbackModule struct {
	// contains filtered or unexported fields
}

type GenAIGenerator struct {
	Client *genai.Client
}

type Generator interface {
	Generate(ctx context.Context, p models.Prompt) (string, error)
}

type IntakeModule struct {
	// contains filtered or unexported fields
}

type MessagingService interface {
	ValidateAndCanonicalizeRecipient(recipient string) (string, error)
	SendMessage(ctx context.Context, to, message string) error
}

type ProfileSaveTool struct {
	// contains filtered or unexported fields
}

type PromptGeneratorService interface {
	ExecutePromptGenerator(ctx context.Context, participantID string, args map[string]interface{}) (string, error)
}

type PromptGeneratorTool struct {
	// contains filtered or unexported fields
}

type Registry struct {
	// contains filtered or unexported fields
}

type SchedulerTool struct {
	// contains filtered or unexported fields
}

type SimpleTimer struct {
	// contains filtered or unexported fields
}

type StateManager interface {
	// GetCurrentState retrieves the current state for a participant in a flow
	GetCurrentState(ctx context.Context, participantID string, flowType models.FlowType) (models.StateType, error)

	// SetCurrentState updates the current state for a participant in a flow
	SetCurrentState(ctx context.Context, participantID string, flowType models.FlowType, state models.StateType) error

	// GetStateData retrieves additional data associated with the participant's state
	GetStateData(ctx context.Context, participantID string, flowType models.FlowType, key models.DataKey) (string, error)

	// SetStateData stores additional data associated with the participant's state
	SetStateData(ctx context.Context, participantID string, flowType models.FlowType, key models.DataKey, value string) error

	// TransitionState transitions from one state to another
	TransitionState(ctx context.Context, participantID string, flowType models.FlowType, fromState, toState models.StateType) error

	// ResetState removes all state data for a participant in a flow
	ResetState(ctx context.Context, participantID string, flowType models.FlowType) error
}

type StateTransitionTool struct {
	// contains filtered or unexported fields
}

type StatefulGenerator interface {
	Generator
	// SetDependencies injects dependencies into the generator
	SetDependencies(deps Dependencies)
}

type StaticCoordinatorModule struct {
	// contains filtered or unexported fields
}

type StaticGenerator struct{}

type StoreBasedStateManager struct {
	// contains filtered or unexported fields
}

type UserProfile struct {
	HabitDomain       string    `json:"habit_domain"`       // e.g., "healthy eating", "physical activity"
	MotivationalFrame string    `json:"motivational_frame"` // User's personal motivation
	PreferredTime     string    `json:"preferred_time"`     // Time window for nudging
	PromptAnchor      string    `json:"prompt_anchor"`      // When habit fits naturally
	AdditionalInfo    string    `json:"additional_info"`    // Any extra personalization info
	CreatedAt         time.Time `json:"created_at"`         // When profile was created
	UpdatedAt         time.Time `json:"updated_at"`         // Last profile update

	// Feedback tracking fields
	LastSuccessfulPrompt string `json:"last_successful_prompt,omitempty"` // Last prompt that worked
	LastBarrier          string `json:"last_barrier,omitempty"`           // Last reported barrier
	LastTweak            string `json:"last_tweak,omitempty"`             // Last requested modification
	SuccessCount         int    `json:"success_count"`                    // Number of successful completions
	TotalPrompts         int    `json:"total_prompts"`                    // Total prompts sent
}