aws-core-utils

aws-core-utils v6.0.8

Core utilities for working with Amazon Web Services (AWS), including ARNs, regions, stages, Lambdas, AWS errors, stream events, Kinesis, DynamoDB.DocumentClients, etc.

Currently includes:

• api-lambdas.js
  • Utilities for working with Lambdas exposed to AWS API Gateway, including functions to:
    • Configure a standard context for AWS Gateway exposed Lambdas (re-exported from contexts.js module)
    • Fail Lambda callbacks with standard AppError errors to facilitate mapping of errors to HTTP status codes on API Gateway.
• arns.js
  • Utilities for working with Amazon Resource Names (ARNs)
• aws-errors.js
  • Utilities for working with AWS errors
• contexts.js
  • Utilities for configuring contexts for AWS Gateway exposed and other types of Lambdas
• dynamodb-doc-client-cache.js
  • A module-scope cache of AWS.DynamoDB.DocumentClient instances by region for Lambda.
• dynamodb-doc-client-utils.js
  • Utilities for working with AWS DynamoDB.DocumentClient.
• dynamodb-utils.js
  • Utilities for working with AWS DynamoDB.
• kinesis-cache.js
  • A module-scope cache of AWS.Kinesis instances by region for Lambda.
• lambdas.js
  • Utilities for working with AWS Lambda, which enable extraction of function names, versions and, most importantly, aliases from AWS contexts and their invoked function ARNs.
  • Utility for failing non-API Gateway Lambda's callbacks with standard AppError errors if mapping of errors to HTTP status codes is needed
• regions.js
  • Utilities for resolving the AWS region from various sources (primarily for AWS Lambda usage).
• stages.js
  • Utilities for resolving or deriving the current stage (e.g. dev, qa, prod) from various sources (primarily for AWS Lambda usage).
  • Utilities for configuration of stage handling.
  • Configurable and default functions for generating stage-qualified stream and resource names.
  • Configurable and default functions for extracting stages from stage-qualified stream and resource names.
• stream-events.js
  • Utilities for extracting information from AWS Kinesis and AWS DynamoDB stream events.

This module is exported as a Node.js module.

Installation

Using npm:

$ {sudo -H} npm i -g npm
$ npm i --save aws-core-utils

In Node.js:

• To use the api-lambdas module within your API Gateway exposed Lambda:

const apiLambdas = require('aws-core-utils/api-lambdas');
const appErrors = require('core-functions/app-errors');
const BadRequest = appErrors.BadRequest;
const context = {}; // or your own pre-configured context
const standardOptions = require('my-options.json'); // or whatever options you want to use to configure stage handling, logging, custom settings, ...
const standardSettings = undefined; // or whatever settings object you want to use to configure stage handling, logging, custom settings, ...
function exampleFunction(event, context) { /* ... */ } // implement and name your own function that does the actual work

// Simplest approach - generate your API Gateway exposed Lambda's handler function
module.exports.handler = apiLambdas.generateHandlerFunction(context, standardSettings, standardOptions, exampleFunction);
  
// OR ... using all optional arguments to change the allowed HTTP status codes and customise logging in the handler function
module.exports.handler = apiLambdas.generateHandlerFunction(context, standardSettings, standardOptions, exampleFunction, 'info', 
  [400, 404, 500], 'Invalid request ...', 'Failed to ...', 'Finished ...');


// OR ... develop your own Lambda handler function (e.g. simplistic example below - see apiLamdas.generateHandlerFunction for a better version)
module.exports.handler = (event, awsContext, callback) => {
  // Configure a standard context
  const context = {};
  try {
    apiLambdas.configureStandardContext(context, standardSettings, standardOptions, event, awsContext);
    
    // ... execute Lambda specific code passing the context to your functions as needed
    exampleFunction(event, context)
      .then(response => {
        context.info('Finished ...');
        callback(null, response);
      })
      .catch(err => {
        // Fail your Lambda callback and map the error to one of the default set of HTTP status codes:
        // i.e. [400, 401, 403, 404, 408, 429, 500, 502, 503, 504]
        if (err instanceof BadRequest || appErrors.getHttpStatus(err) === 400) {
          context.warn('Invalid request ...' + err.message);
        } else {
          context.error('Failed to ...', err.stack);
        }
        apiLambdas.failCallback(callback, err, awsContext);
      });
  
  } catch (err) {
    // Fail your Lambda callback and map the error to one of the default set of HTTP status codes:
    // i.e. [400, 401, 403, 404, 408, 429, 500, 502, 503, 504]
    context.error('Failed to ...', err.stack);
    apiLambdas.failCallback(callback, err, awsContext);
  }
};

