Add repeat option per request

2024-11-26 11:43:08 +03:00 · 2024-06-19 18:20:08 +02:00 · 2024-06-19 18:20:08 +02:00 · c2f4514a24
commit c2f4514a24
parent dc6be76339
19 changed files with 274 additions and 15 deletions
--- a/integration/hurl/tests_ok/repeat_option.hurl
+++ b/integration/hurl/tests_ok/repeat_option.hurl
@ -0,0 +1,33 @@
+GET http://localhost:8000/repeat/hello?name=A
+[Options]
+repeat: 4
+output: -
+HTTP 200
+
+
+GET http://localhost:8000/repeat/hello?name=B
+[Options]
+repeat: 0   # repeat 0 is equivalent to skip
+output: -
+HTTP 200
+
+
+GET http://localhost:8000/repeat/hello?name=C
+[Options]
+repeat: 3
+output: -
+HTTP 200
+
+
+GET http://localhost:8000/repeat/hello?name=D
+[Options]
+repeat: 1
+output: -
+HTTP 200
+
+
+GET http://localhost:8000/repeat/hello?name=E
+[Options]
+repeat: 2
+output: -
+HTTP 200
--- a/integration/hurl/tests_ok/repeat_option.out
+++ b/integration/hurl/tests_ok/repeat_option.out
@ -0,0 +1,10 @@
+Hello A!
+Hello A!
+Hello A!
+Hello A!
+Hello C!
+Hello C!
+Hello C!
+Hello D!
+Hello E!
+Hello E!
--- a/integration/hurl/tests_ok/repeat_option.ps1
+++ b/integration/hurl/tests_ok/repeat_option.ps1
@ -0,0 +1,6 @@
+Set-StrictMode -Version latest
+$ErrorActionPreference = 'Stop'
+
+# We're deactivating output here because we explicitly enable output per request
+# to control the number of repetition for each request.
+hurl --no-output tests_ok/repeat_option.hurl
--- a/integration/hurl/tests_ok/repeat_option.sh
+++ b/integration/hurl/tests_ok/repeat_option.sh
@ -0,0 +1,6 @@
+#!/bin/bash
+set -Eeuo pipefail
+
+# We're deactivating output here because we explicitly enable output per request
+# to control the number of repetition for each request.
+hurl --no-output tests_ok/repeat_option.hurl
--- a/integration/hurlfmt/tests_export/options.html
+++ b/integration/hurlfmt/tests_export/options.html
@ -24,6 +24,8 @@
 <span class="line"><span class="string">output</span>: <span class="filename">output.txt</span></span>
 <span class="line"><span class="string">path-as-is</span>: <span class="boolean">false</span></span>
 <span class="line"><span class="string">proxy</span>: <span class="string">http://proxy.example</span></span>
+<span class="line"><span class="string">repeat</span>: <span class="number">-1</span></span>
+<span class="line"><span class="string">repeat</span>: <span class="number">5</span></span>
 <span class="line"><span class="string">resolve</span>: <span class="string">example.com:443:127.0.0.1</span></span>
 <span class="line"><span class="string">retry</span>: <span class="number">0</span></span>
 <span class="line"><span class="string">retry</span>: <span class="number">-1</span></span>
@ -65,6 +67,7 @@
 <span class="line"><span class="string">output</span>: <span class="filename">{{output}}</span></span>
 <span class="line"><span class="string">path-as-is</span>: <span class="expr">{{path-as-is}}</span></span>
 <span class="line"><span class="string">proxy</span>: <span class="string">{{proxy}}</span></span>
+<span class="line"><span class="string">repeat</span>: <span class="expr">{{repeat}}</span></span>
 <span class="line"><span class="string">resolve</span>: <span class="string">{{resolve}}</span></span>
 <span class="line"><span class="string">retry</span>: <span class="expr">{{retry}}</span></span>
 <span class="line"><span class="string">retry-interval</span>: <span class="expr">{{retry-interval}}</span></span>
