manager

type Callback struct {
	URL     string            `json:"url"`
	Events  []string          `json:"events,omitempty"`
	Headers map[string]string `json:"headers,omitempty"`
}

type CloseRequest struct {
	SessionID string `json:"sessionId"`
}

type ContextInspection struct {
	SessionID string      `json:"sessionId"`
	Path      string      `json:"path,omitempty"`
	Found     bool        `json:"found"`
	Value     interface{} `json:"value,omitempty"`
}

type DebugCommandRequest struct {
	SessionID   string      `json:"sessionId"`
	OperationID string      `json:"operationId"`
	Command     string      `json:"command"`
	Breakpoint  *debug.Step `json:"breakpoint,omitempty"`
}

type DebugState = debug.State

type GetLoggingRequest struct {
	SessionID string `json:"sessionId"`
}

type GetOperationRequest struct {
	SessionID   string `json:"sessionId"`
	OperationID string `json:"operationId"`
}

type InspectContextRequest struct {
	SessionID   string `json:"sessionId"`
	OperationID string `json:"operationId,omitempty"`
	Full        bool   `json:"full,omitempty"`
	Path        string `json:"path,omitempty"`
}

type ListOperationsRequest struct {
	SessionID string `json:"sessionId"`
}

type ListOperationsResponse struct {
	SessionID  string       `json:"sessionId"`
	Operations []*Operation `json:"operations"`
}

type ListSessionsResponse struct {
	Sessions []*SessionInfo `json:"sessions"`
}

type ListTasksRequest struct {
	SessionID       string `json:"sessionId"`
	Workflow        string `json:"workflow"`
	Path            string `json:"path,omitempty"`
	ExpandWorkflows bool   `json:"expandWorkflows,omitempty"`
}

type ListTasksResponse struct {
	SessionID string      `json:"sessionId"`
	Workflow  string      `json:"workflow"`
	Tasks     []*TaskInfo `json:"tasks"`
}

type ListWorkflowsRequest struct {
	SessionID string `json:"sessionId"`
}

type ListWorkflowsResponse struct {
	SessionID string            `json:"sessionId"`
	Workflows []*LoadedWorkflow `json:"workflows"`
}

type LoadWorkflowRequest struct {
	SessionID string `json:"sessionId"`
	URL       string `json:"url"`
	Name      string `json:"name,omitempty"`
	Alias     string `json:"alias,omitempty"`
	Replace   bool   `json:"replace,omitempty"`
	Content   string `json:"content,omitempty"`
	Format    string `json:"format,omitempty"`
}

type LoadedWorkflow struct {
	SessionID string   `json:"sessionId"`
	Alias     string   `json:"alias"`
	Name      string   `json:"name"`
	Source    string   `json:"source"`
	Tasks     []string `json:"tasks"`
}

type LoggingState struct {
	SessionID string `json:"sessionId"`
	Enabled   bool   `json:"enabled"`
}

type ManagerFactory func() endly.Manager

type OpenRequest struct {
	Name    string `json:"name,omitempty"`
	Subject string `json:"-"`
}

type Operation struct {
	ID               string                 `json:"id"`
	SessionID        string                 `json:"sessionId"`
	Status           string                 `json:"status"`
	Kind             string                 `json:"kind"`
	Workflow         string                 `json:"workflow"`
	Service          string                 `json:"service,omitempty"`
	Action           string                 `json:"action,omitempty"`
	Tasks            string                 `json:"tasks"`
	TagIDs           string                 `json:"tagIds,omitempty"`
	CreatedAt        time.Time              `json:"createdAt"`
	StartedAt        *time.Time             `json:"startedAt,omitempty"`
	FinishedAt       *time.Time             `json:"finishedAt,omitempty"`
	Result           map[string]interface{} `json:"result,omitempty"`
	Error            string                 `json:"error,omitempty"`
	Events           []*OperationEvent      `json:"events,omitempty"`
	Debug            *DebugState            `json:"debug,omitempty"`
	PassedAssertions int                    `json:"passedAssertions,omitempty"`
	FailedAssertions int                    `json:"failedAssertions,omitempty"`
	DroppedEvents    int64                  `json:"droppedEvents,omitempty"`
	// contains filtered or unexported fields
}