// ALTERNATIVES for failCallback: 
// Fail your Lambda callback and map the error to one of a specified set of HTTP status codes
apiLambdas.failCallback(callback, err, awsContext, 'My error msg', 'MyErrorCode', [400, 404, 418, 500, 508]);

• To use the AWS ARN utilities

const arns = require('aws-core-utils/arns');

const arnComponent = arns.getArnComponent(arn, index);
const arnPartition = arns.getArnPartition(arn);
const arnService = arns.getArnService(arn);
const arnRegion = arns.getArnRegion(arn);
const arnAccountId = arns.getArnAccountId(arn);
const arnResources = arns.getArnResources(arn);

• To use the AWS errors utilities

const awsErrors = require('aws-core-utils/aws-errors');

• To use the contexts.js module:

// To use the configureStandardContext function, please refer to the 'To use the `api-lambdas` module' example above
// (since the `api-lambdas.js` module simply re-exports the `contexts.js` module's configureStandardContext)

// ALTERNATIVELY if you need the logic of the configureStandardContext function for custom purposes
const contexts = require('aws-core-utils/contexts');
const context = {};
const standardOptions = require('my-standard-options.json'); // or whatever options you want to use to configure stage handling, logging, custom settings, ...
const standardSettings = {}; // or whatever settings you want to use to configure stage handling, logging, custom settings, ...
contexts.configureStandardContext(context, standardSettings, standardOptions, awsEvent, awsContext);

// If you need the logic of the configureCustomSettings function, which is used by configureStandardContext, for other purposes
const myCustomSettings = {myCustomSetting1: 1, myCustomSetting2: 2, myCustomFunction: () => {}};
const myCustomOptions = require('my-custom-options.json');
contexts.configureCustomSettings(context, myCustomSettings, myCustomOptions);
console.log(`context.custom = ${JSON.stringify(context.custom)}; myCustomFunction = ${JSON.stringify(context.custom.myCustomFunction)} `);

• To use the DynamoDB.DocumentClient cache to configure and cache an AWS DynamoDB.DocumentClient instance per region

const dynamoDBDocClientCache = require('aws-core-utils/dynamodb-doc-client-cache');

// Preamble to create a context and configure logging on the context
const context = {};
const logging = require('logging-utils');
logging.configureLogging(context); // or your own custom logging configuration (see logging-utils README.md)

// Define the DynamoDB.DocumentClient's constructor options that you want to use, e.g.
const dynamoDBDocClientOptions = {
  // See http://docs.aws.amazon.com/AWSJavaScriptSDK/latest/AWS/DynamoDB/DocumentClient.html#constructor-property
  // and http://docs.aws.amazon.com/AWSJavaScriptSDK/latest/AWS/DynamoDB.html#constructor-property
  maxRetries: 0
  // ...
};

// To create and cache a new AWS DynamoDB.DocumentClient instance with the given DynamoDB.DocumentClient constructor 
// options for either the current region or the region specified in the given options OR reuse a previously cached 
// DynamoDB.DocumentClient instance (if any) that is compatible with the given options
const dynamoDBDocClient = dynamoDBDocClientCache.setDynamoDBDocClient(dynamoDBDocClientOptions, context);

// To configure a new AWS.DynamoDB.DocumentClient instance (or re-use a cached instance) on a context 
dynamoDBDocClientCache.configureDynamoDBDocClient(context, dynamoDBDocClientOptions);
console.log(context.dynamoDBDocClient);

// To get a previously set or configured AWS DynamoDB.DocumentClient instance for the current AWS region
const dynamoDBDocClient1 = dynamoDBDocClientCache.getDynamoDBDocClient();
// ... or for a specified region
const dynamoDBDocClient2 = dynamoDBDocClientCache.getDynamoDBDocClient('us-west-2');

// To get the original options that were used to construct a cached AWS DynamoDB.DocumentClient instance for the current or specified AWS region
const optionsUsed1 = dynamoDBDocClientCache.getDynamoDBDocClientOptionsUsed();
const optionsUsed2 = dynamoDBDocClientCache.getDynamoDBDocClientOptionsUsed('us-west-1');

// To delete and remove a cached DynamoDB.DocumentClient instance from the cache
const deleted = dynamoDBDocClientCache.deleteDynamoDBDocClient('eu-west-1');

