repository

Documentation

Index

• type CommentRepository
  • func NewCommentRepository(driver *neo4j.DriverWithContext, database string) CommentRepository
• type ContactRepository
  • func NewContactRepository(driver *neo4j.DriverWithContext, database string) ContactRepository
• type Drivers
• type InteractionEventRepository
  • func NewInteractionEventRepository(driver *neo4j.DriverWithContext, database string) InteractionEventRepository
• type InteractionSessionRepository
  • func NewInteractionSessionRepository(driver *neo4j.DriverWithContext, database string) InteractionSessionRepository
• type LocationRepository
  • func NewLocationRepository(driver *neo4j.DriverWithContext) LocationRepository
• type LogEntryRepository
  • func NewLogEntryRepository(driver *neo4j.DriverWithContext) LogEntryRepository
• type OrganizationRepository
  • func NewOrganizationRepository(driver *neo4j.DriverWithContext) OrganizationRepository
• type PhoneNumberRepository
  • func NewPhoneNumberRepository(driver *neo4j.DriverWithContext) PhoneNumberRepository
• type Repositories
  • func InitRepos(driver *neo4j.DriverWithContext, postgresDB *commonConfig.PostgresDB, ...) *Repositories
• type TenantRepository
  • func NewTenantRepository(driver *neo4j.DriverWithContext) TenantRepository
• type UserRepository
  • func NewUserRepository(driver *neo4j.DriverWithContext) UserRepository

Types

type CommentRepository

type CommentRepository interface {
	// Deprecated
	GetById(ctx context.Context, commentId string) (*dbtype.Node, error)
	// Deprecated
	GetMatchedCommentId(ctx context.Context, externalSystem, externalId string) (string, error)
}

func NewCommentRepository

func NewCommentRepository(driver *neo4j.DriverWithContext, database string) CommentRepository

type ContactRepository

type ContactRepository interface {
	// Deprecated
	GetById(ctx context.Context, tenant, contactId string) (*dbtype.Node, error)
	// Deprecated
	GetMatchedContactId(ctx context.Context, tenant, externalSystem, externalId string, emails []string) (string, error)
	// Deprecated
	GetContactIdById(ctx context.Context, tenant, id string) (string, error)
	// Deprecated
	GetContactIdByExternalId(ctx context.Context, tenant, externalId, externalSystemId string) (string, error)
	// Deprecated
	GetJobRoleId(ctx context.Context, tenant, contactId, organizationId string) (string, error)
}

func NewContactRepository

func NewContactRepository(driver *neo4j.DriverWithContext, database string) ContactRepository

type Drivers

type Drivers struct {
	Neo4jDriver *neo4j.DriverWithContext
}

type InteractionEventRepository

type InteractionEventRepository interface {
	// Deprecated
	GetMatchedInteractionEventId(ctx context.Context, tenant, externalId, externalSystem, externalSourceEntity string) (string, error)
	// Deprecated
	GetInteractionEventIdByExternalId(ctx context.Context, tenant, externalId, externalSystem string) (string, error)
	// Deprecated
	GetById(ctx context.Context, tenant, interactionEventId string) (*dbtype.Node, error)
}

func NewInteractionEventRepository

func NewInteractionEventRepository(driver *neo4j.DriverWithContext, database string) InteractionEventRepository

type InteractionSessionRepository

type InteractionSessionRepository interface {
	// Deprecated
	GetInteractionSessionIdByExternalId(ctx context.Context, tenant, externalId, externalSystemId string) (string, error)
	// Deprecated
	GetById(ctx context.Context, tenant, interactionEventId string) (*dbtype.Node, error)
}

func NewInteractionSessionRepository

func NewInteractionSessionRepository(driver *neo4j.DriverWithContext, database string) InteractionSessionRepository

type LocationRepository

type LocationRepository interface {
	// Deprecated
	GetMatchedLocationIdForOrganizationBySource(ctx context.Context, organizationId, externalSystem string) (string, error)
	// Deprecated
	GetMatchedLocationIdForContactBySource(ctx context.Context, contactId, externalSystem string) (string, error)
	// Deprecated
	GetById(ctx context.Context, locationId string) (*dbtype.Node, error)
}

