models

Jun 9, 2019

Changes in this version

+ const TemplateStateEvaluated

+ const TemplateStateLegacy

+ const TemplateStateUnevaluated

+ func MarkBroadcastSent(ctx context.Context, db *sqlx.DB, id BroadcastID) error

type Broadcast

+ func NewBroadcast(orgID OrgID, id BroadcastID, ...) *Broadcast

+ func (b *Broadcast) BroadcastID() BroadcastID

+ func (b *Broadcast) TemplateState() TemplateState

type BroadcastBatch

+ func (b *BroadcastBatch) BroadcastID() BroadcastID

+ func (b *BroadcastBatch) TemplateState() TemplateState

type BroadcastID

+ func (i *BroadcastID) Scan(value interface{}) error

+ func (i *BroadcastID) UnmarshalJSON(b []byte) error

+ func (i BroadcastID) MarshalJSON() ([]byte, error)

+ func (i BroadcastID) Value() (driver.Value, error)

type Msg

+ func (m *Msg) BroadcastID() BroadcastID

+ func (m *Msg) SetBroadcastID(broadcastID BroadcastID)

+ type TemplateState string

Apr 5, 2019

Changes in this version

+ const GoFlowMajorVersion

type Flow

+ func (f *Flow) Version() string

Apr 4, 2019

Changes in this version

type Channel

+ func (c *Channel) Config() map[string]interface{}

type OrgAssets

+ func (a *OrgAssets) Templates() ([]assets.Template, error)

+ type Template struct

+ func (t *Template) MarshalJSON() ([]byte, error)

+ func (t *Template) Name() string

+ func (t *Template) Translations() []assets.TemplateTranslation

+ func (t *Template) UUID() assets.TemplateUUID

+ func (t *Template) UnmarshalJSON(data []byte) error

+ type TemplateTranslation struct

+ func (t *TemplateTranslation) Channel() assets.ChannelReference

+ func (t *TemplateTranslation) Content() string

+ func (t *TemplateTranslation) Language() utils.Language

+ func (t *TemplateTranslation) MarshalJSON() ([]byte, error)

+ func (t *TemplateTranslation) UnmarshalJSON(data []byte) error

+ func (t *TemplateTranslation) VariableCount() int

Apr 3, 2019

Changes in this version

type ChannelEvent

+ func (e *ChannelEvent) ExtraValue(key string) string

Mar 29, 2019

Changes in this version

+ const NilTriggerID

Mar 27, 2019

Changes in this version

+ const CreatedOnKey

+ var CreatedOnFieldID = FieldID(2)

Mar 20, 2019

Changes in this version

+ const NilFlowID

+ var ErrNotFound = errors.New("not found")

type FlowID

+ func (i *FlowID) Scan(value interface{}) error

+ func (i *FlowID) UnmarshalJSON(b []byte) error

+ func (i FlowID) MarshalJSON() ([]byte, error)

+ func (i FlowID) Value() (driver.Value, error)

Mar 11, 2019

Changes in this version

+ const WelcomeMessateEventType

Mar 7, 2019

Changes in this version

+ const ChannelConfigFCMID

+ func ApplyPreWriteEvent(ctx context.Context, tx *sqlx.Tx, rp *redis.Pool, org *OrgAssets, ...) error

+ func RegisterPreWriteHook(eventType string, handler EventHandler)

type Session

+ func (s *Session) ClearTimeoutOn()

Mar 5, 2019

Changes in this version

+ var Org2ChannelUUID = assets.ChannelUUID("a89bc872-3763-4b95-91d9-31d4e56c6651")

Mar 4, 2019

Changes in this version

+ const NilConnectionID

type ChannelID

+ func (i *ChannelID) Scan(value interface{}) error

+ func (i *ChannelID) UnmarshalJSON(b []byte) error

+ func (i ChannelID) MarshalJSON() ([]byte, error)

+ func (i ChannelID) Value() (driver.Value, error)

type ConnectionID

+ func (i *ConnectionID) Scan(value interface{}) error

+ func (i *ConnectionID) UnmarshalJSON(b []byte) error

+ func (i ConnectionID) MarshalJSON() ([]byte, error)

+ func (i ConnectionID) Value() (driver.Value, error)

Mar 1, 2019

Changes in this version

+ const FireResultFired

+ const FireResultSkipped

type ContactID

+ func FindActiveSessionOverlap(ctx context.Context, db *sqlx.DB, contacts []ContactID) ([]ContactID, error)

type EventFire

+ FiredResult EventFireResult

+ type EventFireResult = null.String

Feb 27, 2019

Changes in this version

+ func InsertFlowStarts(ctx context.Context, db Queryer, starts []*FlowStart) error

Feb 21, 2019

Changes in this version

type Trigger

+ func (t *Trigger) Match() *triggers.KeywordMatch

Feb 19, 2019

Changes in this version

+ var ParentTimeoutID = FlowID(10007)

+ var ParentTimeoutUUID = assets.FlowUUID("81c0f323-7e06-4e0c-a960-19c20f17117c")

Feb 13, 2019

Changes in this version

type FlowStart

+ func InsertFlowStart(ctx context.Context, db Queryer, orgID OrgID, flowID FlowID, flowType FlowType, ...) (*FlowStart, error)

+ func (s *FlowStart) ID() StartID

Feb 12, 2019

Changes in this version

+ const NilMsgID

+ func ContactLock(orgID OrgID, contactID flows.ContactID) string

type ContactID

+ func (i *ContactID) Scan(value interface{}) error

+ func (i *ContactID) UnmarshalJSON(b []byte) error

+ func (i ContactID) MarshalJSON() ([]byte, error)

+ func (i ContactID) Value() (driver.Value, error)

type MsgID

+ func (i *MsgID) Scan(value interface{}) error

+ func (i *MsgID) UnmarshalJSON(b []byte) error

+ func (i MsgID) MarshalJSON() ([]byte, error)

+ func (i MsgID) Value() (driver.Value, error)

type StartID

+ func (i *StartID) Scan(value interface{}) error

+ func (i *StartID) UnmarshalJSON(b []byte) error

+ func (i StartID) MarshalJSON() ([]byte, error)

+ func (i StartID) Value() (driver.Value, error)

type TopupID

+ func (i *TopupID) Scan(value interface{}) error

+ func (i *TopupID) UnmarshalJSON(b []byte) error

+ func (i TopupID) MarshalJSON() ([]byte, error)

+ func (i TopupID) Value() (driver.Value, error)

type URNID

+ func (i *URNID) Scan(value interface{}) error

+ func (i *URNID) UnmarshalJSON(b []byte) error

+ func (i URNID) MarshalJSON() ([]byte, error)

+ func (i URNID) Value() (driver.Value, error)

Feb 11, 2019

Changes in this version

type OrgAssets

+ func (a *OrgAssets) AddTestChannel(channel assets.Channel)

