application

type ContactSearch interface {
	Search(userId domain.UserID, searchParams domain.SearchParams) (docs []domain.UnifiedSearch, err error)
}

type ContactSearchService interface {
	SearchContacts(ctx context.Context, userId domain.UserID, searchDto models.SearchContactDto) (unified []*models.Unified, err error)
}

type ContactService interface {
	SaveContact(context.Context, domain.UserID, *models.CreateContactDto) (updated *models.Unified, err error)
	UpdateContact(context.Context, domain.UserID, domain.UnifiedId, *models.UpdateUnifiedDto) (*models.Unified, error)
	UpdateCategory(ctx context.Context, userId domain.UserID, role *domain.Role, unifiedId domain.UnifiedId, category domain.ContactCatgeory) (*models.Unified, error)
	GetContacts(ctx context.Context, id domain.UserID, limit int, lastDocumentId *domain.ContactID) ([]*models.Contact, error)
	GetContactByID(context.Context, domain.UserID, domain.UnifiedId) (*models.Unified, error)
	DeleteContact(context.Context, domain.UserID, domain.UnifiedId) error
}

type ContactSourceDeletedPublisher interface {
	Publish(ctx context.Context, job jobModels.ContactSourceDeleted) (err error)
}

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

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

type GoogleOAuthService interface {
	GetRedirectUrl(ctx context.Context) (url string, err error)
	GetToken(ctx context.Context, code string) (token *oauth2.Token, err error)
	GetUserInfo(ctx context.Context, accessToken string) (info *googleOAuth2.Tokeninfo, err error)
	GetConfig() (config *oauth2.Config)
}

type IContactSource interface {
	Update(ctx context.Context, userId domain.UserID, sourceId domain.ContactSourceID, contactId domain.ContactID, unified domain.Unified) (err error)

	// puller return a new contacts puller.
	Puller(ctx context.Context, userId domain.UserID, source domain.ContactSource) (puller IContactSourcePuller)

	// reader returns a reader instance to read all documents stored in the database (and not from the remote. ie google, outlook etc) for a source.
	Reader(ctx context.Context, userId domain.UserID, sourceId domain.ContactSourceID) IContactSourceReader

	// Remove() will remove contacts from database (and not from the remote, ie google, outlook etc). This is invoked when a contact source is removed.
	Remove(ctx context.Context, userId domain.UserID, sourceId domain.ContactSourceID, contactIds []domain.ContactID) (err error)
}

type IContactSourceProvider interface {
	Get(source domain.Source) IContactSource
}

type IContactSourcePuller interface {
	Pull(ctx context.Context) (newContacts []domain.Contact, updatedContacts []domain.Contact, deletedContacts []domain.Contact, err error)
}

type IContactSourceReader interface {
	Read(ctx context.Context) (contacts []domain.Contact, err error)
}

type ICsvImporter interface {
	Import(ctx context.Context, reader io.Reader, userId domain.UserID) (err error)
}

type ILinkSuggestionService interface {

	// check for existing link suggestion and append to matches
	CheckAndAddToLinkSuggestion(ctx context.Context, userId domain.UserID, unified domain.Unified) (added bool, err error)

	// create new link suggestions if any
	CheckAndCreateLinkSuggestion(ctx context.Context, userId domain.UserID, unified domain.Unified) (added bool, err error)

	GetLinkSuggestions(ctx context.Context, uID domain.UserID, limit int, lastDocumentId *domain.LinkSuggestionID) ([]*models.LinkSuggestion, error)

	ApplyLinkSuggestion(ctx context.Context, uID domain.UserID, suggestionId domain.LinkSuggestionID, request []domain.UnifiedId) (err error)
}

type IUnifiedContactService interface {
	GetContacts(ctx context.Context, id domain.UserID, limit int, lastDocumentId *domain.UnifiedId) ([]*models.Unified, error)
	GetPendingContacts(ctx context.Context, id domain.UserID, limit int, lastDocumentInstant *time.Time, lastDocumentId *domain.UnifiedId) ([]*models.Unified, error)
	GetRecentContacts(ctx context.Context, uid domain.UserID, maxDays *int64, limit int, lastDocumentInstant *time.Time, lastDocumentId *domain.UnifiedId) ([]*models.Unified, error)
}

type IUnifiedSyncer interface {
	SyncContactToUnified(ctx context.Context, userId domain.UserID, source domain.Source, sourceId domain.ContactSourceID, contactId domain.ContactID, contact domain.Contact) (unified *domain.Unified, err error)
}

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

type NoteService interface {
	SaveNote(context.Context, domain.UserID, domain.UnifiedId, *models.Note) (updated *models.Note, err error)
	UpdateNote(context.Context, domain.UserID, domain.UnifiedId, domain.NoteID, *models.Note) (*models.Note, error)
	GetAllNotes(context.Context, domain.UserID, domain.UnifiedId) ([]*models.Note, error)
	GetNotes(ctx context.Context, userID domain.UserID, contactId domain.UnifiedId, limit int, lastDocumentId *domain.NoteID) ([]*models.Note, error)
	DeleteNote(context.Context, domain.UserID, domain.UnifiedId, domain.NoteID) error
}

type PeopleService interface {
	List(pageToken *string) (resp *people.ListConnectionsResponse, err error)
	Update(personId string, person *people.Person) (updated *people.Person, err error)
	Get(personId string) (person *people.Person, err error)
}

type PeopleServiceFactory interface {
	New(ctx context.Context, accessToken string, refreshToken string, expiry time.Time) (service PeopleService)
}

type PullContactPublisher interface {
	Publish(ctx context.Context, job jobModels.PullContactsRequest) (err error)
}

type TagService interface {
	SaveTag(context.Context, domain.UserID, domain.UnifiedId, *models.Tag) (updated *models.Tag, err error)
	UpdateTag(context.Context, domain.UserID, domain.UnifiedId, domain.TagID, *models.Tag) (*models.Tag, error)
	GetAllTags(context.Context, domain.UserID, domain.UnifiedId) ([]*models.Tag, error)
	GetTags(ctx context.Context, userId domain.UserID, contactId domain.UnifiedId, limit int, lastDocumentId *domain.TagID) ([]*models.Tag, error)
	DeleteTag(context.Context, domain.UserID, domain.UnifiedId, domain.TagID) error
}

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

type UserService interface {
	SaveUser(context.Context, domain.UserID, *models.User) (*models.User, error)
	UpdateUser(context.Context, domain.UserID, *models.User) (*models.User, error)
	GetUser(context.Context, domain.UserID) (*models.User, error)
	DeleteUser(context.Context, domain.UserID) error
}