preserve local outbox

data/garbage.go

@@ -48,7 +48,7 @@ func CollectGarbage(ctx context.Context, db *sql.DB) error {
 		return fmt.Errorf("failed to remove old hashtags: %w", err)
 	}
 
-	if _, err := db.ExecContext(ctx, `delete from outbox where inserted < ?`, now.Add(-deliveryTTL).Unix()); err != nil {
+	if _, err := db.ExecContext(ctx, `delete from outbox where inserted < ? and host != ?`, now.Add(-deliveryTTL).Unix(), cfg.Domain); err != nil {
 		return fmt.Errorf("failed to remove old posts: %w", err)
 	}
 

migrations/017_outboxhost.go

@@ -0,0 +1,15 @@
+package migrations
+
+import (
+	"context"
+	"database/sql"
+)
+
+func outboxhost(ctx context.Context, tx *sql.Tx) error {
+	if _, err := tx.ExecContext(ctx, `ALTER TABLE outbox ADD COLUMN host TEXT AS (substr(substr(activity->>'id', 9), 0, instr(substr(activity->>'id', 9), '/')))`); err != nil {
+		return err
+	}
+
+	_, err := tx.ExecContext(ctx, `CREATE INDEX outboxhostinserted ON outbox(host, inserted)`)
+	return err
+}