customerdb

type Customer struct {
	ID                  primitive.ObjectID `bson:"_id,omitempty"`
	CustomerID          string             `bson:"cid,omitempty"`
	Group               string             `bson:"group,omitempty"`
	Name                string             `bson:"name,omitempty"`
	Firstname           string             `bson:"firstname,omitempty"`
	Title               string             `bson:"title,omitempty"`
	Street              string             `bson:"street,omitempty"`
	CityCode            int                `bson:"cityCode,omitempty"`
	City                string             `bson:"city,omitempty"`
	PhoneNumbers        []string           `bson:"phoneNumbers,omitempty"`
	MailAddresses       []string           `bson:"mailAddresses,omitempty"`
	NameMetaphone       string             `bson:"nameMetaphone,omitempty"`
	VaccinationReminder bool               `bson:"vaccinationReminder,omitempty"`

	// CreateAt holds the time this customer has first been imported.
	CreatedAt time.Time

	// ModifiedAt holds the last time this customer has been updated
	// or re-imported
	ModifiedAt time.Time

	// LinkedTo may be set to link customer or contact data from multiple
	// sources.
	LinkedTo string `bson:"linkedTo,omitempty"`

	// Metadata holds additional metadata for the customer.
	// It is not part of the hash calculation.
	Metadata map[string]interface{} `bson:"metadata,omitempty"`
	Source   string                 `bson:"customerSource,omitempty"`
}

type Database interface {
	// CreateCustomer creates a new customer.
	CreateCustomer(ctx context.Context, cu *Customer) error

	// UpdateCustomer replaces an existing customer
	UpdateCustomer(ctx context.Context, cu *Customer) error

	// CustomerByCID returns the customer by it's customer-id
	CustomerByCID(ctx context.Context, source string, cid string) (*Customer, error)

	// FilterCustomer filters all customers according to filter.
	FilterCustomer(ctx context.Context, filter bson.M, textScore bool) ([]*Customer, error)

	// FuzzySearchName searches for a customer by name usign fuzzy-search
	FuzzySearchName(ctx context.Context, name string) ([]*Customer, error)

	// SearchCustomerByName searches for all customers that matches
	// name.
	SearchCustomerByName(ctx context.Context, name string) ([]*Customer, error)

	// DeleteCustomer deletes the customer identified by source and cid.
	DeleteCustomer(ctx context.Context, id string) error

	// Cursor returns a cursor for all objects in filter.
	Cursor(ctx context.Context, filter bson.M) (*mongo.Cursor, error)

	Stats() *dbutils.Stats
}

type Source struct {
	// Name is the name of the customer source and should be set as the "Source"
	// field on each customer record created by this source.
	Name string

	// Description is a human readable description of the source.
	Description string

	// Metadata holds customer source metadata that is serialized
	// as JSON via the customerapi. Values must not change after
	// the source has been registered.
	Metadata map[string]interface{}

	// DeleteFunc should delete the customer from source. Upon successful
	// deletion the customer is also deleted from the internal database.
	DeleteFunc func(ctx context.Context, cus *Customer) error

	// UpdateFunc should update the representation of cus in the source.
	UpdateFunc func(ctx context.Context, cus *Customer) error

	// CreateFunc should create a new customer in source that mirrors the
	// data stored in cus. cus is a new customer object that is not yet
	// associated with any other customer source. CreateFunc should update
	// the customer metadata as it needs. Upon successful return
	// cus is actually created by the database inside the local collection.
	// Note that cus does not yet have an ID property specified.
	CreateFunc func(ctx context.Context, cus *Customer) error
}

type SourceManager struct {
	// contains filtered or unexported fields
}