Prep for implementing commands

Author: theandrew168

backend/command/command.go

@@ -0,0 +1,16 @@
+package command
+
+import (
+	"github.com/theandrew168/bloggulus/backend/repository"
+)
+
+type Command struct {
+	repo *repository.Repository
+}
+
+func New(repo *repository.Repository) *Command {
+	cmd := Command{
+		repo: repo,
+	}
+	return &cmd
+}

backend/command/session.go

@@ -0,0 +1,13 @@
+package command
+
+import (
+	"time"
+
+	"github.com/theandrew168/bloggulus/backend/repository"
+)
+
+func (cmd *Command) DeleteExpiredSessions(now time.Time) error {
+	return cmd.repo.WithTransaction(func(tx *repository.Repository) error {
+		return nil
+	})
+}

backend/postgres/errors.go

@@ -51,9 +51,6 @@ delete (CollectOneRow) - does not exist
 var (
 	ErrNotFound = errors.New("postgres: not found")
 	ErrConflict = errors.New("postgres: conflict")
-
-	// sentinel error used to rollback transactions
-	ErrRollback = errors.New("postgres: rollback")
 )
 
 func CheckCreateError(err error) error {

backend/query/article.go

@@ -22,7 +22,7 @@ type Article struct {
 	Tags        []string  `db:"tags"`
 }
 
-func (f *Query) ListArticles(limit, offset int) ([]Article, error) {
+func (qry *Query) ListArticles(limit, offset int) ([]Article, error) {
 	stmt := `
 		WITH latest AS (
 			SELECT
@@ -51,7 +51,7 @@ func (f *Query) ListArticles(limit, offset int) ([]Article, error) {
 	ctx, cancel := context.WithTimeout(context.Background(), postgres.Timeout)
 	defer cancel()
 
-	rows, err := f.conn.Query(ctx, stmt, limit, offset)
+	rows, err := qry.conn.Query(ctx, stmt, limit, offset)
 	if err != nil {
 		return nil, err
 	}

backend/query/blog.go

@@ -17,7 +17,7 @@ type BlogForAccount struct {
 }
 
 // TODO: Paginate this (will need to add a CountBlogsForAccount method).
-func (f *Query) ListBlogsForAccount(account *model.Account) ([]BlogForAccount, error) {
+func (qry *Query) ListBlogsForAccount(account *model.Account) ([]BlogForAccount, error) {
 	stmt := `
 		SELECT
 			blog.id,
@@ -33,7 +33,7 @@ func (f *Query) ListBlogsForAccount(account *model.Account) ([]BlogForAccount, e
 	ctx, cancel := context.WithTimeout(context.Background(), postgres.Timeout)
 	defer cancel()
 
-	rows, err := f.conn.Query(ctx, stmt, account.ID())
+	rows, err := qry.conn.Query(ctx, stmt, account.ID())
 	if err != nil {
 		return nil, err
 	}

backend/query/query.go

@@ -10,8 +10,8 @@ type Query struct {
 }
 
 func New(conn postgres.Conn) *Query {
-	f := Query{
+	qry := Query{
 		conn: conn,
 	}
-	return &f
+	return &qry
 }