refactor

Author: danicc097

internal/rest/api_user.go

@@ -3,8 +3,6 @@ package rest
 import (
 	"errors"
 	"fmt"
-	"reflect"
-	"time"
 
 	"github.com/danicc097/openapi-go-gin-postgres-sqlc/internal/repos/postgresql/gen/models"
 	"github.com/gin-gonic/gin"
@@ -91,43 +89,6 @@ func (h *StrictHandlers) UpdateUserAuthorization(c *gin.Context, request UpdateU
 	return UpdateUserAuthorization204Response{}, nil
 }
 
-func formatCursorValue(value interface{}) (string, error) {
-	switch v := value.(type) {
-	case time.Time:
-		return v.Format(time.RFC3339Nano), nil
-	case string:
-		return v, nil
-	case int, int8, int16, int32, int64:
-		return fmt.Sprintf("%d", v), nil
-	default:
-		return "", fmt.Errorf("unhandled cursor type: %v", v)
-	}
-}
-
-func getNextCursor(entity interface{}, jsonFieldName string, tableEntity models.TableEntity) (string, error) {
-	if entity == nil {
-		return "", fmt.Errorf("no entity given")
-	}
-
-	if _, ok := models.EntityFields[tableEntity]; !ok {
-		return "", fmt.Errorf("no entity found")
-	}
-
-	entityType := reflect.TypeOf(entity)
-	entityValue := reflect.ValueOf(entity)
-
-	for i := 0; i < entityType.NumField(); i++ {
-		structField := entityType.Field(i)
-		jsonTag := structField.Tag.Get("json")
-		if jsonTag == jsonFieldName {
-			fieldValue := entityValue.Field(i).Interface()
-			return formatCursorValue(fieldValue)
-		}
-	}
-
-	return "", fmt.Errorf("no json tag with value: %v", jsonFieldName)
-}
-
 func (h *StrictHandlers) GetPaginatedUsers(c *gin.Context, request GetPaginatedUsersRequestObject) (GetPaginatedUsersResponseObject, error) {
 	users, err := h.svc.User.Paginated(c, h.pool, request.Params)
 	if err != nil {

internal/rest/pagination.go

@@ -0,0 +1,48 @@
+package rest
+
+import (
+	"fmt"
+	"reflect"
+	"time"
+
+	"github.com/danicc097/openapi-go-gin-postgres-sqlc/internal/repos/postgresql/gen/models"
+)
+
+func formatCursorValue(value interface{}) (string, error) {
+	switch v := value.(type) {
+	case time.Time:
+		return v.Format(time.RFC3339Nano), nil
+	case string:
+		return v, nil
+	case int, int8, int16, int32, int64:
+		return fmt.Sprintf("%d", v), nil
+	default:
+		return "", fmt.Errorf("unhandled cursor type: %v", v)
+	}
+}
+
+// getNextCursor returns the next cursor from an entity struct by a given json tag.
+// This allows for dynamic pagination parameters.
+func getNextCursor(entity interface{}, jsonFieldName string, tableEntity models.TableEntity) (string, error) {
+	if entity == nil {
+		return "", fmt.Errorf("no entity given")
+	}
+
+	if _, ok := models.EntityFields[tableEntity]; !ok {
+		return "", fmt.Errorf("no entity found")
+	}
+
+	entityType := reflect.TypeOf(entity)
+	entityValue := reflect.ValueOf(entity)
+
+	for i := 0; i < entityType.NumField(); i++ {
+		structField := entityType.Field(i)
+		jsonTag := structField.Tag.Get("json")
+		if jsonTag == jsonFieldName {
+			fieldValue := entityValue.Field(i).Interface()
+			return formatCursorValue(fieldValue)
+		}
+	}
+
+	return "", fmt.Errorf("no json tag with value: %v", jsonFieldName)
+}