Fix pagination to use indexed_at for chronological order

- Order by indexed_at DESC instead of uri for proper time ordering
- Use indexed_at timestamp as cursor instead of URI
- Load more now shows older posts in correct chronological order

Author: daviddao

internal/database/repositories/records.go

@@ -242,21 +242,23 @@ func (r *RecordsRepository) GetByCollection(ctx context.Context, collection stri
 }
 
 // GetByCollectionWithCursor retrieves records for a specific collection with cursor-based pagination.
-// The cursor is the URI of the last record from the previous page.
-func (r *RecordsRepository) GetByCollectionWithCursor(ctx context.Context, collection string, limit int, afterURI string) ([]*Record, error) {
+// The cursor is the indexed_at timestamp of the last record from the previous page.
+// Records are ordered by indexed_at DESC (newest first) for chronological feed display.
+func (r *RecordsRepository) GetByCollectionWithCursor(ctx context.Context, collection string, limit int, afterTimestamp string) ([]*Record, error) {
 	var sqlStr string
 	var args []any
 
-	if afterURI == "" {
-		// No cursor - get first page
-		sqlStr = fmt.Sprintf("SELECT %s FROM record WHERE collection = %s ORDER BY uri DESC LIMIT %d",
+	if afterTimestamp == "" {
+		// No cursor - get first page, ordered by indexed_at DESC (newest first)
+		sqlStr = fmt.Sprintf("SELECT %s FROM record WHERE collection = %s ORDER BY indexed_at DESC, uri DESC LIMIT %d",
 			r.recordColumns(), r.db.Placeholder(1), limit)
 		args = []any{collection}
 	} else {
-		// With cursor - get records after the cursor (URI is used for stable ordering)
-		sqlStr = fmt.Sprintf("SELECT %s FROM record WHERE collection = %s AND uri < %s ORDER BY uri DESC LIMIT %d",
+		// With cursor - get records older than the cursor timestamp
+		// Using indexed_at < cursor for "load more" (older posts)
+		sqlStr = fmt.Sprintf("SELECT %s FROM record WHERE collection = %s AND indexed_at < %s ORDER BY indexed_at DESC, uri DESC LIMIT %d",
 			r.recordColumns(), r.db.Placeholder(1), r.db.Placeholder(2), limit)
-		args = []any{collection, afterURI}
+		args = []any{collection, afterTimestamp}
 	}
 
 	rows, err := r.db.DB().QueryContext(ctx, sqlStr, args...)

internal/graphql/schema/builder.go

@@ -321,18 +321,18 @@ func (b *Builder) createGenericRecordsResolver() graphql.FieldResolveFn {
 		}
 		after, _ := p.Args["after"].(string)
 
-		// Decode cursor to URI if provided
-		var afterURI string
+		// Decode cursor to timestamp if provided
+		var afterTimestamp string
 		if after != "" {
 			var err error
-			afterURI, err = decodeCursor(after)
+			afterTimestamp, err = decodeCursor(after)
 			if err != nil {
 				return nil, fmt.Errorf("invalid cursor: %w", err)
 			}
 		}
 
-		// Query database with cursor
-		records, err := repos.Records.GetByCollectionWithCursor(p.Context, collection, first+1, afterURI)
+		// Query database with cursor (ordered by indexed_at DESC)
+		records, err := repos.Records.GetByCollectionWithCursor(p.Context, collection, first+1, afterTimestamp)
 		if err != nil {
 			return nil, fmt.Errorf("failed to query records: %w", err)
 		}
@@ -354,7 +354,8 @@ func (b *Builder) createGenericRecordsResolver() graphql.FieldResolveFn {
 				value = map[string]interface{}{"raw": rec.JSON}
 			}
 
-			cursor := encodeCursor(rec.URI)
+			// Use indexed_at as cursor for chronological pagination
+			cursor := encodeCursor(rec.IndexedAt.Format("2006-01-02 15:04:05"))
 			if startCursor == "" {
 				startCursor = cursor
 			}
@@ -404,18 +405,19 @@ func (b *Builder) createCollectionResolver(lexiconID string) graphql.FieldResolv
 			first = 20
 		}
 
-		// Decode cursor to URI if provided
-		var afterURI string
+		// Decode cursor to timestamp if provided
+		var afterTimestamp string
 		if after != "" {
 			var err error
-			afterURI, err = decodeCursor(after)
+			afterTimestamp, err = decodeCursor(after)
 			if err != nil {
 				return nil, fmt.Errorf("invalid cursor: %w", err)
 			}
 		}
 
 		// Query database with cursor (fetch one extra to determine hasNextPage)
-		records, err := repos.Records.GetByCollectionWithCursor(p.Context, lexiconID, first+1, afterURI)
+		// Ordered by indexed_at DESC for chronological display
+		records, err := repos.Records.GetByCollectionWithCursor(p.Context, lexiconID, first+1, afterTimestamp)
 		if err != nil {
 			return nil, fmt.Errorf("failed to query records: %w", err)
 		}
@@ -441,7 +443,8 @@ func (b *Builder) createCollectionResolver(lexiconID string) graphql.FieldResolv
 			data["uri"] = rec.URI
 			data["cid"] = rec.CID
 
-			cursor := encodeCursor(rec.URI)
+			// Use indexed_at as cursor for chronological pagination
+			cursor := encodeCursor(rec.IndexedAt.Format("2006-01-02 15:04:05"))
 			if startCursor == "" {
 				startCursor = cursor
 			}