migrate code from googleapis/nodejs-tasks

.github/workflows/cloud-tasks.yaml

@@ -0,0 +1,67 @@
+name: cloud-tasks
+on:
+  push:
+    branches:
+    - main
+    paths:
+    - 'cloud-tasks/snippets/*.js'
+  pull_request:
+    paths:
+    - 'cloud-tasks/snippets/*.js'
+  pull_request_target:
+    types: [labeled]
+  schedule:
+  - cron:  '0 0 * * 0'
+jobs:
+  test:
+    if: ${{ github.event.action != 'labeled' || github.event.label.name == 'actions:force-run' }}
+    runs-on: ubuntu-latest
+    timeout-minutes: 60
+    permissions:
+      contents: 'write'
+      pull-requests: 'write'
+      id-token: 'write'
+    steps:
+    - uses: 'google-github-actions/[email protected]'
+      with:
+        workload_identity_provider: 'projects/1046198160504/locations/global/workloadIdentityPools/github-actions-pool/providers/github-actions-provider'
+        service_account: '[email protected]'
+        create_credentials_file: 'true'
+        access_token_lifetime: 600s
+    - uses: actions/checkout@v3
+      with:
+        ref: ${{github.event.pull_request.head.ref}}
+        repository: ${{github.event.pull_request.head.repo.full_name}}
+    - uses: actions/setup-node@v2
+      with:
+        node-version: 16
+    - run: npm install
+      working-directory: cloud-tasks/snippets
+    - run: npm test
+      working-directory: cloud-tasks/snippets
+      env:
+        MOCHA_REPORTER_SUITENAME: cloud_tasks
+        MOCHA_REPORTER_OUTPUT: cloud_tasks_sponge_log.xml
+        MOCHA_REPORTER: xunit
+    - if: ${{ github.event.action == 'labeled' && github.event.label.name == 'actions:force-run' }}
+      uses: actions/github-script@v6
+      with:
+        github-token: ${{ secrets.GITHUB_TOKEN }}
+        script: |
+          try {
+            await github.rest.issues.removeLabel({
+              name: 'actions:force-run',
+              owner: 'GoogleCloudPlatform',
+              repo: 'nodejs-docs-samples',
+              issue_number: context.payload.pull_request.number
+            });
+          } catch (e) {
+            if (!e.message.includes('Label does not exist')) {
+              throw e;
+            }
+          }
+    - if: ${{ github.event_name == 'schedule'}}
+      run: |
+        curl https://github.com/googleapis/repo-automation-bots/releases/download/flakybot-1.1.0/flakybot -o flakybot -s -L
+        chmod +x ./flakybot
+        ./flakybot --repo GoogleCloudPlatform/nodejs-docs-samples --commit_hash ${{github.sha}} --build_url https://github.com/${{github.repository}}/actions/runs/${{github.run_id}}

cloud-tasks/snippets/Dockerfile

@@ -0,0 +1,20 @@
+# Use the official Node.js 10 image.
+# https://hub.docker.com/_/node
+FROM node:10
+
+# Create and change to the app directory.
+WORKDIR /usr/src/app
+
+# Copy application dependency manifests to the container image.
+# A wildcard is used to ensure both package.json AND package-lock.json are copied.
+# Copying this separately prevents re-running npm install on every code change.
+COPY package.json package*.json ./
+
+# Install production dependencies.
+RUN npm install --only=production
+
+# Copy local code to the container image.
+COPY . .
+
+# Run the web service on container startup.
+CMD [ "npm", "start" ]

cloud-tasks/snippets/app.yaml

@@ -0,0 +1,14 @@
+# Copyright 2019 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.
+
+runtime: nodejs10

cloud-tasks/snippets/createHttpTask.js

@@ -0,0 +1,89 @@
+// Copyright 2019 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.
+
+'use strict';
+
+// sample-metadata:
+//   title: Cloud Tasks Create HTTP Target
+//   description: Create Cloud Tasks with a HTTP Target
+//   usage: node createHttpTask.js <projectId> <queueName> <location> <url> <payload> <delayInSeconds>
+
+/**
+ * Create a task with an HTTP target for a given queue with an arbitrary payload.
+ */
+function main(
+  project = 'my-project-id', // Your GCP Project id
+  queue = 'my-appengine-queue', // Name of your Queue
+  location = 'us-central1', // The GCP region of your queue
+  url = 'https://example.com/taskhandler', // The full url path that the request will be sent to
+  payload = 'Hello, World!', // The task HTTP request body
+  inSeconds = 0 // Delay in task execution
+) {
+  // [START cloud_tasks_create_http_task]
+  // Imports the Google Cloud Tasks library.
+  const {CloudTasksClient} = require('@google-cloud/tasks');
+
+  // Instantiates a client.
+  const client = new CloudTasksClient();
+
+  async function createHttpTask() {
+    // TODO(developer): Uncomment these lines and replace with your values.
+    // const project = 'my-project-id';
+    // const queue = 'my-queue';
+    // const location = 'us-central1';
+    // const url = 'https://example.com/taskhandler';
+    // const payload = 'Hello, World!';
+    // const inSeconds = 180;
+
+    // Construct the fully qualified queue name.
+    const parent = client.queuePath(project, location, queue);
+
+    const task = {
+      httpRequest: {
+        headers: {
+          'Content-Type': 'text/plain',
+        },
+        httpMethod: 'POST',
+        url,
+      },
+    };
+
+    if (payload) {
+      task.httpRequest.body = Buffer.from(payload).toString('base64');
+    }
+
+    if (inSeconds) {
+      // The time when the task is scheduled to be attempted.
+      task.scheduleTime = {
+        seconds: parseInt(inSeconds) + Date.now() / 1000,
+      };
+    }
+
+    // Send create task request.
+    console.log('Sending task:');
+    console.log(task);
+    const request = {parent: parent, task: task};
+    const [response] = await client.createTask(request);
+    console.log(`Created task ${response.name}`);
+  }
+  createHttpTask();
+  // [END cloud_tasks_create_http_task]
+}
+
+process.on('unhandledRejection', err => {
+  console.error(err.message);
+  process.exitCode = 1;
+});
+
+main(...process.argv.slice(2));

