freezer/mareshq-yggdrasil
Archived
1
0
Fork 0
Code Activity

feat(training): add fields published and retired

Browse source
This commit is contained in:
Vojtěch Mareš 2024-06-30 15:58:20 +02:00
parent 79b7567627
commit df41b45905
Signed by: vojtech.mares
GPG key ID: C6827B976F17240D
9 changed files with 131 additions and 50 deletions
Download patch file Download diff file Expand all files Collapse all files

20
pkg/training/postgres_repository.go
View file

@ -30,10 +30,10 @@ func (r *PostgresTrainingRepository) Create(training *Training) error {
}
queryErr := tx.QueryRow(ctx, `
INSERT INTO training.trainings (name, slug, description, days)
VALUES ($1, $2, $3, $4)
INSERT INTO training.trainings (name, slug, description, days, published)
VALUES ($1, $2, $3, $4, $5)
RETURNING id
`, training.Name, training.Slug, training.Description, training.Days).Scan(&training.ID)
`, training.Name, training.Slug, training.Description, training.Days, training.Published).Scan(&training.ID)
if queryErr != nil {
return queryErr
}
@ -77,10 +77,10 @@ func (r *PostgresTrainingRepository) FindByID(id ID) (*Training, error) {
var training Training
err := r.pg.QueryRow(ctx, `
SELECT id, name, slug, description, days
SELECT id, name, slug, description, days, published, retired
FROM training.trainings
WHERE id = $1
`, id).Scan(&training.ID, &training.Name, &training.Slug, &training.Description, &training.Days)
`, id).Scan(&training.ID, &training.Name, &training.Slug, &training.Description, &training.Days, &training.Published, &training.Retired)
if err != nil {
return nil, err
@ -122,10 +122,10 @@ func (r *PostgresTrainingRepository) FindBySlug(slug string) (*Training, error)
var training Training
err := r.pg.QueryRow(ctx, `
SELECT id, name, slug, description, days
SELECT id, name, slug, description, days, published, retired
FROM training.trainings
WHERE slug = $1
`, slug).Scan(&training.ID, &training.Name, &training.Slug, &training.Description, &training.Days)
`, slug).Scan(&training.ID, &training.Name, &training.Slug, &training.Description, &training.Days, &training.Published, &training.Retired)
if err != nil {
return nil, err
@ -172,7 +172,7 @@ func (r *PostgresTrainingRepository) FindAll() ([]Training, error) {
trainings, err := pgx.CollectRows(rows, func(row pgx.CollectableRow) (Training, error) {
var training Training
scanErr := row.Scan(&training.ID, &training.Name, &training.Slug, &training.Description, &training.Days)
scanErr := row.Scan(&training.ID, &training.Name, &training.Slug, &training.Description, &training.Days, &training.Published, &training.Retired)
if scanErr != nil {
return Training{}, scanErr
}
@ -217,9 +217,9 @@ func (r *PostgresTrainingRepository) Update(training *Training) error {
_, err = tx.Exec(ctx, `
UPDATE training.trainings
SET name = $1, slug = $2, description = $3, days = $4
SET name = $1, slug = $2, description = $3, days = $4, published = $5, retired = $6
WHERE id = $4
`, training.Name, training.Slug, training.Description, training.Days, training.ID)
`, training.Name, training.Slug, training.Description, training.Days, training.ID, training.Published, training.Retired)
if err != nil {
return err