contact_changed.go

package events

import (
	"encoding/json"

	"github.com/nyaruka/goflow/flows"
)

func init() {
	RegisterType(TypeContactChanged, func() flows.Event { return &ContactChangedEvent{} })
}

// TypeContactChanged is the type of our set contact event
const TypeContactChanged string = "contact_changed"

// ContactChangedEvent events are sent by the caller to tell the engine to update the session contact.
//
//   {
//     "type": "contact_changed",
//     "created_on": "2006-01-02T15:04:05Z",
//     "contact": {
//       "uuid": "0e06f977-cbb7-475f-9d0b-a0c4aaec7f6a",
//       "name": "Bob",
//       "urns": ["tel:+11231234567"]
//     }
//   }
//
// @event contact_changed
type ContactChangedEvent struct {
	BaseEvent

	Contact json.RawMessage `json:"contact"`
}

// Type returns the type of this event
func (e *ContactChangedEvent) Type() string { return TypeContactChanged }

// Validate validates our event is valid and has all the assets it needs
func (e *ContactChangedEvent) Validate(assets flows.SessionAssets) error {
	return nil
}

// Apply applies this event to the given run
func (e *ContactChangedEvent) Apply(run flows.FlowRun) error {
	contact, err := flows.ReadContact(run.Session().Assets(), e.Contact, true)
	if err != nil {
		return err
	}

	run.SetContact(contact)
	run.Session().SetContact(contact)
	return nil
}

var _ flows.CallerEvent = (*ContactChangedEvent)(nil)