Add indexes and properly store quoteUris for mediaquotes

rsky-feedgen/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "rsky-feedgen"
-version = "1.0.1"
+version = "1.0.2"
 authors = ["Rudy Fraser <[email protected]>"]
 description = "A framework for building AT Protocol feed generators, in Rust."
 license = "Apache-2.0"

rsky-feedgen/migrations/2024-12-01-074204_021/down.sql

@@ -0,0 +1,3 @@
+-- This file should undo anything in `up.sql`
+DROP INDEX IF EXISTS idx_like_subjecturi_indexedat;
+DROP INDEX IF EXISTS idx_post_createdAt_cid;

rsky-feedgen/migrations/2024-12-01-074204_021/up.sql

@@ -0,0 +1,4 @@
+-- Your SQL goes here
+CREATE INDEX idx_like_subjecturi_indexedat ON public.like ("subjectUri", "indexedAt");
+CREATE INDEX idx_post_createdAt_cid ON "post" ("createdAt" DESC, "cid" DESC)
+    WHERE "replyParent" IS NULL AND "replyRoot" IS NULL;

rsky-feedgen/src/apis/mod.rs

@@ -174,7 +174,6 @@ pub async fn get_blacksky_trending(
     connection: ReadReplicaConn,
     config: &State<FeedGenConfig>,
 ) -> Result<AlgoResponse, ValidationErrorMessageResponse> {
-    use std::env;
     let trending_percentile_min = config.trending_percentile_min.clone();
 
     let params_cursor = match params_cursor {
@@ -610,6 +609,8 @@ pub async fn queue_creation(
                                     };
                                 }
                                 Embeds::RecordWithMedia(e) => {
+                                    new_post.quote_cid = Some(e.record.record.cid);
+                                    new_post.quote_uri = Some(e.record.record.uri);
                                     match e.media {
                                         MediaUnion::Images(m) => {
                                             for image in m.images {