cloud-tasks/snippets/createHttpTaskWithToken.js

@@ -0,0 +1,86 @@
+// Copyright 2019 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.
+
+'use strict';
+
+// sample-metadata:
+//   title: Cloud Tasks Create HTTP Target with Token
+//   description: Create Cloud Tasks with a HTTP Target with Token
+//   usage: node createHttpTaskWithToken.js <projectId> <queueName> <location> <url> <serviceAccountEmail> <payload> <delayInSeconds>
+
+/**
+ * Create a task with an HTTP target for a given queue with an arbitrary payload.
+ */
+function main(
+  project = 'my-project-id', // Your GCP Project id
+  queue = 'my-queue', // Name of your Queue
+  location = 'us-central1', // The GCP region of your queue
+  url = 'https://example.com/taskhandler', // The full url path that the request will be sent to
+  serviceAccountEmail = 'client@<project-id>.iam.gserviceaccount.com', // Cloud IAM service account
+  payload = 'Hello, World!' // The task HTTP request body
+) {
+  // [START cloud_tasks_create_http_task_with_token]
+  // Imports the Google Cloud Tasks library.
+  const {CloudTasksClient} = require('@google-cloud/tasks');
+
+  // Instantiates a client.
+  const client = new CloudTasksClient();
+
+  async function createHttpTaskWithToken() {
+    // TODO(developer): Uncomment these lines and replace with your values.
+    // const project = 'my-project-id';
+    // const queue = 'my-queue';
+    // const location = 'us-central1';
+    // const url = 'https://example.com/taskhandler';
+    // const serviceAccountEmail = 'client@<project-id>.iam.gserviceaccount.com';
+    // const payload = 'Hello, World!';
+
+    // Construct the fully qualified queue name.
+    const parent = client.queuePath(project, location, queue);
+
+    const task = {
+      httpRequest: {
+        headers: {
+          'Content-Type': 'text/plain',
+        },
+        httpMethod: 'POST',
+        url,
+        oidcToken: {
+          serviceAccountEmail,
+        },
+      },
+    };
+
+    if (payload) {
+      task.httpRequest.body = Buffer.from(payload).toString('base64');
+    }
+
+    console.log('Sending task:');
+    console.log(task);
+    // Send create task request.
+    const request = {parent: parent, task: task};
+    const [response] = await client.createTask(request);
+    const name = response.name;
+    console.log(`Created task ${name}`);
+  }
+  createHttpTaskWithToken();
+  // [END cloud_tasks_create_http_task_with_token]
+}
+
+process.on('unhandledRejection', err => {
+  console.error(err.message);
+  process.exitCode = 1;
+});
+
+main(...process.argv.slice(2));

cloud-tasks/snippets/createQueue.js

@@ -0,0 +1,59 @@
+// Copyright 2018 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
+//
+//     https://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.
+
+'use strict';
+
+/**
+ * Create a new Task Queue
+ */
+function main(
+  project = 'my-project-id', // Your GCP Project id
+  queue = 'my-appengine-queue', // Name of the Queue to create
+  location = 'us-central1' // The GCP region in which to create the queue
+) {
+  // [START cloud_tasks_create_queue]
+  // Imports the Google Cloud Tasks library.
+  const cloudTasks = require('@google-cloud/tasks');
+
+  // Instantiates a client.
+  const client = new cloudTasks.CloudTasksClient();
+
+  async function createQueue() {
+    // Send create queue request.
+    const [response] = await client.createQueue({
+      // The fully qualified path to the location where the queue is created
+      parent: client.locationPath(project, location),
+      queue: {
+        // The fully qualified path to the queue
+        name: client.queuePath(project, location, queue),
+        appEngineHttpQueue: {
+          appEngineRoutingOverride: {
+            // The App Engine service that will receive the tasks.
+            service: 'default',
+          },
+        },
+      },
+    });
+    console.log(`Created queue ${response.name}`);
+  }
+  createQueue();
+  // [END cloud_tasks_create_queue]
+}
+
+process.on('unhandledRejection', err => {
+  console.error(err.message);
+  process.exitCode = 1;
+});
+
+main(...process.argv.slice(2));