hooks

Documentation

Index

• func NoopHandler(ctx context.Context, tx *sqlx.Tx, rp *redis.Pool, org *models.OrgAssets, ...) error
• type CommitAddedLabelsHook
  • func (h *CommitAddedLabelsHook) Apply(ctx context.Context, tx *sqlx.Tx, rp *redis.Pool, org *models.OrgAssets, ...) error
• type CommitFieldChangesHook
  • func (h *CommitFieldChangesHook) Apply(ctx context.Context, tx *sqlx.Tx, rp *redis.Pool, org *models.OrgAssets, ...) error
• type CommitGroupChangesHook
  • func (h *CommitGroupChangesHook) Apply(ctx context.Context, tx *sqlx.Tx, rp *redis.Pool, org *models.OrgAssets, ...) error
• type CommitIVRHook
  • func (h *CommitIVRHook) Apply(ctx context.Context, tx *sqlx.Tx, rp *redis.Pool, org *models.OrgAssets, ...) error
• type CommitLanguageChangesHook
  • func (h *CommitLanguageChangesHook) Apply(ctx context.Context, tx *sqlx.Tx, rp *redis.Pool, org *models.OrgAssets, ...) error
• type CommitMessagesHook
  • func (h *CommitMessagesHook) Apply(ctx context.Context, tx *sqlx.Tx, rp *redis.Pool, org *models.OrgAssets, ...) error
• type CommitNameChangesHook
  • func (h *CommitNameChangesHook) Apply(ctx context.Context, tx *sqlx.Tx, rp *redis.Pool, org *models.OrgAssets, ...) error
• type CommitURNChangesHook
  • func (h *CommitURNChangesHook) Apply(ctx context.Context, tx *sqlx.Tx, rp *redis.Pool, org *models.OrgAssets, ...) error
• type ContactModifiedHook
  • func (h *ContactModifiedHook) Apply(ctx context.Context, tx *sqlx.Tx, rp *redis.Pool, org *models.OrgAssets, ...) error
• type FieldDelete
• type FieldUpdate
• type FieldValue
• type InsertStartHook
  • func (h *InsertStartHook) Apply(ctx context.Context, tx *sqlx.Tx, rp *redis.Pool, org *models.OrgAssets, ...) error
• type InsertWebhookEventHook
  • func (h *InsertWebhookEventHook) Apply(ctx context.Context, tx *sqlx.Tx, rp *redis.Pool, org *models.OrgAssets, ...) error
• type InsertWebhookResultHook
  • func (h *InsertWebhookResultHook) Apply(ctx context.Context, tx *sqlx.Tx, rp *redis.Pool, org *models.OrgAssets, ...) error
• type SendEmailsHook
  • func (h *SendEmailsHook) Apply(ctx context.Context, tx *sqlx.Tx, rp *redis.Pool, org *models.OrgAssets, ...) error
• type SendMessagesHook
  • func (h *SendMessagesHook) Apply(ctx context.Context, tx *sqlx.Tx, rp *redis.Pool, org *models.OrgAssets, ...) error
• type StartBroadcastsHook
  • func (h *StartBroadcastsHook) Apply(ctx context.Context, tx *sqlx.Tx, rp *redis.Pool, org *models.OrgAssets, ...) error
• type StartStartHook
  • func (h *StartStartHook) Apply(ctx context.Context, tx *sqlx.Tx, rp *redis.Pool, org *models.OrgAssets, ...) error
• type UnsubscribeResthookHook
  • func (h *UnsubscribeResthookHook) Apply(ctx context.Context, tx *sqlx.Tx, rp *redis.Pool, org *models.OrgAssets, ...) error
• type UpdateCampaignEventsHook
  • func (h *UpdateCampaignEventsHook) Apply(ctx context.Context, tx *sqlx.Tx, rp *redis.Pool, org *models.OrgAssets, ...) error

Functions

func NoopHandler

func NoopHandler(ctx context.Context, tx *sqlx.Tx, rp *redis.Pool, org *models.OrgAssets, session *models.Session, event flows.Event) error