Feb 11, 2019

Changes in this version

+ const EventStatusComplete

+ const EventTypeFlow

+ func InsertWebhookEvents(ctx context.Context, db Queryer, events []*WebhookEvent) error

+ type EventStatus string

+ type EventType string

type Org

+ func (o *Org) MaxValueLength() int

+ type WebhookEvent struct

+ func NewWebhookEvent(orgID OrgID, resthookID ResthookID, data string, createdOn time.Time) *WebhookEvent

+ func (e *WebhookEvent) ID() WebhookEventID

+ type WebhookEventID int64

Feb 8, 2019

Changes in this version

+ const NilResthookID

type OrgAssets

+ func (a *OrgAssets) ResthookBySlug(slug string) *Resthook

Feb 6, 2019

Changes in this version

+ var IncomingExtraFlowID = FlowID(10006)

+ var IncomingExtraFlowUUID = assets.FlowUUID("376d3de6-7f0e-408c-80d6-b1919738bc80")

type FlowStart

+ func (s *FlowStart) Extra() json.RawMessage

type FlowStartBatch

+ func (b *FlowStartBatch) Extra() json.RawMessage

Feb 5, 2019

Changes in this version

type Msg

+ func (m *Msg) SetURN(urn urns.URN) error

Feb 5, 2019

Changes in this version

+ var FlowTypeMapping = map[flows.FlowType]FlowType

type FlowRun

+ func (r *FlowRun) MarshalJSON() ([]byte, error)

+ func (r *FlowRun) SetConnectionID(connID *ConnectionID)

+ func (r *FlowRun) SetSessionID(sessionID SessionID)

+ func (r *FlowRun) SetStartID(startID StartID)

+ func (r *FlowRun) UnmarshalJSON(b []byte) error

type Msg

+ func NewIncomingMsg(orgID OrgID, channel *Channel, contactID flows.ContactID, in *flows.MsgIn, ...) *Msg

+ func (m *Msg) SetChannelID(channelID ChannelID)

type Session

+ func (s *Session) IncomingMsgExternalID() string

+ func (s *Session) MarshalJSON() ([]byte, error)

+ func (s *Session) SessionType() FlowType

+ func (s *Session) UnmarshalJSON(b []byte) error

Jan 30, 2019

Changes in this version

+ func InsertWebhookResults(ctx context.Context, db Queryer, results []*WebhookResult) error

+ type ResultID int64

+ type WebhookResult struct

+ func NewWebhookResult(orgID OrgID, contactID flows.ContactID, url string, request string, ...) *WebhookResult

+ func (r *WebhookResult) ID() ResultID

Jan 29, 2019

Changes in this version

+ var SurveyorFlowID = FlowID(10005)

+ var SurveyorFlowUUID = assets.FlowUUID("ed8cf8d4-a42c-4ce1-a7e3-44a2918e3cec")

Jan 26, 2019

Changes in this version

+ const ChannelConfigMaxConcurrentEvents

+ const ConnectionDirectionIn

+ const ConnectionDirectionOut

+ const ConnectionMaxRetries

+ const ConnectionRetryWait

+ const ConnectionStatusBusy

+ const ConnectionStatusCancelled

+ const ConnectionStatusCompleted

+ const ConnectionStatusErrored

+ const ConnectionStatusFailed

+ const ConnectionStatusInProgress

+ const ConnectionStatusNoAnswer

+ const ConnectionStatusPending

+ const ConnectionStatusQueued

+ const ConnectionStatusRinging

+ const ConnectionStatusWired

+ const ConnectionThrottleWait

+ const ConnectionTypeIVR

+ const FlowConfigIVRRetryMinutes

+ const MOCallEventType

+ const MOMissEventType

+ const NewConversationEventType

+ const NilOrgID

+ const ReferralEventType

+ var AgeFieldUUID = FieldUUID("903f51da-2717-47c7-a0d3-f2f32877013d")

+ var AlexandriaID = flows.ContactID(10003)

+ var AlexandriaURN = urns.URN("tel:+250700000004")

+ var AlexandriaURNID = URNID(10003)

+ var AlexandriaUUID = flows.ContactUUID("9709c157-4606-4d41-9df3-9e9c9b4ae2d4")

+ var BobID = flows.ContactID(10001)

+ var BobUUID = flows.ContactUUID("b699a406-7e44-49be-9f01-1a82893e8a10")

+ var CampaignFlowID = FlowID(10005)

+ var CampaignFlowUUID = assets.FlowUUID("3a92a964-3a8d-420b-9206-2cd9d884ac30")

+ var CathyID = flows.ContactID(10000)

+ var CathyUUID = flows.ContactUUID("6393abc0-283d-4c9b-a1b3-641a035c34bf")

+ var DoctorRemindersCampaignID = CampaignID(10000)

+ var DoctorRemindersCampaignUUID = CampaignUUID("72aa12c5-cc11-4bc7-9406-044047845c70")

+ var DoctorsGroupID = GroupID(10000)

+ var DoctorsGroupUUID = assets.GroupUUID("c153e265-f7c9-4539-9dbc-9b358714b638")

+ var FavoritesFlowID = FlowID(10000)

+ var FavoritesFlowUUID = assets.FlowUUID("9de3663f-c5c5-4c92-9f45-ecbc09abcc85")

+ var GenderFieldUUID = FieldUUID("3a5891e4-756e-4dc9-8e12-b7a766168824")

+ var GeorgeID = flows.ContactID(10002)

+ var GeorgeURN = urns.URN("tel:+250700000003")

+ var GeorgeURNID = URNID(10002)

+ var GeorgeUUID = flows.ContactUUID("8d024bcd-f473-4719-a00a-bd0bb1190135")

+ var IVRFlowID = FlowID(10003)

+ var IVRFlowUUID = assets.FlowUUID("2f81d0ea-4d75-4843-9371-3f7465311cce")

+ var NexmoChannelID = ChannelID(10001)

+ var NexmoChannelUUID = assets.ChannelUUID("19012bfd-3ce3-4cae-9bb9-76cf92c73d49")

+ var Org2 = OrgID(2)

+ var Org2ChannelID = ChannelID(20000)

+ var Org2FavoritesFlowID = FlowID(20000)

+ var Org2FavoritesFlowUUID = assets.FlowUUID("f161bd16-3c60-40bd-8c92-228ce815b9cd")

+ var Org2FredID = flows.ContactID(20000)

+ var Org2FredURN = urns.URN("tel:+250700000005")

+ var Org2FredURNID = URNID(20000)

+ var Org2FredUUID = flows.ContactUUID("26d20b72-f7d8-44dc-87f2-aae046dbff95")

+ var Org2SingleMessageFlowID = FlowID(20001)

+ var Org2SingleMessageFlowUUID = assets.FlowUUID("5277916d-6011-41ac-a4a4-f6ac6a4f1dd9")

