app

type App struct {
	Cron     *cron.Cron
	Channels *Channels
	// contains filtered or unexported fields
}

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

type Channels struct {
	UpdateUserCorrelationsChan    chan domain.UpdateCorrelationsArgs
	UpdateDatasetAggregationsChan chan domain.UpdateAggregationsArgs
}

type Repository interface {
	// users
	UserCount() (int, error)
	CreateUser(*domain.User) (*domain.User, error)
	GetUserByUsername(string) (*domain.User, error)
	GetUserByID(int) (*domain.User, error)
	GetUserCount() (int, error)

	// indicators
	IndicatorCount() (int, error)
	CreateIndicator(*domain.Indicator) (*domain.Indicator, error)
	UpdateIndicator(*domain.Indicator) (*domain.Indicator, error)
	GetIndicatorByID(int) (*domain.Indicator, error)
	GetIndicatorByCode(string) (*domain.Indicator, error)
	GetIndicators(domain.GetIndicatorsArgs) ([]*domain.Indicator, error)

	// scales
	ScaleCount() (int, error)
	GetScales() ([]*domain.Scale, error)
	GetScaleByType(string) (*domain.Scale, error)
	CreateScale(domain.Scale) (*domain.Scale, error)

	// datasets
	DatasetCount() (int, error)
	CreateDataset(*domain.Dataset) (*domain.Dataset, error)
	GetDatasetByID(id int, observationsLimit int, granularity string) (*domain.Dataset, error)
	GetUserIndicatorDataset(*domain.User, *domain.Indicator) (*domain.Dataset, error)
	GetOrCreateUserIndicatorDataset(*domain.User, *domain.Indicator) (*domain.Dataset, error)
	GetUserDatasets(userID int, withShared bool, observationsLimit int, granularity string) ([]*domain.Dataset, error) // to be deprecated
	GetDatasets(domain.GetDatasetsArgs) ([]*domain.Dataset, error)

	// observations
	ObservationCount() (int, error)
	CreateObservation(*domain.Observation) (*domain.Observation, error)
	CreateOrUpdateObservation(*domain.Observation) (*domain.Observation, error)

	// correlations
	CorrelationCount() (int, error)
	CreateOrUpdateCorrelation(*domain.Correlation) (*domain.Correlation, error)
	GetUserCorrelations(userID int, granularity string) ([]*domain.Correlation, error)
	GetCorrelation(domain.GetCorrelationArgs) (*domain.Correlation, error)

	// dictionary
	CreateDictionaty(*domain.Dictionary) error
	GetDictionaryByCode(code string) (*domain.Dictionary, error)
	GetDictionaryByID(id int) (*domain.Dictionary, error)
	CreateDictionatyEntry(*domain.DictionaryEntry) error
	GetDictionaryEntryByID(id int) (*domain.DictionaryEntry, error)
}