repository

type ContactRepository interface {
	GetContactIdsForEmail(ctx context.Context, tenant, emailId string) ([]string, error)
	GetAllCrossTenantsNotSynced(ctx context.Context, size int) ([]*utils.DbNodeAndId, error)
	GetContactIdById(ctx context.Context, tenant, id string) (string, error)
	GetContactIdByExternalId(ctx context.Context, tenant, externalId, externalSystemId string) (string, error)
	GetJobRoleId(ctx context.Context, tenant, contactId, organizationId string) (string, error)
}

type Dbs struct {
	GormDB         *gorm.DB
	Neo4jDriver    *neo4j.DriverWithContext
	RawDataStoreDB *config.RawDataStoreDB
}

type EmailRepository interface {
	GetEmailId(ctx context.Context, tenant, email string) (string, error)
	GetEmailIdOrCreateContactByEmail(ctx context.Context, tenant, email, firstName, lastName, externalSystemId string) (string, error)
	GetEmailIdOrCreateUserByEmail(ctx context.Context, tenant, email, firstName, lastName, externalSystemId string) (string, error)
	GetAllCrossTenantsWithRawEmail(ctx context.Context, size int) ([]*utils.DbNodeAndId, error)
}

type ExternalSystemRepository interface {
	Merge(ctx context.Context, tenant, externalSystem string) error
}

type InteractionEventRepository interface {
	MergeEmailInteractionSession(ctx context.Context, tenant string, date time.Time, message entity.EmailMessageData) (string, error)
	MergeEmailInteractionEvent(ctx context.Context, tenant, externalSystemId string, date time.Time, message entity.EmailMessageData) (string, error)
	LinkInteractionEventToSession(ctx context.Context, tenant, interactionEventId, interactionSessionId string) error
	InteractionEventSentByEmail(ctx context.Context, tenant, interactionEventId, emailId string) error
	InteractionEventSentToEmails(ctx context.Context, tenant, interactionEventId, sentType string, emails []string) error
}

type LocationRepository interface {
	GetAllCrossTenants(ctx context.Context, size int) ([]*utils.DbNodeAndId, error)
}

type LogEntryRepository interface {
	GetMatchedLogEntryId(ctx context.Context, tenant string, logEntry entity.LogEntryData) (string, error)
	GetLogEntryIdById(ctx context.Context, tenant, id string) (string, error)
}

type MeetingRepository interface {
	GetMatchedMeetingId(ctx context.Context, tenant string, meeting entity.MeetingData) (string, error)
	MergeMeeting(ctx context.Context, tenant string, syncDate time.Time, meeting entity.MeetingData) error
	MergeMeetingLocation(ctx context.Context, tenant string, meeting entity.MeetingData) error
	MeetingLinkWithCreatorUserByExternalId(ctx context.Context, tenant, meetingId, userExternalId, externalSystem string) error
	MeetingLinkWithAttendedByUserByExternalId(ctx context.Context, tenant, meetingId, userExternalId, externalSystem string) error
	MeetingLinkWithAttendedByContactByExternalId(ctx context.Context, tenant, meetingId, contactExternalId, externalSystem string) error
}

type OrganizationRepository interface {
	GetOrganizationIdsForContact(ctx context.Context, tenant, contactId string) ([]string, error)
	GetOrganizationIdsForContactByExternalId(ctx context.Context, tenant, contactExternalId, externalSystem string) ([]string, error)
	GetAllCrossTenantsNotSynced(ctx context.Context, size int) ([]*utils.DbNodeAndId, error)
	GetAllDomainLinksCrossTenantsNotSynced(ctx context.Context, size int) ([]*neo4j.Record, error)
	GetOrganizationIdById(ctx context.Context, tenant, id string) (string, error)
	GetOrganizationIdByExternalId(ctx context.Context, tenant, externalId, externalSystemId string) (string, error)
	GetOrganizationIdByDomain(ctx context.Context, tenant, domain string) (string, error)
}

type PhoneNumberRepository interface {
	GetAllCrossTenantsWithRawPhoneNumber(ctx context.Context, size int) ([]*utils.DbNodeAndId, error)
}

type Repositories struct {
	Dbs Dbs

	PostgresRepositories *postgresRepository.Repositories

	TenantSyncSettingsRepository TenantSyncSettingsRepository
	TenantSettingsRepository     TenantSettingsRepository
	SyncRunRepository            SyncRunRepository

	ContactRepository          ContactRepository
	EmailRepository            EmailRepository
	PhoneNumberRepository      PhoneNumberRepository
	LocationRepository         LocationRepository
	ExternalSystemRepository   ExternalSystemRepository
	OrganizationRepository     OrganizationRepository
	UserRepository             UserRepository
	LogEntryRepository         LogEntryRepository
	InteractionEventRepository InteractionEventRepository
	MeetingRepository          MeetingRepository
}

type SyncRunRepository interface {
	Save(entity entity.SyncRun)
}

type TenantSettingsRepository interface {
	GetTenantSettings(ctx context.Context, tenant string) (entity.TenantSettings, error)
}

type TenantSyncSettingsRepository interface {
	GetTenantsForSync() (entity.TenantSyncSettingsList, error)
}

type UserRepository interface {
	GetUserIdById(ctx context.Context, tenant, id string) (string, error)
	GetUserIdByExternalId(ctx context.Context, tenant, externalId, externalSystemId string) (string, error)
	GetUserIdByExternalOwnerId(ctx context.Context, tenant, externalOwnerId, externalSystemId string) (string, error)
}