• To use the Kinesis cache to configure and cache an AWS Kinesis instance per region

const kinesisCache = require('aws-core-utils/kinesis-cache');

// Preamble to create a context and configure logging on the context
const context = {};
const logging = require('logging-utils');
logging.configureLogging(context); // or your own custom logging configuration (see logging-utils README.md)

// Define the Kinesis constructor options that you want to use, e.g.
const kinesisOptions = {
  // See http://docs.aws.amazon.com/AWSJavaScriptSDK/latest/AWS/Kinesis.html#constructor-property for full details
  maxRetries: 0
  // ...
};

// To create and cache a new AWS Kinesis instance with the given Kinesis constructor options for either the current 
// region or the region specified in the given options OR reuse a previously cached Kinesis instance (if any) that is 
// compatible with the given options
const kinesis = kinesisCache.setKinesis(kinesisOptions, context);

// To configure a new AWS.Kinesis instance (or re-use a cached instance) on a context 
kinesisCache.configureKinesis(context, kinesisOptions);
console.log(context.kinesis);

// To get a previously set or configured AWS Kinesis instance for the current AWS region
const kinesis1 = kinesisCache.getKinesis();
// ... or for a specified region
const kinesis2 = kinesisCache.getKinesis('us-west-2');

// To get the original options that were used to construct a cached AWS Kinesis instance for the current or specified AWS region
const optionsUsed1 = kinesisCache.getKinesisOptionsUsed();
const optionsUsed2 = kinesisCache.getKinesisOptionsUsed('us-west-1');

// To delete and remove a cached Kinesis instance from the cache
const deleted = kinesisCache.deleteKinesis('eu-west-1');

• To use the Lambda utilities

const lambdas = require('aws-core-utils/lambdas');

// To resolve the Lambda alias from an AWS Lambda context
const alias = lambdas.getAlias(awsContext);

// To extract other details from an AWS Lambda context
const functionName = lambdas.getFunctionName(awsContext);
const functionVersion = lambdas.getFunctionVersion(awsContext);
const functionNameVersionAndAlias = lambdas.getFunctionNameVersionAndAlias(awsContext);
const invokedFunctionArn = lambdas.getInvokedFunctionArn(awsContext);
const invokedFunctionArnFunctionName = lambdas.getInvokedFunctionArnFunctionName(awsContext);

// Fail a Lambda's callback with a standard error and preserve HTTP status codes (for non-API Gateway Lambdas) 
// See core-functions/app-errors.js for standard errors to use
lambdas.failCallback(lambdaCallback, error, awsContext, message, code);

• To get the current AWS region & configure it on a context

const regions = require('aws-core-utils/regions');

// To get the current AWS region of your Lambda
const region = regions.getRegion();

// To configure a context with the current AWS region
const context = {};
const failFast = true;
regions.configureRegion(context, failFast);
assert(context.region && typeof context.region === 'string');

• To use the stage utilities

// To configure stage-handling, which determines the behaviour of the functions numbered 1 to 6 below
const stages = require('aws-core-utils/stages');
const settings = undefined; // ... or your own custom settings
const options = require('aws-core-utils/stages-options.json'); // ... or your own custom options

// ... EITHER using the default stage handling configuration and default logging configuration 
stages.configureDefaultStageHandling(context); 
// ... OR using the default stage handling configuration and default logging configuration partially customised via stageHandlingOptions, otherSettings & otherOptions
const stageHandlingOptions = require('aws-core-utils/stages-options.json').stageHandlingOptions; // example ONLY - use your own custom stage handling options if needed
const otherSettings = undefined; // or to configure your own underlying logger use: const otherSettings = {loggingSettings: {underlyingLogger: myCustomLogger}};
const otherOptions = require('aws-core-utils/test/sample-standard-options.json'); // example ONLY - use your own custom standard options file
const forceConfiguration = false;
stages.configureDefaultStageHandling(context, stageHandlingOptions, otherSettings, otherOptions, forceConfiguration); 

// ... OR using your own custom stage-handling configuration
const stageHandlingSettings = stages.getDefaultStageHandlingSettings(options.stageHandlingOptions);
// Optionally override the default stage handling functions with your own custom functions
// stageHandlingSettings.customToStage = undefined;
// stageHandlingSettings.convertAliasToStage = stages.DEFAULTS.convertAliasToStage;
// stageHandlingSettings.injectStageIntoStreamName = stages.DEFAULTS.toStageSuffixedStreamName;
// stageHandlingSettings.extractStageFromStreamName = stages.DEFAULTS.extractStageFromSuffixedStreamName;
// stageHandlingSettings.injectStageIntoResourceName = stages.DEFAULTS.toStageSuffixedResourceName;
// stageHandlingSettings.extractStageFromResourceName = stages.DEFAULTS.extractStageFromSuffixedResourceName;
stages.configureStageHandling(context, stageHandlingSettings, stageHandlingOptions, otherSettings, otherOptions, forceConfiguration);