--- a/integration/hurlfmt/tests_export/options.hurl
+++ b/integration/hurlfmt/tests_export/options.hurl
@ -24,6 +24,8 @@ netrc-optional: false
 output: output.txt
 path-as-is: false
 proxy: http://proxy.example
+repeat: -1
+repeat: 5
 resolve: example.com:443:127.0.0.1
 retry: 0
 retry: -1
@ -65,6 +67,7 @@ netrc-optional: {{netrc-optional}}
 output: {{output}}
 path-as-is: {{path-as-is}}
 proxy: {{proxy}}
+repeat: {{repeat}}
 resolve: {{resolve}}
 retry: {{retry}}
 retry-interval: {{retry-interval}}
--- a/integration/hurlfmt/tests_export/options.json
+++ b/integration/hurlfmt/tests_export/options.json
@ -1 +1 @@
-{"entries":[{"request":{"method":"GET","url":"http://localhost:8000/hello","options":[{"name":"aws-sigv4","value":"aws:amz:eu-central-1:sts"},{"name":"cacert","value":"cacertfile"},{"name":"cert","value":"certfile"},{"name":"cert","value":"certfile:qU114@q,[\"NO"},{"name":"key","value":"keyfile"},{"name":"compressed","value":false},{"name":"connect-to","value":"example.com:443:example.net:8443"},{"name":"delay","value":1000},{"name":"location","value":false},{"name":"location-trusted","value":false},{"name":"http1.0","value":false},{"name":"http1.1","value":false},{"name":"http2","value":false},{"name":"http3","value":false},{"name":"insecure","value":false},{"name":"ipv4","value":false},{"name":"ipv6","value":false},{"name":"max-redirs","value":10},{"name":"netrc","value":false},{"name":"netrc-file","value":"netrcfile"},{"name":"netrc-optional","value":false},{"name":"output","value":"output.txt"},{"name":"path-as-is","value":false},{"name":"proxy","value":"http://proxy.example"},{"name":"resolve","value":"example.com:443:127.0.0.1"},{"name":"retry","value":0},{"name":"retry","value":-1},{"name":"retry","value":4},{"name":"retry-interval","value":1000},{"name":"skip","value":false},{"name":"unix-socket","value":"build/unix_socket.sock"},{"name":"user","value":"bob:secret"},{"name":"variable","value":"user=null"},{"name":"variable","value":"status=true"},{"name":"variable","value":"count=2"},{"name":"variable","value":"score=7.7"},{"name":"variable","value":"name=Bob"},{"name":"verbose","value":false},{"name":"very-verbose","value":false}]}},{"request":{"method":"GET","url":"http://localhost:8000/hello","options":[{"name":"aws-sigv4","value":"{{aws-sigv4}}"},{"name":"cacert","value":"{{cacert}}"},{"name":"cert","value":"{{cert}}"},{"name":"key","value":"{{key}}"},{"name":"compressed","value":"{{compressed}}"},{"name":"connect-to","value":"{{connect-to}}"},{"name":"delay","value":"{{delay}}"},{"name":"location","value":"{{location}}"},{"name":"location-trusted","value":"{{location-trusted}}"},{"name":"http1.0","value":"{{http10}}"},{"name":"http1.1","value":"{{http11}}"},{"name":"http2","value":"{{http2}}"},{"name":"http3","value":"{{http3}}"},{"name":"insecure","value":"{{insecure}}"},{"name":"ipv4","value":"{{ipv4}}"},{"name":"ipv6","value":"{{ipv6}}"},{"name":"max-redirs","value":"{{max-redirs}}"},{"name":"netrc","value":"{{netrc}}"},{"name":"netrc-file","value":"{{netrc-file}}"},{"name":"netrc-optional","value":"{{netrc-optional}}"},{"name":"output","value":"{{output}}"},{"name":"path-as-is","value":"{{path-as-is}}"},{"name":"proxy","value":"{{proxy}}"},{"name":"resolve","value":"{{resolve}}"},{"name":"retry","value":"{{retry}}"},{"name":"retry-interval","value":"{{retry-interval}}"},{"name":"skip","value":"{{skip}}"},{"name":"unix-socket","value":"{{socket-file}}"},{"name":"user","value":"{{user}}"},{"name":"verbose","value":"{{verbose}}"},{"name":"very-verbose","value":"{{very-verbose}}"}]}}]}
+{"entries":[{"request":{"method":"GET","url":"http://localhost:8000/hello","options":[{"name":"aws-sigv4","value":"aws:amz:eu-central-1:sts"},{"name":"cacert","value":"cacertfile"},{"name":"cert","value":"certfile"},{"name":"cert","value":"certfile:qU114@q,[\"NO"},{"name":"key","value":"keyfile"},{"name":"compressed","value":false},{"name":"connect-to","value":"example.com:443:example.net:8443"},{"name":"delay","value":1000},{"name":"location","value":false},{"name":"location-trusted","value":false},{"name":"http1.0","value":false},{"name":"http1.1","value":false},{"name":"http2","value":false},{"name":"http3","value":false},{"name":"insecure","value":false},{"name":"ipv4","value":false},{"name":"ipv6","value":false},{"name":"max-redirs","value":10},{"name":"netrc","value":false},{"name":"netrc-file","value":"netrcfile"},{"name":"netrc-optional","value":false},{"name":"output","value":"output.txt"},{"name":"path-as-is","value":false},{"name":"proxy","value":"http://proxy.example"},{"name":"repeat","value":-1},{"name":"repeat","value":5},{"name":"resolve","value":"example.com:443:127.0.0.1"},{"name":"retry","value":0},{"name":"retry","value":-1},{"name":"retry","value":4},{"name":"retry-interval","value":1000},{"name":"skip","value":false},{"name":"unix-socket","value":"build/unix_socket.sock"},{"name":"user","value":"bob:secret"},{"name":"variable","value":"user=null"},{"name":"variable","value":"status=true"},{"name":"variable","value":"count=2"},{"name":"variable","value":"score=7.7"},{"name":"variable","value":"name=Bob"},{"name":"verbose","value":false},{"name":"very-verbose","value":false}]}},{"request":{"method":"GET","url":"http://localhost:8000/hello","options":[{"name":"aws-sigv4","value":"{{aws-sigv4}}"},{"name":"cacert","value":"{{cacert}}"},{"name":"cert","value":"{{cert}}"},{"name":"key","value":"{{key}}"},{"name":"compressed","value":"{{compressed}}"},{"name":"connect-to","value":"{{connect-to}}"},{"name":"delay","value":"{{delay}}"},{"name":"location","value":"{{location}}"},{"name":"location-trusted","value":"{{location-trusted}}"},{"name":"http1.0","value":"{{http10}}"},{"name":"http1.1","value":"{{http11}}"},{"name":"http2","value":"{{http2}}"},{"name":"http3","value":"{{http3}}"},{"name":"insecure","value":"{{insecure}}"},{"name":"ipv4","value":"{{ipv4}}"},{"name":"ipv6","value":"{{ipv6}}"},{"name":"max-redirs","value":"{{max-redirs}}"},{"name":"netrc","value":"{{netrc}}"},{"name":"netrc-file","value":"{{netrc-file}}"},{"name":"netrc-optional","value":"{{netrc-optional}}"},{"name":"output","value":"{{output}}"},{"name":"path-as-is","value":"{{path-as-is}}"},{"name":"proxy","value":"{{proxy}}"},{"name":"repeat","value":"{{repeat}}"},{"name":"resolve","value":"{{resolve}}"},{"name":"retry","value":"{{retry}}"},{"name":"retry-interval","value":"{{retry-interval}}"},{"name":"skip","value":"{{skip}}"},{"name":"unix-socket","value":"{{socket-file}}"},{"name":"user","value":"{{user}}"},{"name":"verbose","value":"{{verbose}}"},{"name":"very-verbose","value":"{{very-verbose}}"}]}}]}
--- a/integration/hurlfmt/tests_export/options.lint.hurl
+++ b/integration/hurlfmt/tests_export/options.lint.hurl
@ -24,6 +24,8 @@ netrc-optional: false
 output: output.txt
 path-as-is: false
 proxy: http://proxy.example
