swift-mt-message 3.1.5

A fast, type-safe Rust implementation of SWIFT MT message parsing with comprehensive field support, derive macros, and validation.
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

use async_trait::async_trait;
use datafake_rs::DataGenerator;
use dataflow_rs::engine::error::DataflowError;
use dataflow_rs::engine::{
    AsyncFunctionHandler, FunctionConfig,
    error::Result,
    message::{Change, Message},
};
use datalogic_rs::DataLogic;
use serde_json::Value;
use std::sync::Arc;
use tracing::{debug, error, instrument};

pub struct Generate;

#[async_trait]
impl AsyncFunctionHandler for Generate {
    #[instrument(skip(self, message, config, _datalogic))]
    async fn execute(
        &self,
        message: &mut Message,
        config: &FunctionConfig,
        _datalogic: Arc<DataLogic>,
    ) -> Result<(usize, Vec<Change>)> {
        debug!("Starting datafake generation");

        // Extract configuration
        let input = match config {
            FunctionConfig::Custom { input, name: _ } => input,
            _ => {
                return Err(DataflowError::Validation(
                    "Invalid configuration type".to_string(),
                ));
            }
        };

        // Get the output field name for generated data
        let target_field = input.get("target").and_then(Value::as_str).ok_or_else(|| {
            DataflowError::Validation("'target' parameter is required".to_string())
        })?;

        // Get the datafake scenario from payload
        let scenario = (*message.payload).clone();

        debug!(
            target_field = %target_field,
            "Generating data using datafake"
        );

        // Generate data using datafake
        let generated_data = match DataGenerator::from_value(scenario) {
            Ok(generator) => generator.generate().map_err(|e| {
                error!(error = ?e, "Datafake generation failed");
                DataflowError::Validation(format!("Datafake generation failed: {}", e))
            })?,
            Err(e) => {
                error!(error = ?e, "Failed to create datafake generator from scenario");
                return Err(DataflowError::Validation(format!(
                    "Invalid datafake scenario: {}",
                    e
                )));
            }
        };

        // Store the generated data in the target field
        let old_value = message
            .data()
            .get(target_field)
            .cloned()
            .unwrap_or(Value::Null);

        message
            .data_mut()
            .as_object_mut()
            .ok_or_else(|| DataflowError::Validation("Message data must be an object".to_string()))?
            .insert(target_field.to_string(), generated_data.clone());

        // Invalidate cache after modification
        message.invalidate_context_cache();

        debug!("Successfully generated data");

        Ok((
            200,
            vec![Change {
                path: Arc::from(format!("data.{}", target_field)),
                old_value: Arc::new(old_value),
                new_value: Arc::new(generated_data),
            }],
        ))
    }
}