NoopHandler is our hook for events we ignore in a run

Types

type CommitAddedLabelsHook

type CommitAddedLabelsHook struct{}

CommitAddedLabelsHook is our hook for input labels being added

func (*CommitAddedLabelsHook) Apply

func (h *CommitAddedLabelsHook) Apply(ctx context.Context, tx *sqlx.Tx, rp *redis.Pool, org *models.OrgAssets, sessions map[*models.Session][]interface{}) error

Apply applies our input labels added, committing them in a single batch

type CommitFieldChangesHook

type CommitFieldChangesHook struct{}

CommitFieldChangesHook is our hook for contact field changes

func (*CommitFieldChangesHook) Apply

func (h *CommitFieldChangesHook) Apply(ctx context.Context, tx *sqlx.Tx, rp *redis.Pool, org *models.OrgAssets, sessions map[*models.Session][]interface{}) error

Apply squashes and writes all the field updates for the contacts

type CommitGroupChangesHook

type CommitGroupChangesHook struct{}

CommitGroupChangesHook is our hook for all group changes

func (*CommitGroupChangesHook) Apply

func (h *CommitGroupChangesHook) Apply(ctx context.Context, tx *sqlx.Tx, rp *redis.Pool, org *models.OrgAssets, sessions map[*models.Session][]interface{}) error

Apply squashes and adds or removes all our contact groups

type CommitIVRHook

type CommitIVRHook struct{}

CommitIVRHook is our hook for comitting session messages / say commands

func (*CommitIVRHook) Apply

func (h *CommitIVRHook) Apply(ctx context.Context, tx *sqlx.Tx, rp *redis.Pool, org *models.OrgAssets, sessions map[*models.Session][]interface{}) error

Apply takes care of inserting all the messages in the passed in sessions assigning topups to them as needed.

type CommitLanguageChangesHook

type CommitLanguageChangesHook struct{}

CommitLanguageChangesHook is our hook for language changes

func (*CommitLanguageChangesHook) Apply

func (h *CommitLanguageChangesHook) Apply(ctx context.Context, tx *sqlx.Tx, rp *redis.Pool, org *models.OrgAssets, sessions map[*models.Session][]interface{}) error

Apply applies our contact language change before our commit

type CommitMessagesHook

type CommitMessagesHook struct{}

CommitMessagesHook is our hook for comitting session messages

func (*CommitMessagesHook) Apply

func (h *CommitMessagesHook) Apply(ctx context.Context, tx *sqlx.Tx, rp *redis.Pool, org *models.OrgAssets, sessions map[*models.Session][]interface{}) error

Apply takes care of inserting all the messages in the passed in sessions assigning topups to them as needed.

type CommitNameChangesHook

type CommitNameChangesHook struct{}

CommitNameChangesHook is our hook for name changes

func (*CommitNameChangesHook) Apply

func (h *CommitNameChangesHook) Apply(ctx context.Context, tx *sqlx.Tx, rp *redis.Pool, org *models.OrgAssets, sessions map[*models.Session][]interface{}) error

Apply commits our contact name changes as a bulk update for the passed in map of sessions

type CommitURNChangesHook

type CommitURNChangesHook struct{}

CommitURNChangesHook is our hook for when a URN is added to a contact

func (*CommitURNChangesHook) Apply

func (h *CommitURNChangesHook) Apply(ctx context.Context, tx *sqlx.Tx, rp *redis.Pool, org *models.OrgAssets, sessions map[*models.Session][]interface{}) error

Apply adds all our URNS in a batch

type ContactModifiedHook

type ContactModifiedHook struct{}

ContactModifiedHook is our hook for contact changes that require an update to modified_on

func (*ContactModifiedHook) Apply

func (h *ContactModifiedHook) Apply(ctx context.Context, tx *sqlx.Tx, rp *redis.Pool, org *models.OrgAssets, sessions map[*models.Session][]interface{}) error

Apply squashes and updates modified_on on all the contacts passed in

type FieldDelete