func NewLocationRepository

func NewLocationRepository(driver *neo4j.DriverWithContext) LocationRepository

type LogEntryRepository

type LogEntryRepository interface {
	// Deprecated
	GetById(ctx context.Context, tenant, logEntryId string) (*dbtype.Node, error)
	// Deprecated
	GetMatchedLogEntryId(ctx context.Context, tenant, externalSystem, externalId string) (string, error)
}

func NewLogEntryRepository

func NewLogEntryRepository(driver *neo4j.DriverWithContext) LogEntryRepository

type OrganizationRepository

type OrganizationRepository interface {
	// Deprecated
	GetById(ctx context.Context, tenant, organizationId string) (*dbtype.Node, error)
	// Deprecated
	GetMatchedOrganizationId(ctx context.Context, tenant, externalSystem, externalId, customerOsId string, domains []string) (string, error)
	// Deprecated
	GetOrganizationIdById(ctx context.Context, tenant, id string) (string, error)
	// Deprecated
	GetOrganizationIdByExternalId(ctx context.Context, tenant, externalId, externalSystemId string) (string, error)
	// Deprecated
	GetOrganizationIdByDomain(ctx context.Context, tenant, domain string) (string, error)
	// Deprecated
	IsDomainUsedByOrganization(ctx context.Context, tenant, domain, skipOrganizationIds string) (bool, error)
}

func NewOrganizationRepository

func NewOrganizationRepository(driver *neo4j.DriverWithContext) OrganizationRepository

type PhoneNumberRepository

type PhoneNumberRepository interface {
	// Deprecated
	Exists(ctx context.Context, tenant, phoneNumber string) (bool, error)
	// Deprecated
	GetById(ctx context.Context, phoneNumberId string) (*dbtype.Node, error)
	// Deprecated
	GetByPhoneNumber(ctx context.Context, tenant, phoneNumber string) (*dbtype.Node, error)
}

func NewPhoneNumberRepository

func NewPhoneNumberRepository(driver *neo4j.DriverWithContext) PhoneNumberRepository

type Repositories

type Repositories struct {
	Drivers Drivers

	Neo4jRepositories    *neo4jrepository.Repositories
	PostgresRepositories *postgresRepository.Repositories

	SyncRunWebhookRepository     repository.SyncRunWebhookRepository
	UserRepository               UserRepository
	LocationRepository           LocationRepository
	OrganizationRepository       OrganizationRepository
	ContactRepository            ContactRepository
	TenantRepository             TenantRepository
	PhoneNumberRepository        PhoneNumberRepository
	LogEntryRepository           LogEntryRepository
	InteractionSessionRepository InteractionSessionRepository
	InteractionEventRepository   InteractionEventRepository
	CommentRepository            CommentRepository
	// contains filtered or unexported fields
}

func InitRepos

func InitRepos(driver *neo4j.DriverWithContext, postgresDB *commonConfig.PostgresDB, neo4jDatabase string) *Repositories

type TenantRepository

type TenantRepository interface {
	// Deprecated
	GetTenant(ctx context.Context, tenant string) (*dbtype.Node, error)
}

func NewTenantRepository

func NewTenantRepository(driver *neo4j.DriverWithContext) TenantRepository

type UserRepository

type UserRepository interface {
	// Deprecated
	GetMatchedUserId(ctx context.Context, tenant, externalSystem, externalId, email string) (string, error)
	// Deprecated
	GetUserIdById(ctx context.Context, tenant, id string) (string, error)
	// Deprecated
	GetUserIdByExternalId(ctx context.Context, tenant, externalId, externalSystemId string) (string, error)
	// Deprecated
	GetUserIdByExternalIdSecond(ctx context.Context, tenant, externalIdSecond, externalSystemId string) (string, error)
}

func NewUserRepository

func NewUserRepository(driver *neo4j.DriverWithContext) UserRepository