feat: Introduce the event publishing using JSON representation of Clo…

…udEvents (#170)

- [ ] Regenerate this pull request now.

Clients can now use either the Protobuf or the JSON CloudEvents representation
when interacting with Eventarc Publishing API. This change benefits both
Channel and ChannelConnection consumers.

PiperOrigin-RevId: 486208303

Source-Link: https://togithub.com/googleapis/googleapis/commit/079ef843a85546a6d352f8936f5a8442c60f9601

Source-Link: https://togithub.com/googleapis/googleapis-gen/commit/dd62dfc174abb25bf2e50a2a54651da70daed781
Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiZGQ2MmRmYzE3NGFiYjI1YmYyZTUwYTJhNTQ2NTFkYTcwZGFlZDc4MSJ9

BEGIN_NESTED_COMMIT
chore: Set `rest_numeric_enums = False` for all gapic rules explicitly
PiperOrigin-RevId: 485623855

Source-Link: https://togithub.com/googleapis/googleapis/commit/807125e7953e32535710924fe4bf0362ac93754d

Source-Link: https://togithub.com/googleapis/googleapis-gen/commit/c4ddd6d651da69658a4762c5eafff5cd8f0e25c5
Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiYzRkZGQ2ZDY1MWRhNjk2NThhNDc2MmM1ZWFmZmY1Y2Q4ZjBlMjVjNSJ9
END_NESTED_COMMIT

java-eventarc-publishing/google-cloud-eventarc-publishing/src/main/java/com/google/cloud/eventarc/publishing/v1/PublisherClient.java

@@ -62,6 +62,7 @@
  *       PublishChannelConnectionEventsRequest.newBuilder()
  *           .setChannelConnection("channelConnection-1932021695")
  *           .addAllEvents(new ArrayList<Any>())
+ *           .addAllTextEvents(new ArrayList<String>())
  *           .build();
  *   PublishChannelConnectionEventsResponse response =
  *       publisherClient.publishChannelConnectionEvents(request);
@@ -131,11 +132,7 @@
  * // - It may require correct/in-range values for request initialization.
  * // - It may require specifying regional endpoints when creating the service client as shown in
  * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
- * PublisherSettings publisherSettings =
- *     PublisherSettings.newBuilder()
- *         .setTransportChannelProvider(
- *             PublisherSettings.defaultHttpJsonTransportProviderBuilder().build())
- *         .build();
+ * PublisherSettings publisherSettings = PublisherSettings.newHttpJsonBuilder().build();
  * PublisherClient publisherClient = PublisherClient.create(publisherSettings);
  * }</pre>
  *
@@ -206,6 +203,7 @@ public PublisherStub getStub() {
    *       PublishChannelConnectionEventsRequest.newBuilder()
    *           .setChannelConnection("channelConnection-1932021695")
    *           .addAllEvents(new ArrayList<Any>())
+   *           .addAllTextEvents(new ArrayList<String>())
    *           .build();
    *   PublishChannelConnectionEventsResponse response =
    *       publisherClient.publishChannelConnectionEvents(request);
@@ -237,6 +235,7 @@ public final PublishChannelConnectionEventsResponse publishChannelConnectionEven
    *       PublishChannelConnectionEventsRequest.newBuilder()
    *           .setChannelConnection("channelConnection-1932021695")
    *           .addAllEvents(new ArrayList<Any>())
+   *           .addAllTextEvents(new ArrayList<String>())
    *           .build();
    *   ApiFuture<PublishChannelConnectionEventsResponse> future =
    *       publisherClient.publishChannelConnectionEventsCallable().futureCall(request);
@@ -268,6 +267,7 @@ public final PublishChannelConnectionEventsResponse publishChannelConnectionEven
    *       PublishEventsRequest.newBuilder()
    *           .setChannel("channel738950403")
    *           .addAllEvents(new ArrayList<Any>())
+   *           .addAllTextEvents(new ArrayList<String>())
    *           .build();
    *   PublishEventsResponse response = publisherClient.publishEvents(request);
    * }
