xmpkit 0.1.3

Pure Rust implementation of Adobe XMP Toolkit
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

#[cfg(feature = "mutli-thread")]
#[cfg(test)]
mod tests {
    use std::sync::Arc;
    use std::thread;
    use xmpkit::XmpMeta;

    #[test]
    fn test_concurrent_reads() {
        let xml = r#"<?xpacket begin="" id="W5M0MpCehiHzreSzNTczkc9d"?>
<rdf:RDF xmlns:rdf="http://www.w3.org/1999/02/22-rdf-syntax-ns#"
         xmlns:xmp="http://ns.adobe.com/xap/1.0/">
  <rdf:Description rdf:about=""
                   xmp:CreatorTool="TestApp"/>
</rdf:RDF>
<?xpacket end="w"?>"#;

        let meta = Arc::new(XmpMeta::parse(xml).unwrap());

        let mut handles = vec![];

        // Spawn 10 threads that all read concurrently
        for _ in 0..10 {
            let meta_clone = meta.clone();
            let handle = thread::spawn(move || {
                let value = meta_clone.get_property("http://ns.adobe.com/xap/1.0/", "CreatorTool");
                assert_eq!(value, Some(xmpkit::XmpValue::String("TestApp".to_string())));
            });
            handles.push(handle);
        }

        // Wait for all threads to complete
        for handle in handles {
            handle.join().unwrap();
        }
    }

    #[test]
    fn test_concurrent_reads_multiple_properties() {
        let xml = r#"<?xpacket begin="" id="W5M0MpCehiHzreSzNTczkc9d"?>
<rdf:RDF xmlns:rdf="http://www.w3.org/1999/02/22-rdf-syntax-ns#"
         xmlns:xmp="http://ns.adobe.com/xap/1.0/"
         xmlns:dc="http://purl.org/dc/elements/1.1/">
  <rdf:Description rdf:about=""
                   xmp:CreatorTool="TestApp"
                   dc:title="Test Title"/>
</rdf:RDF>
<?xpacket end="w"?>"#;

        let meta = Arc::new(XmpMeta::parse(xml).unwrap());

        let mut handles = vec![];

        // Spawn threads that read different properties concurrently
        for i in 0..5 {
            let meta_clone = meta.clone();
            let handle = thread::spawn(move || {
                if i % 2 == 0 {
                    let value =
                        meta_clone.get_property("http://ns.adobe.com/xap/1.0/", "CreatorTool");
                    assert_eq!(value, Some(xmpkit::XmpValue::String("TestApp".to_string())));
                } else {
                    let value =
                        meta_clone.get_property("http://purl.org/dc/elements/1.1/", "title");
                    assert_eq!(
                        value,
                        Some(xmpkit::XmpValue::String("Test Title".to_string()))
                    );
                }
            });
            handles.push(handle);
        }

        // Wait for all threads to complete
        for handle in handles {
            handle.join().unwrap();
        }
    }
}