Skip to content
Closed
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
3 changes: 2 additions & 1 deletion functions/README.md
Original file line number Diff line number Diff line change
Expand Up @@ -24,6 +24,7 @@ environment.
* [Cloud Storage](gcs/)
* [Cloud Datastore](datastore/)
* [Cloud Pub/Sub](pubsub/)
* [Dependencies](uid/)
* [Dependencies](uuid/)
* [HTTP](http/)
* [Logging](log/)
* [Modules](module/)
File renamed without changes.
49 changes: 49 additions & 0 deletions functions/background/index.js
Original file line number Diff line number Diff line change
@@ -0,0 +1,49 @@
// Copyright 2016, Google, Inc.
// 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';

// [START helloworld]
/**
* Background Cloud Function.
*
* @param {Object} context Cloud Function context.
* @param {Object} data Request data, provided by a trigger.
*/
exports.helloworld = function helloworld (context, data) {
if (data.message === undefined) {
// This is an error case, "message" is required
context.failure('No message defined!');
} else {
// Everything is ok
console.log(data.message);
context.success();
}
};
// [END helloworld]

// [START helloPromise]
var request = require('request-promise');

/**
* Background Cloud Function that returns a Promise.
*
* @param {Object} data Request data, provided by a trigger.
* @returns {Promise}
*/
exports.helloPromise = function helloPromise (data) {
return request({
uri: data.endpoint
});
};
// [END helloPromise]
15 changes: 15 additions & 0 deletions functions/background/package.json
Original file line number Diff line number Diff line change
@@ -0,0 +1,15 @@
{
"name": "nodejs-docs-samples-functions",
"description": "Node.js samples found on https://cloud.google.com",
"version": "0.0.1",
"private": true,
"license": "Apache Version 2.0",
"author": "Google Inc.",
"repository": {
"type": "git",
"url": "https://github.com/GoogleCloudPlatform/nodejs-docs-samples.git"
},
"dependencies": {
"request-promise": "^3.0.0"
}
}
59 changes: 57 additions & 2 deletions functions/helloworld/index.js
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,62 @@
'use strict';

