list_projects_created_by.go

package postgres

import (
	"context"
	"fmt"

	"github.com/pkg/errors"
	"github.com/thavlik/t4vd/sources/pkg/api"
)

func (s *postgresStore) ListProjectsCreatedBy(
	ctx context.Context,
	userID string,
) (projects []*api.Project, err error) {
	rows, err := s.db.QueryContext(
		ctx,
		fmt.Sprintf(`
			SELECT id, name, creator, created, groupid
			FROM %s
			WHERE creator = $1`,
			projectsTable,
		),
		userID,
	)
	if err != nil {
		return nil, errors.Wrap(err, "postgres")
	}
	defer rows.Close()
	for rows.Next() {
		project := &api.Project{}
		if err := rows.Scan(
			&project.ID,
			&project.Name,
			&project.CreatorID,
			&project.Created,
			&project.GroupID,
		); err != nil {
			return nil, errors.Wrap(err, "scan")
		}
		projects = append(projects, project)
	}
	return projects, nil
}