feat(repo): Add block_time to predicate_transactions (#492)

Author: luizstacio

crates/domains/migrations/20250320204420_create_predicates_table.sql

@@ -15,6 +15,7 @@ CREATE TABLE IF NOT EXISTS predicate_transactions (
     subject TEXT UNIQUE NOT NULL,
     predicate_id INTEGER REFERENCES predicates(id),
     block_height BIGINT NOT NULL,
+    block_time TIMESTAMP WITH TIME ZONE NOT NULL,
     tx_id TEXT NOT NULL,
     tx_index INTEGER NOT NULL,
     input_index INTEGER NOT NULL,
@@ -25,6 +26,7 @@ CREATE TABLE IF NOT EXISTS predicate_transactions (
 
 CREATE INDEX IF NOT EXISTS idx_predicate_transactions_cursor ON predicate_transactions (cursor);
 CREATE INDEX IF NOT EXISTS idx_predicate_transactions_predicate_id ON predicate_transactions (predicate_id);
+CREATE INDEX IF NOT EXISTS idx_predicate_transactions_block_time ON predicate_transactions (block_time);
 CREATE INDEX IF NOT EXISTS idx_predicate_transactions_block_height ON predicate_transactions (block_height);
 CREATE INDEX IF NOT EXISTS idx_predicate_transactions_tx_id ON predicate_transactions (tx_id);
 CREATE INDEX IF NOT EXISTS idx_predicate_transactions_tx_index ON predicate_transactions (tx_index);

crates/domains/src/predicates/repository.rs

@@ -56,19 +56,21 @@ impl Predicate {
                 cursor,
                 subject,
                 block_height,
+                block_time,
                 tx_id,
                 tx_index,
                 input_index,
                 asset_id,
                 bytecode
             )
-            VALUES ($1, $2, $3, $4, $5, $6, $7, $8, $9)
+            VALUES ($1, $2, $3, $4, $5, $6, $7, $8, $9, $10)
             "#,
         )
         .bind(predicate_id)
         .bind(db_item.cursor().to_string())
         .bind(&db_item.subject)
         .bind(db_item.block_height.into_inner() as i64)
+        .bind(db_item.block_time)
         .bind(&db_item.tx_id)
         .bind(db_item.tx_index)
         .bind(db_item.input_index)
@@ -145,17 +147,16 @@ mod tests {
         db: &Arc<Db>,
         input: Option<Input>,
         height: BlockHeight,
+        block_time: BlockTimestamp,
         namespace: &str,
     ) -> anyhow::Result<(PredicateDbItem, Input, DynPredicateSubject)> {
         let input = input.unwrap_or_else(MockInput::coin_predicate);
         let tx =
             MockTransaction::script(vec![input.to_owned()], vec![], vec![]);
-
         let subject =
             DynPredicateSubject::new(&input, &height, &tx.id, 0, 0).unwrap();
-        let timestamps = BlockTimestamp::default();
         let packet = subject
-            .build_packet(timestamps, RecordPointer {
+            .build_packet(block_time, RecordPointer {
                 block_height: height,
                 tx_id: Some(tx.id.to_owned()),
                 tx_index: Some(0_u32),
@@ -178,8 +179,14 @@ mod tests {
     ) -> anyhow::Result<Vec<PredicateDbItem>> {
         let mut predicates = Vec::with_capacity(count as usize);
         for height in 1..=count {
-            let (db_item, _, _) =
-                insert_predicate(db, None, height.into(), namespace).await?;
+            let (db_item, _, _) = insert_predicate(
+                db,
+                None,
+                height.into(),
+                BlockTimestamp::now(),
+                namespace,
+            )
+            .await?;
             predicates.push(db_item);
         }
         Ok(predicates)
@@ -192,6 +199,7 @@ mod tests {
             &db,
             Some(MockInput::coin_predicate()),
             1.into(),
+            BlockTimestamp::now(),
             &namespace,
         )
         .await?;
@@ -205,6 +213,7 @@ mod tests {
             &db,
             Some(MockInput::coin_signed(None)),
             1.into(),
+            BlockTimestamp::now(),
             &namespace,
         )
         .await?;
@@ -214,8 +223,14 @@ mod tests {
     #[tokio::test]
     async fn test_find_one_predicate() -> anyhow::Result<()> {
         let (db, namespace) = setup_db().await?;
-        let (db_item, _, subject) =
-            insert_predicate(&db, None, 1.into(), &namespace).await?;
+        let (db_item, _, subject) = insert_predicate(
+            &db,
+            None,
+            1.into(),
+            BlockTimestamp::now(),
+            &namespace,
+        )
+        .await?;
 
         let mut query = subject.to_query_params();
         query.with_namespace(Some(namespace));