edavis.dev
+4
-4
cmd/mostliked/main.go
+4
-4
cmd/mostliked/main.go
···
28
if err := conn.Close(); err != nil {
29
log.Printf("failed to close websocket: %v\n", err)
30
}
31
-
log.Println("websocket closed")
32
}()
33
34
dbCnx, err := sql.Open("sqlite3", "data/mostliked.db?_journal=WAL&_fk=on&_timeout=5000")
···
42
if err := dbCnx.Close(); err != nil {
43
log.Printf("failed to close db: %v\n", err)
44
}
45
-
log.Println("db closed")
46
}()
47
48
jetstreamEvents := make(chan []byte)
49
go mostliked.Handler(ctx, jetstreamEvents, dbCnx)
50
51
-
log.Println("starting up")
52
go func() {
53
for {
54
_, message, err := conn.ReadMessage()
···
60
}()
61
62
<-ctx.Done()
63
-
log.Println("shutting down")
64
}
···
28
if err := conn.Close(); err != nil {
29
log.Printf("failed to close websocket: %v\n", err)
30
}
31
+
log.Printf("websocket closed\n")
32
}()
33
34
dbCnx, err := sql.Open("sqlite3", "data/mostliked.db?_journal=WAL&_fk=on&_timeout=5000")
···
42
if err := dbCnx.Close(); err != nil {
43
log.Printf("failed to close db: %v\n", err)
44
}
45
+
log.Printf("db closed\n")
46
}()
47
48
jetstreamEvents := make(chan []byte)
49
go mostliked.Handler(ctx, jetstreamEvents, dbCnx)
50
51
+
log.Printf("starting up\n")
52
go func() {
53
for {
54
_, message, err := conn.ReadMessage()
···
60
}()
61
62
<-ctx.Done()
63
+
log.Printf("shutting down\n")
64
}
+2
-2
pkg/mostliked/generator.go
+2
-2
pkg/mostliked/generator.go
···
72
if parsed, err := strconv.Atoi(params.Cursor); err == nil {
73
offset = parsed
74
} else {
75
-
log.Println("error converting cursor")
76
}
77
78
rows, err := getPosts(ctx, dbCnx, langs, params.Limit, offset)
79
if err != nil {
80
-
log.Println("error fetching rows:", err)
81
}
82
83
var cursor string
···
72
if parsed, err := strconv.Atoi(params.Cursor); err == nil {
73
offset = parsed
74
} else {
75
+
log.Printf("error converting cursor: %v\n", err)
76
}
77
78
rows, err := getPosts(ctx, dbCnx, langs, params.Limit, offset)
79
if err != nil {
80
+
log.Printf("error fetching rows: %v\n", err)
81
}
82
83
var cursor string
+5
-6
pkg/mostliked/handler.go
+5
-6
pkg/mostliked/handler.go
···
43
for {
44
select {
45
case <-ticker.C:
46
-
log.Println("starting to trim old posts")
47
if err := queries.TrimPosts(ctx); err != nil {
48
-
log.Printf("error trimming posts: %v\n", err)
49
}
50
}
51
}
···
116
var like appbsky.FeedLike
117
var event jetstream.Event
118
if err := json.Unmarshal(evt, &event); err != nil {
119
-
log.Println("error parsing jetstream event")
120
continue
121
}
122
if event.Commit == nil {
···
130
var post appbsky.FeedPost
131
postUri := fmt.Sprintf("at://%s/%s/%s", event.Did, commit.Collection, commit.RKey)
132
if err := json.Unmarshal(commit.Record, &post); err != nil {
133
-
log.Println("error parsing appbsky.FeedPost")
134
continue
135
}
136
draftPost := DraftPost{
···
151
continue
152
} else if commit.Collection == "app.bsky.feed.like" {
153
if err := json.Unmarshal(commit.Record, &like); err != nil {
154
-
log.Println("error parsing appbsky.FeedLike")
155
continue
156
}
157
}
···
165
continue
166
}
167
drafts.Delete(like.Subject.Uri)
168
-
// log.Println("storing", like.Subject.Uri, "in database")
169
err := queriesTx.InsertPost(ctx, db.InsertPostParams{
170
Uri: like.Subject.Uri,
171
CreateTs: draftPost.Created,
···
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
}
···
116
var like appbsky.FeedLike
117
var event jetstream.Event
118
if err := json.Unmarshal(evt, &event); err != nil {
119
+
log.Printf("error parsing jetstream event: %v\n", err)
120
continue
121
}
122
if event.Commit == nil {
···
130
var post appbsky.FeedPost
131
postUri := fmt.Sprintf("at://%s/%s/%s", event.Did, commit.Collection, commit.RKey)
132
if err := json.Unmarshal(commit.Record, &post); err != nil {
133
+
log.Printf("error parsing appbsky.FeedPost: %v\n", err)
134
continue
135
}
136
draftPost := DraftPost{
···
151
continue
152
} else if commit.Collection == "app.bsky.feed.like" {
153
if err := json.Unmarshal(commit.Record, &like); err != nil {
154
+
log.Printf("error parsing appbsky.FeedLike: %v\n", err)
155
continue
156
}
157
}
···
165
continue
166
}
167
drafts.Delete(like.Subject.Uri)
168
err := queriesTx.InsertPost(ctx, db.InsertPostParams{
169
Uri: like.Subject.Uri,
170
CreateTs: draftPost.Created,