rex

type BashAction struct {
	Command              string   `json:"command"`
	Session              string   `json:"session,omitempty"`
	Timeout              *float64 `json:"timeout,omitempty"`
	IsInteractiveCommand bool     `json:"is_interactive_command,omitempty"`
	IsInteractiveQuit    bool     `json:"is_interactive_quit,omitempty"`
	Check                string   `json:"check,omitempty"`
	ErrorMsg             string   `json:"error_msg,omitempty"`
	Expect               []string `json:"expect,omitempty"`
	ActionType           string   `json:"action_type"`
}

type BashInterruptAction struct {
	Session    string   `json:"session,omitempty"`
	Timeout    float64  `json:"timeout,omitempty"`
	NRetry     int      `json:"n_retry,omitempty"`
	Expect     []string `json:"expect,omitempty"`
	ActionType string   `json:"action_type"`
}

type BashObservation struct {
	Output        string `json:"output,omitempty"`
	ExitCode      *int   `json:"exit_code,omitempty"`
	FailureReason string `json:"failure_reason,omitempty"`
	ExpectString  string `json:"expect_string,omitempty"`
	SessionType   string `json:"session_type"`
}

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

type CloseBashSessionRequest struct {
	Session     string `json:"session,omitempty"`
	SessionType string `json:"session_type"`
}

type CloseBashSessionResponse struct {
	SessionType string `json:"session_type"`
}

type CloseResponse struct{}

type Command struct {
	Command  interface{}       `json:"command"`
	Timeout  *float64          `json:"timeout,omitempty"`
	Shell    bool              `json:"shell,omitempty"`
	Check    bool              `json:"check,omitempty"`
	ErrorMsg string            `json:"error_msg,omitempty"`
	Env      map[string]string `json:"env,omitempty"`
	Cwd      string            `json:"cwd,omitempty"`
}

type CommandResponse struct {
	Stdout   string `json:"stdout,omitempty"`
	Stderr   string `json:"stderr,omitempty"`
	ExitCode *int   `json:"exit_code,omitempty"`
}

type CreateBashSessionRequest struct {
	StartupSource  []string `json:"startup_source,omitempty"`
	Session        string   `json:"session,omitempty"`
	SessionType    string   `json:"session_type"`
	StartupTimeout float64  `json:"startup_timeout,omitempty"`
}

type CreateBashSessionResponse struct {
	Output      string `json:"output,omitempty"`
	SessionType string `json:"session_type"`
}

type DefaultLogger struct{}

type Deployment interface {
	Start(ctx context.Context) error

	Stop(ctx context.Context) error

	GetRuntime() Runtime
}

type DeploymentConfig struct {
	Type                DeploymentType `json:"type"`
	DockerConfig        *DockerConfig  `json:"docker_config,omitempty"`
	RemoteConfig        *RemoteConfig  `json:"remote_config,omitempty"`
	PythonStandaloneDir string         `json:"python_standalone_dir,omitempty"`
}

type DeploymentType string

type DockerConfig struct {
	Image       string            `json:"image"`
	Volumes     map[string]string `json:"volumes,omitempty"`
	Environment map[string]string `json:"environment,omitempty"`
	Network     string            `json:"network,omitempty"`
}

type IsAliveResponse struct {
	IsAlive bool   `json:"is_alive"`
	Message string `json:"message,omitempty"`
}

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

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

type Logger interface {
	Debug(format string, args ...interface{})
	Info(format string, args ...interface{})
	Warn(format string, args ...interface{})
	Error(format string, args ...interface{})
}

type ReadFileRequest struct {
	Path     string `json:"path"`
	Encoding string `json:"encoding,omitempty"`
	Errors   string `json:"errors,omitempty"`
}

type ReadFileResponse struct {
	Content string `json:"content,omitempty"`
}

type RemoteConfig struct {
	Host     string `json:"host"`
	Port     int    `json:"port"`
	Username string `json:"username"`
	Password string `json:"password,omitempty"`
	KeyFile  string `json:"key_file,omitempty"`
}

type Runtime struct {
	Agent interfaces.Agent

	Trajectories map[string]*Trajectory

	Context map[string]interface{}
	// contains filtered or unexported fields
}

type RuntimeConfig struct {
	Name string `json:"name"`

	Description string `json:"description"`

	TrajectoryPath string `json:"trajectory_path"`
}

type Trajectory struct {
	Runtime *Runtime

	ID string

	Config TrajectoryConfig

	State TrajectoryState

	CurrentStep string

	Context map[string]interface{}

	Results map[string]interface{}

	Error error

	RetryCount int
	// contains filtered or unexported fields
}

type TrajectoryConfig struct {
	Name string `json:"name"`

	Description string `json:"description"`

	Steps []TrajectoryStep `json:"steps"`

	MaxRetries int `json:"max_retries"`

	RetryDelay time.Duration `json:"retry_delay"`
}

type TrajectoryState string

type TrajectoryStep struct {
	ID string `json:"id"`

	Name string `json:"name"`

	Description string `json:"description"`

	Tool string `json:"tool"`

	Params map[string]interface{} `json:"params"`

	NextSteps []string `json:"next_steps"`

	Condition string `json:"condition"`
}

type UploadRequest struct {
	SourcePath string `json:"source_path"`
	TargetPath string `json:"target_path"`
}

type UploadResponse struct{}

type WriteFileRequest struct {
	Content string `json:"content"`
	Path    string `json:"path"`
}

type WriteFileResponse struct{}