+ var PickNumberFlowID = FlowID(10001)

+ var PickNumberFlowUUID = assets.FlowUUID("5890fe3a-f204-4661-b74d-025be4ee019c")

+ var RemindersEvent1ID = CampaignEventID(10000)

+ var RemindersEvent2ID = CampaignEventID(10001)

+ var ReportingLabelID = LabelID(10000)

+ var ReportingLabelUUID = assets.LabelUUID("ebc4dedc-91c4-4ed4-9dd6-daa05ea82698")

+ var SingleMessageFlowID = FlowID(10004)

+ var SingleMessageFlowUUID = assets.FlowUUID("a7c11d68-f008-496f-b56d-2d5cf4cf16a5")

+ var TestersGroupID = GroupID(10001)

+ var TestersGroupUUID = assets.GroupUUID("5e9d8fab-5e7e-4f51-b533-261af5dea70d")

+ var TestingLabelID = LabelID(10001)

+ var TestingLabelUUID = assets.LabelUUID("a6338cdc-7938-4437-8b05-2d5d785e3a08")

+ var TwilioChannelID = ChannelID(10000)

+ var TwilioChannelUUID = assets.ChannelUUID("74729f45-7f29-4868-9dc4-90e491e3c7d8")

+ var TwitterChannelID = ChannelID(10002)

+ var TwitterChannelUUID = assets.ChannelUUID("0f661e8b-ea9d-4bd3-9953-d368340acf91")

+ func ActiveChannelConnectionCount(ctx context.Context, db Queryer, id ChannelID) (int, error)

+ func Exec(ctx context.Context, label string, tx Queryer, sql string, args ...interface{}) error

+ func ExitSessions(ctx context.Context, tx Queryer, sessionIDs []SessionID, exitType ExitType, ...) error

+ func ExpireRunsAndSessions(ctx context.Context, db Queryer, runIDs []FlowRunID, sessionIDs []SessionID) error

+ func NormalizeAttachment(attachment flows.Attachment) flows.Attachment

+ func URNForID(ctx context.Context, tx Queryer, org *OrgAssets, urnID URNID) (urns.URN, error)

+ func URNForURN(ctx context.Context, tx Queryer, org *OrgAssets, u urns.URN) (urns.URN, error)

+ func UpdateChannelConnectionStatuses(ctx context.Context, db Queryer, connectionIDs []ConnectionID, ...) error

+ type ChannelConnection struct

+ func InsertIVRConnection(ctx context.Context, db *sqlx.DB, orgID OrgID, channelID ChannelID, ...) (*ChannelConnection, error)

+ func LoadChannelConnectionsToRetry(ctx context.Context, db Queryer, limit int) ([]*ChannelConnection, error)

+ func SelectChannelConnection(ctx context.Context, db Queryer, id ConnectionID) (*ChannelConnection, error)

+ func SelectChannelConnectionByExternalID(ctx context.Context, db Queryer, channelID ChannelID, connType ConnectionType, ...) (*ChannelConnection, error)

+ func (c *ChannelConnection) ChannelID() ChannelID

+ func (c *ChannelConnection) ContactID() flows.ContactID

+ func (c *ChannelConnection) ContactURNID() URNID

+ func (c *ChannelConnection) ExternalID() string

+ func (c *ChannelConnection) ID() ConnectionID

+ func (c *ChannelConnection) MarkErrored(ctx context.Context, db Queryer, now time.Time, wait time.Duration) error

+ func (c *ChannelConnection) MarkFailed(ctx context.Context, db Queryer, now time.Time) error

+ func (c *ChannelConnection) MarkStarted(ctx context.Context, db Queryer, now time.Time) error

+ func (c *ChannelConnection) MarkThrottled(ctx context.Context, db Queryer, now time.Time) error

+ func (c *ChannelConnection) NextAttempt() *time.Time

+ func (c *ChannelConnection) OrgID() OrgID

+ func (c *ChannelConnection) StartID() StartID

+ func (c *ChannelConnection) Status() ConnectionStatus

+ func (c *ChannelConnection) UpdateExternalID(ctx context.Context, db *sqlx.DB, id string) error

+ func (c *ChannelConnection) UpdateStatus(ctx context.Context, db Queryer, status ConnectionStatus, duration int, ...) error

+ type ChannelEvent struct

+ func NewChannelEvent(eventType ChannelEventType, orgID OrgID, channelID ChannelID, ...) *ChannelEvent

+ func (e *ChannelEvent) ChannelID() ChannelID

+ func (e *ChannelEvent) ContactID() flows.ContactID

+ func (e *ChannelEvent) Extra() map[string]string

+ func (e *ChannelEvent) ID() ChannelEventID

+ func (e *ChannelEvent) Insert(ctx context.Context, db *sqlx.DB) error

+ func (e *ChannelEvent) IsNewContact() bool

+ func (e *ChannelEvent) MarshalJSON() ([]byte, error)

+ func (e *ChannelEvent) OrgID() OrgID

+ func (e *ChannelEvent) URNID() URNID

+ func (e *ChannelEvent) UnmarshalJSON(b []byte) error

+ type ChannelEventID int64

+ type ChannelEventType string

+ type ChannelLog struct

+ func InsertChannelLog(ctx context.Context, db *sqlx.DB, desc string, isError bool, method string, ...) (*ChannelLog, error)

+ func (l *ChannelLog) ID() ChannelLogID

+ type ChannelLogID int64

+ type ConnectionDirection string

+ type ConnectionStatus string

+ type ConnectionType string

type Contact

+ func (c *Contact) URNForID(urnID URNID) urns.URN

+ type ContactURN struct

+ Auth string

+ ChannelID ChannelID

+ Display string

+ ID URNID

+ Path string

+ Priority int

+ Scheme string

+ func (u *ContactURN) AsURN(org *OrgAssets) (urns.URN, error)

type Flow

+ func (f *Flow) IntConfigValue(key string, defaultValue int64) int64

+ func (f *Flow) StringConfigValue(key string, defaultValue string) string

type FlowID

+ func FlowIDForStart(ctx context.Context, db Queryer, orgID OrgID, startID StartID) (FlowID, error)

type FlowRun

+ ConnectionID *ConnectionID

type FlowStart

+ func (s *FlowStart) FlowType() FlowType

type Msg

+ func NewIncomingIVR(orgID OrgID, conn *ChannelConnection, in *flows.MsgIn, createdOn time.Time) *Msg

+ func NewOutgoingIVR(orgID OrgID, conn *ChannelConnection, out *flows.MsgOut, createdOn time.Time) (*Msg, error)

type OrgID

+ func OrgIDForChannelUUID(ctx context.Context, db *sqlx.DB, channelUUID assets.ChannelUUID) (OrgID, error)

type Queryer

