@cumulus/cumulus-message-adapter-js - npm Package Compare versions

Comparing version 1.0.3 to 1.0.4

CHANGELOG.md

@@ -8,2 +8,8 @@ # Changelog
 ## [Unreleased]
+
+## [v1.0.4] - 2018-08-16
+### Added
+
+- Store task context metadata in `meta.workflow_tasks`, if it exists.
+
 ## [v1.0.3] - 2018-07-26
@@ -10,0 +16,0 @@

index.js

@@ -56,10 +56,15 @@ 'use strict';
 /**
- * If a Cumulus Remote Message is passed, fetch it and return a full Cumulus Message
+ * If a Cumulus Remote Message is passed, fetch it and return a full Cumulus Message with updated task metadata.
  *
  * @param {Object} cumulusMessage - either a full Cumulus Message or a Cumulus Remote Message
+ * @param {Object} context - an AWS Lambda context
  * @param {string} schemaLocations - contains location of schema files, can be null
  * @returns {Promise.<Object>} - a full Cumulus Message
  */
-function loadRemoteEvent(cumulusMessage, schemaLocations) {
-  return callCumulusMessageAdapter('loadRemoteEvent', { event: cumulusMessage, schemas: schemaLocations });
+function loadAndUpdateRemoteEvent(cumulusMessage, context, schemaLocations) {
+  return callCumulusMessageAdapter('loadAndUpdateRemoteEvent', {
+    event: cumulusMessage,
+    context,
+    schemas: schemaLocations
+  });
 }
@@ -156,3 +161,3 @@
   else {
-    const promisedRemoteEvent = loadRemoteEvent(cumulusMessage, schemas);
+    const promisedRemoteEvent = loadAndUpdateRemoteEvent(cumulusMessage, context, schemas);
     const promisedNestedEvent = promisedRemoteEvent
@@ -159,0 +164,0 @@ .then((event) => loadNestedEvent(event, context, schemas));

package.json

 {
   "name": "@cumulus/cumulus-message-adapter-js",
-  "version": "1.0.3",
+  "version": "1.0.4",
   "description": "Cumulus message adapter",
@@ -5,0 +5,0 @@ "main": "index.js",

test/test-index-with-dir-env.js

@@ -18,2 +18,3 @@ const path = require('path');
       event: inputEvent,
+      context: {},
       schemas: null
@@ -20,0 +21,0 @@ },

test/test-index.js

@@ -13,2 +13,3 @@ const test = require('ava');
       event: inputEvent,
+      context: {},
       schemas: null
@@ -39,2 +40,3 @@ },
       event: inputEvent,
+      context: {},
       schemas: null
@@ -61,5 +63,5 @@ },
   const expectedNestedEvent = {
-    event: { event: { a: 1 }, schemas: null },
+    event: { event: { a: 1 }, context, schemas: null },
     schemas: null,
-    context: { b: 2 }
+    context
   };
@@ -66,0 +68,0 @@

No alert changes

Improved metrics

Total package byte prevSize

231952

increased by0.13%

Lines of code

6178

increased by0.13%

No dependency changes