qs_rust 1.0.2

A query string encoding and decoding library for Rust. Ported from qs for JavaScript.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92

//! Duplicate-combine helpers for flat decode accumulation.

use crate::error::DecodeError;
use crate::internal::node::Node;
use crate::internal::overflow::overflow_from_items;
use crate::options::DecodeOptions;
use crate::value::Value;

pub(in crate::decode) fn combine_with_limit(
    current: Node,
    next: Node,
    options: &DecodeOptions,
) -> Result<Node, DecodeError> {
    let mut next_items = Vec::new();
    flatten_for_combine(next, &mut next_items);

    if let Node::OverflowObject {
        mut entries,
        mut max_index,
    } = current
    {
        let current_len = max_index.saturating_add(1);
        if options.throw_on_limit_exceeded
            && current_len.saturating_add(next_items.len()) > options.list_limit
        {
            return Err(DecodeError::ListLimitExceeded {
                limit: options.list_limit,
            });
        }

        for item in next_items {
            max_index = max_index.saturating_add(1);
            entries.insert(max_index.to_string(), item);
        }
        return Ok(Node::OverflowObject { entries, max_index });
    }

    let mut combined = Vec::new();
    flatten_for_combine(current, &mut combined);
    combined.extend(next_items);

    if combined.len() <= options.list_limit {
        return Ok(Node::Array(combined));
    }

    if options.throw_on_limit_exceeded {
        return Err(DecodeError::ListLimitExceeded {
            limit: options.list_limit,
        });
    }

    Ok(overflow_from_items(combined))
}

fn flatten_for_combine(node: Node, output: &mut Vec<Node>) {
    match node {
        Node::Array(items) => output.extend(items.into_iter().filter(|item| !item.is_undefined())),
        Node::OverflowObject { entries, .. } => {
            output.extend(entries.into_values().filter(|item| !item.is_undefined()))
        }
        other => output.push(other),
    }
}

pub(super) fn try_combine_direct_values(
    current: &Value,
    next: &Value,
    options: &DecodeOptions,
) -> Result<Option<Value>, DecodeError> {
    let mut combined = Vec::new();
    flatten_value_for_combine(current.clone(), &mut combined);
    flatten_value_for_combine(next.clone(), &mut combined);

    if combined.len() <= options.list_limit {
        return Ok(Some(Value::Array(combined)));
    }

    if options.throw_on_limit_exceeded {
        return Err(DecodeError::ListLimitExceeded {
            limit: options.list_limit,
        });
    }

    Ok(None)
}

fn flatten_value_for_combine(value: Value, output: &mut Vec<Value>) {
    match value {
        Value::Array(items) => output.extend(items),
        other => output.push(other),
    }
}