+ GetContext func(ctx context.Context, value interface{}, query string, args ...interface{}) error

type Session

+ ConnectionID *ConnectionID

+ func (s *Session) ChannelConnection() *ChannelConnection

+ func (s *Session) SetChannelConnection(cc *ChannelConnection)

+ func (s *Session) Sprint() flows.Sprint

+ func (s *Session) Wait() flows.Wait

type Trigger

+ func FindMatchingMOCallTrigger(org *OrgAssets, contact *Contact) *Trigger

+ func FindMatchingMissedCallTrigger(org *OrgAssets) *Trigger

type URNID

+ func GetURNID(urn urns.URN) URNID

Dec 18, 2018

Changes in this version

+ const Bob

+ const BobURN

+ const BobURNID

+ const Cathy

+ const CathyURN

+ const CathyURNID

+ const Channel1

+ const ChannelConfigCallbackDomain

+ const ChannelSessionDirectionIn

+ const ChannelSessionDirectionOut

+ const ChannelSessionStatusBusy

+ const ChannelSessionStatusCancelled

+ const ChannelSessionStatusCompleted

+ const ChannelSessionStatusFailed

+ const ChannelSessionStatusInProgress

+ const ChannelSessionStatusNoAnswer

+ const ChannelSessionStatusPending

+ const ChannelSessionStatusQueued

+ const ChannelSessionStatusRinging

+ const ChannelSessionStatusWired

+ const ChannelSessionTypeIVR

+ const Evan

+ const IVRFlow

+ const MessagingFlow

+ const Org1

+ const SurveyorFlow

+ func GetURNInt(urn urns.URN, key string) int

type Channel

+ func (c *Channel) ConfigValue(key string, def string) string

type ChannelID

+ func GetURNChannelID(org *OrgAssets, urn urns.URN) *ChannelID

+ type ChannelSession struct

+ func CreateIVRSession(ctx context.Context, db *sqlx.DB, orgID OrgID, channelID ChannelID, ...) (*ChannelSession, error)

+ func (s *ChannelSession) ContactID() flows.ContactID

+ func (s *ChannelSession) ExternalID() string

+ func (s *ChannelSession) ID() ChannelSessionID

+ func (s *ChannelSession) OrgID() OrgID

+ func (s *ChannelSession) Status() ChannelSessionStatus

+ func (s *ChannelSession) UpdateExternalID(ctx context.Context, db *sqlx.DB, id string) error

+ func (s *ChannelSession) UpdateStatus(ctx context.Context, db *sqlx.DB, status ChannelSessionStatus) error

+ type ChannelSessionDirection string

+ type ChannelSessionID int64

+ type ChannelSessionStatus string

+ type ChannelSessionType string

type Flow

+ func (f *Flow) FlowType() FlowType

+ type FlowType string

Dec 6, 2018

Changes in this version

type Msg

+ func (m *Msg) SetTimeout(id SessionID, start time.Time, timeout time.Duration)

type Session

+ WaitStartedOn *time.Time

+ func (s *Session) OutputMD5() string

+ func (s *Session) Timeout() *time.Duration

Nov 6, 2018

Changes in this version

+ const NilFlowRunID

+ func RunExpiration(ctx context.Context, db *sqlx.DB, runID FlowRunID) (time.Time, error)

Oct 31, 2018

Changes in this version

+ const NilBroadcastID

+ func ContactIDsForGroupIDs(ctx context.Context, tx Queryer, groupIDs []GroupID) ([]flows.ContactID, error)

+ type Broadcast struct

+ func NewBroadcastFromEvent(ctx context.Context, tx Queryer, org *OrgAssets, ...) (*Broadcast, error)

+ func (b *Broadcast) ContactIDs() []flows.ContactID

+ func (b *Broadcast) CreateBatch(contactIDs []flows.ContactID) *BroadcastBatch

+ func (b *Broadcast) GroupIDs() []GroupID

+ func (b *Broadcast) MarshalJSON() ([]byte, error)

+ func (b *Broadcast) OrgID() OrgID

+ func (b *Broadcast) Translations() map[utils.Language]*BroadcastTranslation

+ func (b *Broadcast) URNs() []urns.URN

+ func (b *Broadcast) UnmarshalJSON(data []byte) error

+ type BroadcastBatch struct

+ func (b *BroadcastBatch) BaseLanguage() utils.Language

+ func (b *BroadcastBatch) ContactIDs() []flows.ContactID

+ func (b *BroadcastBatch) IsLast() bool

+ func (b *BroadcastBatch) MarshalJSON() ([]byte, error)

+ func (b *BroadcastBatch) OrgID() OrgID

+ func (b *BroadcastBatch) SetIsLast(last bool)

+ func (b *BroadcastBatch) SetURNs(urns map[flows.ContactID]urns.URN)

+ func (b *BroadcastBatch) Translations() map[utils.Language]*BroadcastTranslation

+ func (b *BroadcastBatch) URNs() map[flows.ContactID]urns.URN

+ func (b *BroadcastBatch) UnmarshalJSON(data []byte) error

+ type BroadcastID int64

+ type BroadcastTranslation struct

+ Attachments []flows.Attachment

+ QuickReplies []string

+ Text string

type Msg

+ func CreateBroadcastMessages(ctx context.Context, db *sqlx.DB, org *OrgAssets, sa flows.SessionAssets, ...) ([]*Msg, error)

Oct 29, 2018

Changes in this version

+ const NilContactID

+ func CalculateDynamicGroups(ctx context.Context, tx Queryer, org *OrgAssets, contact *flows.Contact) error

+ func ContactIDsFromReferences(ctx context.Context, tx Queryer, org *OrgAssets, ...) ([]flows.ContactID, error)

+ func ContactIDsFromURNs(ctx context.Context, db *sqlx.DB, org *OrgAssets, assets flows.SessionAssets, ...) ([]flows.ContactID, error)

+ func CreateContact(ctx context.Context, db *sqlx.DB, org *OrgAssets, assets flows.SessionAssets, ...) (flows.ContactID, error)

+ func DeleteUnfiredContactEvents(ctx context.Context, tx Queryer, contactID flows.ContactID) error

type FlowStart

+ func (s *FlowStart) CreateContact() bool

+ func (s *FlowStart) Parent() json.RawMessage

+ func (s *FlowStart) URNs() []urns.URN

type FlowStartBatch

+ func (b *FlowStartBatch) Parent() json.RawMessage

Oct 25, 2018

Changes in this version

+ func AddMsgLabels(ctx context.Context, tx *sqlx.Tx, adds []*MsgLabelAdd) error

type Msg

+ func (m *Msg) SetResponseTo(id null.Int, externalID string)

+ type MsgLabelAdd struct

+ LabelID LabelID

+ MsgID flows.MsgID

type OrgAssets

+ func (a *OrgAssets) LabelByUUID(uuid assets.LabelUUID) *Label

