Function preparsePolicySetJni

CedarJavaFFI/src/interface.rs:131–193

(
    mut env: JNIEnv<'_>,
    _class: JClass<'_>,
    j_id: JString<'_>,
    j_policies_json: JString<'_>,
)

/// Direct JNI entry point to pre-parse and cache a policy set.
#[jni_fn("com.cedarpolicy.model.policy.PolicySet")]
pub fn preparsePolicySetJni(
    mut env: JNIEnv<'_>,
    _class: JClass<'_>,
    j_id: JString<'_>,
    j_policies_json: JString<'_>,
) {
    let id: String = match env.get_string(&j_id) {
        Ok(s) => s.into(),
        Err(e) => {
            let _ = env.throw_new(
                "com/cedarpolicy/model/exception/InternalException",
                format!("Failed to read policy set cache ID: {e}"),
            );
            return;
        }
    };
    let policies_json: String = match env.get_string(&j_policies_json) {
        Ok(s) => s.into(),
        Err(e) => {
            let _ = env.throw_new(
                "com/cedarpolicy/model/exception/InternalException",
                format!("Failed to read policy set JSON: {e}"),
            );
            return;
        }
    };
    let policy_set_ffi: PolicySetFFI = match serde_json::from_str(&policies_json) {
        Ok(ps) => ps,
        Err(e) => {
            let _ = env.throw_new(
                "com/cedarpolicy/model/exception/InternalException",
                format!("Failed to parse policy set JSON: {e}"),
            );
            return;
        }
    };
    match policy_set_ffi.parse() {
        Ok(parsed) => {
            if is_cache_full(
                &CACHED_POLICY_SETS,
                MAX_CACHED_POLICY_SETS.load(Ordering::Relaxed),
            ) {
                let _ = env.throw_new(
                    "com/cedarpolicy/model/exception/InternalException",
                    "Policy set cache is full; increase cedar.cache.maxPolicySets or clear unused entries",
                );
                return;
            }
            CACHED_POLICY_SETS.insert(id, parsed);
        }
        Err(errors) => {
            let msg = errors
                .into_iter()
                .map(|e| e.to_string())
                .collect::<Vec<_>>()
                .join("; ");
            let _ = env.throw_new(
                "com/cedarpolicy/model/exception/InternalException",