Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Cumulus-687 #15

Merged
merged 1 commit into from
Jul 23, 2018
Merged

Cumulus-687 #15

Changes from all commits
Commits
Show all changes
1 commit
Select commit
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
17 changes: 11 additions & 6 deletions index.js
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -56,7 +56,7 @@ function callCumulusMessageAdapter(command, input) {
* If a Cumulus Remote Message is passed, fetch it and return a full Cumulus Message
*
* @param {Object} cumulusMessage - either a full Cumulus Message or a Cumulus Remote Message
* @param {String} schemaLocations - contains location of schema files, can be null
* @param {string} schemaLocations - contains location of schema files, can be null
* @returns {Promise.<Object>} - a full Cumulus Message
*/
function loadRemoteEvent(cumulusMessage, schemaLocations) {
Expand All @@ -68,7 +68,7 @@ function loadRemoteEvent(cumulusMessage, schemaLocations) {
*
* @param {Object} cumulusMessage - a full Cumulus Message
* @param {Object} context - an AWS Lambda context
* @param {String} schemaLocations - contains location of schema files, can be null
* @param {string} schemaLocations - contains location of schema files, can be null
* @returns {Promise.<Object>} - an Object containing the keys input, config and messageConfig
*/
function loadNestedEvent(cumulusMessage, context, schemaLocations) {
Expand All @@ -85,7 +85,7 @@ function loadNestedEvent(cumulusMessage, context, schemaLocations) {
* @param {Object} handlerResponse - the return value of the task function
* @param {Object} cumulusMessage - a full Cumulus Message
* @param {Object} messageConfig - the value of the messageConfig key returned by loadNestedEvent
* @param {String} schemaLocations - contains location of schema files, can be null
* @param {string} schemaLocations - contains location of schema files, can be null
* @returns {Promise.<Object>} - a Cumulus Message or a Cumulus Remote Message
*/
function createNextEvent(handlerResponse, cumulusMessage, messageConfig, schemaLocations) {
Expand Down Expand Up @@ -129,15 +129,20 @@ function invokePromisedTaskFunction(taskFunction, cumulusMessage, context) {
* @param {Object} context - an AWS Lambda context
* @param {Function} callback - the callback to be called when the taskFunction
* has completed. This should be the callback passed to the Lambda handler.
* @param {string} schemas - Location of schema files, can be null.
* @returns {undefined} - there is no return value from this function, but
* the callback function will be invoked with either an error or a full
* Cumulus message containing the result of the business logic function.
*/
function runCumulusTask(taskFunction, cumulusMessage, context, callback, schemas) {
let promisedNextEvent;
if (cumulusMessage.config) process.env.EXECUTIONS = cumulusMessage.config.cumulus_meta.execution_name;
process.env.SENDER = context.function_name;
if (typeof schemas == 'undefined') schemas = null;
if (cumulusMessage.input) {
process.env.EXECUTIONS = cumulusMessage.input.cumulus_meta.execution_name;
}
process.env.SENDER = context.functionName;
process.env.TASKVERSION = context.functionVersion;

if (typeof schemas === 'undefined') schemas = null;

if (process.env.CUMULUS_MESSAGE_ADAPTER_DISABLED === 'true') {
promisedNextEvent = invokePromisedTaskFunction(
Expand Down