// [START helloworld]
exports.helloworld = function (context, data) {
context.success('Hello World!');
/**
* Cloud Function.
*
* @param {Object} context Cloud Function context.
* @param {Object} data Request data, provided by a trigger.
*/
exports.helloworld = function helloworld (context, data) {
console.log('My Cloud Function: ' + data.message);
context.success();
};
// [END helloworld]

// [START helloHttp]
/**
* HTTP Cloud Function.
*
* @param {Object} req Cloud Function request context.
* @param {Object} res Cloud Function response context.
*/
exports.helloHttp = function helloHttp (req, res) {
res.send('Hello ' + (req.body.name || 'World') + '!');
};
// [END helloHttp]

// [START helloBackground]
/**
* Background Cloud Function.
*
* @param {Object} context Cloud Function context.
* @param {Object} data Request data, provided by a trigger.
*/
exports.helloBackground = function helloBackground (context, data) {
context.success('Hello ' + (data.name || 'World') + '!');
};
// [END helloBackground]

// [START helloPubSub]
/**
* Background Cloud Function to be triggered by Pub/Sub.
*
* @param {Object} context Cloud Function context.
* @param {Object} data Request data, provided by a Pub/Sub trigger.
*/
exports.helloPubSub = function helloPubSub (context, data) {
context.success('Hello ' + (data.name || 'World') + '!');
};
// [END helloPubSub]

// [START helloGCS]
/**
* Background Cloud Function to be triggered by Cloud Storage.
*
* @param {Object} context Cloud Function context.
* @param {Object} data Request data, provided by a Cloud Storage trigger.
*/
exports.helloGCS = function helloGCS (context, data) {
context.success('Hello ' + (data.name || 'World') + '!');
};
// [END helloGCS]
35 changes: 35 additions & 0 deletions functions/http/README.md
Original file line number Diff line number Diff line change
@@ -0,0 +1,35 @@
<img src="https://avatars2.githubusercontent.com/u/2810941?v=3&s=96" alt="Google Cloud Platform logo" title="Google Cloud Platform" align="right" height="96" width="96"/>

# Google Cloud Functions HTTP sample

This recipe shows you how to respond to HTTP requests with a Cloud Function.

View the [source code][code].

[code]: index.js

## Deploy and Test

1. Follow the [Cloud Functions quickstart guide][quickstart] to setup Cloud
Functions for your project.

1. Clone this repository:

git clone https://github.com/GoogleCloudPlatform/nodejs-docs-samples.git
cd nodejs-docs-samples/functions/http

1. Create a Cloud Storage Bucket to stage our deployment:

gsutil mb gs://[YOUR_BUCKET_NAME]

* Replace `[YOUR_BUCKET_NAME]` with the name of your Cloud Storage Bucket.

1. Deploy the "helloGET" function with an HTTP trigger

gcloud alpha functions deploy publish --bucket [YOUR_BUCKET_NAME] --trigger-http

1. Call the "helloGET" function:

curl https://[YOUR_PROJECT_REGION].[YOUR_PROJECT_ID].cloudfunctions.net/helloGET

[quickstart]: https://cloud.google.com/functions/quickstart
104 changes: 104 additions & 0 deletions functions/http/index.js
Original file line number Diff line number Diff line change
@@ -0,0 +1,104 @@
// Copyright 2016, Google, Inc.
// 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';

// [START helloworld]
/**
* Responds to any HTTP request that can provide a "message" field in the body.
*
* @param {Object} req Cloud Function request context.
* @param {Object} res Cloud Function response context.
*/
exports.helloworld = function helloworld (req, res) {
if (req.body.message === undefined) {
// This is an error case, as "message" is required
res.status(400).send('No message defined!');
} else {
// Everything is ok
console.log(req.body.message);
res.status(200).end();
}
};
// [END helloworld]

// [START helloHttp]
function handleGET (req, res) {
// Do something with the GET request
res.status(200).send('Hello World!');
}

function handlePUT (req, res) {
// Do something with the PUT request
res.status(403).send('Forbidden!');
}

/**
* Responds to a GET request with "Hello World!". Forbids a PUT request.
*
* @example
* gcloud alpha functions call helloHttp
*
* @param {Object} req Cloud Function request context.
* @param {Object} res Cloud Function response context.
*/
exports.helloHttp = function helloHttp (req, res) {
switch (req.method) {
case 'GET':
handleGET(req, res);
break;
case 'PUT':
handlePUT(req, res)
break;
default:
res.status(500).send({ error: 'Something blew up!' });
break;
}
};
// [END helloHttp]

// [START helloContent]
/**
* Responds to any HTTP request that can provide a "message" field in the body.
*
* @param {Object} req Cloud Function request context.
* @param {Object} res Cloud Function response context.
*/
exports.helloContent = function helloContent (req, res) {
var name;

switch (req.get('content-type')) {
// '{"name":"John"}'
case 'application/json':
name = req.body.name;
break;

// 'John', stored in a Buffer
case 'application/octet-stream':
name = req.body.toString(); // Convert buffer to a string
break;

// 'John'
case 'text/plain':
name = req.body;
break;

// 'name=John'
case 'application/x-www-form-urlencoded':
name = req.body.name;
break;
}

res.status(200).send('Hello ' + (name || 'World') + '!');
};
// [END helloContent]
6 changes: 3 additions & 3 deletions functions/log2/index.js
Original file line number Diff line number Diff line change
Expand Up @@ -21,8 +21,8 @@ exports.helloworld = function (context, data) {
// [END walkthrough_pubsub]

// [START walkthrough_http]
exports.hellohttp = function (context, data) {
// Use the success argument to send data back to the caller
context.success('My GCF Function: ' + data.message);
exports.hellohttp = function (req, res) {
// Use the response argument to send data back to the caller
res.send('My GCF Function: ' + req.body.message);
};
// [END walkthrough_http]
29 changes: 0 additions & 29 deletions functions/message/index.js

This file was deleted.

11 changes: 4 additions & 7 deletions functions/pubsub/index.js
Original file line number Diff line number Diff line change
Expand Up @@ -31,7 +31,7 @@ var pubsub = gcloud.pubsub();
* @param {string} data.topic Topic name on which to publish.
* @param {string} data.message Message to publish.
*/
function publish (context, data) {
exports.publish = function publish (context, data) {
try {
if (!data.topic) {
throw new Error('Topic not provided. Make sure you have a ' +
Expand Down Expand Up @@ -63,7 +63,7 @@ function publish (context, data) {
console.error(err);
return context.failure(err.message);
}
}
};

/**
* Triggered from a message on a Pub/Sub topic.
Expand All @@ -74,13 +74,10 @@ function publish (context, data) {
* @param {Object} data Request data, in this case an object provided by the Pub/Sub trigger.
* @param {Object} data.message Message that was published via Pub/Sub.
*/
function subscribe (context, data) {
exports.subscribe = function subscribe (context, data) {
// We're just going to log the message to prove that it worked!
console.log(data.message);

// Don't forget to call success!
context.success();
}

exports.publish = publish;
exports.subscribe = subscribe;
};