// ... OR using completely customised stage handling settings
const stageHandlingSettings2 = {
    envStageName: myEnvStageName,
    customToStage: myCustomToStageFunction, // or undefined if not needed
    convertAliasToStage: myConvertAliasToStageFunction, // or undefined to knockout using AWS aliases as stages

    injectStageIntoStreamName: myInjectStageIntoStreamNameFunction, 
    extractStageFromStreamName: myExtractStageFromStreamNameFunction,
    streamNameStageSeparator: myStreamNameStageSeparator,

    injectStageIntoResourceName: myInjectStageIntoResourceNameFunction,
    extractStageFromResourceName: myExtractStageFromResourceNameFunction,
    resourceNameStageSeparator: myResourceNameStageSeparator,

    injectInCase: myInjectInCase,
    extractInCase: myExtractInCase,

    defaultStage: myDefaultStage, // or undefined
};
stages.configureStageHandling(context, stageHandlingSettings2, undefined, otherSettings, otherOptions, forceConfiguration);

// ... OR using custom stage handling settings and/or options and configuring dependencies at the same time
stages.configureStageHandling(context, stageHandlingSettings, stageHandlingOptions, otherSettings, otherOptions, forceConfiguration);

// To check if stage handling is configured
const configured = stages.isStageHandlingConfigured(context);

// To look up stage handling settings and functions
const settingName = 'injectInCase'; // example stage handling setting name
const setting = stages.getStageHandlingSetting(context, settingName);

const functionSettingName = 'convertAliasToStage'; // example stage handling function name
const fn = stages.getStageHandlingFunction(context, functionSettingName);

// 1. To resolve / derive a stage from an AWS event
const context = {};
const stage = stages.resolveStage(awsEvent, awsContext, context);

// 2. To configure a context with a resolved stage (uses resolveStage)
const failFast = true;
stages.configureStage(context, awsEvent, awsContext, failFast);
assert(context.stage && typeof context.stage === 'string');

// 3. To extract a stage from a qualified stream name
const qualifiedStreamName = 'TestStream_PROD';
const stage2 = stages.extractStageFromQualifiedStreamName(qualifiedStreamName, context);
assert(stage2 === 'prod'); // assuming default stage handling configuration

// 4. To qualify an unqualified stream name with a stage
const unqualifiedStreamName = 'TestStream';
const stageQualifiedStreamName = stages.toStageQualifiedStreamName(unqualifiedStreamName, stage2, context);
assert(stageQualifiedStreamName === 'TestStream_PROD'); // assuming default stage handling configuration

// 5. To extract a stage from a qualified resource name
const qualifiedTableName = 'TestTable_QA';
const stage3 = stages.extractStageFromQualifiedResourceName(qualifiedTableName, context);
assert(stage3 === 'qa'); // assuming default stage handling configuration

// 6. To qualify an unqualified resource name with a stage
const unqualifiedTableName = 'TestTable';
const stageQualifiedResourceName = stages.toStageQualifiedResourceName(unqualifiedTableName, stage3, context);
assert(stageQualifiedResourceName === 'TestTable_QA'); // assuming default stage handling configuration

• To use the stream event utilities

const streamEvents = require('aws-core-utils/stream-events');

// To extract event soure ARNs from AWS events 
const eventSourceARNs = streamEvents.getEventSourceARNs(event);

// To extract Kinesis stream names from AWS events and event records
const eventSourceStreamNames = streamEvents.getKinesisEventSourceStreamNames(event);
const eventSourceStreamName = streamEvents.getKinesisEventSourceStreamName(record);

// To extract DynamoDB table names from DynamoDB stream event records
const dynamoDBEventSourceTableName = streamEvents.getDynamoDBEventSourceTableName(record);

// To extract DynamoDB table names and stream timestamps/suffixes from DynamoDB stream event records
const tableNameAndStreamTimestamp = streamEvents.getDynamoDBEventSourceTableNameAndStreamTimestamp(record);
const dynamoDBEventSourceTableName1 = tableNameAndStreamTimestamp[0];
const dynamoDBEventSourceStreamTimestamp = tableNameAndStreamTimestamp[1];

