use affinidi_vc::VerifiableCredential;
use chrono::Duration;
use vti_common::error::AppError;
use crate::acl::VtcRole;
use super::LocalSigner;
pub const VAC_TYPE: &str = vta_sdk::protocols::members::AUTHORITY_CREDENTIAL_TYPE;
pub const DEFAULT_ROLE_VAC_VALIDITY: Duration = Duration::days(30);
#[derive(Debug, Clone)]
pub struct RoleVacParams {
pub member_did: String,
pub id: Option<String>,
pub role: VtcRole,
pub validity: Duration,
}
impl RoleVacParams {
pub fn new(member_did: impl Into<String>, role: VtcRole) -> Self {
Self {
member_did: member_did.into(),
id: None,
role,
validity: DEFAULT_ROLE_VAC_VALIDITY,
}
}
pub fn with_id(mut self, id: impl Into<String>) -> Self {
self.id = Some(id.into());
self
}
pub fn with_validity(mut self, validity: Duration) -> Self {
self.validity = validity;
self
}
}
pub async fn build_role_vac(
signer: &LocalSigner,
params: RoleVacParams,
) -> Result<VerifiableCredential, AppError> {
let doc = super::dtg::issue_role(
signer,
¶ms.member_did,
¶ms.role,
params.id.as_deref(),
None,
params.validity,
)
.await?;
super::dtg::into_typed(doc, "role VAC")
}
#[cfg(test)]
mod tests {
use super::*;
use affinidi_vc::SubjectValue;
use serde_json::{Map, Value as JsonValue};
const TEST_VTC_DID: &str = "did:webvh:vtc.example.com:abc";
const MEMBER_DID: &str = "did:key:zMember1";
fn signer() -> LocalSigner {
LocalSigner::from_ed25519_seed(TEST_VTC_DID.into(), &[0xBB; 32])
}
fn subject_map(vc: &VerifiableCredential) -> Map<String, JsonValue> {
match &vc.credential_subject {
SubjectValue::Single(m) => m.clone(),
SubjectValue::Multiple(v) => v[0].clone(),
}
}
#[tokio::test]
async fn role_vac_round_trips_for_each_standard_role() {
let signer = signer();
let cases = [
(VtcRole::Admin, "role:admin"),
(VtcRole::Moderator, "role:moderator"),
(VtcRole::Issuer, "role:issuer"),
(VtcRole::Member, "role:member"),
(VtcRole::Custom("editor".into()), "role:custom:editor"),
];
for (role, expected_action) in cases {
let vc = build_role_vac(&signer, RoleVacParams::new(MEMBER_DID, role.clone()))
.await
.unwrap_or_else(|e| panic!("build VAC for {role:?}: {e:?}"));
assert!(vc.types.iter().any(|t| t == VAC_TYPE));
let subj = subject_map(&vc);
let authority = &subj["authority"];
assert_eq!(authority["scope"], TEST_VTC_DID);
assert_eq!(authority["actions"], serde_json::json!([expected_action]));
assert_eq!(authority["maxAttenuation"], 0);
assert_eq!(subj["id"], MEMBER_DID);
signer
.verify(&vc)
.unwrap_or_else(|e| panic!("VAC proof must verify for {role:?}: {e:?}"));
}
}
#[tokio::test]
async fn role_vac_tampered_action_invalidates_proof() {
let signer = signer();
let mut vc = build_role_vac(&signer, RoleVacParams::new(MEMBER_DID, VtcRole::Member))
.await
.unwrap();
let mut as_value = serde_json::to_value(&vc).unwrap();
as_value["credentialSubject"]["authority"]["actions"] = serde_json::json!(["role:admin"]);
vc = serde_json::from_value(as_value).unwrap();
let err = signer.verify(&vc).expect_err("tampered VAC must fail");
assert!(
matches!(err, AppError::Forbidden(_)),
"expected Forbidden, got {err:?}"
);
}
}