+repeat: -1
+repeat: 5
 resolve: example.com:443:127.0.0.1
 retry: 0
 retry: -1
@ -65,6 +67,7 @@ netrc-optional: {{netrc-optional}}
 output: {{output}}
 path-as-is: {{path-as-is}}
 proxy: {{proxy}}
+repeat: {{repeat}}
 resolve: {{resolve}}
 retry: {{retry}}
 retry-interval: {{retry-interval}}
--- a/packages/hurl/src/runner/hurl_file.rs
+++ b/packages/hurl/src/runner/hurl_file.rs
@ -26,7 +26,7 @@ use hurl_core::ast::{
 };
 use hurl_core::error::DisplaySourceError;
 use hurl_core::parser;
-use hurl_core::typing::Retry;
+use hurl_core::typing::{Repeat, Retry};

 use crate::http::{Call, Client};
 use crate::runner::event::EventListener;
@ -140,6 +140,7 @@ pub fn run_entries(
    let mut entries_result = vec![];
    let mut variables = variables.clone();
    let mut entry_index = runner_options.from_entry.unwrap_or(1);
+    let mut repeat_count = 0;
    let n = runner_options.to_entry.unwrap_or(entries.len());
    let default_verbosity = logger.verbosity;
    let start = Instant::now();
@ -215,6 +216,14 @@ pub fn run_entries(
            continue;
        }

+        // Repeat 0 is equivalent to skip.
+        if options.repeat == Some(Repeat::Count(0)) {
+            logger.debug("");
+            logger.debug_important(&format!("Entry {entry_index} is skipped (repeat 0 times)"));
+            entry_index += 1;
+            continue;
+        }
+
        // Should we delay?
        let delay = options.delay;
        let delay_ms = delay.as_millis();
@ -252,8 +261,27 @@ pub fn run_entries(
            break;
        }

-        // We pass to the next entry
-        entry_index += 1;
+        // We pass to the next entry if the repeat count is reached.
+        repeat_count += 1;
+        match options.repeat {
+            None => {
+                repeat_count = 0;
+                entry_index += 1;
+            }
+            Some(Repeat::Count(n)) => {
+                if repeat_count >= n {
+                    repeat_count = 0;
+                    entry_index += 1;
+                } else {
+                    logger.debug_important(&format!(
+                        "Repeat entry {entry_index} (x{repeat_count}/{n})"
+                    ));
+                }
+            }
+            Some(Repeat::Forever) => {
+                logger.debug_important(&format!("Repeat entry {entry_index} (x{repeat_count})"));
+            }
+        }
    }

    let time_in_ms = start.elapsed().as_millis();
