Skip to content

Commit

Permalink
43811 - Updating docs to use MetaData.Key
Browse files Browse the repository at this point in the history
  • Loading branch information
tmulle committed Oct 10, 2024
1 parent 691dd46 commit db3b0c1
Showing 1 changed file with 24 additions and 6 deletions.
30 changes: 24 additions & 6 deletions docs/src/main/asciidoc/grpc-service-implementation.adoc
Original file line number Diff line number Diff line change
Expand Up @@ -521,29 +521,47 @@ quarkus.http.auth.basic=true <1>
----
package org.acme.grpc.auth;
import static org.assertj.core.api.Assertions.assertThat;
import static org.hamcrest.MatcherAssert.assertThat;
import static org.hamcrest.Matchers.is;
import com.rajant.connector.proto.Greeter;
import com.rajant.connector.proto.HelloRequest;
import io.grpc.Metadata;
import io.quarkus.grpc.GrpcClient;
import io.quarkus.grpc.GrpcClientUtils;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.TimeoutException;
import io.quarkus.test.junit.QuarkusTest;
import org.junit.jupiter.api.Test;
public class HelloServiceTest implements Greeter {
@QuarkusTest
public class HelloServiceTest {
@GrpcClient
Greeter greeterClient;
@Test
void shouldReturnHello() {
void shouldReturnHello() throws ExecutionException, InterruptedException, TimeoutException {
Metadata headers = new Metadata();
headers.put("Authorization", "Basic am9objpqb2hu");
// Set the headers - Basic auth for testing
Metadata.Key<String> key = Metadata.Key.of("Authorization", Metadata.ASCII_STRING_MARSHALLER);
headers.put(key, "Basic YWxpY2U6YWxpY2U="); // alice:alice with "admin" role
var client = GrpcClientUtils.attachHeaders(greeterClient, headers);
// Call the client
CompletableFuture<String> message = new CompletableFuture<>();
client.sayHello(HelloRequest.newBuilder().setName("Quarkus").build())
.subscribe().with(reply -> message.complete(reply.getMessage()));
assertThat(message.get(5, TimeUnit.SECONDS)).isEqualTo("Hello Quarkus");
// Get the values
String theValue = message.get(5, TimeUnit.SECONDS);
// Assert
assertThat(theValue, is("Hello Quarkus"));
}
}
----
Expand Down Expand Up @@ -596,7 +614,7 @@ import io.quarkus.security.identity.request.UsernamePasswordAuthenticationReques
@Singleton
public class CustomGrpcSecurityMechanism implements GrpcSecurityMechanism {
private static final String AUTHORIZATION = "Authorization";
private static final MetaData.Key<String> AUTHORIZATION = Metadata.Key.of("Authorization", Metadata.ASCII_STRING_MARSHALLER);
@Override
public boolean handles(Metadata metadata) {
Expand Down

0 comments on commit db3b0c1

Please sign in to comment.