Live video on the AT Protocol
stream.place
feeds: skip users who have streamed with no livestream
+3
-1
pkg/spxrpc/app_bsky_feed.go
+3
-1
pkg/spxrpc/app_bsky_feed.go
···
11
"github.com/bluesky-social/indigo/api/bsky"
12
appbskytypes "github.com/bluesky-social/indigo/api/bsky"
13
"github.com/labstack/echo/v4"
14
"stream.place/streamplace/pkg/model"
15
)
16
···
63
for _, seg := range segs {
64
ls, err := s.model.GetLatestLivestreamForRepo(seg.RepoDID)
65
if err != nil {
66
-
return nil, echo.NewHTTPError(http.StatusInternalServerError, fmt.Sprintf("failed to get latest livestream: %v", err))
67
}
68
posts = append(posts, model.FeedPost{
69
URI: ls.PostURI,
···
11
"github.com/bluesky-social/indigo/api/bsky"
12
appbskytypes "github.com/bluesky-social/indigo/api/bsky"
13
"github.com/labstack/echo/v4"
14
+
"stream.place/streamplace/pkg/log"
15
"stream.place/streamplace/pkg/model"
16
)
17
···
64
for _, seg := range segs {
65
ls, err := s.model.GetLatestLivestreamForRepo(seg.RepoDID)
66
if err != nil {
67
+
log.Error(ctx, "failed to get latest livestream, skipping", "repoDID", seg.RepoDID, "error", err)
68
+
continue
69
}
70
posts = append(posts, model.FeedPost{
71
URI: ls.PostURI,