Oct 25, 2018

Changes in this version

+ func NewSessionAssets(org *OrgAssets) (flows.SessionAssets, error)

Oct 24, 2018

Changes in this version

type CampaignEvent

+ func (e *CampaignEvent) QualifiesByField(contact *flows.Contact) bool

+ func (e *CampaignEvent) QualifiesByGroup(contact *flows.Contact) bool

Oct 24, 2018

Changes in this version

type Flow

+ func (f *Flow) SetDefinition(definition json.RawMessage)

+ func (f *Flow) SetLegacyDefinition(legacyDefinition json.RawMessage) error

type Org

+ func (o *Org) DefaultCountry() utils.Country

Oct 23, 2018

Changes in this version

+ func UpdateContactModifiedOn(ctx context.Context, tx Queryer, contactIDs []flows.ContactID) error

+ func UpdateContactURNs(ctx context.Context, tx Queryer, org *OrgAssets, changes []*ContactURNsChanged) error

type Contact

+ func (c *Contact) UpdatePreferredURN(ctx context.Context, tx Queryer, org *OrgAssets, urnID URNID, channel *Channel) error

+ type ContactURNsChanged struct

+ ContactID flows.ContactID

+ OrgID OrgID

+ URNs []urns.URN

type Queryer

+ NamedExecContext func(ctx context.Context, query string, arg interface{}) (sql.Result, error)

Oct 21, 2018

Changes in this version

type Org

+ func (o *Org) ConfigValue(key string, def string) string

type OrgAssets

+ func (a *OrgAssets) Org() *Org

Oct 18, 2018

Changes in this version

+ const StartModeInterrupt

+ const StartModePassive

+ const StartModeSkip

type CampaignEvent

+ func (e *CampaignEvent) StartMode() StartMode

+ type StartMode string

Oct 16, 2018

Changes in this version

+ const CallTriggerType

+ const CatchallTriggerType

+ const KeywordTriggerType

+ const MatchFirst

+ const MatchOnly

+ const MissedCallTriggerType

+ const NewConversationTriggerType

+ const ReferralTriggerType

+ const SessionStatusExpired

+ var NilChannelID = ChannelID(0)

+ var NilURNID = URNID(0)

+ func AddContactURNs(ctx context.Context, tx *sqlx.Tx, adds []*ContactURNAdd) error

+ func AddContactsToGroups(ctx context.Context, tx *sqlx.Tx, adds []*GroupAdd) error

+ func AddEventFires(ctx context.Context, tx *sqlx.Tx, adds []*FireAdd) error

+ func DeleteUnfiredEventFires(ctx context.Context, tx *sqlx.Tx, removes []*FireDelete) error

+ func FlushCache()

+ func GetSessionAssets(org *OrgAssets) (flows.SessionAssets, error)

+ func InsertMessages(ctx context.Context, tx Queryer, msgs []*Msg) error

+ func RegisterEventHook(eventType string, handler EventHandler)

+ func RemoveContactsFromGroups(ctx context.Context, tx *sqlx.Tx, removals []*GroupRemove) error

+ func StopContact(ctx context.Context, tx *sqlx.Tx, orgID OrgID, contactID flows.ContactID) error

+ func UnsubscribeResthooks(ctx context.Context, tx *sqlx.Tx, unsubs []*ResthookUnsubscribe) error

+ func UpdateMessage(ctx context.Context, tx Queryer, msgID flows.MsgID, status MsgStatus, ...) error

type CampaignEvent

+ func (e *CampaignEvent) ScheduleForContact(tz *time.Location, now time.Time, contact *flows.Contact) (*time.Time, error)

type Channel

+ func (c *Channel) ChannelReference() *assets.ChannelReference

+ type Contact struct

+ func (c *Contact) CreatedOn() time.Time

+ func (c *Contact) Fields() map[string]*flows.Value

+ func (c *Contact) FlowContact(org *OrgAssets, session flows.SessionAssets) (*flows.Contact, error)

+ func (c *Contact) Groups() []assets.Group

+ func (c *Contact) ID() flows.ContactID

+ func (c *Contact) IsBlocked() bool

+ func (c *Contact) IsStopped() bool

+ func (c *Contact) Language() utils.Language

+ func (c *Contact) ModifiedOn() time.Time

+ func (c *Contact) Name() string

+ func (c *Contact) URNs() []urns.URN

+ func (c *Contact) UUID() flows.ContactUUID

+ func (c *Contact) Unstop(ctx context.Context, db *sqlx.DB) error

+ func (c *Contact) UpdatePreferredURNAndChannel(ctx context.Context, db *sqlx.DB, urnID URNID, channel *Channel) error

+ type ContactURNAdd struct

+ Auth *string

+ ContactID flows.ContactID

+ Display *string

+ Identity string

+ OrgID OrgID

+ Path string

+ Priority int

+ Scheme string

+ type FireAdd struct

+ ContactID flows.ContactID

+ EventID CampaignEventID

+ Scheduled time.Time

+ type FireDelete struct

+ ContactID flows.ContactID

+ EventID CampaignEventID

type Flow

+ func (f *Flow) FlowReference() *assets.FlowReference

+ func (f *Flow) IgnoreTriggers() bool

type FlowRun

+ ParentUUID *flows.RunUUID

+ type FlowRunID int64

+ type GroupAdd struct

+ ContactID flows.ContactID

+ GroupID GroupID

+ type GroupRemove struct

+ ContactID flows.ContactID

+ GroupID GroupID

+ type MatchType string

type Msg

+ func (m *Msg) MarshalJSON() ([]byte, error)

+ func (m *Msg) SetReplyTo(id null.Int, externalID string)

+ func (m *Msg) SetTopup(topupID TopupID)

+ func (m *Msg) TopupID() TopupID

type Org

+ func (o *Org) AllowedLanguages() []utils.Language

+ func (o *Org) DefaultLanguage() utils.Language

+ func (o *Org) Equal(env utils.Environment) bool

+ func (o *Org) NumberFormat() *utils.NumberFormat

type OrgAssets

+ func (a *OrgAssets) SetFlow(flowID FlowID, flow flows.Flow) (*Flow, error)

+ func (a *OrgAssets) Triggers() []*Trigger

+ type Queryer interface

+ ExecContext func(ctx context.Context, query string, args ...interface{}) (sql.Result, error)

+ QueryxContext func(ctx context.Context, query string, args ...interface{}) (*sqlx.Rows, error)

+ Rebind func(query string) string

+ type ResthookUnsubscribe struct

+ OrgID OrgID

+ Slug string

+ URL string

type Session

+ CurrentFlowID *FlowID

+ EndedOn *time.Time

+ IncomingExternalID string

+ IncomingMsgID null.Int

+ TimeoutOn *time.Time

+ func ActiveSessionForContact(ctx context.Context, db *sqlx.DB, org *OrgAssets, contact *flows.Contact) (*Session, error)

