models

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