add verify tx execution in the workflow.

.gitignore

@@ -3,6 +3,7 @@
 .DS_Store
 .idea
 *.pki
+**/.sqlx
 crates/tests/e2e-tests/files
 crates/tests/e2e-tests/prover
 crates/tests/e2e-tests/verifier

crates/node/src/main.rs

@@ -163,6 +163,9 @@ impl workflow::TransactionStore for storage::Database {
     async fn find_transaction(&self, tx_hash: &Hash) -> Result<Option<Transaction<Validated>>> {
         self.find_transaction(tx_hash).await
     }
+    async fn mark_tx_executed(&self, tx_hash: &Hash) -> Result<()> {
+        self.mark_tx_executed(tx_hash).await
+    }
 }
 
 async fn run(config: Arc<Config>) -> Result<()> {

crates/node/src/storage/database/postgres.rs

@@ -622,6 +622,7 @@ impl Database {
                 verification,
                 files,
             } => {
+                tracing::trace!("Postgres add_transaction tx:{}", tx.hash.to_string());
                 sqlx::query(
                     "INSERT INTO verification ( tx, parent, verifier, verification ) VALUES ( $1, $2, $3, $4 ) ON CONFLICT (tx) DO NOTHING",
                 )

crates/node/src/workflow/mod.rs

@@ -31,6 +31,7 @@ pub enum WorkflowError {
 #[async_trait]
 pub trait TransactionStore: Sync + Send {
     async fn find_transaction(&self, tx_hash: &Hash) -> Result<Option<Transaction<Validated>>>;
+    async fn mark_tx_executed(&self, tx_hash: &Hash) -> Result<()>;
 }
 
 pub struct WorkflowEngine {
@@ -149,6 +150,14 @@ impl WorkflowEngine {
                     Err(WorkflowError::IncompatibleTransaction(proof_tx.hash.to_string()).into())
                 }
             }
+            Payload::Verification { .. } => {
+                // Execute the verify tx by setting to executed.
+                // Ideally it's not the right place to execute a Tx
+                // but as the execution is nothing, it's more convenient.
+                tracing::debug!("Mark as executed Payload::Verification tx {}", &cur_tx.hash);
+                self.tx_store.mark_tx_executed(&cur_tx.hash).await?;
+                Ok(None)
+            }
             _ => Err(WorkflowError::IncompatibleTransaction(
                 "unsupported payload type".to_string(),
             )
@@ -328,6 +337,10 @@ mod tests {
         async fn find_transaction(&self, tx_hash: &Hash) -> Result<Option<Transaction<Validated>>> {
             Ok(self.txs.get(tx_hash).cloned())
         }
+        async fn mark_tx_executed(&self, tx_hash: &Hash) -> Result<()> {
+            // Do nothing because the txs map can't be modified behind a &self.
+            Ok(())
+        }
     }
 
     #[tokio::test]