+ func (s *Session) FlowSession(sa flows.SessionAssets, env utils.Environment, client *utils.HTTPClient) (flows.Session, error)

+ func (s *Session) SetIncomingMsg(id flows.MsgID, externalID string)

+ func (s *Session) WriteUpdatedSession(ctx context.Context, tx *sqlx.Tx, rp *redis.Pool, org *OrgAssets, ...) error

+ type Trigger struct

+ func FindMatchingMsgTrigger(org *OrgAssets, contact *flows.Contact, text string) *Trigger

+ func FindMatchingNewConversationTrigger(org *OrgAssets, channel *Channel) *Trigger

+ func FindMatchingReferralTrigger(org *OrgAssets, channel *Channel, referrerID string) *Trigger

+ func (t *Trigger) ChannelID() ChannelID

+ func (t *Trigger) FlowID() FlowID

+ func (t *Trigger) GroupIDs() []GroupID

+ func (t *Trigger) ID() TriggerID

+ func (t *Trigger) Keyword() string

+ func (t *Trigger) KeywordMatchType() triggers.KeywordMatchType

+ func (t *Trigger) MatchType() MatchType

+ func (t *Trigger) ReferrerID() string

+ func (t *Trigger) TriggerType() TriggerType

+ type TriggerID int

+ type TriggerType string

+ type URNID int

Oct 2, 2018

Changes in this version

+ func MarkStartStarted(ctx context.Context, db *sqlx.DB, startID StartID, contactCount int) error

Oct 2, 2018

Changes in this version

+ var NilStartID = StartID

+ func DeleteEventFires(ctx context.Context, db *sqlx.DB, fires []*EventFire) error

+ func FindActiveRunOverlap(ctx context.Context, db *sqlx.DB, contacts []flows.ContactID) ([]flows.ContactID, error)

+ func FindFlowStartedOverlap(ctx context.Context, db *sqlx.DB, flowID FlowID, contacts []flows.ContactID) ([]flows.ContactID, error)

+ func InterruptContactRuns(ctx context.Context, tx *sqlx.Tx, contactIDs []flows.ContactID) error

+ func MarkStartComplete(ctx context.Context, db *sqlx.DB, startID StartID) error

type Flow

+ func (f *Flow) IsArchived() bool

+ type FlowStart struct

+ func NewFlowStart(startID StartID, orgID OrgID, flowID FlowID, groupIDs []GroupID, ...) *FlowStart

+ func (s *FlowStart) ContactIDs() []flows.ContactID

+ func (s *FlowStart) CreateBatch(contactIDs []flows.ContactID) *FlowStartBatch

+ func (s *FlowStart) FlowID() FlowID

+ func (s *FlowStart) GroupIDs() []GroupID

+ func (s *FlowStart) IncludeActive() bool

+ func (s *FlowStart) MarshalJSON() ([]byte, error)

+ func (s *FlowStart) OrgID() OrgID

+ func (s *FlowStart) RestartParticipants() bool

+ func (s *FlowStart) StartID() StartID

+ func (s *FlowStart) UnmarshalJSON(data []byte) error

+ type FlowStartBatch struct

+ func (b *FlowStartBatch) ContactIDs() []flows.ContactID

+ func (b *FlowStartBatch) FlowID() FlowID

+ func (b *FlowStartBatch) IncludeActive() bool

+ func (b *FlowStartBatch) IsLast() bool

+ func (b *FlowStartBatch) MarshalJSON() ([]byte, error)

+ func (b *FlowStartBatch) OrgID() OrgID

+ func (b *FlowStartBatch) RestartParticipants() bool

+ func (b *FlowStartBatch) SetIsLast(last bool)

+ func (b *FlowStartBatch) StartID() StartID

+ func (b *FlowStartBatch) UnmarshalJSON(data []byte) error

type OrgAssets

+ func (a *OrgAssets) CampaignEventByID(eventID CampaignEventID) *CampaignEvent

+ func (a *OrgAssets) FlowByID(flowID FlowID) (assets.Flow, error)

+ type StartID struct

+ func NewStartID(id int) StartID

Sep 27, 2018

Changes in this version

+ func BulkSQL(ctx context.Context, label string, tx *sqlx.Tx, sql string, vs []interface{}) error

type Org

+ func (o *Org) MarshalJSON() ([]byte, error)

Sep 26, 2018

Changes in this version

+ func MarkEventsFired(ctx context.Context, tx *sqlx.Tx, fires []*EventFire, fired time.Time) error

+ type EventCommitHook interface

+ Apply func(context.Context, *sqlx.Tx, *redis.Pool, *OrgAssets, map[*Session][]interface{}) error

+ type EventFire struct

+ ContactID flows.ContactID

+ EventID CampaignEventID

+ FireID FireID

+ Fired *time.Time

+ Scheduled time.Time

+ func LoadEventFires(ctx context.Context, db *sqlx.DB, ids []int64) ([]*EventFire, error)

+ type FireID int

+ type SessionCommitHook func(context.Context, *sqlx.Tx, *redis.Pool, *OrgAssets, []*Session) error

Sep 26, 2018

Changes in this version

+ const InsertMsgSQL

+ const NilDeliveryHour

+ const OffsetDay

+ const OffsetHour

+ const OffsetMinute

+ const OffsetWeek

+ func ApplyPostEventHooks(ctx context.Context, tx *sqlx.Tx, rp *redis.Pool, orgID OrgID, ...) error

+ func ApplyPreEventHooks(ctx context.Context, tx *sqlx.Tx, rp *redis.Pool, orgID OrgID, ...) error

+ func BulkInsert(ctx context.Context, tx *sqlx.Tx, sql string, vs []interface{}) error

+ func RegisterEventHandler(eventType string, handler EventHandler)

+ type Campaign struct

+ func (c *Campaign) Events() []*CampaignEvent

+ func (c *Campaign) GroupID() GroupID

+ func (c *Campaign) GroupUUID() assets.GroupUUID

+ func (c *Campaign) ID() CampaignID

+ func (c *Campaign) Name() string

+ func (c *Campaign) UUID() CampaignUUID

+ type CampaignEvent struct

+ func (e *CampaignEvent) Campaign() *Campaign

+ func (e *CampaignEvent) DeliveryHour() int

+ func (e *CampaignEvent) ID() CampaignEventID

+ func (e *CampaignEvent) Offset() int

+ func (e *CampaignEvent) RelativeToID() FieldID

+ func (e *CampaignEvent) RelativeToKey() string

+ func (e *CampaignEvent) ScheduleForTime(tz *time.Location, now time.Time, start time.Time) (*time.Time, error)

+ func (e *CampaignEvent) UUID() CampaignEventUUID

+ func (e *CampaignEvent) Unit() OffsetUnit

