Merge pull request #29 from w6d-io/develop

[ADD] disable opa
w6d-io · Nov 7, 2023 · 7cd72fa · 7cd72fa
2 parents e36ba06 + 3da7492
commit 7cd72fa
Show file tree

Hide file tree

Showing 2 changed files with 17 additions and 17 deletions.
diff --git a/src/controller/update.rs b/src/controller/update.rs
@@ -94,7 +94,7 @@ pub async fn update_controller(
     let mut handles = JoinSet::new();
     let mut object_identity: Option<Arc<Identity>> = None;
     for data in payload.iter() {
-        if !validate_roles(
+        /* if !validate_roles(
             &config,
             &identity,
             &data.ressource_id,
@@ -104,7 +104,7 @@ pub async fn update_controller(
         .await?
         {
             Err(anyhow!("Invalid role!"))?;
-        }
+        } */
         println!("role validated!");
         match object_identity {
             Some(ref ident) => {
@@ -202,19 +202,19 @@ pub mod test_controler {
             .with_body(body)
             .create_async()
             .await;
-        let opa_mock = opa_server
+        /* let opa_mock = opa_server
             .mock("post", "/")
             .with_status(200)
             .with_header("content-type", "application/json")
             .with_body(r#"true"#)
             .create_async()
-            .await;
+            .await; */
         let identity = serde_json::from_str(IDENTITY_USER).unwrap();
         update_controller(Arc::new(config), vec![data], uuid, identity)
             .await
             .unwrap();
         kratos_mock.assert_async().await;
-        opa_mock.assert_async().await;
+        // opa_mock.assert_async().await;
     }
 
     #[tokio::test]
@@ -240,20 +240,20 @@ pub mod test_controler {
             .with_body(body)
             .create_async()
             .await;
-        let opa_mock = opa_server
+        /* let opa_mock = opa_server
             .mock("post", "/")
             .with_status(200)
             .with_header("content-type", "application/json")
             .with_body(r#"true"#)
             .expect(2)
             .create_async()
-            .await;
+            .await; */
 
         let identity = serde_json::from_str(IDENTITY_USER).unwrap();
         update_controller(Arc::new(config), vec![data.clone(), data], uuid, identity)
             .await
             .unwrap();
         kratos_mock.assert_async().await;
-        opa_mock.assert_async().await;
+        // opa_mock.assert_async().await;
     }
 }
diff --git a/src/router.rs b/src/router.rs
@@ -341,13 +341,13 @@ mod http_router_test {
             .with_body(serde_json::to_string(&session).unwrap())
             .create_async()
             .await;
-        let opa_mock = opa_server
+        /* let opa_mock = opa_server
             .mock("post", "/")
             .with_status(200)
             .with_header("content-type", "application/json")
             .with_body(r#"true"#)
             .create_async()
-            .await;
+            .await; */
         let config = Arc::new(RwLock::new(config));
         let app = app(config);
         let response = app
@@ -372,7 +372,7 @@ mod http_router_test {
             .unwrap();
         kratos_mock_session.assert_async().await;
         kratos_mock_admin.assert_async().await;
-        opa_mock.assert_async().await;
+        // opa_mock.assert_async().await;
         assert_eq!(response.status(), StatusCode::OK);
     }
 
@@ -402,13 +402,13 @@ mod http_router_test {
             .with_body(serde_json::to_string(&session).unwrap())
             .create_async()
             .await;
-        let opa_mock = opa_server
+        /* let opa_mock = opa_server
             .mock("post", "/")
             .with_status(200)
             .with_header("content-type", "application/json")
             .with_body(r#"true"#)
             .create_async()
-            .await;
+            .await; */
         let config = Arc::new(RwLock::new(config));
         let app = app(config);
         let response = app
@@ -434,7 +434,7 @@ mod http_router_test {
             .unwrap();
         kratos_mock_session.assert_async().await;
         kratos_mock_admin.assert_async().await;
-        opa_mock.assert_async().await;
+        // opa_mock.assert_async().await;
         println!("{:#?}", response);
         assert_eq!(response.status(), StatusCode::OK);
     }
@@ -465,13 +465,13 @@ mod http_router_test {
             .with_body(serde_json::to_string(&session).unwrap())
             .create_async()
             .await;
-        let opa_mock = opa_server
+        /* let opa_mock = opa_server
             .mock("post", "/")
             .with_status(200)
             .with_header("content-type", "application/json")
             .with_body(r#"true"#)
             .create_async()
-            .await;
+            .await; */
         let config = Arc::new(RwLock::new(config));
         let app = app(config);
         let response = app
@@ -497,7 +497,7 @@ mod http_router_test {
             .unwrap();
         kratos_mock_session.assert_async().await;
         kratos_mock_admin.assert_async().await;
-        opa_mock.assert_async().await;
+        // opa_mock.assert_async().await;
         println!("{:#?}", response);
         assert_eq!(response.status(), StatusCode::OK);
     }