···

       
1
       
1
       
 
       
module github.com/edavis/bsky-feeds

     

       
2
       
2
       
 
       


     

       
3
       
3
       
-
       
go 1.23.0

     

       
3
       
3
       
+
       
go 1.24

     

       
4
       
4
       
+
       


     

       
5
       
5
       
+
       
toolchain go1.24.4

     

       
4
       
6
       
 
       


     

       
5
       
7
       
 
       
require (

     

       
6
       
6
       
-
       
	github.com/bluesky-social/indigo v0.0.0-20240905024844-a4f38639767f

     

       
8
       
8
       
+
       
	github.com/bluesky-social/indigo v0.0.0-20250703203720-0f3058806983

     

       
7
       
9
       
 
       
	github.com/bluesky-social/jetstream v0.0.0-20241020000921-dcd43344c716

     

       
8
       
10
       
 
       
	github.com/gorilla/websocket v1.5.3

     

       
9
       
11
       
 
       
	github.com/karlseguin/ccache/v3 v3.0.5

     
···

       
55
       
57
       
 
       
	github.com/spaolacci/murmur3 v1.1.0 // indirect

     

       
56
       
58
       
 
       
	github.com/valyala/bytebufferpool v1.0.0 // indirect

     

       
57
       
59
       
 
       
	github.com/valyala/fasttemplate v1.2.2 // indirect

     

       
58
       
58
       
-
       
	github.com/whyrusleeping/cbor-gen v0.1.3-0.20240904181319-8dc02b38228c // indirect

     

       
60
       
60
       
+
       
	github.com/whyrusleeping/cbor-gen v0.2.1-0.20241030202151-b7a6831be65e // indirect

     

       
59
       
61
       
 
       
	go.opentelemetry.io/contrib/instrumentation/net/http/otelhttp v0.46.1 // indirect

     

       
60
       
62
       
 
       
	go.opentelemetry.io/otel v1.21.0 // indirect

     

       
61
       
63
       
 
       
	go.opentelemetry.io/otel/metric v1.21.0 // indirect

     

···

       
1
       
1
       
 
       
github.com/BurntSushi/toml v0.3.1/go.mod h1:xHWCNGjB5oqiDr8zfno3MHue2Ht5sIBksp03qcyfWMU=

     

       
2
       
2
       
 
       
github.com/benbjohnson/clock v1.1.0/go.mod h1:J11/hYXuz8f4ySSvYwY0FKfm+ezbsZBKZxNJlLklBHA=

     

       
3
       
3
       
-
       
github.com/bluesky-social/indigo v0.0.0-20240905024844-a4f38639767f h1:Q9cfCAlYWIWPsSDhg5w6qcutQ7YaJtfTjiRLP/mw+pc=

     

       
4
       
4
       
-
       
github.com/bluesky-social/indigo v0.0.0-20240905024844-a4f38639767f/go.mod h1:Zx9nSWgd/FxMenkJW07VKnzspxpHBdPrPmS+Fspl2I0=

     

       
5
       
5
       
-
       
github.com/bluesky-social/jetstream v0.0.0-20240925210745-2cd1b6147279 h1:45wwXL1io7pAcgqFMBHFi2GdF4CRg0/4Sq65JY3PfkM=

     

       
6
       
6
       
-
       
github.com/bluesky-social/jetstream v0.0.0-20240925210745-2cd1b6147279/go.mod h1:/GMZrwKMbAiWU2MVCswH8+Jd3ybrpkHX4qM6tTfyv1k=

     

       
3
       
3
       
+
       
github.com/bluesky-social/indigo v0.0.0-20250703203720-0f3058806983 h1:nLyzyJRFa1NiglgvKYa6k4WIC31vX5YtxGnXM9trMMQ=

     

       
4
       
4
       
+
       
github.com/bluesky-social/indigo v0.0.0-20250703203720-0f3058806983/go.mod h1:tM+dqMA0M4vbpXB2qAcDpBwRC5VUHxGwEh/TQvHeTNA=

     

       
7
       
5
       
 
       
github.com/bluesky-social/jetstream v0.0.0-20241020000921-dcd43344c716 h1:I8+VaZKaNIGCPGXE2/VXzJGlPFEZgiFLjnge+OWFl5w=

     

       
8
       
6
       
 
       
github.com/bluesky-social/jetstream v0.0.0-20241020000921-dcd43344c716/go.mod h1:/dE2dmFell/m4zxgIbH3fkiqZ1obzr/ETj4RpgomgMs=

     

       
9
       
7
       
 
       
github.com/carlmjohnson/versioninfo v0.22.5 h1:O00sjOLUAFxYQjlN/bzYTuZiS0y6fWDQjMRvwtKgwwc=

     
···

       
150
       
148
       
 
       
github.com/valyala/fasttemplate v1.2.2/go.mod h1:KHLXt3tVN2HBp8eijSv/kGJopbvo7S+qRAEEKiv+SiQ=

     

       
151
       
149
       
 
       
github.com/warpfork/go-wish v0.0.0-20220906213052-39a1cc7a02d0 h1:GDDkbFiaK8jsSDJfjId/PEGEShv6ugrt4kYsC5UIDaQ=

     

       
152
       
150
       
 
       
github.com/warpfork/go-wish v0.0.0-20220906213052-39a1cc7a02d0/go.mod h1:x6AKhvSSexNrVSrViXSHUEbICjmGXhtgABaHIySUSGw=

     

       
153
       
153
       
-
       
github.com/whyrusleeping/cbor-gen v0.1.3-0.20240904181319-8dc02b38228c h1:UsxJNcLPfyLyVaA4iusIrsLAqJn/xh36Qgb8emqtXzk=

     

       
154
       
154
       
-
       
github.com/whyrusleeping/cbor-gen v0.1.3-0.20240904181319-8dc02b38228c/go.mod h1:pM99HXyEbSQHcosHc0iW7YFmwnscr+t9Te4ibko05so=

     

       
151
       
151
       
+
       
github.com/whyrusleeping/cbor-gen v0.2.1-0.20241030202151-b7a6831be65e h1:28X54ciEwwUxyHn9yrZfl5ojgF4CBNLWX7LR0rvBkf4=

     

       
152
       
152
       
+
       
github.com/whyrusleeping/cbor-gen v0.2.1-0.20241030202151-b7a6831be65e/go.mod h1:pM99HXyEbSQHcosHc0iW7YFmwnscr+t9Te4ibko05so=

     

       
155
       
153
       
 
       
github.com/yuin/goldmark v1.1.27/go.mod h1:3hX8gzYuyVAZsxl0MRgGTJEmQBFcNTphYh9decYSb74=

     

       
156
       
154
       
 
       
github.com/yuin/goldmark v1.2.1/go.mod h1:3hX8gzYuyVAZsxl0MRgGTJEmQBFcNTphYh9decYSb74=

     

       
157
       
155
       
 
       
github.com/yuin/goldmark v1.3.5/go.mod h1:mwnBkeHKe2W/ZEtQ+71ViKU8L12m81fl3OWwC1Zlc8k=

     

···

       
77
       
77
       
 
       
		}

     

       
