tackler-core 0.18.0

Core components for Tackler accounting engine with native GIT SCM support
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
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137

/*
 * Tackler-NG 2025
 * SPDX-License-Identifier: Apache-2.0
 */

use itertools::Itertools;
use winnow::{
    Parser,
    combinator::{eof, opt, preceded, repeat_till},
};

use crate::kernel::Settings;
use crate::model::price_entry::PriceDb;
use crate::parser::Stream;

use super::parts::{pricedb::parse_price_entry, txns::multispace0_line_ending};

use crate::tackler;
use std::path::Path;

/// # Errors
/// Returns `Err` in case of invalid pricedb data
pub fn pricedb_from_str(
    input: &mut &str,
    settings: &mut Settings,
) -> Result<PriceDb, tackler::Error> {
    let is = Stream {
        input,
        state: settings,
    };

    preceded(
        opt(multispace0_line_ending),
        repeat_till(1.., parse_price_entry, eof),
    )
    .parse(is)
    .map(|(price_entries, _): (Vec<_>, _)| price_entries.into_iter().sorted().dedup().collect())
    .map_err(|err| err.to_string().into())
}

/// # Errors
/// Returns `Err` in case of invalid pricedb data
pub fn pricedb_from_file(path: &Path, settings: &mut Settings) -> Result<PriceDb, tackler::Error> {
    let pricedb_str = std::fs::read_to_string(path)
        .map_err(|err| format!("Can't open file: '{}' - {}", path.display(), err))?;

    // todo: error log
    pricedb_from_str(&mut pricedb_str.as_str(), settings)
}

#[cfg(test)]
mod tests {
    use super::*;
    use crate::kernel::Settings;
    use indoc::indoc;
    use tackler_rs::IndocUtils;

    #[test]
    fn test_parse_pricedb() {
        #[rustfmt::skip]
        let pok_pricedbs = vec![
            (indoc!(
               "|P 2024-01-09 XAU 2659.645203 USD
                |"
            ).strip_margin(), 1usize),
            (indoc!(
               "|P 2024-01-09 XAU 2659.645203 USD
                |P 2024-01-09 USD  121.306155 BDT
                |P 2024-01-09 XAG  3652.77663 BDT
                |"
            ).strip_margin(), 3usize),
            (indoc!(
               "|\t \n\
                | \t  \t
                |P 2024-01-09 XAU 2659.645203 USD
                |P 2024-01-09 USD  121.306155 BDT
                |P 2024-01-09 XAG  3652.77663 BDT
                |"
            ).strip_margin(), 3usize),
            (indoc!(
               "|P 2024-01-09 XAU 2659.645203 USD
                |P 2024-01-09 USD  121.306155 BDT
                |P 2024-01-09 XAG  3652.77663 BDT
                |\t \n\
                | \t  \t
                |"
            ).strip_margin(), 3usize),
            (indoc!(
               "|\t \n\
                | \t  \t
                |P 2024-01-09 XAU 2659.645203 USD
                |P 2024-01-09 USD  121.306155 BDT
                |P 2024-01-09 XAG  3652.77663 BDT
                |\t \n\
                | \t  \t
                |"
            ).strip_margin(), 3usize),
            (indoc!(
               "|\t \n\
                | \t  \t
                |P 2024-01-09 XAU 2659.645203 USD
                |\t \n\
                | \t  \t
                |P 2024-01-09 USD  121.306155 BDT
                |P 2024-01-09 XAG  3652.77663 BDT
                |\t \n\
                | \t  \t
                |"
            ).strip_margin(), 3usize),
        ];

        let mut count = 0;
        let pok_count = pok_pricedbs.len();
        for t in pok_pricedbs {
            let mut settings = Settings::default();

            let res = pricedb_from_str(&mut t.0.as_str(), &mut settings);

            assert!(
                res.is_ok(),
                "\nPOK is error: Offending test vector item: {}\n",
                count + 1
            );

            let pricedb = res.unwrap(/*:test:*/);
            assert_eq!(
                pricedb.len(),
                t.1,
                "\nWrong price entry count: Offending test vector item: {}",
                count + 1
            );

            count += 1;
        }
        assert_eq!(count, pok_count);
    }
}