add outgoing posts graph

dimkr · Jun 6, 2023 · 5531df2 · 5531df2
1 parent 5214cb4
commit 5531df2
Show file tree

Hide file tree

Showing 3 changed files with 18 additions and 1 deletion.
diff --git a/data/garbage.go b/data/garbage.go
@@ -26,7 +26,7 @@ import (
 
 const (
 	notesTTL    = time.Hour * 24 * 30
-	deliveryTTL = time.Hour * 24
+	deliveryTTL = time.Hour * 24 * 7
 )
 
 func CollectGarbage(ctx context.Context, db *sql.DB) error {

diff --git a/data/schema.go b/data/schema.go
@@ -77,6 +77,10 @@ func Migrate(ctx context.Context, db *sql.DB) error {
 		return err
 	}
 
+	if _, err := db.ExecContext(ctx, `CREATE INDEX IF NOT EXISTS deliveriesinserted ON deliveries(inserted)`); err != nil {
+		return err
+	}
+
 	if _, err := db.ExecContext(ctx, `CREATE INDEX IF NOT EXISTS hashtagshashtag ON hashtags(hashtag)`); err != nil {
 		return err
 	}

diff --git a/front/stats.go b/front/stats.go
@@ -63,6 +63,12 @@ func getWeeklyPostsGraph(r *request) string {
 	return getGraph(r, `select strftime('%Y-%m-%d', datetime(inserted*60*60*24, 'unixepoch')), count(*) from (select inserted/(60*60*24) as inserted from notes where inserted>unixepoch()-60*60*24*7 and inserted<unixepoch()/(60*60*24)*(60*60*24)) group by inserted order by inserted`, keys, values)
 }
 
+func getWeeklyDeliveriesGraph(r *request) string {
+	keys := make([]string, 7)
+	values := make([]int64, 7)
+	return getGraph(r, `select strftime('%Y-%m-%d %H:%M', datetime(day*60*60*24, 'unixepoch')), count(*) from (select inserted/(60*60*24) as day from deliveries where inserted>unixepoch()-60*60*24*7 and inserted<unixepoch()/(60*60*24)*60*60*24) group by day order by day`, keys, values)
+}
+
 func getUsersGraph(r *request) string {
 	keys := make([]string, 24)
 	values := make([]int64, 24)
@@ -155,6 +161,7 @@ func stats(w text.Writer, r *request) {
 
 	dailyPostsGraph := getDailyPostsGraph(r)
 	weeklyPostsGraph := getWeeklyPostsGraph(r)
+	weeklyDeliveriesGraph := getWeeklyDeliveriesGraph(r)
 	usersGraph := getUsersGraph(r)
 	activeUsersGraph := getActiveUsersGraph(r)
 	instancesGraph := getInstancesGraph(r)
@@ -175,6 +182,12 @@ func stats(w text.Writer, r *request) {
 		w.Empty()
 	}
 
+	if weeklyDeliveriesGraph != "" {
+		w.Subtitle("Outgoing Posts Per Day")
+		w.Raw("Outgoing posts graph", weeklyDeliveriesGraph)
+		w.Empty()
+	}
+
 	if usersGraph != "" {
 		w.Subtitle("New Federated Users Per Hour")
 		w.Raw("Users graph", usersGraph)