type FieldDelete struct {
	ContactID models.ContactID `db:"contact_id"`
	FieldUUID models.FieldUUID `db:"field_uuid"`
}

type FieldUpdate

type FieldUpdate struct {
	ContactID models.ContactID `db:"contact_id"`
	Updates   string           `db:"updates"`
}

type FieldValue

type FieldValue struct {
	Text string `json:"text"`
}

type InsertStartHook

type InsertStartHook struct{}

InsertStartHook is our hook to fire insert our starts

func (*InsertStartHook) Apply

func (h *InsertStartHook) Apply(ctx context.Context, tx *sqlx.Tx, rp *redis.Pool, org *models.OrgAssets, sessions map[*models.Session][]interface{}) error

Apply inserts our starts

type InsertWebhookEventHook

type InsertWebhookEventHook struct{}

InsertWebhookEventHook is our hook for when a resthook needs to be inserted

func (*InsertWebhookEventHook) Apply

func (h *InsertWebhookEventHook) Apply(ctx context.Context, tx *sqlx.Tx, rp *redis.Pool, org *models.OrgAssets, sessions map[*models.Session][]interface{}) error

Apply inserts all the webook events that were created

type InsertWebhookResultHook

type InsertWebhookResultHook struct{}

InsertWebhookResultHook is our hook for inserting webhook results

func (*InsertWebhookResultHook) Apply

func (h *InsertWebhookResultHook) Apply(ctx context.Context, tx *sqlx.Tx, rp *redis.Pool, org *models.OrgAssets, sessions map[*models.Session][]interface{}) error

Apply inserts all the webook results that were created

type SendEmailsHook

type SendEmailsHook struct{}

SendEmailsHook is our hook for sending emails

func (*SendEmailsHook) Apply

func (h *SendEmailsHook) Apply(ctx context.Context, tx *sqlx.Tx, rp *redis.Pool, org *models.OrgAssets, sessions map[*models.Session][]interface{}) error

Apply sends all our emails

type SendMessagesHook

type SendMessagesHook struct{}

SendMessagesHook is our hook for sending session messages

func (*SendMessagesHook) Apply

func (h *SendMessagesHook) Apply(ctx context.Context, tx *sqlx.Tx, rp *redis.Pool, org *models.OrgAssets, sessions map[*models.Session][]interface{}) error

Apply sends all non-android messages to courier

type StartBroadcastsHook

type StartBroadcastsHook struct{}

StartBroadcastsHook is our hook for starting the broadcasts created in these sessions

func (*StartBroadcastsHook) Apply

func (h *StartBroadcastsHook) Apply(ctx context.Context, tx *sqlx.Tx, rp *redis.Pool, org *models.OrgAssets, sessions map[*models.Session][]interface{}) error

Apply queues up our broadcasts for sending

type StartStartHook

type StartStartHook struct{}

StartStartHook is our hook to fire our session starts

func (*StartStartHook) Apply

func (h *StartStartHook) Apply(ctx context.Context, tx *sqlx.Tx, rp *redis.Pool, org *models.OrgAssets, sessions map[*models.Session][]interface{}) error

Apply queues up our flow starts

type UnsubscribeResthookHook

type UnsubscribeResthookHook struct{}

UnsubscribeResthookHook is our hook for when a webhook is called

func (*UnsubscribeResthookHook) Apply

func (h *UnsubscribeResthookHook) Apply(ctx context.Context, tx *sqlx.Tx, rp *redis.Pool, org *models.OrgAssets, sessions map[*models.Session][]interface{}) error

Apply squashes and applies all our resthook unsubscriptions

type UpdateCampaignEventsHook

type UpdateCampaignEventsHook struct{}

UpdateCampaignEventsHook is our hook to update any campaign events

func (*UpdateCampaignEventsHook) Apply

func (h *UpdateCampaignEventsHook) Apply(ctx context.Context, tx *sqlx.Tx, rp *redis.Pool, org *models.OrgAssets, sessions map[*models.Session][]interface{}) error

Apply will update all the campaigns for the passed in sessions, minimizing the number of queries to do so