type OperationEvent struct {
	Sequence    int64           `json:"sequence"`
	Type        string          `json:"type"`
	EndlyType   string          `json:"endlyType,omitempty"`
	Timestamp   time.Time       `json:"timestamp"`
	Value       interface{}     `json:"value,omitempty"`
	Messages    []*msg.Message  `json:"messages,omitempty"`
	Activity    *model.Activity `json:"activity,omitempty"`
	ActivityEnd bool            `json:"activityEnd,omitempty"`
}

type Option func(*Service)

type RunActionRequest struct {
	SessionID     string                 `json:"sessionId"`
	Service       string                 `json:"service"`
	Action        string                 `json:"action"`
	Request       map[string]interface{} `json:"request,omitempty"`
	Callbacks     []Callback             `json:"callbacks,omitempty"`
	TimeoutMillis int64                  `json:"timeoutMillis,omitempty"`
}

type RunWorkflowRequest struct {
	SessionID         string                 `json:"sessionId"`
	Workflow          string                 `json:"workflow"`
	Tasks             string                 `json:"tasks,omitempty"`
	TagIDs            string                 `json:"tagIds,omitempty"`
	SelectorMode      string                 `json:"selectorMode,omitempty"`
	Params            map[string]interface{} `json:"params,omitempty"`
	SharedState       *bool                  `json:"sharedState,omitempty"`
	Callbacks         []Callback             `json:"callbacks,omitempty"`
	Debug             bool                   `json:"debug,omitempty"`
	Breakpoints       []debug.Step           `json:"breakpoints,omitempty"`
	Timeout           time.Duration          `json:"-"`
	TimeoutMillis     int64                  `json:"timeoutMillis,omitempty"`
	PublishParameters *bool                  `json:"publishParameters,omitempty"`
}

type Service struct {
	*endly.AbstractService
	// contains filtered or unexported fields
}

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

type SessionInfo struct {
	SessionID string    `json:"sessionId"`
	Name      string    `json:"name,omitempty"`
	Subject   string    `json:"subject,omitempty"`
	CreatedAt time.Time `json:"createdAt"`
}

type SetLoggingRequest struct {
	SessionID string `json:"sessionId"`
	Enabled   bool   `json:"enabled"`
}

type StartOperationRequest struct {
	Kind     string              `json:"kind"`
	Workflow *RunWorkflowRequest `json:"workflow,omitempty"`
	Action   *RunActionRequest   `json:"action,omitempty"`
}

type StopOperationRequest = GetOperationRequest

type TaskActionInfo struct {
	Name    string `json:"name"`
	Service string `json:"service"`
	Action  string `json:"action"`
	TagID   string `json:"tagId,omitempty"`
	Skip    string `json:"skip,omitempty"`
}

type TaskInfo struct {
	Name      string                  `json:"name"`
	Path      string                  `json:"path"`
	Tasks     []*TaskInfo             `json:"tasks,omitempty"`
	Actions   []TaskActionInfo        `json:"actions,omitempty"`
	Instances []*TemplateInstanceInfo `json:"instances,omitempty"`
	Workflows []*WorkflowTaskInfo     `json:"workflows,omitempty"`
}

type TemplateInstanceInfo struct {
	TagID       string           `json:"tagId"`
	Index       string           `json:"index,omitempty"`
	Tag         string           `json:"tag,omitempty"`
	Description string           `json:"description,omitempty"`
	Actions     []TaskActionInfo `json:"actions"`
}

type UnloadWorkflowRequest struct {
	SessionID string `json:"sessionId"`
	Workflow  string `json:"workflow"`
	Force     bool   `json:"force,omitempty"`
}

type ValidationError struct{ Message string }

type WorkflowTaskInfo struct {
	Name   string      `json:"name"`
	Source string      `json:"source"`
	Tasks  []*TaskInfo `json:"tasks"`
}