use affinidi_vc::VerifiableCredential;
use chrono::Duration;
use vti_common::error::AppError;
use crate::acl::VtcRole;
use super::LocalSigner;
pub const VEC_TYPE: &str = "EndorsementCredential";
pub const COMMUNITY_ROLE_ENDORSEMENT_TYPE: &str = "CommunityRole";
pub const DEFAULT_ROLE_VEC_VALIDITY: Duration = Duration::days(30);
#[derive(Debug, Clone)]
pub struct RoleVecParams {
pub member_did: String,
pub id: Option<String>,
pub role: VtcRole,
pub validity: Duration,
}
impl RoleVecParams {
pub fn new(member_did: impl Into<String>, role: VtcRole) -> Self {
Self {
member_did: member_did.into(),
id: None,
role,
validity: DEFAULT_ROLE_VEC_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_vec(
signer: &LocalSigner,
params: RoleVecParams,
) -> Result<VerifiableCredential, AppError> {
let doc = super::dtg::issue_role(
signer,
¶ms.member_did,
¶ms.role,
params.id.as_deref(),
None,
params.validity,
)
.await?;
serde_json::from_value(doc)
.map_err(|e| AppError::Internal(format!("DTG VEC -> VerifiableCredential: {e}")))
}
#[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_vec_round_trips_for_each_standard_role() {
let signer = signer();
let cases = [
(VtcRole::Admin, "admin"),
(VtcRole::Moderator, "moderator"),
(VtcRole::Issuer, "issuer"),
(VtcRole::Member, "member"),
(VtcRole::Custom("editor".into()), "custom:editor"),
];
for (role, expected_wire) in cases {
let vc = build_role_vec(&signer, RoleVecParams::new(MEMBER_DID, role.clone()))
.await
.unwrap_or_else(|e| panic!("build VEC for {role:?}: {e:?}"));
assert!(vc.types.iter().any(|t| t == VEC_TYPE));
let subj = subject_map(&vc);
let endorsement = &subj["endorsement"];
assert_eq!(endorsement["type"], COMMUNITY_ROLE_ENDORSEMENT_TYPE);
assert_eq!(endorsement["role"], expected_wire);
assert_eq!(endorsement["communityDid"], TEST_VTC_DID);
assert_eq!(subj["id"], MEMBER_DID);
signer
.verify(&vc)
.unwrap_or_else(|e| panic!("VEC proof must verify for {role:?}: {e:?}"));
}
}
#[tokio::test]
async fn role_vec_tampered_role_invalidates_proof() {
let signer = signer();
let mut vc = build_role_vec(&signer, RoleVecParams::new(MEMBER_DID, VtcRole::Member))
.await
.unwrap();
let mut as_value = serde_json::to_value(&vc).unwrap();
as_value["credentialSubject"]["endorsement"]["role"] = JsonValue::String("admin".into());
vc = serde_json::from_value(as_value).unwrap();
let err = signer.verify(&vc).expect_err("tampered VEC must fail");
assert!(
matches!(err, AppError::Forbidden(_)),
"expected Forbidden, got {err:?}"
);
}
}