database

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

type Database interface {
	// CreateUnidentified creates new "unidentified" calllog record where
	// we don't know the caller.
	CreateUnidentified(ctx context.Context, log *structs.CallLog) error

	// RecordCustomerCall records a call that has been associated with a customer.
	// When called, RecordCustomerCall searches for an "unidentified" calllog that
	// was recorded at the same time and replaces that entry.
	RecordCustomerCall(ctx context.Context, record *structs.CallLog) error

	// Search searches for all records that match query.
	Search(ctx context.Context, query *SearchQuery) ([]structs.CallLog, error)

	Search2(ctx context.Context, opts ...QueryOption) ([]structs.CallLog, error)

	StreamSearch(ctx context.Context, query *SearchQuery) (<-chan structs.CallLog, <-chan error)

	FindDistinctNumbersWithoutCustomers(ctx context.Context) ([]string, error)

	UpdateUnmatchedNumber(ctx context.Context, number string, customerId string) error
}

type ExtensionDatabase interface {
	UpdatePhoneExtension(ctx context.Context, extension string, ext *pbx3cxv1.PhoneExtension) error
	SavePhoneExtension(context.Context, *pbx3cxv1.PhoneExtension) error
	DeletePhoneExtension(context.Context, string) error
	ListPhoneExtensions(context.Context) ([]*pbx3cxv1.PhoneExtension, error)
}

type MailboxDatabase interface {
	CreateMailbox(ctx context.Context, mailbox *pbx3cxv1.Mailbox) error
	ListMailboxes(ctx context.Context) ([]*pbx3cxv1.Mailbox, error)
	GetMailbox(ctx context.Context, id string) (*pbx3cxv1.Mailbox, error)
	DeleteMailbox(ctx context.Context, id string) error
	AppendNotificationSetting(ctx context.Context, mailbox string, nfs *pbx3cxv1.NotificationSettings) error
	DeleteNotificationSetting(ctx context.Context, mailbox, name string) error
	UpdateMailbox(ctx context.Context, mb *pbx3cxv1.Mailbox) error

	UpdateUnmatchedNumber(ctx context.Context, number string, customerId string) error
	FindDistinctNumbersWithoutCustomers(ctx context.Context) ([]string, error)
	CreateVoiceMail(ctx context.Context, voicemail *pbx3cxv1.VoiceMail) error
	ListVoiceMails(ctx context.Context, mailbox string, query *pbx3cxv1.VoiceMailFilter) ([]*pbx3cxv1.VoiceMail, error)
	SearchVoiceMails(ctx context.Context, mailbox string, query string) ([]*pbx3cxv1.VoiceMail, error)
	MarkVoiceMails(ctx context.Context, seen bool, mailbox string, ids []string) error
	GetVoicemail(ctx context.Context, id string) (*pbx3cxv1.VoiceMail, error)

	FindNotificationCandidates(ctx context.Context, mailbox string, unseen bool, notification string) ([]string, error)
	MarkAsNotificationSent(ctx context.Context, mailbox, notification string, recordIds []string) error

	mailsync.Store
}

type QueryOption func(*query)

type SearchQuery struct {
	dbutils.SimpleQueryBuilder
}