feat: add timestamps parameter

README.md

@@ -156,6 +156,7 @@ Options:
 
 Content Options:
   -b, --blocks <BLOCKS>...           Block numbers, see syntax below
+      --timestamps <TIMESTAMPS>...   Timestamp numbers in unix, overriden by blocks
   -t, --txs <TXS>...                 Transaction hashes, see syntax below
   -a, --align                        Align chunk boundaries to regular intervals,
                                      e.g. (1000 2000 3000), not (1106 2106 3106)
@@ -243,6 +244,18 @@ Block specification syntax
 - can use every nth value            2000:5000:1000 == 2000 3000 4000
 - can use n values total             100:200/5 == 100 124 149 174 199
 
+Timestamp specification syntax
+- can use numbers                    --timestamp 5000 6000 7000
+- can use ranges                     --timestamp 12M:13M 15M:16M
+- can use a parquet file             --timestamp ./path/to/file.parquet[:COLUMN_NAME]
+- can use multiple parquet files     --timestamp ./path/to/files/*.parquet[:COLUMN_NAME]
+- numbers can contain { _ . K M }    5_000 5K 15M 15.5M
+- omitting range end means latest    15.5M: == 15.5M:latest
+- omitting range start means 0       :700 == 0:700
+- minus on start means minus end     -1000:7000 == 6000:7000
+- plus sign on end means plus start  15M:+1000 == 15M:15.001K
+- can use n values total             100:200/5 == 100 124 149 174 199
+
 Transaction specification syntax
 - can use transaction hashes         --txs TX_HASH1 TX_HASH2 TX_HASH3
 - can use a parquet file             --txs ./path/to/file.parquet[:COLUMN_NAME]

crates/cli/src/args.rs

@@ -26,6 +26,10 @@ pub struct Args {
     #[arg(short, long, allow_negative_numbers = true, help_heading = "Content Options", num_args(1..))]
     pub blocks: Option<Vec<String>>,
 
+    /// Timestamps in unix, see syntax below
+    #[arg(long, allow_negative_numbers = true, help_heading = "Content Options", num_args(0..))]
+    pub timestamps: Option<Vec<String>>,
+
     /// Transaction hashes, see syntax below
     #[arg(
         short,

crates/cli/src/parse/blocks.rs

@@ -106,7 +106,7 @@ fn read_integer_column(path: &str, column: &str) -> Result<Vec<u64>, ParseError>
     }
 }
 
-async fn postprocess_block_chunks<P: JsonRpcClient>(
+pub(crate) async fn postprocess_block_chunks<P: JsonRpcClient>(
     block_chunks: Vec<BlockChunk>,
     args: &Args,
     fetcher: Arc<Fetcher<P>>,
@@ -218,7 +218,7 @@ async fn parse_block_token<P: JsonRpcClient>(
     }
 }
 
-fn block_range_to_block_chunk(
+pub(crate) fn block_range_to_block_chunk(
     start_block: u64,
     end_block: u64,
     as_range: bool,
@@ -389,6 +389,16 @@ async fn apply_reorg_buffer<P: JsonRpcClient>(
     }
 }
 
+pub(crate) async fn get_latest_block_number<P: JsonRpcClient>(
+    fetcher: &Fetcher<P>,
+) -> Result<u64, ParseError> {
+    return fetcher
+        .get_block_number()
+        .await
+        .map(|n| n.as_u64())
+        .map_err(|_e| ParseError::ParseError("Error retrieving latest block number".to_string()));
+}
+
 #[cfg(test)]
 mod tests {
     use super::*;

crates/cli/src/parse/mod.rs

@@ -7,6 +7,7 @@ mod partitions;
 mod query;
 pub(crate) mod schemas;
 mod source;
+mod timestamps;
 
 pub use args::*;
 use schemas::*;

crates/cli/src/parse/partitions.rs

@@ -1,6 +1,7 @@
 use super::{
     blocks,
     parse_utils::{hex_string_to_binary, hex_strings_to_binary, parse_binary_arg},
+    timestamps,
 };
 use crate::args::Args;
 use cryo_freeze::{
@@ -23,6 +24,11 @@ pub(crate) async fn parse_partitions<P: JsonRpcClient>(
 
     // parse chunk data
     let (block_number_labels, block_numbers) = blocks::parse_blocks(args, fetcher.clone()).await?;
+    let (block_number_labels, block_numbers) = if block_numbers.is_none() {
+        timestamps::parse_timestamps(args, fetcher.clone()).await?
+    } else {
+        (block_number_labels, block_numbers)
+    };
     let (transaction_hash_labels, transactions) =
         parse_transaction_chunks(&args.txs, "transaction_hash")?;
     let call_datas = parse_call_datas(&args.call_data, &args.function, &args.inputs)?;