pdk-core 1.7.0

PDK Core
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

// Copyright (c) 2026, Salesforce, Inc.,
// All rights reserved.
// For full license text, see the LICENSE.txt file

use crate::host::property::PropertyAccessor;
use crate::policy_context::static_policy_context_cache::StaticPolicyContextCache;
use std::fmt::{Display, Formatter};
use std::rc::Rc;

#[derive(Debug, Default)]
pub struct LogMetadata {
    api_id: Rc<String>,
    policy_name: Rc<String>,
    req_id: Option<String>,
}

impl Clone for LogMetadata {
    fn clone(&self) -> Self {
        Self {
            api_id: Rc::clone(&self.api_id),
            policy_name: Rc::clone(&self.policy_name),
            req_id: self.req_id.clone(),
        }
    }
}

impl LogMetadata {
    fn load_metadata() -> LogMetadata {
        let metadata = StaticPolicyContextCache::read_metadata();
        let api_name = StaticPolicyContextCache::read_plugin_name_api_id().to_string();
        let policy_name = metadata.policy_id();
        let policy_namespace = metadata.policy_namespace();

        LogMetadata {
            api_id: Rc::new(api_name),
            policy_name: Rc::new(format!("{policy_name}.{policy_namespace}")),
            req_id: None,
        }
    }
}

impl<'a> From<&'a dyn PropertyAccessor> for LogMetadata {
    fn from(property_accessor: &'a dyn PropertyAccessor) -> Self {
        let mut metadata = Self::load_metadata();
        metadata.req_id = property_accessor.tracing().id().ok().flatten();
        metadata
    }
}

impl Display for LogMetadata {
    fn fmt(&self, f: &mut Formatter<'_>) -> std::fmt::Result {
        match self.req_id {
            None => {
                let _ = f.write_fmt(format_args!(
                    "[policy: {}][api: {}]",
                    self.policy_name, self.api_id
                ));
            }
            Some(ref id) => {
                let _ = f.write_fmt(format_args!(
                    "[policy: {}][api: {}][req: {}]",
                    self.policy_name, self.api_id, &id
                ));
            }
        }
        Ok(())
    }
}