pub async fn get_pending_txs_hashes_after(
        &mut self,
        from_timestamp: NaiveDateTime,
        limit: Option<usize>,
    ) -> DalResult<Vec<(NaiveDateTime, H256)>> {
        let records = sqlx::query!(
            r#"
            SELECT
                transactions.hash,
                transactions.received_at
            FROM
                transactions
            WHERE
                received_at > $1
            ORDER BY
                received_at ASC
            LIMIT
                $2
            "#,
            from_timestamp,
            limit.map(|limit| limit as i64)
        )
        .instrument("get_pending_txs_hashes_after")
        .with_arg("from_timestamp", &from_timestamp)
        .with_arg("limit", &limit)
        .fetch_all(self.storage)
        .await?;

        let hashes = records
            .into_iter()
            .map(|record| (record.received_at, H256::from_slice(&record.hash)))
            .collect();
        Ok(hashes)
    }
Returns hashes of txs which were received after `from_timestamp` and the time of receiving the last tx.
core/lib/dal/src/transactions_web3_dal.rs