--- a/packages/hurl/src/runner/options.rs
+++ b/packages/hurl/src/runner/options.rs
@ -20,9 +20,9 @@ use std::time::Duration;

 use hurl_core::ast::{
    BooleanOption, Entry, EntryOption, Float, NaturalOption, Number as AstNumber, OptionKind,
-    RetryOption, SectionValue, VariableDefinition, VariableValue,
+    RepeatOption, RetryOption, SectionValue, VariableDefinition, VariableValue,
 };
-use hurl_core::typing::Retry;
+use hurl_core::typing::{Repeat, Retry};

 use crate::http::{IpResolve, RequestedHttpVersion};
 use crate::runner::template::{eval_expression, eval_template};
@ -199,6 +199,10 @@ pub fn get_entry_options(
                        let value = eval_template(value, variables)?;
                        entry_options.proxy = Some(value);
                    }
+                    OptionKind::Repeat(value) => {
+                        let value = eval_repeat_option(value, variables)?;
+                        entry_options.repeat = Some(value);
+                    }
                    OptionKind::Resolve(value) => {
                        let value = eval_template(value, variables)?;
                        entry_options.resolves.push(value);
@ -347,6 +351,41 @@ fn eval_natural_option(
    }
 }

+/// Render an AST repeat option with a `variables` set.
+fn eval_repeat_option(
+    repeat_option_value: &RepeatOption,
+    variables: &HashMap<String, Value>,
+) -> Result<Repeat, RunnerError> {
+    match repeat_option_value {
+        RepeatOption::Literal(repeat) => Ok(*repeat),
+        RepeatOption::Expression(expr) => match eval_expression(expr, variables)? {
+            Value::Number(Number::Integer(value)) => {
+                if value == -1 {
+                    Ok(Repeat::Forever)
+                } else if value >= 0 {
+                    Ok(Repeat::Count(value as usize))
+                } else {
+                    let kind = RunnerErrorKind::TemplateVariableInvalidType {
+                        name: expr.variable.name.clone(),
+                        value: value.to_string(),
+                        expecting: "integer".to_string(),
+                    };
+                    Err(RunnerError::new(expr.variable.source_info, kind, false))
+                }
+            }
+            v => {
+                let kind = RunnerErrorKind::TemplateVariableInvalidType {
+                    name: expr.variable.name.clone(),
+                    value: v.to_string(),
+                    expecting: "integer".to_string(),
+                };
+                Err(RunnerError::new(expr.variable.source_info, kind, false))
+            }
+        },
+    }
+}
+
+/// Render an AST retry option with a `variables` set.
 fn eval_retry_option(
    retry_option_value: &RetryOption,
    variables: &HashMap<String, Value>,
--- a/packages/hurl/src/runner/runner_options.rs
+++ b/packages/hurl/src/runner/runner_options.rs
@ -18,7 +18,7 @@
 use std::time::Duration;

 use hurl_core::ast::Entry;
-use hurl_core::typing::Retry;
+use hurl_core::typing::{Repeat, Retry};

 use crate::http::{IpResolve, RequestedHttpVersion};
 use crate::runner::Output;
@ -54,6 +54,7 @@ pub struct RunnerOptionsBuilder {
    post_entry: Option<fn() -> bool>,
    pre_entry: Option<fn(Entry) -> bool>,
    proxy: Option<String>,
+    repeat: Option<Repeat>,
    resolves: Vec<String>,
    retry: Option<Retry>,
    retry_interval: Duration,
@ -98,6 +99,7 @@ impl Default for RunnerOptionsBuilder {
            post_entry: None,
            pre_entry: None,
            proxy: None,
+            repeat: None,
            resolves: vec![],
            retry: None,
            retry_interval: Duration::from_millis(1000),
@ -319,6 +321,12 @@ impl RunnerOptionsBuilder {
        self
    }

+    /// Set the number of repetition for a given entry.
+    pub fn repeat(&mut self, repeat: Option<Repeat>) -> &mut Self {
+        self.repeat = repeat;
+        self
+    }
+
    /// Provides a custom address for a specific host and port pair.
    pub fn resolves(&mut self, resolves: &[String]) -> &mut Self {
        self.resolves = resolves.to_vec();
@ -416,6 +424,7 @@ impl RunnerOptionsBuilder {
            post_entry: self.post_entry,
            pre_entry: self.pre_entry,
            proxy: self.proxy.clone(),
+            repeat: self.repeat,
            resolves: self.resolves.clone(),
            retry: self.retry,
            retry_interval: self.retry_interval,
@ -461,6 +470,7 @@ pub struct RunnerOptions {
    pub(crate) post_entry: Option<fn() -> bool>,
    pub(crate) pre_entry: Option<fn(Entry) -> bool>,
    pub(crate) proxy: Option<String>,
+    pub(crate) repeat: Option<Repeat>,
    pub(crate) resolves: Vec<String>,
    pub(crate) retry: Option<Retry>,
    pub(crate) retry_interval: Duration,
--- a/packages/hurl_core/src/ast/core.rs
+++ b/packages/hurl_core/src/ast/core.rs
@ -16,7 +16,7 @@
 *
 */
 use crate::ast::json;
-use crate::typing::Retry;
+use crate::typing::{Repeat, Retry};

 ///
 /// Hurl AST
@ -737,6 +737,7 @@ pub enum OptionKind {
    Output(Template),
    PathAsIs(BooleanOption),
    Proxy(Template),
+    Repeat(RepeatOption),
    Resolve(Template),
    Retry(RetryOption),
    RetryInterval(NaturalOption),
@ -774,6 +775,7 @@ impl OptionKind {
            OptionKind::Output(_) => "output",
            OptionKind::PathAsIs(_) => "path-as-is",
            OptionKind::Proxy(_) => "proxy",
+            OptionKind::Repeat(_) => "repeat",
            OptionKind::Resolve(_) => "resolve",
            OptionKind::Retry(_) => "retry",
            OptionKind::RetryInterval(_) => "retry-interval",
@ -811,6 +813,7 @@ impl OptionKind {
            OptionKind::Output(filename) => filename.to_string(),
            OptionKind::PathAsIs(value) => value.to_string(),
            OptionKind::Proxy(value) => value.to_string(),
+            OptionKind::Repeat(value) => value.to_string(),
            OptionKind::Resolve(value) => value.to_string(),
            OptionKind::Retry(value) => value.to_string(),
            OptionKind::RetryInterval(value) => value.to_string(),
@ -838,6 +841,12 @@ pub enum NaturalOption {
    Expression(Expr),
 }

+#[derive(Clone, Debug, PartialEq, Eq)]
+pub enum RepeatOption {
+    Literal(Repeat),
+    Expression(Expr),
+}
+
 #[derive(Clone, Debug, PartialEq, Eq)]
 pub enum RetryOption {
    Literal(Retry),
--- a/packages/hurl_core/src/ast/display.rs
+++ b/packages/hurl_core/src/ast/display.rs
@ -187,6 +187,15 @@ impl fmt::Display for NaturalOption {
    }
 }

+impl fmt::Display for RepeatOption {
+    fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
+        match self {
+            RepeatOption::Literal(v) => write!(f, "{}", v),
+            RepeatOption::Expression(v) => write!(f, "{}", v),
+        }
+    }
+}
+
 impl fmt::Display for RetryOption {
    fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
        match self {
--- a/packages/hurl_core/src/format/html.rs
+++ b/packages/hurl_core/src/format/html.rs
@ -18,7 +18,7 @@
 use std::fmt::Display;

 use crate::ast::*;
-use crate::typing::Retry;
+use crate::typing::{Repeat, Retry};

 /// Returns an HTML string of the Hurl file `hurl_file`.
 ///
@ -238,6 +238,7 @@ impl HtmlFormatter {
            OptionKind::Output(filename) => self.fmt_filename(filename),
            OptionKind::PathAsIs(value) => self.fmt_bool_option(value),
            OptionKind::Proxy(value) => self.fmt_template(value),
+            OptionKind::Repeat(value) => self.fmt_repeat_option(value),
            OptionKind::Resolve(value) => self.fmt_template(value),
            OptionKind::Retry(value) => self.fmt_retry_option(value),
            OptionKind::RetryInterval(value) => self.fmt_natural_option(value),
@ -252,6 +253,20 @@ impl HtmlFormatter {
        self.fmt_lt(&option.line_terminator0);
    }

+    fn fmt_repeat_option(&mut self, repeat_option: &RepeatOption) {
+        match repeat_option {
+            RepeatOption::Literal(repeat) => self.fmt_repeat(repeat),
+            RepeatOption::Expression(expr) => self.fmt_expr(expr),
+        }
+    }
+
+    fn fmt_repeat(&mut self, repeat: &Repeat) {
+        match repeat {
+            Repeat::Count(n) => self.fmt_number(n),
+            Repeat::Forever => self.fmt_number(-1),
+        };
+    }
+
    fn fmt_retry_option(&mut self, retry_option: &RetryOption) {
        match retry_option {
            RetryOption::Literal(retry) => self.fmt_retry(retry),
--- a/packages/hurl_core/src/parser/option.rs
+++ b/packages/hurl_core/src/parser/option.rs
@ -23,7 +23,7 @@ use crate::parser::primitives::*;
 use crate::parser::reader::Reader;
 use crate::parser::string::*;
 use crate::parser::{expr, filename, filename_password, ParseResult};
-use crate::typing::Retry;
+use crate::typing::{Repeat, Retry};

 /// Parse an option in an `[Options]` section.
 pub fn parse(reader: &mut Reader) -> ParseResult<EntryOption> {
@ -62,6 +62,7 @@ pub fn parse(reader: &mut Reader) -> ParseResult<EntryOption> {
        "output" => option_output(reader)?,
        "path-as-is" => option_path_as_is(reader)?,
        "proxy" => option_proxy(reader)?,
+        "repeat" => option_repeat(reader)?,
        "resolve" => option_resolve(reader)?,
        "retry" => option_retry(reader)?,
        "retry-interval" => option_retry_interval(reader)?,
@ -206,6 +207,11 @@ fn option_proxy(reader: &mut Reader) -> ParseResult<OptionKind> {
    Ok(OptionKind::Proxy(value))
 }

+fn option_repeat(reader: &mut Reader) -> ParseResult<OptionKind> {
+    let value = repeat_option(reader)?;
+    Ok(OptionKind::Repeat(value))
+}
+
 fn option_resolve(reader: &mut Reader) -> ParseResult<OptionKind> {
    let value = unquoted_template(reader)?;
    Ok(OptionKind::Resolve(value))
@ -251,6 +257,21 @@ fn option_very_verbose(reader: &mut Reader) -> ParseResult<OptionKind> {
    Ok(OptionKind::VeryVerbose(value))
 }

+fn repeat(reader: &mut Reader) -> ParseResult<Repeat> {
+    let pos = reader.state.pos;
+    let value = nonrecover(integer, reader)?;
+    if value == -1 {
+        Ok(Repeat::Forever)
+    } else if value >= 0 {
+        Ok(Repeat::Count(value as usize))
+    } else {
+        let kind = ParseErrorKind::Expecting {
+            value: "Expecting a repeat value".to_string(),
+        };
+        Err(ParseError::new(pos, false, kind))
+    }
+}
+
 fn retry(reader: &mut Reader) -> ParseResult<Retry> {
    let pos = reader.state.pos;
    let value = nonrecover(integer, reader)?;
@ -300,6 +321,23 @@ fn natural_option(reader: &mut Reader) -> ParseResult<NaturalOption> {
    }
 }

+fn repeat_option(reader: &mut Reader) -> ParseResult<RepeatOption> {
+    let start = reader.state;
+    match repeat(reader) {
+        Ok(v) => Ok(RepeatOption::Literal(v)),
+        Err(_) => {
+            reader.state = start;
+            let exp = expr::parse(reader).map_err(|e| {
+                let kind = ParseErrorKind::Expecting {
+                    value: "integer".to_string(),
+                };
+                ParseError::new(e.pos, false, kind)
+            })?;
+            Ok(RepeatOption::Expression(exp))
+        }
+    }
+}
+
 fn retry_option(reader: &mut Reader) -> ParseResult<RetryOption> {
    let start = reader.state;
    match retry(reader) {
--- a/packages/hurl_core/src/typing/mod.rs
+++ b/packages/hurl_core/src/typing/mod.rs
@ -31,6 +31,15 @@ impl Default for Repeat {
    }
 }

+impl fmt::Display for Repeat {
+    fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
+        let value = match self {
+            Repeat::Count(n) => *n as i64,
+            Repeat::Forever => -1,
+        };
+        write!(f, "{}", value)
+    }
+}
 /// Represents a retry operation (when an operation has failed), either finite or infinite.
 /// Contrary to [`Repeat`], [`Retry`] has a notion of retry only on operation failure, while
 /// [`Repeat`] is unconditional.
@ -43,7 +52,7 @@ pub enum Retry {
 impl fmt::Display for Retry {
    fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
        let value = match self {
-            Retry::Finite(n) => *n as i32,
+            Retry::Finite(n) => *n as i64,
            Retry::Infinite => -1,
        };
        write!(f, "{}", value)
--- a/packages/hurlfmt/src/format/json.rs
+++ b/packages/hurlfmt/src/format/json.rs
@ -18,7 +18,7 @@
 use base64::engine::general_purpose;
 use base64::Engine;
 use hurl_core::ast::*;
-use hurl_core::typing::Retry;
+use hurl_core::typing::{Repeat, Retry};

 use super::serialize_json::*;

@ -316,6 +316,7 @@ impl ToJson for EntryOption {
            OptionKind::Output(filename) => JValue::String(filename.to_string()),
            OptionKind::PathAsIs(value) => value.to_json(),
            OptionKind::Proxy(value) => JValue::String(value.to_string()),
+            OptionKind::Repeat(value) => value.to_json(),
            OptionKind::Resolve(value) => JValue::String(value.to_string()),
            OptionKind::Retry(value) => value.to_json(),
            OptionKind::RetryInterval(value) => value.to_json(),
@ -352,6 +353,24 @@ impl ToJson for NaturalOption {
    }
 }

+impl ToJson for RepeatOption {
+    fn to_json(&self) -> JValue {
+        match self {
+            RepeatOption::Literal(value) => value.to_json(),
+            RepeatOption::Expression(expr) => expr.to_json(),
+        }
+    }
+}
+
+impl ToJson for Repeat {
+    fn to_json(&self) -> JValue {
+        match self {
+            Repeat::Count(n) => JValue::Number(n.to_string()),
+            Repeat::Forever => JValue::Number("-1".to_string()),
+        }
+    }
+}
+
 impl ToJson for RetryOption {
    fn to_json(&self) -> JValue {
        match self {
@ -364,7 +383,7 @@ impl ToJson for RetryOption {
 impl ToJson for Retry {
    fn to_json(&self) -> JValue {
        match self {
-            Retry::Finite(value) => JValue::Number(value.to_string()),
+            Retry::Finite(n) => JValue::Number(n.to_string()),
            Retry::Infinite => JValue::Number("-1".to_string()),
        }
    }
--- a/packages/hurlfmt/src/format/serialize_json.rs
+++ b/packages/hurlfmt/src/format/serialize_json.rs
@ -17,7 +17,7 @@
 */

 /**
- * Serde json son can not be easily used for serialization here because of the orphan rule.
+ * Serde-json can not be easily used for serialization here because of the orphan rule.
 * It seems easier just to reimplement it from scratch (around 50 lines of code)
 */

--- a/packages/hurlfmt/src/format/token.rs
+++ b/packages/hurlfmt/src/format/token.rs
@ -16,7 +16,7 @@
 *
 */
 use hurl_core::ast::*;
-use hurl_core::typing::Retry;
+use hurl_core::typing::{Repeat, Retry};

 #[derive(Clone, Debug, PartialEq, Eq)]
 pub enum Token {
@ -903,6 +903,7 @@ impl Tokenizable for OptionKind {
            OptionKind::Output(filename) => filename.tokenize(),
            OptionKind::PathAsIs(value) => value.tokenize(),
            OptionKind::Proxy(value) => value.tokenize(),
+            OptionKind::Repeat(value) => value.tokenize(),
            OptionKind::Resolve(value) => value.tokenize(),
            OptionKind::Retry(value) => value.tokenize(),
            OptionKind::RetryInterval(value) => value.tokenize(),
@ -934,6 +935,24 @@ impl Tokenizable for NaturalOption {
    }
 }

+impl Tokenizable for RepeatOption {
+    fn tokenize(&self) -> Vec<Token> {
+        match self {
+            RepeatOption::Literal(retry) => retry.tokenize(),
+            RepeatOption::Expression(expr) => expr.tokenize(),
+        }
+    }
+}
+
+impl Tokenizable for Repeat {
+    fn tokenize(&self) -> Vec<Token> {
+        match self {
+            Repeat::Count(n) => vec![Token::Number(n.to_string())],
+            Repeat::Forever => vec![Token::Number("-1".to_string())],
+        }
+    }
+}
+
 impl Tokenizable for RetryOption {
    fn tokenize(&self) -> Vec<Token> {
        match self {