|
42 | 42 | config_check,
|
43 | 43 | api_config_handler,
|
44 | 44 | )
|
| 45 | +from codeflare_sdk.utils.openshift_oauth import create_openshift_oauth_objects |
45 | 46 | from codeflare_sdk.utils.pretty_print import (
|
46 | 47 | print_no_resources_found,
|
47 | 48 | print_app_wrappers_status,
|
@@ -2294,6 +2295,56 @@ def test_export_env():
|
2294 | 2295 | )
|
2295 | 2296 |
|
2296 | 2297 |
|
| 2298 | +# TODO add checks to make sure that when calling generate oauth objects that the fields that are expected to match do |
| 2299 | +def test_create_openshift_oauth(mocker: MockerFixture): |
| 2300 | + create_namespaced_service_account = MagicMock() |
| 2301 | + create_cluster_role_binding = MagicMock() |
| 2302 | + create_namespaced_service = MagicMock() |
| 2303 | + create_namespaced_ingress = MagicMock() |
| 2304 | + mocker.patch.object( |
| 2305 | + client.CoreV1Api, |
| 2306 | + "create_namespaced_service_account", |
| 2307 | + create_namespaced_service_account, |
| 2308 | + ) |
| 2309 | + mocker.patch.object( |
| 2310 | + client.RbacAuthorizationV1Api, |
| 2311 | + "create_cluster_role_binding", |
| 2312 | + create_cluster_role_binding, |
| 2313 | + ) |
| 2314 | + mocker.patch.object( |
| 2315 | + client.CoreV1Api, "create_namespaced_service", create_namespaced_service |
| 2316 | + ) |
| 2317 | + mocker.patch.object( |
| 2318 | + client.NetworkingV1Api, "create_namespaced_ingress", create_namespaced_ingress |
| 2319 | + ) |
| 2320 | + mocker.patch( |
| 2321 | + "codeflare_sdk.utils.openshift_oauth._get_api_host", return_value="foo.com" |
| 2322 | + ) |
| 2323 | + create_openshift_oauth_objects("foo", "bar") |
| 2324 | + create_ns_sa_args = create_namespaced_service_account.call_args |
| 2325 | + create_crb_args = create_cluster_role_binding.call_args |
| 2326 | + create_ns_serv_args = create_namespaced_service.call_args |
| 2327 | + create_ns_ingress_args = create_namespaced_ingress.call_args |
| 2328 | + assert ( |
| 2329 | + create_ns_sa_args.kwargs["namespace"] == create_ns_serv_args.kwargs["namespace"] |
| 2330 | + ) |
| 2331 | + assert ( |
| 2332 | + create_ns_serv_args.kwargs["namespace"] |
| 2333 | + == create_ns_ingress_args.kwargs["namespace"] |
| 2334 | + ) |
| 2335 | + assert isinstance(create_ns_sa_args.kwargs["body"], client.V1ServiceAccount) |
| 2336 | + assert isinstance(create_crb_args.kwargs["body"], client.V1ClusterRoleBinding) |
| 2337 | + assert isinstance(create_ns_serv_args.kwargs["body"], client.V1Service) |
| 2338 | + assert isinstance(create_ns_ingress_args.kwargs["body"], client.V1Ingress) |
| 2339 | + assert ( |
| 2340 | + create_ns_serv_args.kwargs["body"].spec.ports[0].name |
| 2341 | + == create_ns_ingress_args.kwargs["body"] |
| 2342 | + .spec.rules[0] |
| 2343 | + .http.paths[0] |
| 2344 | + .backend.service.port.name |
| 2345 | + ) |
| 2346 | + |
| 2347 | + |
2297 | 2348 | # Make sure to always keep this function last
|
2298 | 2349 | def test_cleanup():
|
2299 | 2350 | os.remove("unit-test-cluster.yaml")
|
|
0 commit comments