+ func (e *CampaignEvent) UnmarshalJSON(data []byte) error

+ type CampaignEventID int

+ type CampaignEventUUID utils.UUID

+ type CampaignID int

+ type CampaignUUID utils.UUID

+ type CommitHook interface

+ Apply func(context.Context, *sqlx.Tx, *redis.Pool, OrgID, map[*Session][]interface{}) error

+ type EventHandler func(context.Context, *sqlx.Tx, *redis.Pool, *Session, flows.Event) error

type Field

+ func (f *Field) ID() FieldID

+ type FieldID int

+ type FieldValue struct

+ Datetime *types.XDateTime

+ District flows.LocationPath

+ Number *types.XNumber

+ State flows.LocationPath

+ Text types.XText

+ Ward flows.LocationPath

type Msg

+ func NewOutgoingMsg(ctx context.Context, tx *sqlx.Tx, rp *redis.Pool, orgID OrgID, ...) (*Msg, error)

+ type OffsetUnit string

type OrgAssets

+ func (a *OrgAssets) CampaignByGroupID(groupID GroupID) []*Campaign

+ func (a *OrgAssets) CampaignEventsByFieldID(fieldID FieldID) []*CampaignEvent

+ func (a *OrgAssets) Campaigns() []*Campaign

+ func (a *OrgAssets) FieldByKey(key string) *Field

type Session

+ func NewSession(org *OrgAssets, s flows.Session) (*Session, error)

+ func (s *Session) AddPostCommitEvent(hook CommitHook, event interface{})

+ func (s *Session) AddPreCommitEvent(hook CommitHook, event interface{})

+ func (s *Session) Contact() *flows.Contact

+ func (s *Session) ContactUUID() flows.ContactUUID

+ func (s *Session) Org() *OrgAssets

+ func (s *Session) Runs() []*FlowRun

type TopupID

+ func DecrementOrgCredits(ctx context.Context, db sqlx.Queryer, rc redis.Conn, orgID OrgID, amount int) (TopupID, error)

Sep 21, 2018

Changes in this version

+ func AssertContactMessagesPresent(t *testing.T, db *sqlx.DB, contactIDs []flows.ContactID, extraWhere string)

+ func AssertContactRunsPresent(t *testing.T, db *sqlx.DB, contactIDs []flows.ContactID, flowID FlowID, ...)

+ func AssertContactSessionsPresent(t *testing.T, db *sqlx.DB, contactIDs []flows.ContactID, extraWhere string)

Sep 20, 2018

Changes in this version

+ var NilTopupID = TopupID(null.NewInt(0, false))

type Session

+ func WriteSessions(ctx context.Context, tx *sqlx.Tx, track *Track, ss []flows.Session) ([]*Session, error)

+ func (s *Session) Outbox() []*Msg

+ type Topup struct

+ Expiration time.Time

+ ID TopupID

+ Remaining int

+ type TopupID null.Int

Sep 14, 2018

Changes in this version

+ const ChannelTypeAndroid

+ const DirectionIn

+ const DirectionOut

+ const MsgStatusErrored

+ const MsgStatusFailed

+ const MsgStatusHandled

+ const MsgStatusInitializing

+ const MsgStatusPending

+ const MsgStatusQueued

+ const MsgStatusResent

+ const MsgStatusSent

+ const MsgStatusWired

+ const SessionStatusActive

+ const SessionStatusCompleted

+ const SessionStatusErrored

+ const SessionStatusWaiting

+ const TypeFlow

+ const TypeIVR

+ const TypeInbox

+ const TypeUSSD

+ const VisibilityArchived

+ const VisibilityDeleted

+ const VisibilityVisible

+ func LoadContacts(ctx context.Context, db *sqlx.DB, session flows.SessionAssets, org *OrgAssets, ...) ([]*flows.Contact, error)

+ func MarkMessagesPending(ctx context.Context, db *sqlx.DB, msgs []*Msg) error

+ type Channel struct

+ func (c *Channel) Address() string

+ func (c *Channel) Country() string

+ func (c *Channel) ID() ChannelID

+ func (c *Channel) MatchPrefixes() []string

+ func (c *Channel) Name() string

+ func (c *Channel) Parent() *assets.ChannelReference

+ func (c *Channel) Roles() []assets.ChannelRole

+ func (c *Channel) Schemes() []string

+ func (c *Channel) TPS() int

+ func (c *Channel) Type() ChannelType

+ func (c *Channel) UUID() assets.ChannelUUID

+ type ChannelType string

+ type Field struct

+ func (f *Field) Key() string

+ func (f *Field) Name() string

+ func (f *Field) Type() assets.FieldType

+ func (f *Field) UUID() FieldUUID

+ type FieldUUID utils.UUID

+ type Flow struct

+ func (f *Flow) Definition() json.RawMessage

+ func (f *Flow) ID() FlowID

+ func (f *Flow) Name() string

+ func (f *Flow) UUID() assets.FlowUUID

type FlowRun

+ func WriteRun(ctx context.Context, tx *sqlx.Tx, track *Track, session *Session, ...) (*FlowRun, error)

+ type Group struct

+ func (g *Group) ID() GroupID

+ func (g *Group) Name() string

+ func (g *Group) Query() string

+ func (g *Group) UUID() assets.GroupUUID

+ type GroupID int

+ type Label struct

+ func (l *Label) ID() LabelID

+ func (l *Label) Name() string

+ func (l *Label) UUID() assets.LabelUUID

+ type LabelID int

+ type Location struct

+ Aliases_ []string

+ Children_ []*Location

+ Name_ string

+ func (l *Location) Aliases() []string

+ func (l *Location) Children() []*Location

+ func (l *Location) ID() int

+ func (l *Location) Level() int

+ func (l *Location) Name() string

+ func (l *Location) OSMID() string

type Msg

+ URNAuth string

+ func (m *Msg) Channel() *Channel

+ type Org struct

+ func (o *Org) DateFormat() utils.DateFormat

+ func (o *Org) Extension(name string) json.RawMessage

+ func (o *Org) ID() OrgID

+ func (o *Org) Languages() utils.LanguageList

+ func (o *Org) Now() time.Time

+ func (o *Org) RedactionPolicy() utils.RedactionPolicy

+ func (o *Org) TimeFormat() utils.TimeFormat

+ func (o *Org) Timezone() *time.Location

type OrgAssets

+ func GetOrgAssets(ctx context.Context, db *sqlx.DB, orgID OrgID) (*OrgAssets, error)

+ func (a *OrgAssets) ChannelByID(channelID ChannelID) *Channel

+ func (a *OrgAssets) ChannelByUUID(channelUUID assets.ChannelUUID) *Channel

+ func (a *OrgAssets) Channels() ([]assets.Channel, error)

+ func (a *OrgAssets) Env() utils.Environment

+ func (a *OrgAssets) FieldByUUID(fieldUUID FieldUUID) *Field

