agenticdispatch

type ActivityEvent struct {
	Type      string          `json:"type"` // loop_created, loop_updated, loop_deleted
	LoopID    string          `json:"loop_id"`
	Timestamp time.Time       `json:"timestamp"`
	Data      json.RawMessage `json:"data,omitempty"`
}

type CommandConfig struct {
	Pattern     string `json:"pattern"`      // Regex pattern to match
	Permission  string `json:"permission"`   // Required permission
	RequireLoop bool   `json:"require_loop"` // Requires an active loop
	Help        string `json:"help"`         // Help text
}

type CommandContext struct {
	NATSClient    *natsclient.Client
	LoopTracker   *LoopTracker
	Logger        *slog.Logger
	HasPermission func(userID, permission string) bool
}

type CommandExecutor interface {
	Execute(ctx context.Context, cmdCtx *CommandContext, msg agentic.UserMessage, args []string, loopID string) (agentic.UserResponse, error)
	Config() CommandConfig
}

type CommandHandler func(ctx context.Context, msg agentic.UserMessage, args []string, loopID string) (agentic.UserResponse, error)

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

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

type Config struct {
	DefaultRole          string                `json:"default_role" schema:"type:string,description:Default role for new tasks,default:general,category:basic,required"`
	AutoContinue         bool                  `json:"auto_continue" schema:"type:bool,description:Automatically continue last active loop,default:true,category:basic"` // Continue last loop if exists
	Permissions          PermissionConfig      `json:"permissions" schema:"type:object,description:Permission configuration,category:advanced"`
	StreamName           string                `json:"stream_name" schema:"type:string,description:NATS stream name for user messages,default:USER,category:advanced"`
	ConsumerNameSuffix   string                `` /* 137-byte string literal not displayed */
	DeleteConsumerOnStop bool                  `` /* 157-byte string literal not displayed */
	Ports                *component.PortConfig `json:"ports,omitempty" schema:"type:ports,description:Port configuration for inputs and outputs,category:basic"`
}

type DebugConfig struct {
	DefaultRole  string `json:"default_role"`
	DefaultModel string `json:"default_model"` // Resolved from model registry
	AutoContinue bool   `json:"auto_continue"`
	StreamName   string `json:"stream_name"`
}

type DebugState struct {
	Started      bool        `json:"started"`
	StartTime    time.Time   `json:"start_time,omitempty"`
	Uptime       string      `json:"uptime,omitempty"`
	LoopCount    int         `json:"loop_count"`
	CommandCount int         `json:"command_count"`
	Loops        []*LoopInfo `json:"loops"`
	Commands     []string    `json:"commands"`
	Config       DebugConfig `json:"config"`
}

type HTTPMessageRequest struct {
	Content     string            `json:"content"`
	UserID      string            `json:"user_id,omitempty"`
	ChannelType string            `json:"channel_type,omitempty"`
	ChannelID   string            `json:"channel_id,omitempty"`
	ReplyTo     string            `json:"reply_to,omitempty"`
	Metadata    map[string]string `json:"metadata,omitempty"`
}

type HTTPMessageResponse struct {
	ResponseID string `json:"response_id"`
	Type       string `json:"type"`
	Content    string `json:"content"`
	InReplyTo  string `json:"in_reply_to,omitempty"`
	Error      string `json:"error,omitempty"`
	Timestamp  string `json:"timestamp"`
}

type LoopInfo struct {
	LoopID        string    `json:"loop_id"`
	TaskID        string    `json:"task_id"`
	UserID        string    `json:"user_id"`
	ChannelType   string    `json:"channel_type"`
	ChannelID     string    `json:"channel_id"`
	State         string    `json:"state"`
	Iterations    int       `json:"iterations"`
	MaxIterations int       `json:"max_iterations"`
	CreatedAt     time.Time `json:"created_at"`

	// Workflow context (for loops created by workflow commands)
	WorkflowSlug string `json:"workflow_slug,omitempty"` // e.g., "add-user-auth"
	WorkflowStep string `json:"workflow_step,omitempty"` // e.g., "design"

	// Context assembly reference (links to assembled context)
	ContextRequestID string `json:"context_request_id,omitempty"`

	// Completion data (populated when loop completes)
	Outcome     string    `json:"outcome,omitempty"`      // success, failed, cancelled
	Result      string    `json:"result,omitempty"`       // LLM response content
	Error       string    `json:"error,omitempty"`        // Error message on failure
	CompletedAt time.Time `json:"completed_at,omitempty"` // When the loop completed
}

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

type PermissionConfig struct {
	View       []string `json:"view"`        // Who can view status, loops, history
	SubmitTask []string `json:"submit_task"` // Who can submit new tasks
	CancelOwn  bool     `json:"cancel_own"`  // Users can cancel their own loops
	CancelAny  []string `json:"cancel_any"`  // Who can cancel any loop
	Approve    []string `json:"approve"`     // Who can approve results
}

type RegisteredCommand struct {
	Name    string
	Config  CommandConfig
	Pattern *regexp.Regexp
	Handler CommandHandler
}

type SignalMessage struct {
	LoopID    string    `json:"loop_id"`
	Type      string    `json:"type"`   // pause, resume, cancel
	Reason    string    `json:"reason"` // optional reason
	Timestamp time.Time `json:"timestamp"`
}

type SignalRequest struct {
	Type   string `json:"type"`   // pause, resume, cancel
	Reason string `json:"reason"` // optional reason
}

type SignalResponse struct {
	LoopID    string `json:"loop_id"`
	Signal    string `json:"signal"`
	Accepted  bool   `json:"accepted"`
	Message   string `json:"message,omitempty"`
	Timestamp string `json:"timestamp"`
}