Pulling feat/list-content into develop

internal/repository/arangodb/arangodb.go

@@ -216,3 +216,55 @@ func (arp *arangorepository) EditContent(
 func (arp *arangorepository) Dbh() *manager.Database {
 	return arp.database
 }
+
+func (arp *arangorepository) ListContents(
+	cursor int64,
+	limit int64,
+	filter string,
+) ([]*model.ContentDoc, error) {
+	bindVars := map[string]interface{}{
+		"@content_collection": arp.content.Name(),
+		"limit":               limit + 1,
+	}
+	if cursor != 0 {
+		bindVars["cursor"] = cursor
+	}
+	stmt := getListContentStatement(filter, cursor)
+	res, err := arp.database.SearchRows(stmt, bindVars)
+	if err != nil {
+		return nil, fmt.Errorf("error in searching rows %s", err)
+	}
+	if res.IsEmpty() {
+		return nil, &repository.ContentListNotFoundError{}
+	}
+
+	contentModel := make([]*model.ContentDoc, 0)
+	for res.Scan() {
+		m := &model.ContentDoc{}
+		if err := res.Read(m); err != nil {
+			return nil, fmt.Errorf(
+				"error in reading data to structure %s",
+				err,
+			)
+		}
+		contentModel = append(contentModel, m)
+	}
+
+	return contentModel, nil
+}
+
+func getListContentStatement(filter string, cursor int64) string {
+	var stmt string
+	switch {
+	case len(filter) > 0 && cursor == 0:
+		stmt = fmt.Sprintf(ContentListFilter, filter)
+	case len(filter) > 0 && cursor != 0:
+		stmt = fmt.Sprintf(ContentListFilterWithCursor, filter)
+	case len(filter) == 0 && cursor == 0:
+		stmt = ContentList
+	case len(filter) == 0 && cursor != 0:
+		stmt = ContentListWithCursor
+	}
+
+	return stmt
+}

internal/repository/arangodb/arangodb_test.go

@@ -2,6 +2,8 @@ package arangodb
 
 import (
 	"encoding/json"
+	"fmt"
+	"regexp"
 	"strconv"
 	"testing"
 	"time"
@@ -87,6 +89,42 @@ func TestGetContentBySlug(t *testing.T) {
 	testContentProperties(assert, sct, nct)
 }
 
+func TestListContents(t *testing.T) {
+	t.Parallel()
+	assert, repo := setUp(t)
+	defer tearDown(repo)
+	for i := 0; i < 19; i++ {
+		_, err := repo.AddContent(
+			testutils.NewStoreContent(fmt.Sprintf("gallery-%d", i), "genome"),
+		)
+		assert.NoErrorf(
+			err,
+			"expect no error from creating gallery genome content %s",
+			err,
+		)
+	}
+	clist, err := repo.ListContents(0, 4, "")
+	assert.NoError(err, "expect no error from listing content")
+	assert.Len(clist, 5, "should have 5 content entries")
+	nrxp := regexp.MustCompile(`gallery-\d+`)
+	for _, cnt := range clist {
+		assert.Equal(
+			cnt.Namespace,
+			"genome",
+			"should match the genome namespace",
+		)
+		assert.Regexp(nrxp, cnt.Name, "should match gallery names")
+	}
+	assert.True(
+		clist[0].CreatedOn.After(clist[1].CreatedOn),
+		"first gallery record should be created after the second one",
+	)
+	assert.False(
+		clist[2].CreatedOn.After(clist[1].CreatedOn),
+		"third gallery record should not be created after the second one",
+	)
+}
+
 func TestGetContent(t *testing.T) {
 	t.Parallel()
 	assert, repo := setUp(t)

internal/repository/arangodb/statement.go

@@ -7,7 +7,34 @@ const (
 			LIMIT 1
 			RETURN cnt
 	`
-
+	ContentList = `
+		FOR cnt IN @@content_collection
+			SORT cnt.created_on DESC
+			LIMIT @limit
+			RETURN cnt
+	`
+	ContentListWithCursor = `
+		FOR cnt IN @@content_collection
+			FILTER cnt.created_on <= DATE_ISO8601(@cursor)
+			SORT cnt.created_on DESC
+			LIMIT @limit
+			RETURN cnt
+	`
+	ContentListFilter = `
+		FOR cnt IN @@content_collection
+			%s
+			SORT cnt.created_on DESC
+			LIMIT @limit
+			RETURN cnt
+	`
+	ContentListFilterWithCursor = `
+		FOR cnt IN @@content_collection
+			FILTER cnt.created_on <= DATE_ISO8601(@cursor)
+			%s
+			SORT cnt.created_on DESC
+			LIMIT @limit
+			RETURN cnt
+	`
 	ContentInsert = `
 		INSERT {
 			name: @name,

internal/repository/repository.go

@@ -15,5 +15,24 @@ type ContentRepository interface {
 		cnt *content.ExistingContentAttributes,
 	) (*model.ContentDoc, error)
 	DeleteContent(cid int64) error
+	ListContents(
+		cursor int64,
+		limit int64,
+		filter string,
+	) ([]*model.ContentDoc, error)
 	Dbh() *manager.Database
 }
+
+type ContentListNotFoundError struct{}
+
+func (al *ContentListNotFoundError) Error() string {
+	return "annotation list not found"
+}
+
+func IsContentListNotFound(err error) bool {
+	if _, ok := err.(*ContentListNotFoundError); ok {
+		return true
+	}
+
+	return false
+}