+ func (a *OrgAssets) Fields() ([]assets.Field, error)

+ func (a *OrgAssets) Flow(flowUUID assets.FlowUUID) (assets.Flow, error)

+ func (a *OrgAssets) GroupByID(groupID GroupID) *Group

+ func (a *OrgAssets) GroupByUUID(groupUUID assets.GroupUUID) *Group

+ func (a *OrgAssets) Groups() ([]assets.Group, error)

+ func (a *OrgAssets) Labels() ([]assets.Label, error)

+ func (a *OrgAssets) Locations() ([]assets.LocationHierarchy, error)

+ func (a *OrgAssets) OrgID() OrgID

+ func (a *OrgAssets) Resthooks() ([]assets.Resthook, error)

+ type Resthook struct

+ func (r *Resthook) ID() ResthookID

+ func (r *Resthook) Slug() string

+ func (r *Resthook) Subscribers() []string

+ type ResthookID int64

type Session

+ func WriteSession(ctx context.Context, tx *sqlx.Tx, track *Track, s flows.Session) (*Session, error)

+ type Track struct

+ func NewTrack(ctx context.Context, db *sqlx.DB, rp *redis.Pool, org *OrgAssets) *Track

+ func (t *Track) Org() *OrgAssets

Sep 7, 2018

Changes in this version

+ func MarkMessagesQueued(ctx context.Context, db *sqlx.DB, msgs []*Msg) error

Sep 7, 2018

Changes in this version

+ const StatusPending

+ const StatusQueued

+ var ExitCompleted = null.NewString("C", true)

+ var ExitExpired = null.NewString("E", true)

+ var ExitInterrupted = null.NewString("I", true)

+ func ApplyEvent(ctx context.Context, tx *sqlx.Tx, org *OrgAssets, session *Session, ...) error

+ func ApplyMsgCreatedEvent(ctx context.Context, tx *sqlx.Tx, org *OrgAssets, session *Session, ...) error

+ func LoadContact(o *OrgAssets, id ContactID) (*flows.Contact, error)

+ func MarkCampaignEventFired(ctx context.Context, db *sqlx.DB, fireID int, fired time.Time) error

+ func MarkMessageQueued(ctx context.Context, db *sqlx.DB, m *Msg) error

+ type ChannelID int

+ type ConnectionID null.Int

+ type ContactID int

+ type ContactURNID int

+ type ExitType null.String

+ type FlowDefinition struct

+ Definition string

+ ID FlowID

+ type FlowID int64

+ type FlowRun struct

+ ContactID int

+ CreatedOn time.Time

+ CurrentNodeUUID flows.NodeUUID

+ Events string

+ ExitType null.String

+ ExitedOn *time.Time

+ ExpiresOn *time.Time

+ FlowID FlowID

+ ID FlowID

+ IsActive bool

+ ModifiedOn time.Time

+ OrgID OrgID

+ ParentID null.Int

+ Path string

+ Responded bool

+ Results string

+ SessionID SessionID

+ StartID null.Int

+ TimeoutOn *time.Time

+ UUID flows.RunUUID

+ func CreateRun(ctx context.Context, tx *sqlx.Tx, org *OrgAssets, session *Session, ...) (*FlowRun, error)

+ type Msg struct

+ Attachments []string

+ ChannelID ChannelID

+ ChannelUUID flows.ChannelUUID

+ ConnectionID ConnectionID

+ ContactID ContactID

+ ContactURNID ContactURNID

+ CreatedOn time.Time

+ Direction MsgDirection

+ ErrorCount int

+ ExternalID null.String

+ HighPriority bool

+ ID MsgID

+ Metadata null.String

+ ModifiedOn time.Time

+ MsgCount int

+ MsgType MsgType

+ NextAttempt time.Time

+ OrgID OrgID

+ QueuedOn time.Time

+ SentOn time.Time

+ Status MsgStatus

+ Text string

+ TopUpID TopUpID

+ URN urns.URN

+ UUID flows.MsgUUID

+ Visibility MsgVisibility

+ func CreateOutgoingMsg(ctx context.Context, tx *sqlx.Tx, org *OrgAssets, contactID ContactID, ...) (*Msg, error)

+ type MsgDirection string

+ type MsgID int64

+ type MsgStatus string

+ type MsgType string

+ type MsgVisibility string

+ type OrgAssets struct

+ func NewOrgAssets(ctx context.Context, db *sqlx.DB, orgID OrgID) *OrgAssets

+ func (o *OrgAssets) GetActiveTopup() (TopUpID, error)

+ func (o *OrgAssets) GetChannel(uuid flows.ChannelUUID) (flows.Channel, error)

+ func (o *OrgAssets) GetChannelID(uuid flows.ChannelUUID) (ChannelID, error)

+ func (o *OrgAssets) GetChannelSet() (*flows.ChannelSet, error)

+ func (o *OrgAssets) GetField(key string) (*flows.Field, error)

+ func (o *OrgAssets) GetFieldSet() (*flows.FieldSet, error)

+ func (o *OrgAssets) GetFlow(uuid flows.FlowUUID) (flows.Flow, error)

+ func (o *OrgAssets) GetFlowID(uuid flows.FlowUUID) (FlowID, error)

+ func (o *OrgAssets) GetGroup(uuid flows.GroupUUID) (*flows.Group, error)

+ func (o *OrgAssets) GetGroupSet() (*flows.GroupSet, error)

+ func (o *OrgAssets) GetLabel(uuid flows.LabelUUID) (*flows.Label, error)

+ func (o *OrgAssets) GetLabelSet() (*flows.LabelSet, error)

+ func (o *OrgAssets) GetLocationHierarchySet() (*flows.LocationHierarchySet, error)

+ func (o *OrgAssets) GetOrgID() OrgID

+ func (o *OrgAssets) GetResthookSet() (*flows.ResthookSet, error)

+ func (o *OrgAssets) HasLocations() bool

+ type OrgID int

+ type Session struct

+ ContactID ContactID

+ CreatedOn time.Time

+ ID SessionID

+ OrgID OrgID

+ Output string

+ Responded bool

+ Status SessionStatus

+ func CreateSession(ctx context.Context, tx *sqlx.Tx, org *OrgAssets, s flows.Session) (*Session, error)

+ func (s *Session) AddFlowIDMapping(uuid flows.FlowUUID, id FlowID)

+ func (s *Session) AddOutboxMsg(m *Msg)

+ func (s *Session) GetFlowID(uuid flows.FlowUUID) (FlowID, bool)

+ func (s *Session) GetOutbox() []*Msg

+ type SessionID float64

+ type SessionStatus string

+ type Step struct

+ ArrivedOn time.Time

+ ExitUUID flows.ExitUUID

+ NodeUUID flows.NodeUUID

+ UUID flows.StepUUID

+ type TopUpID null.Int