+15 -15

consumer.go

··· 12 "github.com/bluesky-social/jetstream/pkg/client/schedulers/sequential" 13 "github.com/bluesky-social/jetstream/pkg/models" 14 "github.com/bugsnag/bugsnag-go" 15 - "tangled.sh/tangled.sh/core/api/tangled" 16 ) 17 18 type Issue struct { ··· 199 createdAt = time.Now().UTC() 200 } 201 202 - // TODO: if there is a reply to present, don't store the comment because replies can't be replied to so 203 // the reply comment doesn't need to be stored 204 - 205 - err = h.store.CreateComment(Comment{ 206 - AuthorDID: did, 207 - RKey: rkey, 208 - Body: comment.Body, 209 - Issue: comment.Issue, 210 - CreatedAt: createdAt.UnixMilli(), 211 - //ReplyTo: comment, // TODO: there should be a ReplyTo field that can be used as well once the right type is imported 212 - }) 213 - if err != nil { 214 - bugsnag.Notify(err) 215 - slog.Error("create comment", "error", err, "did", did, "rkey", rkey) 216 - return 217 } 218 219 // TODO: now send a notification to either the issue creator or whoever the comment was a reply to

··· 12 "github.com/bluesky-social/jetstream/pkg/client/schedulers/sequential" 13 "github.com/bluesky-social/jetstream/pkg/models" 14 "github.com/bugsnag/bugsnag-go" 15 + "tangled.org/core/api/tangled" 16 ) 17 18 type Issue struct { ··· 199 createdAt = time.Now().UTC() 200 } 201 202 + // if there is a replyTo present, don't store the comment because replies can't be replied to so 203 // the reply comment doesn't need to be stored 204 + if comment.ReplyTo == nil || *comment.ReplyTo == "" { 205 + err = h.store.CreateComment(Comment{ 206 + AuthorDID: did, 207 + RKey: rkey, 208 + Body: comment.Body, 209 + Issue: comment.Issue, 210 + CreatedAt: createdAt.UnixMilli(), 211 + }) 212 + if err != nil { 213 + bugsnag.Notify(err) 214 + slog.Error("create comment", "error", err, "did", did, "rkey", rkey) 215 + return 216 + } 217 } 218 219 // TODO: now send a notification to either the issue creator or whoever the comment was a reply to

+1 -1

go.mod

··· 8 github.com/bugsnag/bugsnag-go v2.6.2+incompatible 9 github.com/glebarez/go-sqlite v1.22.0 10 github.com/joho/godotenv v1.5.1 11 - tangled.sh/tangled.sh/core v1.8.1-alpha.0.20250828210137-07b009bd6b98 12 ) 13 14 require (

··· 8 github.com/bugsnag/bugsnag-go v2.6.2+incompatible 9 github.com/glebarez/go-sqlite v1.22.0 10 github.com/joho/godotenv v1.5.1 11 + tangled.org/core v1.9.0-alpha.0.20250924195920-24d79d05e4d2 12 ) 13 14 require (

+4 -2

go.sum

··· 103 modernc.org/memory v1.7.2/go.mod h1:NO4NVCQy0N7ln+T9ngWqOQfi7ley4vpwvARR+Hjw95E= 104 modernc.org/sqlite v1.28.0 h1:Zx+LyDDmXczNnEQdvPuEfcFVA2ZPyaD7UCZDjef3BHQ= 105 modernc.org/sqlite v1.28.0/go.mod h1:Qxpazz0zH8Z1xCFyi5GSL3FzbtZ3fvbjmywNogldEW0= 106 - tangled.sh/tangled.sh/core v1.8.1-alpha.0.20250828210137-07b009bd6b98 h1:WovrwwBufU89zoSaStoc6+qyUTEB/LxhUCM1MqGEUwU= 107 - tangled.sh/tangled.sh/core v1.8.1-alpha.0.20250828210137-07b009bd6b98/go.mod h1:zXmPB9VMsPWpJ6Y51PWnzB1fL3w69P0IhR9rTXIfGPY= 0 0

··· 103 modernc.org/memory v1.7.2/go.mod h1:NO4NVCQy0N7ln+T9ngWqOQfi7ley4vpwvARR+Hjw95E= 104 modernc.org/sqlite v1.28.0 h1:Zx+LyDDmXczNnEQdvPuEfcFVA2ZPyaD7UCZDjef3BHQ= 105 modernc.org/sqlite v1.28.0/go.mod h1:Qxpazz0zH8Z1xCFyi5GSL3FzbtZ3fvbjmywNogldEW0= 106 + tangled.org/core v1.9.0-alpha.0.20250924195920-24d79d05e4d2 h1:4bcQewZPzb7WfCuUPf4MPVWb04JiTbjbShcg5ONi9co= 107 + tangled.org/core v1.9.0-alpha.0.20250924195920-24d79d05e4d2/go.mod h1:tYTB3RkgkeDAOFE0qX/9tQB80fdlDPR+vz4CdTMar3Y= 108 + tangled.org/core v1.9.0-alpha.0.20250924200730-b2d8a54abc3d h1:DmdCyK+BZDYitJy6TdqTwvcci2EVYgDu2+LR853nyls= 109 + tangled.org/core v1.9.0-alpha.0.20250924200730-b2d8a54abc3d/go.mod h1:tYTB3RkgkeDAOFE0qX/9tQB80fdlDPR+vz4CdTMar3Y=