enabled pipelines env var

Author: John Gilbert

package-lock.json

@@ -1,6 +1,6 @@
 {
   "name": "aws-lambda-stream",
-  "version": "1.1.13",
+  "version": "1.1.14",
   "description": "Create stream processors with AWS Lambda functions.",
   "keywords": [
     "aws",

package.json

@@ -49,8 +49,8 @@ export const initializeFrom = (rules) => rules.reduce(
 );
 
 const assemble = (opt) => (head, includeFaultHandler = true) => {
-  const enabledPipelines = (opt.ENABLED_PIPELINES || process.env.ENABLED_PIPELINES)?.split(',');
-  const disabledPipelines = (opt.DISABLED_PIPELINES || process.env.DISABLED_PIPELINES)?.split(',');
+  const enabledPipelines = (opt.ENABLED_PIPELINES || process.env.ENABLED_PIPELINES)?.split(',').map((pipeline) => pipeline.trim());
+  const disabledPipelines = (opt.DISABLED_PIPELINES || process.env.DISABLED_PIPELINES)?.split(',').map((pipeline) => pipeline.trim());
   const keys = Object.keys(thePipelines)
     .filter((k) => !disabledPipelines?.includes(k))
     .filter((k) =>

src/pipelines/index.js

@@ -52,7 +52,7 @@ describe('pipelines/index.js', () => {
   });
 
   it('should only run enabled pipelines - string', (done) => {
-    process.env.ENABLED_PIPELINES = 'p1,p1b';
+    process.env.ENABLED_PIPELINES = 'p1,p1b '; // extra space on purpose
     let counter = 0;
 
     const count = (uow) => {