chore: migrate java-pubsub to monorepo

.github/CODEOWNERS

@@ -9,3 +9,4 @@
 /java-vertexai/   @googleapis/vertexai-team @googleapis/cloud-sdk-java-team
 /java-bigquerystorage/ @googleapis/bigquery-team @googleapis/cloud-sdk-java-team
 /java-bigquery/ @googleapis/bigquery-team @googleapis/cloud-sdk-java-team
+/java-pubsub/ @googleapis/pubsub-team @googleapis/cloud-sdk-java-team

.kokoro/common.sh

@@ -23,6 +23,7 @@ excluded_modules=(
   'java-bigquerystorage'
   'java-datastore'
   'java-logging-logback'
+  'java-pubsub'
 )
 
 function retry_with_backoff {

.kokoro/presubmit/logging-graalvm-native-presubmit.cfg

@@ -3,7 +3,7 @@
 # Configure the docker image for kokoro-trampoline.
 env_vars: {
   key: "TRAMPOLINE_IMAGE"
-  value: "gcr.io/cloud-devrel-public-resources/graalvm_sdk_platform_a:3.56.1"
+  value: "gcr.io/cloud-devrel-public-resources/graalvm_sdk_platform_a:3.57.0" # {x-version-update:google-cloud-shared-dependencies:current}
 }
 
 env_vars: {
@@ -14,25 +14,29 @@ env_vars: {
 # TODO: remove this after we've migrated all tests and scripts
 env_vars: {
   key: "GCLOUD_PROJECT"
-  value: "cloud-java-ci-test"
+  value: "gcloud-devel"
 }
 
 env_vars: {
   key: "GOOGLE_CLOUD_PROJECT"
-  value: "cloud-java-ci-test"
+  value: "gcloud-devel"
 }
 
 env_vars: {
   key: "GOOGLE_APPLICATION_CREDENTIALS"
-  value: "secret_manager/cloud-java-ci-it-service-account"
+  value: "secret_manager/java-it-service-account"
 }
 
 env_vars: {
   key: "SECRET_MANAGER_KEYS"
-  value: "cloud-java-ci-it-service-account, java-bigqueryconnection-samples-secrets"
+  value: "java-it-service-account"
 }
 
+env_vars: {
+  key: "IT_SERVICE_ACCOUNT_EMAIL"
+  value: "it-service-account@gcloud-devel.iam.gserviceaccount.com"
+}
 env_vars: {
   key: "BUILD_SUBDIR"
-  value: "java-logging"
+  value: "java-pubsub"
 }

.kokoro/presubmit/logging-integration.cfg

@@ -3,7 +3,7 @@
 # Configure the docker image for kokoro-trampoline.
 env_vars: {
   key: "TRAMPOLINE_IMAGE"
-  value: "gcr.io/cloud-devrel-kokoro-resources/java11"
+  value: "gcr.io/cloud-devrel-kokoro-resources/java8"
 }
 
 env_vars: {
@@ -14,25 +14,26 @@ env_vars: {
 # TODO: remove this after we've migrated all tests and scripts
 env_vars: {
   key: "GCLOUD_PROJECT"
-  value: "cloud-java-ci-test"
+  value: "gcloud-devel"
 }
 
 env_vars: {
   key: "GOOGLE_CLOUD_PROJECT"
-  value: "cloud-java-ci-test"
+  value: "gcloud-devel"
 }
 
 env_vars: {
   key: "GOOGLE_APPLICATION_CREDENTIALS"
-  value: "secret_manager/cloud-java-ci-it-service-account"
+  value: "secret_manager/java-it-service-account"
 }
 
 env_vars: {
   key: "SECRET_MANAGER_KEYS"
-  value: "cloud-java-ci-it-service-account, java-bigqueryconnection-samples-secrets"
+  value: "java-it-service-account"
 }
 
+
 env_vars: {
   key: "BUILD_SUBDIR"
-  value: "java-logging"
+  value: "java-pubsub"
 }

.kokoro/presubmit/pubsub-graalvm-native-presubmit.cfg

@@ -0,0 +1,42 @@
+# Format: //devtools/kokoro/config/proto/build.proto
+
+# Configure the docker image for kokoro-trampoline.
+env_vars: {
+  key: "TRAMPOLINE_IMAGE"
+  value: "gcr.io/cloud-devrel-public-resources/graalvm_sdk_platform_a:3.57.0" # {x-version-update:google-cloud-shared-dependencies:current}
+}
+
+env_vars: {
+  key: "JOB_TYPE"
+  value: "graalvm-single"
+}
+
+# TODO: remove this after we've migrated all tests and scripts
+env_vars: {
+  key: "GCLOUD_PROJECT"
+  value: "gcloud-devel"
+}
+
+env_vars: {
+  key: "GOOGLE_CLOUD_PROJECT"
+  value: "gcloud-devel"
+}
+
+env_vars: {
+  key: "GOOGLE_APPLICATION_CREDENTIALS"
+  value: "secret_manager/java-it-service-account"
+}
+
+env_vars: {
+  key: "SECRET_MANAGER_KEYS"
+  value: "java-it-service-account"
+}
+
+env_vars: {
+  key: "IT_SERVICE_ACCOUNT_EMAIL"
+  value: "it-service-account@gcloud-devel.iam.gserviceaccount.com"
+}
+env_vars: {
+  key: "BUILD_SUBDIR"
+  value: "java-pubsub"
+}

.kokoro/presubmit/pubsub-integration.cfg

@@ -0,0 +1,39 @@
+# Format: //devtools/kokoro/config/proto/build.proto
+
+# Configure the docker image for kokoro-trampoline.
+env_vars: {
+  key: "TRAMPOLINE_IMAGE"
+  value: "gcr.io/cloud-devrel-kokoro-resources/java8"
+}
+
+env_vars: {
+  key: "JOB_TYPE"
+  value: "integration-single"
+}
+
+# TODO: remove this after we've migrated all tests and scripts
+env_vars: {
+  key: "GCLOUD_PROJECT"
+  value: "gcloud-devel"
+}
+
+env_vars: {
+  key: "GOOGLE_CLOUD_PROJECT"
+  value: "gcloud-devel"
+}
+
+env_vars: {
+  key: "GOOGLE_APPLICATION_CREDENTIALS"
+  value: "secret_manager/java-it-service-account"
+}
+
+env_vars: {
+  key: "SECRET_MANAGER_KEYS"
+  value: "java-it-service-account"
+}
+
+
+env_vars: {
+  key: "BUILD_SUBDIR"
+  value: "java-pubsub"
+}

gapic-libraries-bom/pom.xml

@@ -1074,6 +1074,13 @@
         <type>pom</type>
         <scope>import</scope>
       </dependency>
+      <dependency>
+        <groupId>com.google.cloud</groupId>
+        <artifactId>google-cloud-pubsub-bom</artifactId>
+        <version>1.149.1-SNAPSHOT</version><!-- {x-version-update:google-cloud-pubsub:current} -->
+        <type>pom</type>
+        <scope>import</scope>
+      </dependency>
       <dependency>
         <groupId>com.google.cloud</groupId>
         <artifactId>google-cloud-rapidmigrationassessment-bom</artifactId>

generation/check_non_release_please_versions.sh

@@ -12,6 +12,7 @@ for pomFile in $(find . -mindepth 2 -name pom.xml | sort ); do
       [[ "${pomFile}" =~ .*java-datastore.* ]] || \
       [[ "${pomFile}" =~ .*java-logging-logback.* ]] || \
       [[ "${pomFile}" =~ .*java-bigquery.* ]] || \
+      [[ "${pomFile}" =~ .*java-pubsub.* ]] || \
       [[ "${pomFile}" =~ .*.github*. ]]; then
     continue
   fi

generation_config.yaml

@@ -2019,6 +2019,27 @@ libraries:
   GAPICs:
   - proto_path: google/cloud/security/publicca/v1beta1
   - proto_path: google/cloud/security/publicca/v1
+- api_shortname: pubsub
+  name_pretty: Cloud Pub/Sub
+  api_reference: https://cloud.google.com/pubsub/
+  product_documentation: https://cloud.google.com/pubsub/docs/
+  client_documentation: https://cloud.google.com/java/docs/reference/google-cloud-pubsub/latest/history
+  api_description: is designed to provide reliable, many-to-many, asynchronous messaging
+    between applications. Publisher applications can send messages to a topic and
+    other applications can subscribe to that topic to receive the messages. By decoupling
+    senders and receivers, Google Cloud Pub/Sub allows developers to communicate between
+    independently written applications.
+  issue_tracker: https://issuetracker.google.com/savedsearches/559741
+  release_level: stable
+  language: java
+  distribution_name: com.google.cloud:google-cloud-pubsub
+  codeowner_team: '@googleapis/pubsub-team'
+  api_id: pubsub.googleapis.com
+  library_type: GAPIC_COMBO
+  requires_billing: true
+  recommended_package: com.google.cloud.pubsub.v1
+  GAPICs:
+  - proto_path: google/pubsub/v1
 - api_shortname: rapidmigrationassessment
   name_pretty: Rapid Migration Assessment API
   product_documentation: https://cloud.google.com/migration-center/docs

java-pubsub/.OwlBot-hermetic.yaml

@@ -0,0 +1,77 @@
+# Copyright 2021 Google LLC
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#     http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+
+deep-remove-regex:
+- /java-pubsub/grpc-google-.*/src
+- /java-pubsub/proto-google-.*/src
+- /java-pubsub/google-.*/src
+deep-preserve-regex:
+- /java-pubsub/google-cloud-pubsub/src/test/resources/META-INF/native-image/.*
+- /java-pubsub/google-cloud-pubsub/src/main/java/com/google/cloud/.*/v.*/it/IT.*Test.java
+- /java-pubsub/google-.*/src/test/java/com/google/cloud/.*/v.*/it/IT.*Test.java
+- /java-pubsub/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/DeletedTopic.java
+- /java-pubsub/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/ProjectSnapshotName.java
+- /java-pubsub/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/ProjectSubscriptionName.java
+- /java-pubsub/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/ProjectTopicName.java
+- /java-pubsub/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/TopicNames.java
+- /java-pubsub/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/UntypedTopicName.java
+- /java-pubsub/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/it/ITPubSubTest.java
+- /java-pubsub/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/CustomArgumentMatchers.java
+- /java-pubsub/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/FakeClock.java
+- /java-pubsub/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/FakePublisherServiceImpl.java
+- /java-pubsub/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/FakeScheduledExecutorService.java
+- /java-pubsub/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/FakeSubscriberServiceImpl.java
+- /java-pubsub/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/MessageDataMatcher.java
+- /java-pubsub/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/MessageDispatcherTest.java
+- /java-pubsub/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/OpenCensusUtilTest.java
+- /java-pubsub/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/OpenTelemetryTest.java
+- /java-pubsub/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/PublisherImplTest.java
+- /java-pubsub/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/SequentialExecutorServiceTest.java
+- /java-pubsub/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/StatusUtilTest.java
+- /java-pubsub/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/StreamingSubscriberConnectionTest.java
+- /java-pubsub/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/SubscriberShutdownSettingsTest.java
+- /java-pubsub/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/SubscriberTest.java
+- /java-pubsub/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/TopicAdminSmokeTest.java
+- /java-pubsub/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/WaiterTest.java
+- /java-pubsub/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/AckReplyConsumer.java
+- /java-pubsub/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/AckReplyConsumerImpl.java
+- /java-pubsub/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/AckReplyConsumerWithResponse.java
+- /java-pubsub/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/AckReplyConsumerWithResponseImpl.java
+- /java-pubsub/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/AckRequestData.java
+- /java-pubsub/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/AckResponse.java
+- /java-pubsub/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/MessageDispatcher.java
+- /java-pubsub/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/MessageReceiver.java
+- /java-pubsub/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/MessageReceiverWithAckResponse.java
+- /java-pubsub/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/ModackRequestData.java
+- /java-pubsub/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/OpenCensusUtil.java
+- /java-pubsub/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/OpenTelemetryPubsubTracer.java
+- /java-pubsub/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/Publisher.java
+- /java-pubsub/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/PublisherInterface.java
+- /java-pubsub/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/PubsubMessageWrapper.java
+- /java-pubsub/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/SequentialExecutorService.java
+- /java-pubsub/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/StatusUtil.java
+- /java-pubsub/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/StreamingSubscriberConnection.java
+- /java-pubsub/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/Subscriber.java
+- /java-pubsub/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/SubscriberInterface.java
+- /java-pubsub/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/SubscriberShutdownSettings.java
+- /java-pubsub/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/SubscriberStats.java
+- /java-pubsub/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/Waiter.java
+- /java-pubsub/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/LoggingUtil.java
+deep-copy-regex:
+- source: /google/pubsub/(v.*)/.*-java/proto-google-.*/src
+  dest: /owl-bot-staging/java-pubsub/$1/proto-google-cloud-pubsub-$1/src
+- source: /google/pubsub/(v.*)/.*-java/grpc-google-.*/src
+  dest: /owl-bot-staging/java-pubsub/$1/grpc-google-cloud-pubsub-$1/src
+- source: /google/pubsub/(v.*)/.*-java/gapic-google-.*/src
+  dest: /owl-bot-staging/java-pubsub/$1/google-cloud-pubsub/src

java-pubsub/.cloudbuild/samples_build.yaml

@@ -0,0 +1,31 @@
+steps:
+- name: gcr.io/cloud-devrel-public-resources/java8
+  entrypoint: ls
+  args: [
+    '-alt',
+  ]
+- name: gcr.io/cloud-devrel-public-resources/java8
+  entrypoint: curl
+  args: [
+    '--header',
+    'Metadata-Flavor: Google',
+    'http://metadata.google.internal/computeMetadata/v1/instance/service-accounts/default/email'
+  ]
+- name: gcr.io/cloud-devrel-public-resources/java8
+  entrypoint: pwd
+- name: gcr.io/cloud-devrel-public-resources/java8
+  entrypoint: bash
+  args: [
+    '.kokoro/build.sh'
+  ]
+  env:
+  - 'JOB_TYPE=samples'
+  - 'GOOGLE_CLOUD_PROJECT=cloud-java-ci-sample'
+- name: gcr.io/cloud-devrel-public-resources/java8
+  entrypoint: echo
+  args: [
+    'Sample job succeeded',
+  ]
+timeout: 3600s
+options:
+  defaultLogsBucketBehavior: REGIONAL_USER_OWNED_BUCKET