From 2fb01d220207be3e9776dced854cd0b87caa008a Mon Sep 17 00:00:00 2001
From: Will <did:plc:dadhhalkfcq3gucaq25hjqon>
Date: Mon, 17 Aug 2026 16:41:37 +0000
Subject: [PATCH] only store posts to database

Signed-off-by: Will <did:plc:dadhhalkfcq3gucaq25hjqon>
---
 src/jetstream.rs | 35 ++++++++++++++++++-----------------
 1 file(s) changed, 18 insertion(s)(+), 17 deletion(s)(-)

diff --git a/src/jetstream.rs b/src/jetstream.rs
--- a/src/jetstream.rs
+++ b/src/jetstream.rs
@@ -1,9 +1,9 @@
+use ::chrono::{DateTime, Utc};
 use async_trait::async_trait;
 use atproto_jetstream::{EventHandler, JetstreamEvent};
-use serde::Serialize;
 use std::sync::Arc;
 
-use crate::jetstream;
+use crate::store;
 
 pub struct MyEventHandler {
     pub pool: sqlx::SqlitePool,
@@ -20,15 +20,22 @@ did,
                 time_us,
                 kind,
                 commit,
-            } => {
-                println!("hello: {}", commit.record)
-            }
-            JetstreamEvent::Delete {
-                did,
-                time_us,
-                kind,
-                commit,
-            } => {}
+            } => match commit.collection.as_str() {
+                "app.bsky.feed.post" => {
+                    let post = store::PostRecord {
+                        created: Utc::now(),
+                        indexed: Utc::now(),
+                        author: did.to_string(),
+                        rkey: commit.rkey.to_string(),
+                        cid: commit.cid.to_string(),
+                    };
+
+                    store::insert_post(post, &self.pool).await;
+                }
+                _ => {
+                    println!("it was something else {}", commit.collection);
+                }
+            },
             JetstreamEvent::Delete {
                 did,
                 time_us,
@@ -48,12 +55,6 @@ kind,
                 account,
             } => {}
         }
-
-        // let result = sqlx::query("INSERT INTO follows (subject, rkey) VALUES ($1, $2)")
-        //     .bind(&follow.subject)
-        //     .bind(record.rkey.to_string())
-        //     .execute(&self.pool)
-        //     .await;
 
         Ok(())
     }

--
tangled.sh