@@ -297,6 +297,7 @@ public final PublishEventsResponse publishEvents(PublishEventsRequest request) {
    *       PublishEventsRequest.newBuilder()
    *           .setChannel("channel738950403")
    *           .addAllEvents(new ArrayList<Any>())
+   *           .addAllTextEvents(new ArrayList<String>())
    *           .build();
    *   ApiFuture<PublishEventsResponse> future =
    *       publisherClient.publishEventsCallable().futureCall(request);

java-eventarc-publishing/google-cloud-eventarc-publishing/src/main/java/com/google/cloud/eventarc/publishing/v1/package-info.java

@@ -56,6 +56,7 @@
  *       PublishChannelConnectionEventsRequest.newBuilder()
  *           .setChannelConnection("channelConnection-1932021695")
  *           .addAllEvents(new ArrayList<Any>())
+ *           .addAllTextEvents(new ArrayList<String>())
  *           .build();
  *   PublishChannelConnectionEventsResponse response =
  *       publisherClient.publishChannelConnectionEvents(request);

java-eventarc-publishing/google-cloud-eventarc-publishing/src/test/java/com/google/cloud/eventarc/publishing/v1/PublisherClientHttpJsonTest.java

@@ -83,6 +83,7 @@ public void publishChannelConnectionEventsTest() throws Exception {
             .setChannelConnection(
                 "projects/project-748/locations/location-748/channelConnections/channelConnection-748")
             .addAllEvents(new ArrayList<Any>())
+            .addAllTextEvents(new ArrayList<String>())
             .build();
 
     PublishChannelConnectionEventsResponse actualResponse =
@@ -117,6 +118,7 @@ public void publishChannelConnectionEventsExceptionTest() throws Exception {
               .setChannelConnection(
                   "projects/project-748/locations/location-748/channelConnections/channelConnection-748")
               .addAllEvents(new ArrayList<Any>())
+              .addAllTextEvents(new ArrayList<String>())
               .build();
       client.publishChannelConnectionEvents(request);
       Assert.fail("No exception raised");
@@ -134,6 +136,7 @@ public void publishEventsTest() throws Exception {
         PublishEventsRequest.newBuilder()
             .setChannel("projects/project-2616/locations/location-2616/channels/channel-2616")
             .addAllEvents(new ArrayList<Any>())
+            .addAllTextEvents(new ArrayList<String>())
             .build();
 
     PublishEventsResponse actualResponse = client.publishEvents(request);
@@ -166,6 +169,7 @@ public void publishEventsExceptionTest() throws Exception {
           PublishEventsRequest.newBuilder()
               .setChannel("projects/project-2616/locations/location-2616/channels/channel-2616")
               .addAllEvents(new ArrayList<Any>())
+              .addAllTextEvents(new ArrayList<String>())
               .build();
       client.publishEvents(request);
       Assert.fail("No exception raised");

java-eventarc-publishing/google-cloud-eventarc-publishing/src/test/java/com/google/cloud/eventarc/publishing/v1/PublisherClientTest.java

@@ -87,6 +87,7 @@ public void publishChannelConnectionEventsTest() throws Exception {
         PublishChannelConnectionEventsRequest.newBuilder()
             .setChannelConnection("channelConnection-1932021695")
             .addAllEvents(new ArrayList<Any>())
+            .addAllTextEvents(new ArrayList<String>())
             .build();
 
     PublishChannelConnectionEventsResponse actualResponse =
@@ -100,6 +101,7 @@ public void publishChannelConnectionEventsTest() throws Exception {
 
     Assert.assertEquals(request.getChannelConnection(), actualRequest.getChannelConnection());
     Assert.assertEquals(request.getEventsList(), actualRequest.getEventsList());
+    Assert.assertEquals(request.getTextEventsList(), actualRequest.getTextEventsList());
     Assert.assertTrue(
         channelProvider.isHeaderSent(
             ApiClientHeaderProvider.getDefaultApiClientHeaderKey(),
@@ -116,6 +118,7 @@ public void publishChannelConnectionEventsExceptionTest() throws Exception {
           PublishChannelConnectionEventsRequest.newBuilder()
               .setChannelConnection("channelConnection-1932021695")
               .addAllEvents(new ArrayList<Any>())
+              .addAllTextEvents(new ArrayList<String>())
               .build();
       client.publishChannelConnectionEvents(request);
       Assert.fail("No exception raised");
@@ -133,6 +136,7 @@ public void publishEventsTest() throws Exception {
         PublishEventsRequest.newBuilder()
             .setChannel("channel738950403")
             .addAllEvents(new ArrayList<Any>())
+            .addAllTextEvents(new ArrayList<String>())
             .build();
 
     PublishEventsResponse actualResponse = client.publishEvents(request);
@@ -144,6 +148,7 @@ public void publishEventsTest() throws Exception {
 
     Assert.assertEquals(request.getChannel(), actualRequest.getChannel());
     Assert.assertEquals(request.getEventsList(), actualRequest.getEventsList());
+    Assert.assertEquals(request.getTextEventsList(), actualRequest.getTextEventsList());
     Assert.assertTrue(
         channelProvider.isHeaderSent(
             ApiClientHeaderProvider.getDefaultApiClientHeaderKey(),
@@ -160,6 +165,7 @@ public void publishEventsExceptionTest() throws Exception {
           PublishEventsRequest.newBuilder()
               .setChannel("channel738950403")
               .addAllEvents(new ArrayList<Any>())
+              .addAllTextEvents(new ArrayList<String>())
               .build();
       client.publishEvents(request);
       Assert.fail("No exception raised");