fix GCP pub/sub auth issue - remore redundant apikey param (akka#427)

joneyin · Nov 13, 2017 · 72bf890 · 72bf890
1 parent 35216f6
commit 72bf890
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/google-cloud-pub-sub/src/main/scala/akka/stream/alpakka/googlecloud/pubsub/HttpApi.scala b/google-cloud-pub-sub/src/main/scala/akka/stream/alpakka/googlecloud/pubsub/HttpApi.scala
@@ -103,7 +103,7 @@ private trait HttpApi {
   ): Future[immutable.Seq[String]] = {
     import materializer.executionContext
 
-    val url: Uri = s"$PubSubGoogleApisHost/v1/projects/$project/topics/$topic:publish?key=$apiKey"
+    val url: Uri = s"$PubSubGoogleApisHost/v1/projects/$project/topics/$topic:publish"
 
     for {
       request <- Marshal((HttpMethods.POST, url, request)).to[HttpRequest]

diff --git a/google-cloud-pub-sub/src/test/scala/akka/stream/alpakka/googlecloud/pubsub/HttpApiSpec.scala b/google-cloud-pub-sub/src/test/scala/akka/stream/alpakka/googlecloud/pubsub/HttpApiSpec.scala
@@ -81,7 +81,7 @@ class HttpApiSpec extends FlatSpec with BeforeAndAfterAll with ScalaFutures with
     mock.register(
       WireMock
         .post(
-          urlEqualTo(s"/v1/projects/${TestCredentials.projectId}/topics/topic1:publish?key=${TestCredentials.apiKey}")
+          urlEqualTo(s"/v1/projects/${TestCredentials.projectId}/topics/topic1:publish")
         )
         .withRequestBody(WireMock.equalTo(expectedPublishRequest))
         .withHeader("Authorization", WireMock.equalTo("Bearer " + accessToken))