flows

Documentation

Index

• func CreateFlow(s *service.Services) gin.HandlerFunc
• func CreateFlowEdge(s *service.Services) gin.HandlerFunc
• func CreateFlowNode(s *service.Services) gin.HandlerFunc
• func CreateWebhook(s *service.Services, baseURL, flowsPath string) gin.HandlerFunc
• func DeactivateWebhook(s *service.Services) gin.HandlerFunc
• func DeleteFlow(s *service.Services) gin.HandlerFunc
• func DeleteFlowEdge(s *service.Services) gin.HandlerFunc
• func DeleteFlowNode(s *service.Services) gin.HandlerFunc
• func GetActiveWebhooks(s *service.Services, baseURL, flowsPath string) gin.HandlerFunc
• func GetAgents(s *service.Services) gin.HandlerFunc
• func GetFlowEdges(s *service.Services) gin.HandlerFunc
• func GetFlowNodes(s *service.Services) gin.HandlerFunc
• func GetFlows(s *service.Services) gin.HandlerFunc
• func GetListeners(s *service.Services) gin.HandlerFunc
• func GetTransitions(s *service.Services) gin.HandlerFunc
• func HandleWebhook(s *service.Services, flowsPath string) gin.HandlerFunc
• func RotateWebhook(s *service.Services, baseURL, flowsPath string) gin.HandlerFunc
• func TurnOff(s *service.Services) gin.HandlerFunc
• func TurnOn(s *service.Services) gin.HandlerFunc
• func UpdateFlow(s *service.Services) gin.HandlerFunc
• func UpdateFlowEdge(s *service.Services) gin.HandlerFunc
• func UpdateFlowNode(s *service.Services) gin.HandlerFunc
• type ActiveWebhookRecord
• type ActiveWebhooksResponse
• type CreateFlowEdgeRequest
• type CreateFlowNodeRequest
• type CreateWebhookRecord
• type CreateWebhookRequest
• type CreateWebhookResponse
• type FlowAgentRecord
• type FlowAgentResponse
• type FlowAgentSingleResponse
• type FlowEdgeRecord
• type FlowEdgeResponse
• type FlowEdgesResponse
• type FlowListenerEventRecord
• type FlowListenerEventSingleResponse
• type FlowListenerEventsResponse
• type FlowNodeRecord
• type FlowNodeResponse
• type FlowNodesResponse
• type FlowRecord
• type FlowResponse
• type FlowTransitionRecord
• type FlowTransitionResponse
• type FlowTransitionSingleResponse
• type FlowsResponse
• type NextStepRecord
• type NoActiveWebhooks
• type OneActiveWebhook

Functions

func CreateFlow

func CreateFlow(s *service.Services) gin.HandlerFunc

func CreateFlowEdge

func CreateFlowEdge(s *service.Services) gin.HandlerFunc

func CreateFlowNode

func CreateFlowNode(s *service.Services) gin.HandlerFunc

func CreateWebhook

func CreateWebhook(s *service.Services, baseURL, flowsPath string) gin.HandlerFunc

func DeactivateWebhook

func DeactivateWebhook(s *service.Services) gin.HandlerFunc

func DeleteFlow

func DeleteFlow(s *service.Services) gin.HandlerFunc

func DeleteFlowEdge

func DeleteFlowEdge(s *service.Services) gin.HandlerFunc

func DeleteFlowNode

func DeleteFlowNode(s *service.Services) gin.HandlerFunc

func GetActiveWebhooks

func GetActiveWebhooks(s *service.Services, baseURL, flowsPath string) gin.HandlerFunc

func GetAgents

func GetAgents(s *service.Services) gin.HandlerFunc

func GetFlowEdges

func GetFlowEdges(s *service.Services) gin.HandlerFunc

func GetFlowNodes

func GetFlowNodes(s *service.Services) gin.HandlerFunc

func GetFlows

func GetFlows(s *service.Services) gin.HandlerFunc

func GetListeners

func GetListeners(s *service.Services) gin.HandlerFunc

func GetTransitions

func GetTransitions(s *service.Services) gin.HandlerFunc

func HandleWebhook

func HandleWebhook(s *service.Services, flowsPath string) gin.HandlerFunc

func RotateWebhook

func RotateWebhook(s *service.Services, baseURL, flowsPath string) gin.HandlerFunc

func TurnOff

func TurnOff(s *service.Services) gin.HandlerFunc

func TurnOn

func TurnOn(s *service.Services) gin.HandlerFunc

func UpdateFlow

func UpdateFlow(s *service.Services) gin.HandlerFunc

func UpdateFlowEdge

func UpdateFlowEdge(s *service.Services) gin.HandlerFunc

func UpdateFlowNode

func UpdateFlowNode(s *service.Services) gin.HandlerFunc

Types

type ActiveWebhookRecord

type ActiveWebhookRecord struct {
	URL         string    `json:"url"`
	Integration string    `json:"integration"`
	CreatedAt   time.Time `json:"createdAt"`
	Active      bool      `json:"active"`
}

type ActiveWebhooksResponse

type ActiveWebhooksResponse struct {
	enum.BaseResponse
	Hooks []ActiveWebhookRecord `json:"hooks"`
}

type CreateFlowEdgeRequest

