• Home
  • Line#
  • Scopes#
  • Navigate#
  • Raw
  • Download
1 /*
2  * Copyright 2022 Google LLC
3  *
4  * Licensed under the Apache License, Version 2.0 (the "License");
5  * you may not use this file except in compliance with the License.
6  * You may obtain a copy of the License at
7  *
8  *      https://www.apache.org/licenses/LICENSE-2.0
9  *
10  * Unless required by applicable law or agreed to in writing, software
11  * distributed under the License is distributed on an "AS IS" BASIS,
12  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13  * See the License for the specific language governing permissions and
14  * limitations under the License.
15  */
16 
17 package com.google.protos.google.cloud.binaryauthorization.v1;
18 
19 import static com.google.protos.google.cloud.binaryauthorization.v1.BinauthzManagementServiceV1Client.ListAttestorsPagedResponse;
20 
21 import com.google.api.gax.core.NoCredentialsProvider;
22 import com.google.api.gax.grpc.GaxGrpcProperties;
23 import com.google.api.gax.grpc.testing.LocalChannelProvider;
24 import com.google.api.gax.grpc.testing.MockGrpcService;
25 import com.google.api.gax.grpc.testing.MockServiceHelper;
26 import com.google.api.gax.rpc.ApiClientHeaderProvider;
27 import com.google.api.gax.rpc.InvalidArgumentException;
28 import com.google.common.collect.Lists;
29 import com.google.protobuf.AbstractMessage;
30 import com.google.protobuf.Empty;
31 import com.google.protobuf.Timestamp;
32 import io.grpc.StatusRuntimeException;
33 import java.io.IOException;
34 import java.util.ArrayList;
35 import java.util.Arrays;
36 import java.util.HashMap;
37 import java.util.List;
38 import java.util.UUID;
39 import javax.annotation.Generated;
40 import org.junit.After;
41 import org.junit.AfterClass;
42 import org.junit.Assert;
43 import org.junit.Before;
44 import org.junit.BeforeClass;
45 import org.junit.Test;
46 
47 @Generated("by gapic-generator-java")
48 public class BinauthzManagementServiceV1ClientTest {
49   private static MockBinauthzManagementServiceV1 mockBinauthzManagementServiceV1;
50   private static MockServiceHelper mockServiceHelper;
51   private LocalChannelProvider channelProvider;
52   private BinauthzManagementServiceV1Client client;
53 
54   @BeforeClass
startStaticServer()55   public static void startStaticServer() {
56     mockBinauthzManagementServiceV1 = new MockBinauthzManagementServiceV1();
57     mockServiceHelper =
58         new MockServiceHelper(
59             UUID.randomUUID().toString(),
60             Arrays.<MockGrpcService>asList(mockBinauthzManagementServiceV1));
61     mockServiceHelper.start();
62   }
63 
64   @AfterClass
stopServer()65   public static void stopServer() {
66     mockServiceHelper.stop();
67   }
68 
69   @Before
setUp()70   public void setUp() throws IOException {
71     mockServiceHelper.reset();
72     channelProvider = mockServiceHelper.createChannelProvider();
73     BinauthzManagementServiceV1Settings settings =
74         BinauthzManagementServiceV1Settings.newBuilder()
75             .setTransportChannelProvider(channelProvider)
76             .setCredentialsProvider(NoCredentialsProvider.create())
77             .build();
78     client = BinauthzManagementServiceV1Client.create(settings);
79   }
80 
81   @After
tearDown()82   public void tearDown() throws Exception {
83     client.close();
84   }
85 
86   @Test
getPolicyTest()87   public void getPolicyTest() throws Exception {
88     Resources.Policy expectedResponse =
89         Resources.Policy.newBuilder()
90             .setName(PolicyName.ofProjectName("[PROJECT]").toString())
91             .setDescription("description-1724546052")
92             .addAllAdmissionWhitelistPatterns(new ArrayList<Resources.AdmissionWhitelistPattern>())
93             .putAllClusterAdmissionRules(new HashMap<String, Resources.AdmissionRule>())
94             .putAllKubernetesNamespaceAdmissionRules(new HashMap<String, Resources.AdmissionRule>())
95             .putAllKubernetesServiceAccountAdmissionRules(
96                 new HashMap<String, Resources.AdmissionRule>())
97             .putAllIstioServiceIdentityAdmissionRules(
98                 new HashMap<String, Resources.AdmissionRule>())
99             .setDefaultAdmissionRule(Resources.AdmissionRule.newBuilder().build())
100             .setUpdateTime(Timestamp.newBuilder().build())
101             .build();
102     mockBinauthzManagementServiceV1.addResponse(expectedResponse);
103 
104     PolicyName name = PolicyName.ofProjectName("[PROJECT]");
105 
106     Resources.Policy actualResponse = client.getPolicy(name);
107     Assert.assertEquals(expectedResponse, actualResponse);
108 
109     List<AbstractMessage> actualRequests = mockBinauthzManagementServiceV1.getRequests();
110     Assert.assertEquals(1, actualRequests.size());
111     Service.GetPolicyRequest actualRequest = ((Service.GetPolicyRequest) actualRequests.get(0));
112 
113     Assert.assertEquals(name.toString(), actualRequest.getName());
114     Assert.assertTrue(
115         channelProvider.isHeaderSent(
116             ApiClientHeaderProvider.getDefaultApiClientHeaderKey(),
117             GaxGrpcProperties.getDefaultApiClientHeaderPattern()));
118   }
119 
120   @Test
getPolicyExceptionTest()121   public void getPolicyExceptionTest() throws Exception {
122     StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT);
123     mockBinauthzManagementServiceV1.addException(exception);
124 
125     try {
126       PolicyName name = PolicyName.ofProjectName("[PROJECT]");
127       client.getPolicy(name);
128       Assert.fail("No exception raised");
129     } catch (InvalidArgumentException e) {
130       // Expected exception.
131     }
132   }
133 
134   @Test
getPolicyTest2()135   public void getPolicyTest2() throws Exception {
136     Resources.Policy expectedResponse =
137         Resources.Policy.newBuilder()
138             .setName(PolicyName.ofProjectName("[PROJECT]").toString())
139             .setDescription("description-1724546052")
140             .addAllAdmissionWhitelistPatterns(new ArrayList<Resources.AdmissionWhitelistPattern>())
141             .putAllClusterAdmissionRules(new HashMap<String, Resources.AdmissionRule>())
142             .putAllKubernetesNamespaceAdmissionRules(new HashMap<String, Resources.AdmissionRule>())
143             .putAllKubernetesServiceAccountAdmissionRules(
144                 new HashMap<String, Resources.AdmissionRule>())
145             .putAllIstioServiceIdentityAdmissionRules(
146                 new HashMap<String, Resources.AdmissionRule>())
147             .setDefaultAdmissionRule(Resources.AdmissionRule.newBuilder().build())
148             .setUpdateTime(Timestamp.newBuilder().build())
149             .build();
150     mockBinauthzManagementServiceV1.addResponse(expectedResponse);
151 
152     String name = "name3373707";
153 
154     Resources.Policy actualResponse = client.getPolicy(name);
155     Assert.assertEquals(expectedResponse, actualResponse);
156 
157     List<AbstractMessage> actualRequests = mockBinauthzManagementServiceV1.getRequests();
158     Assert.assertEquals(1, actualRequests.size());
159     Service.GetPolicyRequest actualRequest = ((Service.GetPolicyRequest) actualRequests.get(0));
160 
161     Assert.assertEquals(name, actualRequest.getName());
162     Assert.assertTrue(
163         channelProvider.isHeaderSent(
164             ApiClientHeaderProvider.getDefaultApiClientHeaderKey(),
165             GaxGrpcProperties.getDefaultApiClientHeaderPattern()));
166   }
167 
168   @Test
getPolicyExceptionTest2()169   public void getPolicyExceptionTest2() throws Exception {
170     StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT);
171     mockBinauthzManagementServiceV1.addException(exception);
172 
173     try {
174       String name = "name3373707";
175       client.getPolicy(name);
176       Assert.fail("No exception raised");
177     } catch (InvalidArgumentException e) {
178       // Expected exception.
179     }
180   }
181 
182   @Test
updatePolicyTest()183   public void updatePolicyTest() throws Exception {
184     Resources.Policy expectedResponse =
185         Resources.Policy.newBuilder()
186             .setName(PolicyName.ofProjectName("[PROJECT]").toString())
187             .setDescription("description-1724546052")
188             .addAllAdmissionWhitelistPatterns(new ArrayList<Resources.AdmissionWhitelistPattern>())
189             .putAllClusterAdmissionRules(new HashMap<String, Resources.AdmissionRule>())
190             .putAllKubernetesNamespaceAdmissionRules(new HashMap<String, Resources.AdmissionRule>())
191             .putAllKubernetesServiceAccountAdmissionRules(
192                 new HashMap<String, Resources.AdmissionRule>())
193             .putAllIstioServiceIdentityAdmissionRules(
194                 new HashMap<String, Resources.AdmissionRule>())
195             .setDefaultAdmissionRule(Resources.AdmissionRule.newBuilder().build())
196             .setUpdateTime(Timestamp.newBuilder().build())
197             .build();
198     mockBinauthzManagementServiceV1.addResponse(expectedResponse);
199 
200     Resources.Policy policy = Resources.Policy.newBuilder().build();
201 
202     Resources.Policy actualResponse = client.updatePolicy(policy);
203     Assert.assertEquals(expectedResponse, actualResponse);
204 
205     List<AbstractMessage> actualRequests = mockBinauthzManagementServiceV1.getRequests();
206     Assert.assertEquals(1, actualRequests.size());
207     Service.UpdatePolicyRequest actualRequest =
208         ((Service.UpdatePolicyRequest) actualRequests.get(0));
209 
210     Assert.assertEquals(policy, actualRequest.getPolicy());
211     Assert.assertTrue(
212         channelProvider.isHeaderSent(
213             ApiClientHeaderProvider.getDefaultApiClientHeaderKey(),
214             GaxGrpcProperties.getDefaultApiClientHeaderPattern()));
215   }
216 
217   @Test
updatePolicyExceptionTest()218   public void updatePolicyExceptionTest() throws Exception {
219     StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT);
220     mockBinauthzManagementServiceV1.addException(exception);
221 
222     try {
223       Resources.Policy policy = Resources.Policy.newBuilder().build();
224       client.updatePolicy(policy);
225       Assert.fail("No exception raised");
226     } catch (InvalidArgumentException e) {
227       // Expected exception.
228     }
229   }
230 
231   @Test
createAttestorTest()232   public void createAttestorTest() throws Exception {
233     Resources.Attestor expectedResponse =
234         Resources.Attestor.newBuilder()
235             .setName(AttestorName.of("[PROJECT]", "[ATTESTOR]").toString())
236             .setDescription("description-1724546052")
237             .setUpdateTime(Timestamp.newBuilder().build())
238             .build();
239     mockBinauthzManagementServiceV1.addResponse(expectedResponse);
240 
241     ProjectName parent = ProjectName.of("[PROJECT]");
242     String attestorId = "attestorId2055733027";
243     Resources.Attestor attestor = Resources.Attestor.newBuilder().build();
244 
245     Resources.Attestor actualResponse = client.createAttestor(parent, attestorId, attestor);
246     Assert.assertEquals(expectedResponse, actualResponse);
247 
248     List<AbstractMessage> actualRequests = mockBinauthzManagementServiceV1.getRequests();
249     Assert.assertEquals(1, actualRequests.size());
250     Service.CreateAttestorRequest actualRequest =
251         ((Service.CreateAttestorRequest) actualRequests.get(0));
252 
253     Assert.assertEquals(parent.toString(), actualRequest.getParent());
254     Assert.assertEquals(attestorId, actualRequest.getAttestorId());
255     Assert.assertEquals(attestor, actualRequest.getAttestor());
256     Assert.assertTrue(
257         channelProvider.isHeaderSent(
258             ApiClientHeaderProvider.getDefaultApiClientHeaderKey(),
259             GaxGrpcProperties.getDefaultApiClientHeaderPattern()));
260   }
261 
262   @Test
createAttestorExceptionTest()263   public void createAttestorExceptionTest() throws Exception {
264     StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT);
265     mockBinauthzManagementServiceV1.addException(exception);
266 
267     try {
268       ProjectName parent = ProjectName.of("[PROJECT]");
269       String attestorId = "attestorId2055733027";
270       Resources.Attestor attestor = Resources.Attestor.newBuilder().build();
271       client.createAttestor(parent, attestorId, attestor);
272       Assert.fail("No exception raised");
273     } catch (InvalidArgumentException e) {
274       // Expected exception.
275     }
276   }
277 
278   @Test
createAttestorTest2()279   public void createAttestorTest2() throws Exception {
280     Resources.Attestor expectedResponse =
281         Resources.Attestor.newBuilder()
282             .setName(AttestorName.of("[PROJECT]", "[ATTESTOR]").toString())
283             .setDescription("description-1724546052")
284             .setUpdateTime(Timestamp.newBuilder().build())
285             .build();
286     mockBinauthzManagementServiceV1.addResponse(expectedResponse);
287 
288     String parent = "parent-995424086";
289     String attestorId = "attestorId2055733027";
290     Resources.Attestor attestor = Resources.Attestor.newBuilder().build();
291 
292     Resources.Attestor actualResponse = client.createAttestor(parent, attestorId, attestor);
293     Assert.assertEquals(expectedResponse, actualResponse);
294 
295     List<AbstractMessage> actualRequests = mockBinauthzManagementServiceV1.getRequests();
296     Assert.assertEquals(1, actualRequests.size());
297     Service.CreateAttestorRequest actualRequest =
298         ((Service.CreateAttestorRequest) actualRequests.get(0));
299 
300     Assert.assertEquals(parent, actualRequest.getParent());
301     Assert.assertEquals(attestorId, actualRequest.getAttestorId());
302     Assert.assertEquals(attestor, actualRequest.getAttestor());
303     Assert.assertTrue(
304         channelProvider.isHeaderSent(
305             ApiClientHeaderProvider.getDefaultApiClientHeaderKey(),
306             GaxGrpcProperties.getDefaultApiClientHeaderPattern()));
307   }
308 
309   @Test
createAttestorExceptionTest2()310   public void createAttestorExceptionTest2() throws Exception {
311     StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT);
312     mockBinauthzManagementServiceV1.addException(exception);
313 
314     try {
315       String parent = "parent-995424086";
316       String attestorId = "attestorId2055733027";
317       Resources.Attestor attestor = Resources.Attestor.newBuilder().build();
318       client.createAttestor(parent, attestorId, attestor);
319       Assert.fail("No exception raised");
320     } catch (InvalidArgumentException e) {
321       // Expected exception.
322     }
323   }
324 
325   @Test
getAttestorTest()326   public void getAttestorTest() throws Exception {
327     Resources.Attestor expectedResponse =
328         Resources.Attestor.newBuilder()
329             .setName(AttestorName.of("[PROJECT]", "[ATTESTOR]").toString())
330             .setDescription("description-1724546052")
331             .setUpdateTime(Timestamp.newBuilder().build())
332             .build();
333     mockBinauthzManagementServiceV1.addResponse(expectedResponse);
334 
335     AttestorName name = AttestorName.of("[PROJECT]", "[ATTESTOR]");
336 
337     Resources.Attestor actualResponse = client.getAttestor(name);
338     Assert.assertEquals(expectedResponse, actualResponse);
339 
340     List<AbstractMessage> actualRequests = mockBinauthzManagementServiceV1.getRequests();
341     Assert.assertEquals(1, actualRequests.size());
342     Service.GetAttestorRequest actualRequest = ((Service.GetAttestorRequest) actualRequests.get(0));
343 
344     Assert.assertEquals(name.toString(), actualRequest.getName());
345     Assert.assertTrue(
346         channelProvider.isHeaderSent(
347             ApiClientHeaderProvider.getDefaultApiClientHeaderKey(),
348             GaxGrpcProperties.getDefaultApiClientHeaderPattern()));
349   }
350 
351   @Test
getAttestorExceptionTest()352   public void getAttestorExceptionTest() throws Exception {
353     StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT);
354     mockBinauthzManagementServiceV1.addException(exception);
355 
356     try {
357       AttestorName name = AttestorName.of("[PROJECT]", "[ATTESTOR]");
358       client.getAttestor(name);
359       Assert.fail("No exception raised");
360     } catch (InvalidArgumentException e) {
361       // Expected exception.
362     }
363   }
364 
365   @Test
getAttestorTest2()366   public void getAttestorTest2() throws Exception {
367     Resources.Attestor expectedResponse =
368         Resources.Attestor.newBuilder()
369             .setName(AttestorName.of("[PROJECT]", "[ATTESTOR]").toString())
370             .setDescription("description-1724546052")
371             .setUpdateTime(Timestamp.newBuilder().build())
372             .build();
373     mockBinauthzManagementServiceV1.addResponse(expectedResponse);
374 
375     String name = "name3373707";
376 
377     Resources.Attestor actualResponse = client.getAttestor(name);
378     Assert.assertEquals(expectedResponse, actualResponse);
379 
380     List<AbstractMessage> actualRequests = mockBinauthzManagementServiceV1.getRequests();
381     Assert.assertEquals(1, actualRequests.size());
382     Service.GetAttestorRequest actualRequest = ((Service.GetAttestorRequest) actualRequests.get(0));
383 
384     Assert.assertEquals(name, actualRequest.getName());
385     Assert.assertTrue(
386         channelProvider.isHeaderSent(
387             ApiClientHeaderProvider.getDefaultApiClientHeaderKey(),
388             GaxGrpcProperties.getDefaultApiClientHeaderPattern()));
389   }
390 
391   @Test
getAttestorExceptionTest2()392   public void getAttestorExceptionTest2() throws Exception {
393     StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT);
394     mockBinauthzManagementServiceV1.addException(exception);
395 
396     try {
397       String name = "name3373707";
398       client.getAttestor(name);
399       Assert.fail("No exception raised");
400     } catch (InvalidArgumentException e) {
401       // Expected exception.
402     }
403   }
404 
405   @Test
updateAttestorTest()406   public void updateAttestorTest() throws Exception {
407     Resources.Attestor expectedResponse =
408         Resources.Attestor.newBuilder()
409             .setName(AttestorName.of("[PROJECT]", "[ATTESTOR]").toString())
410             .setDescription("description-1724546052")
411             .setUpdateTime(Timestamp.newBuilder().build())
412             .build();
413     mockBinauthzManagementServiceV1.addResponse(expectedResponse);
414 
415     Resources.Attestor attestor = Resources.Attestor.newBuilder().build();
416 
417     Resources.Attestor actualResponse = client.updateAttestor(attestor);
418     Assert.assertEquals(expectedResponse, actualResponse);
419 
420     List<AbstractMessage> actualRequests = mockBinauthzManagementServiceV1.getRequests();
421     Assert.assertEquals(1, actualRequests.size());
422     Service.UpdateAttestorRequest actualRequest =
423         ((Service.UpdateAttestorRequest) actualRequests.get(0));
424 
425     Assert.assertEquals(attestor, actualRequest.getAttestor());
426     Assert.assertTrue(
427         channelProvider.isHeaderSent(
428             ApiClientHeaderProvider.getDefaultApiClientHeaderKey(),
429             GaxGrpcProperties.getDefaultApiClientHeaderPattern()));
430   }
431 
432   @Test
updateAttestorExceptionTest()433   public void updateAttestorExceptionTest() throws Exception {
434     StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT);
435     mockBinauthzManagementServiceV1.addException(exception);
436 
437     try {
438       Resources.Attestor attestor = Resources.Attestor.newBuilder().build();
439       client.updateAttestor(attestor);
440       Assert.fail("No exception raised");
441     } catch (InvalidArgumentException e) {
442       // Expected exception.
443     }
444   }
445 
446   @Test
listAttestorsTest()447   public void listAttestorsTest() throws Exception {
448     Resources.Attestor responsesElement = Resources.Attestor.newBuilder().build();
449     Service.ListAttestorsResponse expectedResponse =
450         Service.ListAttestorsResponse.newBuilder()
451             .setNextPageToken("")
452             .addAllAttestors(Arrays.asList(responsesElement))
453             .build();
454     mockBinauthzManagementServiceV1.addResponse(expectedResponse);
455 
456     ProjectName parent = ProjectName.of("[PROJECT]");
457 
458     ListAttestorsPagedResponse pagedListResponse = client.listAttestors(parent);
459 
460     List<Resources.Attestor> resources = Lists.newArrayList(pagedListResponse.iterateAll());
461 
462     Assert.assertEquals(1, resources.size());
463     Assert.assertEquals(expectedResponse.getAttestorsList().get(0), resources.get(0));
464 
465     List<AbstractMessage> actualRequests = mockBinauthzManagementServiceV1.getRequests();
466     Assert.assertEquals(1, actualRequests.size());
467     Service.ListAttestorsRequest actualRequest =
468         ((Service.ListAttestorsRequest) actualRequests.get(0));
469 
470     Assert.assertEquals(parent.toString(), actualRequest.getParent());
471     Assert.assertTrue(
472         channelProvider.isHeaderSent(
473             ApiClientHeaderProvider.getDefaultApiClientHeaderKey(),
474             GaxGrpcProperties.getDefaultApiClientHeaderPattern()));
475   }
476 
477   @Test
listAttestorsExceptionTest()478   public void listAttestorsExceptionTest() throws Exception {
479     StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT);
480     mockBinauthzManagementServiceV1.addException(exception);
481 
482     try {
483       ProjectName parent = ProjectName.of("[PROJECT]");
484       client.listAttestors(parent);
485       Assert.fail("No exception raised");
486     } catch (InvalidArgumentException e) {
487       // Expected exception.
488     }
489   }
490 
491   @Test
listAttestorsTest2()492   public void listAttestorsTest2() throws Exception {
493     Resources.Attestor responsesElement = Resources.Attestor.newBuilder().build();
494     Service.ListAttestorsResponse expectedResponse =
495         Service.ListAttestorsResponse.newBuilder()
496             .setNextPageToken("")
497             .addAllAttestors(Arrays.asList(responsesElement))
498             .build();
499     mockBinauthzManagementServiceV1.addResponse(expectedResponse);
500 
501     String parent = "parent-995424086";
502 
503     ListAttestorsPagedResponse pagedListResponse = client.listAttestors(parent);
504 
505     List<Resources.Attestor> resources = Lists.newArrayList(pagedListResponse.iterateAll());
506 
507     Assert.assertEquals(1, resources.size());
508     Assert.assertEquals(expectedResponse.getAttestorsList().get(0), resources.get(0));
509 
510     List<AbstractMessage> actualRequests = mockBinauthzManagementServiceV1.getRequests();
511     Assert.assertEquals(1, actualRequests.size());
512     Service.ListAttestorsRequest actualRequest =
513         ((Service.ListAttestorsRequest) actualRequests.get(0));
514 
515     Assert.assertEquals(parent, actualRequest.getParent());
516     Assert.assertTrue(
517         channelProvider.isHeaderSent(
518             ApiClientHeaderProvider.getDefaultApiClientHeaderKey(),
519             GaxGrpcProperties.getDefaultApiClientHeaderPattern()));
520   }
521 
522   @Test
listAttestorsExceptionTest2()523   public void listAttestorsExceptionTest2() throws Exception {
524     StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT);
525     mockBinauthzManagementServiceV1.addException(exception);
526 
527     try {
528       String parent = "parent-995424086";
529       client.listAttestors(parent);
530       Assert.fail("No exception raised");
531     } catch (InvalidArgumentException e) {
532       // Expected exception.
533     }
534   }
535 
536   @Test
deleteAttestorTest()537   public void deleteAttestorTest() throws Exception {
538     Empty expectedResponse = Empty.newBuilder().build();
539     mockBinauthzManagementServiceV1.addResponse(expectedResponse);
540 
541     AttestorName name = AttestorName.of("[PROJECT]", "[ATTESTOR]");
542 
543     client.deleteAttestor(name);
544 
545     List<AbstractMessage> actualRequests = mockBinauthzManagementServiceV1.getRequests();
546     Assert.assertEquals(1, actualRequests.size());
547     Service.DeleteAttestorRequest actualRequest =
548         ((Service.DeleteAttestorRequest) actualRequests.get(0));
549 
550     Assert.assertEquals(name.toString(), actualRequest.getName());
551     Assert.assertTrue(
552         channelProvider.isHeaderSent(
553             ApiClientHeaderProvider.getDefaultApiClientHeaderKey(),
554             GaxGrpcProperties.getDefaultApiClientHeaderPattern()));
555   }
556 
557   @Test
deleteAttestorExceptionTest()558   public void deleteAttestorExceptionTest() throws Exception {
559     StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT);
560     mockBinauthzManagementServiceV1.addException(exception);
561 
562     try {
563       AttestorName name = AttestorName.of("[PROJECT]", "[ATTESTOR]");
564       client.deleteAttestor(name);
565       Assert.fail("No exception raised");
566     } catch (InvalidArgumentException e) {
567       // Expected exception.
568     }
569   }
570 
571   @Test
deleteAttestorTest2()572   public void deleteAttestorTest2() throws Exception {
573     Empty expectedResponse = Empty.newBuilder().build();
574     mockBinauthzManagementServiceV1.addResponse(expectedResponse);
575 
576     String name = "name3373707";
577 
578     client.deleteAttestor(name);
579 
580     List<AbstractMessage> actualRequests = mockBinauthzManagementServiceV1.getRequests();
581     Assert.assertEquals(1, actualRequests.size());
582     Service.DeleteAttestorRequest actualRequest =
583         ((Service.DeleteAttestorRequest) actualRequests.get(0));
584 
585     Assert.assertEquals(name, actualRequest.getName());
586     Assert.assertTrue(
587         channelProvider.isHeaderSent(
588             ApiClientHeaderProvider.getDefaultApiClientHeaderKey(),
589             GaxGrpcProperties.getDefaultApiClientHeaderPattern()));
590   }
591 
592   @Test
deleteAttestorExceptionTest2()593   public void deleteAttestorExceptionTest2() throws Exception {
594     StatusRuntimeException exception = new StatusRuntimeException(io.grpc.Status.INVALID_ARGUMENT);
595     mockBinauthzManagementServiceV1.addException(exception);
596 
597     try {
598       String name = "name3373707";
599       client.deleteAttestor(name);
600       Assert.fail("No exception raised");
601     } catch (InvalidArgumentException e) {
602       // Expected exception.
603     }
604   }
605 }
606