summaryrefslogtreecommitdiff
path: root/srv/src/post/post.go
diff options
context:
space:
mode:
Diffstat (limited to 'srv/src/post/post.go')
-rw-r--r--srv/src/post/post.go26
1 files changed, 20 insertions, 6 deletions
diff --git a/srv/src/post/post.go b/srv/src/post/post.go
index 30ded15..cadfcfc 100644
--- a/srv/src/post/post.go
+++ b/srv/src/post/post.go
@@ -74,21 +74,33 @@ type Store interface {
// ascending, or empty slice.
GetByTag(tag string) ([]StoredPost, error)
+ // WithOrderDesc will return a Store whose Get operations return Posts in
+ // time descending order, rather than ascending.
+ WithOrderDesc() Store
+
// Delete will delete the StoredPost with the given ID.
Delete(id string) error
}
type store struct {
- db *sql.DB
+ db *sql.DB
+ order string
}
// NewStore initializes a new Store using an existing SQLDB.
func NewStore(db *SQLDB) Store {
return &store{
- db: db.db,
+ db: db.db,
+ order: "ASC",
}
}
+func (s *store) WithOrderDesc() Store {
+ s2 := *s
+ s2.order = "DESC"
+ return &s2
+}
+
// if the callback returns an error then the transaction is aborted.
func (s *store) withTx(cb func(*sql.Tx) error) error {
@@ -185,15 +197,17 @@ func (s *store) get(
[]StoredPost, error,
) {
- query := `
- SELECT
+ query := fmt.Sprintf(
+ `SELECT
p.id, p.title, p.description, p.series, pt.tag,
p.published_at, p.last_updated_at,
p.body
FROM posts p
LEFT JOIN post_tags pt ON (p.id = pt.post_id)
- ` + where + `
- ORDER BY p.published_at ASC, p.title ASC`
+ `+where+`
+ ORDER BY p.published_at %s, p.title %s`,
+ s.order, s.order,
+ )
if limit > 0 {
query += fmt.Sprintf(" LIMIT %d", limit)