edavis.dev
this repo has no description
feat: move post trimming out of the goroutine
+4
-17
+4
-17
pkg/mostliked/handler.go
+4
-17
pkg/mostliked/handler.go
···
36
36
Transferred int
37
37
}
38
38
39
-
func trimPostsTable(ctx context.Context, queries *db.Queries) {
40
-
ticker := time.NewTicker(1 * time.Minute)
41
-
defer ticker.Stop()
42
-
43
-
for {
44
-
select {
45
-
case <-ticker.C:
46
-
log.Printf("clearing expired posts\n")
47
-
if err := queries.TrimPosts(ctx); err != nil {
48
-
log.Printf("error clearing expired posts: %v\n", err)
49
-
}
50
-
}
51
-
}
52
-
}
53
-
54
39
func findDetectableText(post appbsky.FeedPost) string {
55
40
// if we have text, detect against that
56
41
// no text but we do have images, detect against first alt text
···
92
77
FromLanguages(languages...).
93
78
WithPreloadedLanguageModels().
94
79
Build()
95
-
96
-
go trimPostsTable(ctx, queries)
97
80
98
81
var (
99
82
dbTx *sql.Tx
···
191
174
192
175
eventCount += 1
193
176
if eventCount%1000 == 0 {
177
+
if err := queriesTx.TrimPosts(ctx); err != nil {
178
+
log.Printf("error clearing expired posts: %v\n", err)
179
+
}
180
+
194
181
if err := dbTx.Commit(); err != nil {
195
182
log.Printf("commit failed: %v\n", err)
196
183
}