78
       
78
       
 
       
	}

     

       
79
       
79
       
 
       


     

       
80
       
80
       
-
       
	rows, err := getPosts(ctx, dbCnx, langs, params.Limit, offset)

     

       
80
       
80
       
+
       
	rows, err := getPosts(ctx, dbCnx, langs, params.Limit-1, offset)

     

       
81
       
81
       
 
       
	if err != nil {

     

       
82
       
82
       
 
       
		log.Printf("error fetching rows: %v\n", err)

     

       
83
       
83
       
 
       
	}

     

       
84
       
84
       
 
       


     

       
85
       
85
       
 
       
	var cursor string

     

       
86
       
86
       
 
       
	posts := make([]*appbsky.FeedDefs_SkeletonFeedPost, 0, params.Limit)

     

       
87
       
87
       
+
       


     

       
88
       
88
       
+
       
	posts = append(posts, &appbsky.FeedDefs_SkeletonFeedPost{

     

       
89
       
89
       
+
       
		Post: "at://did:plc:4nsduwlpivpuur4mqkbfvm6a/app.bsky.feed.post/3ltbfk5yfbs2n",

     

       
90
       
90
       
+
       
		Reason: &appbsky.FeedDefs_SkeletonFeedPost_Reason{

     

       
91
       
91
       
+
       
			FeedDefs_SkeletonReasonPin: &appbsky.FeedDefs_SkeletonReasonPin{},

     

       
92
       
92
       
+
       
		},

     

       
93
       
93
       
+
       
	})

     

       
87
       
94
       
 
       


     

       
88
       
95
       
 
       
	for _, row := range rows {

     

       
89
       
96
       
 
       
		posts = append(posts, &appbsky.FeedDefs_SkeletonFeedPost{Post: row.Uri})

     

···

       
77
       
77
       
 
       
		}

     

       
78
       
78
       
 
       
	}

     

       
79
       
79
       
 
       


     

       
80
       
80
       
-
       
	rows, err := getPosts(ctx, dbCnx, langs, params.Limit, offset)

     

       
80
       
80
       
+
       
	rows, err := getPosts(ctx, dbCnx, langs, params.Limit-1, offset)

     

       
81
       
81
       
 
       
	if err != nil {

     

       
82
       
82
       
 
       
		log.Printf("error fetching rows: %v\n", err)

     

       
83
       
83
       
 
       
	}

     

       
84
       
84
       
 
       


     

       
85
       
85
       
 
       
	var cursor string

     

       
86
       
86
       
 
       
	posts := make([]*appbsky.FeedDefs_SkeletonFeedPost, 0, params.Limit)

     

       
87
       
87
       
+
       


     

       
88
       
88
       
+
       
	posts = append(posts, &appbsky.FeedDefs_SkeletonFeedPost{

     

       
89
       
89
       
+
       
		Post: "at://did:plc:4nsduwlpivpuur4mqkbfvm6a/app.bsky.feed.post/3ltbfk5yfbs2n",

     

       
90
       
90
       
+
       
		Reason: &appbsky.FeedDefs_SkeletonFeedPost_Reason{

     

       
91
       
91
       
+
       
			FeedDefs_SkeletonReasonPin: &appbsky.FeedDefs_SkeletonReasonPin{},

     

       
92
       
92
       
+
       
		},

     

       
93
       
93
       
+
       
	})

     

       
87
       
94
       
 
       


     

       
88
       
95
       
 
       
	for _, row := range rows {

     

       
89
       
96
       
 
       
		posts = append(posts, &appbsky.FeedDefs_SkeletonFeedPost{Post: row.Uri})