type CreateFlowEdgeRequest struct {
	FromNodeID string  `json:"fromNodeId"`
	ToNodeID   string  `json:"toNodeId"`
	Condition  *string `json:"condition"`
	Data       *any    `json:"data"`
}

type CreateFlowNodeRequest

type CreateFlowNodeRequest struct {
	Type      string  `json:"type"`
	Event     *string `json:"event"`
	EventData *any    `json:"eventData"`
}

type CreateWebhookRecord

type CreateWebhookRecord struct {
	URL         string `json:"url"`
	Integration string `json:"integration"`
	Secret      string `json:"secret"`
}

type CreateWebhookRequest

type CreateWebhookRequest struct {
	Integration string `json:"integration"`
}

type CreateWebhookResponse

type CreateWebhookResponse struct {
	enum.BaseResponse
	Hook CreateWebhookRecord `json:"hook"`
}

type FlowAgentRecord

type FlowAgentRecord struct {
	Agent       string `json:"action"`
	Name        string `json:"name"`
	Description string `json:"description"`
}

type FlowAgentResponse

type FlowAgentResponse struct {
	enum.BaseResponse
	Agents []FlowAgentRecord `json:"actions"`
}

type FlowAgentSingleResponse

type FlowAgentSingleResponse struct {
	enum.BaseResponse
	Agent FlowAgentRecord `json:"action"`
}

type FlowEdgeRecord

type FlowEdgeRecord struct {
	ID         string     `json:"id"`
	FlowID     string     `json:"flowId"`
	FromNodeID string     `json:"fromNodeId"`
	ToNodeID   string     `json:"toNodeId"`
	Condition  *string    `json:"condition,omitempty"`
	CreatedAt  time.Time  `json:"createdAt"`
	UpdatedAt  *time.Time `json:"updatedAt,omitempty"`
	Data       *any       `json:"data,omitempty"`
}

type FlowEdgeResponse

type FlowEdgeResponse struct {
	enum.BaseResponse
	Edge FlowEdgeRecord `json:"edge"`
}

type FlowEdgesResponse

type FlowEdgesResponse struct {
	enum.BaseResponse
	Edges []FlowEdgeRecord `json:"edges"`
}

type FlowListenerEventRecord

type FlowListenerEventRecord struct {
	System      string `json:"system"`
	Event       string `json:"event"`
	Name        string `json:"name"`
	Description string `json:"description"`
}

type FlowListenerEventSingleResponse

type FlowListenerEventSingleResponse struct {
	enum.BaseResponse
	Event FlowListenerEventRecord `json:"event"`
}

type FlowListenerEventsResponse

type FlowListenerEventsResponse struct {
	enum.BaseResponse
	Events []FlowListenerEventRecord `json:"events"`
}

type FlowNodeRecord

type FlowNodeRecord struct {
	ID        string     `json:"id"`
	FlowID    string     `json:"flowId"`
	Type      string     `json:"type"`
	Event     *string    `json:"event,omitempty"`
	CreatedAt time.Time  `json:"createdAt"`
	UpdatedAt *time.Time `json:"updatedAt,omitempty"`
	EventData *any       `json:"eventData,omitempty"`
}

type FlowNodeResponse

type FlowNodeResponse struct {
	enum.BaseResponse
	Node FlowNodeRecord `json:"node"`
}

type FlowNodesResponse

type FlowNodesResponse struct {
	enum.BaseResponse
	Nodes []FlowNodeRecord `json:"nodes"`
}

type FlowRecord

type FlowRecord struct {
	ID            string     `json:"id"`
	Name          string     `json:"name"`
	Description   string     `json:"description,omitempty"`
	Trigger       string     `json:"triggerOn,omitempty"`
	TriggerNodeID string     `json:"triggerNodeId,omitempty"`
	VisibleUI     *bool      `json:"visible"`
	Status        string     `json:"status"`
	CreatedAt     time.Time  `json:"createdAt"`
	UpdatedAt     *time.Time `json:"updatedAt,omitempty"`
}

type FlowResponse

type FlowResponse struct {
	enum.BaseResponse
	Flow FlowRecord `json:"flow"`
}

type FlowTransitionRecord

type FlowTransitionRecord struct {
	Step               string           `json:"step"`
	Type               string           `json:"type"`
	AvailableNextSteps []NextStepRecord `json:"availableNextSteps"`
}

type FlowTransitionResponse

type FlowTransitionResponse struct {
	enum.BaseResponse
	Transitions []FlowTransitionRecord `json:"transitions"`
}

type FlowTransitionSingleResponse

type FlowTransitionSingleResponse struct {
	enum.BaseResponse
	Transition FlowTransitionRecord `json:"transition"`
}

type FlowsResponse

type FlowsResponse struct {
	enum.BaseResponse
	Flows []FlowRecord `json:"flows"`
}

type NextStepRecord

type NextStepRecord struct {
	Step string `json:"step"`
	Type string `json:"type"`
}

type NoActiveWebhooks

type NoActiveWebhooks struct {
	enum.BaseResponse
	Message string `json:"message"`
}

type OneActiveWebhook

type OneActiveWebhook struct {
	enum.BaseResponse
	Hook ActiveWebhookRecord `json:"hook"`
}