handler

Documentation

Index

• Constants
• func AddHandleTask(rc redis.Conn, contactID flows.ContactID, task *queue.Task) error
• func NewExpirationTask(orgID models.OrgID, contactID flows.ContactID, sessionID models.SessionID, ...) *queue.Task
• func NewTimeoutTask(orgID models.OrgID, contactID flows.ContactID, sessionID models.SessionID, ...) *queue.Task
• type ChannelEvent
• type HandleEventTask
• type MsgEvent
• type StopEvent
• type TimedEvent

Constants

const (
	StopEventType            = "stop_event"
	MsgEventType             = "msg_event"
	NewConversationEventType = "new_conversation"
	ReferralEventType        = "referral"
	ExpirationEventType      = "expiration_event"
	TimeoutEventType         = "timeout_event"
)

Functions

func AddHandleTask

func AddHandleTask(rc redis.Conn, contactID flows.ContactID, task *queue.Task) error

AddHandleTask adds a single task for the passed in contact

func NewExpirationTask

func NewExpirationTask(orgID models.OrgID, contactID flows.ContactID, sessionID models.SessionID, runID models.FlowRunID, time time.Time) *queue.Task

NewExpirationTask creates a new event task for the passed in expiration event

func NewTimeoutTask

func NewTimeoutTask(orgID models.OrgID, contactID flows.ContactID, sessionID models.SessionID, time time.Time) *queue.Task

NewTimeoutTask creates a new event task for the passed in timeout event

Types

type ChannelEvent

type ChannelEvent struct {
	ContactID  flows.ContactID   `json:"contact_id"`
	URNID      models.URNID      `json:"urn_id"`
	OrgID      models.OrgID      `json:"org_id"`
	ChannelID  models.ChannelID  `json:"channel_id"`
	Extra      map[string]string `json:"extra"`
	NewContact bool              `json:"new_contact"`
}

type HandleEventTask

type HandleEventTask struct {
	ContactID flows.ContactID `json:"contact_id"`
}

type MsgEvent

type MsgEvent struct {
	ContactID     flows.ContactID    `json:"contact_id"`
	OrgID         models.OrgID       `json:"org_id"`
	ChannelID     models.ChannelID   `json:"channel_id"`
	MsgID         flows.MsgID        `json:"msg_id"`
	MsgUUID       flows.MsgUUID      `json:"msg_uuid"`
	MsgExternalID string             `json:"msg_external_id"`
	URN           urns.URN           `json:"urn"`
	URNID         models.URNID       `json:"urn_id"`
	Text          string             `json:"text"`
	Attachments   []flows.Attachment `json:"attachments"`
	NewContact    bool               `json:"new_contact"`
}

type StopEvent

type StopEvent struct {
	ContactID flows.ContactID `json:"contact_id"`
	OrgID     models.OrgID    `json:"org_id"`
}

type TimedEvent

type TimedEvent struct {
	ContactID flows.ContactID  `json:"contact_id"`
	OrgID     models.OrgID     `json:"org_id"`
	SessionID models.SessionID `json:"session_id"`
	RunID     models.FlowRunID `json:"run_id,omitempty"`
	Time      time.Time        `json:"time"`
}