commit f0a564b1447e921004c7db2955441eba331a2f3b · hailey.at/peruse

+13 -10
peruse/handle_wikidata_feed.go
···

       5
       5
        
       	"encoding/json"

     

       6
       6
        
       	"fmt"

     

       7
       7
        
       	"log/slog"

     

       8
       8
       +
       	"strconv"

     

       8
       9
        
       	"strings"

     

       9
       10
        
       	"sync"

     

       10
       11
        
       	"time"

     
···

       82
       83
        
       func (f *WikidataFeed) FeedSkeleton(e echo.Context, req FeedSkeletonRequest) error {

     

       83
       84
        
       	ctx := e.Request().Context()

     

       84
       85
        
       

     

       85
       85
       -
       	cursor, err := getTimeBasedCursor(req)

     

       86
       86
       -
       	if err != nil {

     

       87
       87
       -
       		f.logger.Error("error getting cursor", "error", err)

     

       88
       88
       -
       		return helpers.InputError(e, "FeedError", "Invalid cursor for feed")

     

       86
       86
       +
       	var cursor int

     

       87
       87
       +
       	if req.Cursor != "" {

     

       88
       88
       +
       		cursor64, err := strconv.ParseInt(req.Cursor, 10, 32)

     

       89
       89
       +
       		if err != nil {

     

       90
       90
       +
       			f.logger.Error("error converting cursor", "error", err)

     

       91
       91
       +
       		}

     

       92
       92
       +
       		cursor = int(cursor64)

     

       89
       93
        
       	}

     

       90
       94
        
       

     

       91
       95
        
       	posts, err := f.getPosts(ctx)

     
···

       94
       98
        
       		return helpers.ServerError(e, "FeedError", "Unable to get posts for feed")

     

       95
       99
        
       	}

     

       96
       100
        
       

     

       97
       97
       -
       	for i, p := range posts {

     

       98
       98
       -
       		if p.CreatedAt == cursor {

     

       99
       99
       -
       			posts = posts[i:]

     

       100
       100
       -
       			break

     

       101
       101
       -
       		}

     

       101
       101
       +
       	if len(posts) < cursor {

     

       102
       102
       +
       		cursor = len(posts)

     

       102
       103
        
       	}

     

       104
       104
       +
       

     

       105
       105
       +
       	posts = posts[cursor:]

     

       103
       106
        
       

     

       104
       107
        
       	if len(posts) > 30 {

     

       105
       108
        
       		posts = posts[:30]

     
···

       112
       115
        
       		})

     

       113
       116
        
       	}

     

       114
       117
        
       

     

       115
       115
       -
       	newCursor := fmt.Sprintf("%d", posts[len(posts)-1].CreatedAt.UnixMilli())

     

       118
       118
       +
       	newCursor := fmt.Sprintf("%d", cursor+len(posts))

     

       116
       119
        
       

     

       117
       120
        
       	return e.JSON(200, FeedSkeletonResponse{

     

       118
       121
        
       		Feed:   items,