SQuiz/common
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

init new statistics repo

Browse Source
This commit is contained in:
Pavel 2024-03-15 15:31:12 +03:00
parent a26dce3bed
commit db75b0e515
2 changed files with 49 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

44
dal/dal.go
View File

@ -15,6 +15,7 @@ import (
"penahub.gitlab.yandexcloud.net/backend/quiz/common.git/repository/question" "penahub.gitlab.yandexcloud.net/backend/quiz/common.git/repository/question"
"penahub.gitlab.yandexcloud.net/backend/quiz/common.git/repository/quiz" "penahub.gitlab.yandexcloud.net/backend/quiz/common.git/repository/quiz"
"penahub.gitlab.yandexcloud.net/backend/quiz/common.git/repository/result" "penahub.gitlab.yandexcloud.net/backend/quiz/common.git/repository/result"
"penahub.gitlab.yandexcloud.net/backend/quiz/common.git/repository/statistics"
"penahub.gitlab.yandexcloud.net/backend/quiz/common.git/repository/workers" "penahub.gitlab.yandexcloud.net/backend/quiz/common.git/repository/workers"
"penahub.gitlab.yandexcloud.net/backend/quiz/core.git/clients/auth" "penahub.gitlab.yandexcloud.net/backend/quiz/core.git/clients/auth"
"time" "time"
@ -23,15 +24,16 @@ import (
var errNextDeclined = errors.New("next is declined") var errNextDeclined = errors.New("next is declined")
type DAL struct { type DAL struct {
conn *sql.DB conn *sql.DB
authClient *auth.AuthClient authClient *auth.AuthClient
queries *sqlcgen.Queries queries *sqlcgen.Queries
AccountRepo *account.AccountRepository AccountRepo *account.AccountRepository
AnswerRepo *answer.AnswerRepository AnswerRepo *answer.AnswerRepository
QuestionRepo *question.QuestionRepository QuestionRepo *question.QuestionRepository
QuizRepo *quiz.QuizRepository QuizRepo *quiz.QuizRepository
ResultRepo *result.ResultRepository ResultRepo *result.ResultRepository
WorkerRepo *workers.WorkerRepository WorkerRepo *workers.WorkerRepository
StatisticsRepo *statistics.StatisticsRepository
} }
func New(ctx context.Context, cred string, authClient *auth.AuthClient) (*DAL, error) { func New(ctx context.Context, cred string, authClient *auth.AuthClient) (*DAL, error) {
@ -79,16 +81,22 @@ func New(ctx context.Context, cred string, authClient *auth.AuthClient) (*DAL, e
Queries: queries, Queries: queries,
}) })
statisticsRepo := statistics.NewStatisticsRepo(statistics.Deps{
Queries: queries,
Pool: pool,
})
return &DAL{ return &DAL{
conn: pool, conn: pool,
authClient: authClient, authClient: authClient,
queries: queries, queries: queries,
AccountRepo: accountRepo, AccountRepo: accountRepo,
AnswerRepo: answerRepo, AnswerRepo: answerRepo,
QuestionRepo: questionRepo, QuestionRepo: questionRepo,
QuizRepo: quizRepo, QuizRepo: quizRepo,
ResultRepo: resultRepo, ResultRepo: resultRepo,
WorkerRepo: workerRepo, WorkerRepo: workerRepo,
StatisticsRepo: statisticsRepo,
}, nil }, nil
} }

23
repository/statistics/statistics.go Normal file
View File

@ -0,0 +1,23 @@
package statistics
import (
"database/sql"
"penahub.gitlab.yandexcloud.net/backend/quiz/common.git/dal/sqlcgen"
)
type Deps struct {
Queries *sqlcgen.Queries
Pool *sql.DB
}
type StatisticsRepository struct {
queries *sqlcgen.Queries
pool *sql.DB
}
func NewStatisticsRepo(deps Deps) *StatisticsRepository {
return &StatisticsRepository{
queries: deps.Queries,
pool: deps.Pool,
}
}