feat: init IsuanceService

Cargo.toml

@@ -17,7 +17,7 @@ edition = "2021"
 rust-version = "1.76.0"
 
 [workspace.dependencies]
-did_manager = { git = "https://git@github.com/impierce/did-manager.git", rev = "b9e5594" }
+did_manager = { git = "https://git@github.com/impierce/did-manager.git", rev = "2bda2b8" }
 siopv2 = { git = "https://git@github.com/impierce/openid4vc.git", rev = "12fed14" }
 oid4vci = { git = "https://git@github.com/impierce/openid4vc.git", rev = "12fed14" }
 oid4vc-core = { git = "https://git@github.com/impierce/openid4vc.git", rev = "12fed14" }
@@ -35,6 +35,7 @@ identity_credential = { version = "1.3", default-features = false, features = [
     "presentation",
     "domain-linkage"
 ] }
+identity_iota = { version = "1.3" }
 jsonwebtoken = "9.3"
 lazy_static = "1.4"
 rstest = "0.19"

agent_api_rest/src/issuance/credential_issuer/credential.rs

@@ -155,6 +155,7 @@ mod tests {
     use crate::issuance::credentials::tests::credentials;
     use crate::API_VERSION;
     use agent_event_publisher_http::EventPublisherHttp;
+    use agent_issuance::services::test_utils::test_issuance_services;
     use agent_issuance::{offer::event::OfferEvent, startup_commands::startup_commands, state::initialize};
     use agent_shared::config::{set_config, Events};
     use agent_store::{in_memory, EventPublisher};
@@ -297,7 +298,7 @@ mod tests {
             (None, Default::default(), Default::default())
         };
 
-        let issuance_state = in_memory::issuance_state(issuance_event_publishers).await;
+        let issuance_state = in_memory::issuance_state(test_issuance_services(), issuance_event_publishers).await;
         let verification_state =
             in_memory::verification_state(test_verification_services(), verification_event_publishers).await;
         initialize(&issuance_state, startup_commands(BASE_URL.clone())).await;

agent_api_rest/src/issuance/credential_issuer/token.rs

@@ -67,7 +67,9 @@ pub mod tests {
     };
 
     use super::*;
-    use agent_issuance::{startup_commands::startup_commands, state::initialize};
+    use agent_issuance::{
+        services::test_utils::test_issuance_services, startup_commands::startup_commands, state::initialize,
+    };
     use agent_store::in_memory;
     use agent_verification::services::test_utils::test_verification_services;
     use axum::{
@@ -110,7 +112,7 @@ pub mod tests {
 
     #[tokio::test]
     async fn test_token_endpoint() {
-        let issuance_state = in_memory::issuance_state(Default::default()).await;
+        let issuance_state = in_memory::issuance_state(test_issuance_services(), Default::default()).await;
         let verification_state = in_memory::verification_state(test_verification_services(), Default::default()).await;
         initialize(&issuance_state, startup_commands(BASE_URL.clone())).await;
 

agent_api_rest/src/issuance/credential_issuer/well_known/oauth_authorization_server.rs

@@ -26,7 +26,9 @@ mod tests {
     use crate::{app, tests::BASE_URL};
 
     use super::*;
-    use agent_issuance::{startup_commands::startup_commands, state::initialize};
+    use agent_issuance::{
+        services::test_utils::test_issuance_services, startup_commands::startup_commands, state::initialize,
+    };
     use agent_store::in_memory;
     use agent_verification::services::test_utils::test_verification_services;
     use axum::{
@@ -70,7 +72,7 @@ mod tests {
 
     #[tokio::test]
     async fn test_oauth_authorization_server_endpoint() {
-        let issuance_state = in_memory::issuance_state(Default::default()).await;
+        let issuance_state = in_memory::issuance_state(test_issuance_services(), Default::default()).await;
         let verification_state = in_memory::verification_state(test_verification_services(), Default::default()).await;
         initialize(&issuance_state, startup_commands(BASE_URL.clone())).await;
 

agent_api_rest/src/issuance/credential_issuer/well_known/openid_credential_issuer.rs

@@ -28,7 +28,9 @@ mod tests {
     use crate::{app, tests::BASE_URL};
 
     use super::*;
-    use agent_issuance::{startup_commands::startup_commands, state::initialize};
+    use agent_issuance::{
+        services::test_utils::test_issuance_services, startup_commands::startup_commands, state::initialize,
+    };
     use agent_shared::UrlAppendHelpers;
     use agent_store::in_memory;
     use agent_verification::services::test_utils::test_verification_services;
@@ -131,7 +133,7 @@ mod tests {
 
     #[tokio::test]
     async fn test_openid_credential_issuer_endpoint() {
-        let issuance_state = in_memory::issuance_state(Default::default()).await;
+        let issuance_state = in_memory::issuance_state(test_issuance_services(), Default::default()).await;
         let verification_state = in_memory::verification_state(test_verification_services(), Default::default()).await;
         initialize(&issuance_state, startup_commands(BASE_URL.clone())).await;
 

agent_api_rest/src/issuance/credentials.rs

@@ -158,6 +158,7 @@ pub mod tests {
         app,
         tests::{BASE_URL, CREDENTIAL_CONFIGURATION_ID, OFFER_ID},
     };
+    use agent_issuance::services::test_utils::test_issuance_services;
     use agent_issuance::{startup_commands::startup_commands, state::initialize};
     use agent_store::in_memory;
     use agent_verification::services::test_utils::test_verification_services;
@@ -252,7 +253,7 @@ pub mod tests {
     #[tokio::test]
     #[tracing_test::traced_test]
     async fn test_credentials_endpoint() {
-        let issuance_state = in_memory::issuance_state(Default::default()).await;
+        let issuance_state = in_memory::issuance_state(test_issuance_services(), Default::default()).await;
         let verification_state = in_memory::verification_state(test_verification_services(), Default::default()).await;
         initialize(&issuance_state, startup_commands(BASE_URL.clone())).await;
 

agent_api_rest/src/issuance/offers.rs

@@ -91,7 +91,9 @@ pub mod tests {
 
     use super::*;
     use crate::API_VERSION;
-    use agent_issuance::{startup_commands::startup_commands, state::initialize};
+    use agent_issuance::{
+        services::test_utils::test_issuance_services, startup_commands::startup_commands, state::initialize,
+    };
     use agent_store::in_memory;
     use agent_verification::services::test_utils::test_verification_services;
     use axum::{
@@ -154,7 +156,7 @@ pub mod tests {
     #[tokio::test]
     #[tracing_test::traced_test]
     async fn test_offers_endpoint() {
-        let issuance_state = in_memory::issuance_state(Default::default()).await;
+        let issuance_state = in_memory::issuance_state(test_issuance_services(), Default::default()).await;
 
         let verification_state = in_memory::verification_state(test_verification_services(), Default::default()).await;
 

agent_api_rest/src/lib.rs

@@ -126,6 +126,7 @@ fn get_base_path() -> Result<String, ConfigError> {
 mod tests {
     use std::collections::HashMap;
 
+    use agent_issuance::services::test_utils::test_issuance_services;
     use agent_store::in_memory;
     use agent_verification::services::test_utils::test_verification_services;
     use axum::routing::post;
@@ -182,7 +183,7 @@ mod tests {
     #[tokio::test]
     #[should_panic]
     async fn test_base_path_routes() {
-        let issuance_state = in_memory::issuance_state(Default::default()).await;
+        let issuance_state = in_memory::issuance_state(test_issuance_services(), Default::default()).await;
         let verification_state = in_memory::verification_state(test_verification_services(), Default::default()).await;
         std::env::set_var("UNICORE__BASE_PATH", "unicore");
         let router = app((issuance_state, verification_state));

agent_api_rest/src/verification/authorization_requests.rs

@@ -139,6 +139,7 @@ pub(crate) async fn authorization_requests(
 pub mod tests {
     use super::*;
     use crate::app;
+    use agent_issuance::services::test_utils::test_issuance_services;
     use agent_store::in_memory;
     use agent_verification::services::test_utils::test_verification_services;
     use axum::{
@@ -220,7 +221,7 @@ pub mod tests {
     #[tokio::test]
     #[tracing_test::traced_test]
     async fn test_authorization_requests_endpoint(#[case] by_value: bool) {
-        let issuance_state = in_memory::issuance_state(Default::default()).await;
+        let issuance_state = in_memory::issuance_state(test_issuance_services(), Default::default()).await;
         let verification_state = in_memory::verification_state(test_verification_services(), Default::default()).await;
         let mut app = app((issuance_state, verification_state));
 

agent_api_rest/src/verification/relying_party/redirect.rs

@@ -62,6 +62,7 @@ pub mod tests {
         verification::{authorization_requests::tests::authorization_requests, relying_party::request::tests::request},
     };
     use agent_event_publisher_http::EventPublisherHttp;
+    use agent_issuance::services::test_utils::test_issuance_services;
     use agent_secret_manager::{secret_manager, subject::Subject};
     use agent_shared::config::{set_config, Events};
     use agent_store::{in_memory, EventPublisher};
@@ -161,7 +162,7 @@ pub mod tests {
 
         let event_publishers = vec![Box::new(EventPublisherHttp::load().unwrap()) as Box<dyn EventPublisher>];
 
-        let issuance_state = in_memory::issuance_state(Default::default()).await;
+        let issuance_state = in_memory::issuance_state(test_issuance_services(), Default::default()).await;
         let verification_state = in_memory::verification_state(test_verification_services(), event_publishers).await;
 
         let mut app = app((issuance_state, verification_state));

agent_api_rest/src/verification/relying_party/request.rs

@@ -34,6 +34,7 @@ pub(crate) async fn request(
 pub mod tests {
     use super::*;
     use crate::{app, verification::authorization_requests::tests::authorization_requests};
+    use agent_issuance::services::test_utils::test_issuance_services;
     use agent_store::in_memory;
     use agent_verification::services::test_utils::test_verification_services;
     use axum::{
@@ -69,7 +70,7 @@ pub mod tests {
     #[tokio::test]
     #[tracing_test::traced_test]
     async fn test_request_endpoint() {
-        let issuance_state = in_memory::issuance_state(Default::default()).await;
+        let issuance_state = in_memory::issuance_state(test_issuance_services(), Default::default()).await;
         let verification_state = in_memory::verification_state(test_verification_services(), Default::default()).await;
         let mut app = app((issuance_state, verification_state));
 

agent_application/Cargo.toml

@@ -16,6 +16,7 @@ agent_verification = { path = "../agent_verification" }
 axum.workspace = true
 did_manager.workspace = true
 identity_document = { version = "1.3" }
+identity_iota.workspace = true
 serde_json.workspace = true
 tokio.workspace = true
 tower-http.workspace = true