feat: add run_events_pubsub

run/README.md

@@ -16,6 +16,7 @@
 |[Cloud SQL (MySQL)][mysql]               | Use MySQL with Cloud Run | - |
 |[Cloud SQL (Postgres)][postgres]         | Use Postgres with Cloud Run | - |
 |[Hello Broken][hello_broken]             | Something is wrong, how do you fix it? | [<img src="https://storage.googleapis.com/cloudrun/button.svg" alt="Run on Google Cloud" height="30"/>][run_button_hello_broken] |
+|[Events – Pub/Sub][events_pubsub]         | Use Pub/Sub with Cloud Run | - |
 
 For more Cloud Run samples beyond Node.js, see the main list in the [Cloud Run Samples repository](https://github.com/GoogleCloudPlatform/cloud-run-samples).
 
@@ -127,3 +128,4 @@ for more information.
 [run_button_image_processing]: https://deploy.cloud.run/?git_repo=https://github.com/GoogleCloudPlatform/nodejs-docs-samples&dir=run/image-processing
 [run_button_manual_logging]: https://deploy.cloud.run/?git_repo=https://github.com/GoogleCloudPlatform/nodejs-docs-samples&dir=run/logging-manual
 [run_button_hello_broken]: https://deploy.cloud.run/?git_repo=https://github.com/GoogleCloudPlatform/nodejs-docs-samples&dir=run/hello-broken
+[events_pubsub]: https://deploy.cloud.run/?git_repo=https://github.com/GoogleCloudPlatform/nodejs-docs-samples&dir=run/events-pubsub

run/events-pubsub/.dockerignore

@@ -0,0 +1,4 @@
+Dockerfile
+.dockerignore
+node_modules
+npm-debug.log

run/events-pubsub/.gcloudignore

@@ -0,0 +1,3 @@
+.git
+node_modules
+npm-debug.log

run/events-pubsub/.gitignore

@@ -0,0 +1 @@
+node_modules

run/events-pubsub/Dockerfile

@@ -0,0 +1,30 @@
+# Copyright 2019 Google LLC. All rights reserved.
+# Use of this source code is governed by the Apache 2.0
+# license that can be found in the LICENSE file.
+
+# [START run_pubsub_dockerfile]
+
+# Use the official lightweight Node.js 10 image.
+# https://hub.docker.com/_/node
+FROM node:10-slim
+
+# 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 ./
+
+# Install dependencies.
+# If you add a package-lock.json speed your build by switching to 'npm ci'.
+# RUN npm ci --only=production
+RUN npm install --production
+
+# Copy local code to the container image.
+COPY . .
+
+# Run the web service on container startup.
+CMD [ "npm", "start" ]
+
+# [END run_pubsub_dockerfile]

run/events-pubsub/README.md

@@ -0,0 +1,35 @@
+# Events for Cloud Run – Pub/Sub tutorial
+
+This sample shows how to create a service that processes Pub/Sub messages.
+
+For more details on how to work with this sample read the [Google Cloud Run Node.js Samples README](https://github.com/GoogleCloudPlatform/nodejs-docs-samples/tree/master/run).
+
+## Dependencies
+
+* **express**: Web server framework.
+* **body-parser**: express middleware for request payload processing.
+* **mocha**: [development] Test running framework.
+* **supertest**: [development] HTTP assertion test client.
+
+## Quickstart
+
+```sh
+gcloud pubsub topics create my-topic
+
+gcloud alpha events triggers create pubsub-trigger \
+--target-service cloudrun-events \
+--type com.google.cloud.pubsub.topic.publish \
+--parameters topic=my-topic
+
+gcloud builds submit \
+ --tag gcr.io/$(gcloud config get-value project)/"$MY_RUN_CONTAINER"
+gcloud run deploy "$MY_RUN_SERVICE" \
+ --image gcr.io/$(gcloud config get-value project)/"$MY_RUN_CONTAINER" \
+ --allow-unauthenticated # Note: The "allowed unauthenticated requests" flag is not needed in production.
+ ```
+
+ Test:
+
+ ```
+ gcloud pubsub topics publish my-topic --message="Hello there"
+ ```

run/events-pubsub/app.js

@@ -0,0 +1,37 @@
+// Copyright 2019 Google LLC. All rights reserved.
+// Use of this source code is governed by the Apache 2.0
+// license that can be found in the LICENSE file.
+
+// [START run_events_pubsub_server_setup]
+const express = require('express');
+const bodyParser = require('body-parser');
+const app = express();
+
+app.use(bodyParser.json());
+// [END run_events_pubsub_server_setup]
+
+// [START run_events_pubsub_handler]
+app.post('/', (req, res) => {
+  if (!req.body) {
+    const msg = 'no Pub/Sub message received';
+    res.status(400).send(`Bad Request: ${msg}`);
+    return;
+  }
+  if (!req.body.message) {
+    const msg = 'invalid Pub/Sub message format';
+    res.status(400).send(`Bad Request: ${msg}`);
+    return;
+  }
+  const pubSubMessage = req.body.message;
+  const name = pubSubMessage.data
+    ? Buffer.from(pubSubMessage.data, 'base64').toString().trim()
+    : 'World';
+
+  res.send({
+    message: `Hello, ${name}!`,
+    id: req.get('ce-id')
+  });
+});
+
+module.exports = app;
+// [END run_events_pubsub_handler]

run/events-pubsub/index.js

@@ -0,0 +1,12 @@
+// Copyright 2019 Google LLC. All rights reserved.
+// Use of this source code is governed by the Apache 2.0
+// license that can be found in the LICENSE file.
+
+// [START run_pubsub_server]
+const app = require('./app.js');
+const PORT = process.env.PORT || 8080;
+
+app.listen(PORT, () =>
+  console.log(`nodejs-run-events-pubsub listening on port ${PORT}`)
+);
+// [END run_pubsub_server]

run/events-pubsub/package.json

@@ -0,0 +1,30 @@
+{
+  "name": "cloud-run-events-pubsub",
+  "version": "1.0.0",
+  "private": true,
+  "description": "Simple Events for Cloud Run – Pub/Sub sample",
+  "main": "index.js",
+  "author": "Google LLC",
+  "license": "Apache-2.0",
+  "repository": {
+    "type": "git",
+    "url": "https://github.com/GoogleCloudPlatform/nodejs-docs-samples.git"
+  },
+  "engines": {
+    "node": ">= 8.0.0"
+  },
+  "scripts": {
+    "start": "node index.js",
+    "test": "mocha test/*.test.js --check-leaks"
+  },
+  "dependencies": {
+    "body-parser": "^1.19.0",
+    "express": "^4.16.4"
+  },
+  "devDependencies": {
+    "mocha": "^7.0.0",
+    "sinon": "^9.0.0",
+    "supertest": "^4.0.2",
+    "uuid": "^8.0.0"
+  }
+}

run/events-pubsub/test/app.test.js

@@ -0,0 +1,73 @@
+// 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.
+
+// NOTE:
+// This app can only be fully tested when deployed, because
+// Pub/Sub requires a live endpoint URL to hit. Nevertheless,
+// these tests mock it and partially test it locally.
+
+'use strict';
+
+const assert = require('assert');
+const path = require('path');
+const supertest = require('supertest');
+
+let request;
+
+describe('Unit Tests', () => {
+  before(() => {
+    const app = require(path.join(__dirname, '..', 'app'));
+    request = supertest(app);
+  });
+
+  describe('should fail', () => {
+    it(`on a Bad Request with an empty payload`, async () => {
+      await request.post('/').type('json').send('').expect(400);
+    });
+
+    it(`on a Bad Request with an invalid payload`, async () => {
+      await request
+        .post('/')
+        .type('json')
+        .send({nomessage: 'invalid'})
+        .expect(400);
+    });
+
+    it(`on a Bad Request with an invalid mimetype`, async () => {
+      await request.post('/').type('text').send('{message: true}').expect(400);
+    });
+  });
+
+  describe('should succeed', () => {
+    it(`with a minimally valid Pub/Sub Message`, async () => {
+      await request
+        .post('/')
+        .type('json')
+        .send({message: true})
+        .expect((res) => {
+          assert.equal(res.body.message, 'Hello, World!');
+        });
+    });
+
+    it(`with CloudEvent HTTP headers`, async () => {
+      await request
+        .post('/')
+        .type('json')
+        .set('ce-id', 1234)
+        .send({message: true})
+        .expect((res) => {
+          assert.equal(res.body.id, 1234);
+        });
+    });
+  });
+});