helios-sof 0.1.47

This crate provides a complete implementation of the SQL-on-FHIR specification for Rust, enabling the transformation of FHIR resources into tabular data using declarative ViewDefinitions. It supports all major FHIR versions (R4, R4B, R5, R6) through a version-agnostic abstraction layer.
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

use helios_sof::{ContentType, SofBundle, SofViewDefinition, run_view_definition};

#[test]
fn test_extension_value_access_patterns() {
    // Create test bundle
    let bundle_json = serde_json::json!({
        "resourceType": "Bundle",
        "id": "test-bundle",
        "type": "collection",
        "entry": [
            {
                "resource": {
                    "resourceType": "Patient",
                    "id": "pt1",
                    "extension": [
                        {
                            "id": "birthsex",
                            "url": "http://hl7.org/fhir/us/core/StructureDefinition/us-core-birthsex",
                            "valueCode": "F"
                        }
                    ]
                }
            }
        ]
    });

    let bundle: helios_fhir::r4::Bundle =
        serde_json::from_value(bundle_json).expect("Failed to parse bundle");
    let sof_bundle = SofBundle::R4(bundle);

    // Test different access patterns
    let test_cases = vec![
        // Test 1: Direct extension function
        (
            "extension_func",
            "extension('http://hl7.org/fhir/us/core/StructureDefinition/us-core-birthsex')",
        ),
        // Test 2: Extension function + value access
        (
            "extension_value",
            "extension('http://hl7.org/fhir/us/core/StructureDefinition/us-core-birthsex').value",
        ),
        // Test 3: Extension function + valueCode access (what should work)
        (
            "extension_valuecode",
            "extension('http://hl7.org/fhir/us/core/StructureDefinition/us-core-birthsex').valueCode",
        ),
        // Test 4: Extension function + value + ofType
        (
            "extension_value_oftype",
            "extension('http://hl7.org/fhir/us/core/StructureDefinition/us-core-birthsex').value.ofType(code)",
        ),
        // Test 5: Full path from failing test
        (
            "full_path",
            "extension('http://hl7.org/fhir/us/core/StructureDefinition/us-core-birthsex').value.ofType(code).first()",
        ),
        // Test 6: Alternative using valueCode
        (
            "valuecode_direct",
            "extension('http://hl7.org/fhir/us/core/StructureDefinition/us-core-birthsex').valueCode",
        ),
    ];

    for (name, path) in test_cases {
        println!("\n=== Testing: {} ===", name);
        println!("Path: {}", path);

        let view = serde_json::json!({
            "resourceType": "ViewDefinition",
            "status": "active",
            "resource": "Patient",
            "select": [{
                "column": [
                    {
                        "path": "id",
                        "name": "id",
                        "type": "id"
                    },
                    {
                        "name": name,
                        "path": path,
                        "type": "code"
                    }
                ]
            }]
        });

        let view_definition: helios_fhir::r4::ViewDefinition =
            serde_json::from_value(view).expect("Failed to parse ViewDefinition");
        let sof_view = SofViewDefinition::R4(view_definition);

        match run_view_definition(sof_view, sof_bundle.clone(), ContentType::Json) {
            Ok(result) => {
                let actual_rows: Vec<serde_json::Value> =
                    serde_json::from_slice(&result).expect("Failed to parse result as JSON");

                println!("Result: {:?}", actual_rows);

                if let Some(row) = actual_rows.first() {
                    if let Some(value) = row.get(name) {
                        if value.is_null() {
                            println!("❌ FAILED: Got null");
                        } else {
                            println!("✅ SUCCESS: Got value: {}", value);
                        }
                    }
                }
            }
            Err(e) => {
                println!("❌ ERROR: {}", e);
            }
        }
    }
}