// Simple checks to validate existance of some of the properties of Kinesis & DynamoDB stream event records
try {
  streamEvents.validateStreamEventRecord(record);
  streamEvents.validateKinesisStreamEventRecord(record);
  streamEvents.validateDynamoDBStreamEventRecord(record);
} catch (err) { 
  // ... 
}

Unit tests

This module's unit tests were developed with and must be run with tape. The unit tests have been tested on Node.js v4.3.2.

Install tape globally if you want to run multiple tests at once:

$ npm install tape -g

Run all unit tests with:

$ npm test

or with tape:

$ tape test/*.js

See the package source for more details.

Changes

6.0.8

• Upgraded aws-core-test-utils test dependency to 2.0.4

6.0.7

• Upgraded aws-core-test-utils test dependency to 2.0.3

6.0.6

• Upgraded aws-core-test-utils test dependency to 2.0.2

6.0.5

• Upgraded aws-core-test-utils test dependency to 2.0.1

6.0.4

• Added new dynamodb-doc-client-utils module
• Changes to type-defs module (to sync with get method of DynamoDB.DocumentClient rather than getItem method):
  • Renamed DynamoDBGetItemOpts to DynamoDBGetOpts type definition
  • Renamed DynamoDBGetItemResult to DynamoDBGetResult type definition

6.0.3

• Changes to regions module:
  • Changed getRegion function to treat "undefined" or "null" regions as undefined
  • Added setRegion function
  • Changed setRegionIfNotSet function to use setRegion
  • Deprecated setRegionIfNotSet function
  • Changed configureRegion function to fallback to using console.log if context.info is not configured yet
• Changes to stages module:
  • Added configureStageAndAwsContext convenience function to configure resolved stage and AWS context on the given context
  • Deprecated old configureRegionStageAndAwsContext convenience function
• Changes to contexts module:
  • Changed configureStandardContext function to invoke regions.configureRegion as early in the function as possible & to invoke stages.configureStageAndAwsContext instead of stages.configureRegionStageAndAwsContext
• Changes to type-defs module:
  • Added StageAndAWSContextAware type definition
  • Added DynamoDBGetItemOpts, DynamoDBGetItemResult, DynamoDBQueryOpts, DynamoDBQueryResult & ConsumedCapacity type definitions

6.0.2

• Upgraded to Node 6.10.3
• Updated core-functions dependency to version 3.0.4
• Updated logging-utils dependency to version 4.0.3
• Upgraded aws-sdk dev dependency to version 2.45.0
• Changes to dynamodb-doc-client-cache module:
  • Changed setDynamoDBDocClient to create & cache each new DynamoDB.DocumentClient instance with a COPY of the options while still caching the ORIGINAL options to avoid subsequent cache comparison failures related to AWS SDK 2.45.0 mutating the options passed to the constructor, e.g. by adding "attrValue" with value "S8"

6.0.1

• Updated core-functions dependency to version 3.0.2
• Updated logging-utils dependency to version 4.0.1
• Patches to test/samples.js:
  • Fixed potential shared global regular expression issues in sampleAwsContext function
• Changes to aws-errors module:
  • Added isResourceNotFoundException function
• Changes to dynamodb-utils module:
  • Added simplifyKeysNewImageAndOldImage function

6.0.0

• Updated core-functions dependency to version 3.0.0
• Updated logging-utils dependency to version 4.0.0
• Changes to api-lambdas.js module:
  • Removed log function (replaced use with new log function & log method in logging-utils)
• Changes to arns.js module:
  • Moved ArnResources typedef to type-defs.js
• Changes to aws-errors.js module:
  • Added isItemCollectionSizeLimitExceededException function
  • Added isLimitExceeded function
  • Removed limit exceeded cases from isThrottled function (not backward-compatible)
  • Added S3 SlowDown case to isThrottled function
  • Added isLimitExceeded & err.retryable checks to isRetryable function
• Changes to dynamodb-utils.js module:
  • Removed toNumber function (replaced use with new toNumberOrIntegerLike function in core-functions/numbers.js)
  • Added new toStorableObject function
  • Added new defaults static property with emptyStringReplacement property
• Changes to stages.js module:
  • Replaced all setting names constants (e.g. CUSTOM_TO_STAGE_SETTING) with use of a new module-scope settingNames object property that holds all the standard stage handling settings names (e.g. settingNames.customToStage)
  • Added new extractNameAndStageFromStreamName & extractNameAndStageFromResourceName settings
  • Added extractNameAndStageFromQualifiedStreamName & extractNameAndStageFromQualifiedResourceName functions
  • Added extractNameAndStageFromSuffixedStreamName & extractNameAndStageFromSuffixedResourceName functions
  • Added _extractNameAndStageFromQualifiedName & _extractNameAndStageFromSuffixedName functions
  • Changed extractStageFromQualifiedStreamName to attempt fallback with _extractNameAndStageFromQualifiedName
  • Changed extractStageFromQualifiedResourceName to attempt fallback with _extractNameAndStageFromQualifiedName
• Changes to stream-events.js module:
  • Added MAX_PARTITION_KEY_SIZE constant
  • Added DynamoDBEventName enum
  • Added getEventID, getEventName, getEventSource & getEventSourceARN functions
  • Added getKinesisShardId, getKinesisShardIdFromEventID, getKinesisShardIdAndEventNoFromEventID & getKinesisSequenceNumber functions
  • Added getDynamoDBSequenceNumber function
  • Added additional validation checks to validateStreamEventRecord, validateKinesisStreamEventRecord & validateDynamoDBStreamEventRecord functions
• Added many new typedefs to type-defs.js

5.0.17

• Fixed critical module-scope defects in generateHandlerFunction function in api-lambdas module
• Changes to dynamodb-utils module:
  • Changed toNumber function to return the given string if a large integer number's precision cannot be preserved
  • Added toKeyValuePairs function
• Updated core-functions dependency to version 2.0.14
• Updated logging-utils dependency to version 3.0.12

5.0.16

• Added missing context as first argument to generateHandlerFunction function of api-lambdas.js module

5.0.15

• Fixed missing require core-functions/promises issue in api-lambdas.js module

5.0.14

• Fixed defect in generateHandlerFunction function of api-lambdas.js module

5.0.13

• Added new generateHandlerFunction function to api-lambdas.js module
• More improvements to typedefs in type-defs.js module
• Updated core-functions dependency to version 2.0.12
• Updated logging-utils dependency to version 3.0.10

5.0.12

• Updated logging-utils dependency to version 3.0.9

5.0.11

• Changes to type-defs.js module:
  • Added StandardContext, StandardSettings, StandardOptions, CustomAware, CustomSettings, CustomOptions and RegionStageAWSContextAware
• Added new contexts.js module with configureStandardContext and configureCustomSettings functions
• Added new api-lambdas.js module with failCallback (and synonym failCallbackForApiGateway) functions and re-exported configureStandardContext function from contexts.js to simplify imports for API Gateway exposed Lambdas
• Changes to lambdas.js module:
  • Moved failCallbackForApiGateway function to new api-lambdas.js module
• Changes to stages.js module:
  • Added new configureRegionStageAndAwsContext convenience function to configure current region, resolved stage and AWS context on the given context
  • Improved JsDoc type definitions on all of the configuration functions
• Added and improved existing examples in README.md

5.0.10

• Fixed broken unit tests by changing incorrect imports of node-uuid to uuid
• Added new RegionAware, KinesisAware and DynamoDBDocClientAware typedefs to type-defs.js module
• Changes to regions.js module:
  • Changed the context argument and return type of configureRegion function to use new RegionAware typedef
• Changes to kinesis-cache.js module:
  • Changed the context argument and return types of configureKinesis function to use new KinesisAware typedef
• Changes to dynamodb-doc-client-cache.js module:
  • Changed the context argument and return type of configureDynamoDBDocClient function to use new DynamoDBDocClientAware typedef

5.0.9

• Updated logging-utils dependency to version 3.0.8
• Renamed stages-defs.js module to type-defs.js to synchronize with other modules

5.0.8

• Renamed stage-handling-type-defs.js module to stages-type-defs.js

5.0.7

• Added stage-handling-type-defs.js module to hold all of the stage handling related typedefs
  • Added StageHandlingOptions and StageHandlingSettings typedefs from stages.js
  • Added new StageHandling and StageAware typedefs
• Changes to stages.js module:
  • Removed StageHandlingOptions and StageHandlingSettings typedefs
  • Changed the argument and return types on many of the functions to use the existing and new typedefs
• Updated logging-utils dependency to version 3.0.7

5.0.6

• Updated core-functions dependency to version 2.0.11
• Updated logging-utils dependency to version 3.0.6
• Replaced node-uuid dependency with uuid dependency in test\package.json

5.0.5

• Changes to stream-events module:
  • Added new getEventSources function
  • Added new getDynamoDBEventSourceTableNames function
• Changes to stages module:
  • Changed resolveStage function to resolve the event's eventSource and when its DynamoDB to use the table names of the DynamoDB stream event as a stage source, instead of always assuming the event is a Kinesis stream event and only using the stream names of the Kinesis stream event as a stage source
• Updated core-functions dependency to version 2.0.10
• Updated logging-utils dependency to version 3.0.5

5.0.4

• Updated core-functions dependency to version 2.0.9
• Updated logging-utils dependency to version 3.0.3

5.0.3

• Updated core-functions dependency to version 2.0.8
• Updated logging-utils dependency to version 3.0.2

5.0.2

• Changes to stages.js module:
  • Moved export of configureStageHandlingWithSettings to FOR_TESTING_ONLY
  • Added missing notes on changes for Release 5.0.1 to README.md

5.0.1

• Changes to stages.js module:
  • Changed configureStageHandling function to use core-functions/objects module's copy and merge functions to ensure that any and all given custom settings and options are not lost
  • Changed getDefaultStageHandlingSettings & loadDefaultStageHandlingOptions functions to use core-functions/objects module's copy and merge functions to ensure that any and all given custom options are not lost
• Changes to kinesis-cache.js module:
  • Changed setKinesis to only modify a copy of the given kinesisOptions to avoid side-effects
• Changes to dynamodb-doc-client-cache.js module:
  • Changed setDynamoDBDocClient to only modify a copy of the given dynamoDBDocClientOptions to avoid side-effects
• Updated core-functions dependency to version 2.0.7
• Updated tape dependency to 4.6.3

5.0.0

• Changes to arns.js module:
  • Changed getArnResources function to support DynamoDB eventSourceARNs
• Changes to stream-events.js module:
  • Renamed getEventSourceStreamNames function to getKinesisEventSourceStreamNames
  • Renamed getEventSourceStreamName function to getKinesisEventSourceStreamName
  • Added new getDynamoDBEventSourceTableName function
  • Added new getDynamoDBEventSourceTableNameAndStreamTimestamp function
• Changes to stages.js module:
  • Renamed configureStageHandling function to configureStageHandlingWithSettings
  • Renamed configureStageHandlingAndDependencies function to configureStageHandling
  • Removed configureDependenciesIfNotConfigured function
  • Removed configureDefaultStageHandlingIfNotConfigured function
  • Removed configureStageHandlingIfNotConfigured function
• Renamed config.json to stages-options.json
• Updated core-functions dependency to version 2.0.5
• Updated logging-utils dependency to version 3.0.0

4.0.0

• Renamed kinesis-utils module to kinesis-cache to better reflect its actual purpose
• Renamed dynamodb-doc-clients module to dynamodb-doc-client-cache to better reflect its actual purpose
• Added new dynamodb-utils module
• Changes to stages.js module:
  • Added new configureStageHandlingAndDependencies function to enable configuration of stage handling settings and all stage handling dependencies (currently just logging) at the same time
  • Added new configureDependencies function, which is used by the new configureStageHandlingAndDependencies function
  • Added new envStageName setting to enable configuration of the name of the process.env environment variable to be checked for a stage value during execution of the resolveStage or configureStage functions
  • Changed resolveStage function to first attempt to resolve a stage from a named process.env environment variable (if available), which must be configured using AWS Lambda's new environment support

3.0.2

• Changes to stages.js module:
  • Added configureDependenciesIfNotConfigured function to configure stage handling dependencies (i.e. only logging for now)
  • Changed configureStageHandlingIfNotConfigured function to first invoke new configureDependenciesIfNotConfigured function
  • Changed configureStageHandling function to accept otherSettings and otherOptions as 3rd & 4th arguments to enable configuration of dependencies and to first invoke invoke new configureDependenciesIfNotConfigured function
  • Changed configureDefaultStageHandling function to accept otherSettings and otherOptions as 3rd & 4th arguments to enable configuration of dependencies and to always invoke configureStageHandling

3.0.1

• Changes to stages.js module:
  • Added a convenience configureStageHandlingIfNotConfigured function
  • Changed configureDefaultStageHandlingIfNotConfigured function to use new configureStageHandlingIfNotConfigured function
• Updated logging-utils dependency to version 2.0.3

3.0.0

• Changes to stages.js module:
  • Added typedef for StageHandlingOptions to better define parameters and return types
  • Changed getDefaultStageHandlingSettings function to accept an options argument of type StageHandlingOptions instead of an arbitrary config object and to also load default options from config.json
  • Changed configureDefaultStageHandling function to accept a new options argument of type StageHandlingOptions to enable optional, partial overriding of default stage handling settings
  • Changed stageHandlingSettings to stageHandlingOptions in config.json
  • Fixed require logging-utils link
• Updated logging-utils dependency to version 2.0.1

2.1.4

• Updated JsDoc comments in dynamodb-doc-clients and kinesis-utils modules.

2.1.3

• Added a new dynamodb-doc-clients module to enable creation and configuration of AWS DynamoDB.DocumentClient instances and caching of a DynamoDB.DocumentClient instance per region. Note that this new module is an almost exact replica of the kinesis-utils module, but for getting, setting and caching DynamoDB.DocumentClient instances instead of Kinesis instances.
  • Added setDynamoDBDocClient, getDynamoDBDocClient, getDynamoDBDocClientOptionsUsed, deleteDynamoDBDocClient and configureDynamoDBDocClient functions and unit tests for same.

2.1.2

• Updated core-functions dependency to version 2.0.3
• Updated logging-utils dependency to version 1.0.6

2.1.1

• Added getDefaultStageHandlingSettings function to get the default stage handling settings

2.1.0

• Changes to stages module:
  • Changed API of configureStageHandling function to accept a setting object instead of the multiple fixed parameters, to simplify configuration of new, custom settings.
  • Minor changes and fixes to code & unit tests to accommodate this change.
• Major overhaul of kinesis-utils module to enable full configuration of an AWS Kinesis instance and caching of a Kinesis instance per region.
  • Added setKinesis, getKinesis, getKinesisOptionsUsed & deleteKinesis functions and unit tests for same.
  • Rewrote and changed API of configureKinesis function to use the new setKinesis function and patched its unit tests.
• Technically should have been a 3.0.0 release semantically speaking, since I changed the APIs of two existing functions, but it did not seem warranted.

2.0.1

• Added new kinesis-utils module to provide basic configuration and caching of an AWS.Kinesis instance for Lambda
• Changes to stream-events module:
  • Added validateStreamEventRecord function to check if a record is either a valid Kinesis or DynamoDB stream event record
  • Added validateKinesisStreamEventRecord function to check if a record is a valid Kinesis stream event record
  • Added validateDynamoDBStreamEventRecord function to check if a record is a valid DynamoDB stream event record
  • Added unit tests for new functions
• Minor change to setRegionIfNotSet to eliminate unnecessary logging when regions are the same
• Updated core-functions dependency to version 2.0.2
• Updated logging-utils dependency to version 1.0.5

2.0.0

• Major changes to stages:
  • Changed existing configuration API from resolveStage-specific configuration to general stage handling configuration.
    • Added support for a custom to stage function.
    • Added support for configuration of stream and resource name qualification.
  • Added configureStage function.
  • Added configurable toStageQualifiedStreamName and default toStageSuffixedStreamName functions.
  • Added configurable extractStageFromQualifiedStreamName and default extractStageFromSuffixedStreamName functions.
  • Added configurable toStageQualifiedResourceName and default toStageSuffixedResourceName functions.
  • Added configurable extractStageFromQualifiedResourceName and default extractStageFromSuffixedResourceName functions.
  • Changed and added unit tests for revamped stages module.
• Changes to regions:
  • Added configureRegion function.
  • Added optional, hidden failFast argument to getRegion function needed for configureRegion function.
• Changes to aws-errors:
  • Fixed incorrect usage in comments.
  • Moved exported object's methods bodies to module-level functions.
• Changes to lambdas:
  • Added failCallback function to fail non-API Gateway Lambda callbacks with standard app errors to facilitate mapping of errors to HTTP status codes
  • Added failCallbackForApiGateway function to fail API Gateway Lambda callbacks with standard app errors to facilitate mapping of errors to HTTP status codes
• Added stream-events module and unit tests for it.
• Updated core-functions dependency to version 1.2.0.
• Added logging-utils 1.0.2 dependency.

1.0.0

• Completed changes needed to release 1.0.0
• Added unit tests for stages.js
• Simplified regions.js API down to relevant methods
• Fixed defects attempting to source awsRegion and eventSourceARN from event instead of Kinesis records within event.
• Patched repository in package.json

0.9.0

• Initial commit

Changelog

6.0.8

• Upgraded aws-core-test-utils test dependency to 2.0.4