sls-helper-plugin-janis

v10.1.0

Published

a month ago

A Serverless Helper plugin to add custom helpers for Janis Commerce

Downloads

1,690

0High
0Medium
0Low

janiscommerce

jormaechea

serverless serverless-framework serverless-config-file helper serverless-helper node js sls-helper sls-helper-plugin sls-helper-plugin-janis janis janis-commerce janiscommerce

Serverless Helper Plugin JANIS

A plugin for JANIS Commerce to use with the Serverless Helper Framework.

Helpers

base

Used to implement a base service with minimal setup

| Option | Type | Description | Attributes | Default value | |--------|------|-------------|------------|---------------| | serviceCode | string | The service name in lowercase dash separated | Required | | | servicePort | number | The service port | Required | | | params | { [env]: { [param]: value } } | A mapping of param name and value by environment. Well known environments are: local, beta, qa and prod, but any other env will be kept | | The params humanReadableStage and janisDomain are defined for each well-known env. |

Some properties of the initial configuration have a new special meaning:

package.include and package.includeOnly

package.exclude and package.excludeOnly

package.plugins and package.pluginsOnly

This properties (if present in the initial service configuration) have the following behavior:

package.include, package.exclude and plugins will be appended to the hooks defaults
package.includeOnly, package.excludeOnly and pluginsOnly will replace entirely the hooks defaults

Trace Lambda Layer

If the env vars TRACE_ACCOUNT_ID and JANIS_TRACE_EXTENSION_VERSION are set, the Trace Lambda Layer will be set for every function by default.

apiGet and apiList are the only functions that have this behaviour changed by default.

To disable the layer, see the skipTraceLayer property in other helpers.

templates

Used to implement Lambda APIs requests and response templates as custom props

No options

authorizers

Used to implement APIs authorizers as custom props.

Using the env var AUTHORIZER_ACCOUNT_ID that indicates the AWS account ID where the authorizers are deployed. Required.

cors

Used to implement APIs CORS configuration as custom props

If options is undefined or set to true it will use the default CORS config for every property. You can also customize or override every property:

| Option | Type | Description | Default value | |--------|------|-------------|---------------| | replace | boolean | Indicates whether it should replace the CORS properties or merge then with the default | false | | origins | array<string> | An array of allowed origins | ['*'] | | headers | array<string> | An array of allowed headers | See below | | allowCredentials | boolean | Indicates whether the credentials header should be set | true | | maxAge | number | The time in seconds thar CORS headers should be cached | 600 |

CORS Default headers:

[
	'authorization',
	'content-type',
	'janis-api-key',
	'janis-api-secret',
	'janis-client',
	'janis-service',
	'janis-entity',
	'x-api-key',
	'x-janis-totals',
	'x-janis-only-totals',
	'x-janis-page',
	'x-janis-page-size'
]

api

Used to implement a custom API

| Option | Type | Description | Attributes | Default value | |--------|------|-------------|------------|---------------| | functionName | string | The name of the lambda function. Will be used in API-{serviceName}-{functionName}-{stage}. Since 5.6.0 | | | | path | string | The API path | Required | | | method | string | The API HTTP Method | | 'get' | | methodName | string | The JANIS API Method | Enum<list, get, post, put, patch, delete> | Defaults to same value of method option | | layers | array[object] | An array of function-level layers. This will override any provider-level layers, except for the Trace Layer. Use together with skipTraceLayer to remove the Trace layer (since 8.2.0) | | | | addLayers | array[object] | An array of function-level layers. This will be appended to any provider-level layers (since 8.2.0) | | | | skipTraceLayer | boolean | Set to true if the API should not use the Trace Lambda Layer | | false | | handler | string | The lambda handler path and function | | 'src/lambda/RestApi/index.handler' | | caching | boolean | Set to true to enable cache | | false | | cors | boolean|object | Set to true to enable services default CORS, or configure as an object as explained in CORS to customize the API CORS | | false | | queryParameters | object | A key value to map query string parameters to a boolean indicating if it's required or not | | | | requestTemplates | object | A key value to map content types to request mapping headers. By default only application/json is enabled (Docs) | | | | requestHeaders | object | A key value to map headers to a boolean indicating if it's required or not | | | | authorizer | string | The name of the authorizer | | | | timeout | number | The function timeout in seconds | | | | package.include | array[string] | The List of paths of files to include | | | | functionRawProps | object | Custom properties to set in the function configuration | | | | eventRawProps | object | Custom properties to set in the event configuration | | |

apiList, apiGet, apiPost and apiPut

Used to implement JANIS CRUD APIs.

| Option | Type | Description | Attributes | Default value | |--------|------|-------------|------------|---------------| | functionName | string | The name of the lambda function. Will be used in API-{serviceName}-{functionName}-{stage}. Since 5.6.0 | | | | entityName | string | The entity name | Required | | | handler | string | The lambda handler path and function | | 'src/lambda/RestApi/index.handler' | | path | string | The API path | | /[entity-name] (for apiList and apiPost) or /[entity-name]/{id} (for apiGet and apiPut) | | layers | array[object] | An array of function-level layers. This will override any provider-level layers, except for the Trace Layer. Use together with skipTraceLayer to remove the Trace layer (since 8.2.0) | | | | addLayers | array[object] | An array of function-level layers. This will be appended to any provider-level layers (since 8.2.0) | | | | skipTraceLayer | boolean | Set to true if the API should not use the Trace Lambda Layer | | false for post and put APIs, true for get and list APIs | | caching | boolean | Set to true to enable cache | | false | | cors | boolean|object | Set to true to enable services default CORS, or configure as an object as explained in CORS to customize the API CORS | | false | | queryParameters | object | A key value to map query string parameters to a boolean indicating if it's required or not | | | | requestTemplates | object | A key value to map content types to request mapping headers. By default only application/json is enabled (Docs) | | | | requestHeaders | object | A key value to map headers to a boolean indicating if it's required or not | | | | authorizer | string | The name of the authorizer | | | | timeout | number | The function timeout in seconds | | | | package.include | array[string] | The List of paths of files to include | | | | functionRawProps | object | Custom properties to set in the function configuration | | | | eventRawProps | object | Custom properties to set in the event configuration | | |

eventListener

Used to implement JANIS Events listeners

| Option | Type | Description | Attributes | Default value | |--------|------|-------------|------------|---------------| | serviceName | string | The service name | Required | | | entityName | string | The entity name | Required | | | eventName | string | The event name | Required | | | mustHaveClient | boolean | Indicates if authorizer must validate that client or not | | false | | listenersDirName | string | Indicates the path where the event listener files are placed | | 'event-listeners' | | layers | array[object] | An array of function-level layers. This will override any provider-level layers, except for the Trace Layer. Use together with skipTraceLayer to remove the Trace layer (since 8.2.0) | | | | addLayers | array[object] | An array of function-level layers. This will be appended to any provider-level layers (since 8.2.0) | | | | skipTraceLayer | boolean | Set to true if the API should not use the Trace Lambda Layer (since 8.2.0) | | false | | authorizer | string | The name of the authorizer | | If not set, it defaults to ServiceAuthorizer or ServiceNoClientAuthorizer based on the value of mustHaveClient | | package.include | array[string] | The List of paths of files to include | | timeout | number | The function timeout in seconds | | | | functionRawProps | object | Custom properties to set in the function configuration | | |

dbConfig

(since 3.1.0)

Used to implement JANIS Database config as secret with an auto-generated password

| Option | Type | Description | Attributes | Default value | |--------|------|-------------|------------|---------------| | secret | string | object | The secret content as an object or a JSON stringified object | Required | | | secretName | string | The secret name | | 'janis/${self:custom.serviceCode}/${self:custom.stage}/db-config' | | description | string | The secret description | | 'Database config secret for janis ${self:custom.serviceCode} ${self:custom.stage}' | | passwordKey | string | The property name where the password will be generated | | 'password' | | passwordLength | number | The generated password length | | 40 |

stateMachine

(since 4.3.0)

Used to implement AWS State Machines

| Option | Type | Description | Attributes | Default value | |--------|------|-------------|------------|---------------| | name | string | The name of the state machine | Required | | | definition | object | The definition of the state machine. See more Step Functions| Required | | | type | string | The type of workflow of the state machine. | Enum<STANDARD,EXPRESS> | STANDARD | | loggingConfig | boolean|string|object | The Cloudwatch Logging Configuration of the state machine. | If not set, logging will be OFF. If set to true, logging will be set to INFO and a default Log Group will be created. If set as string, it will be used as log level and a default Log Group will be created. If set as an object, it will be used as is (a default Log Group will be created if destinations property is not set) See loggingConfig documentation for full configuration options. | | | rawProperties | object | A free form object to set any property supported by the Step Functions Plugin but not supported by this package. | |

It will automatically include the serverless-step-functions plugin.

It also defines 2 properties in the custom namespace:

custom.machines.{MachineName}.arn: The State Machine ARN
custom.machines.{MachineName}.name: The State Machine Name

Important: The {MachineName} in the custom.machines path will replaced be the name property converted to PascalCase. For example, if the following hook is configured

['janis.stateMachine', {
	name: 'my-super-machine',
	definition: myDefinition
}]

The following custom props will be set: custom.machines.MySuperMachine.arn and custom.machines.MySuperMachine.name

functionsVpc

(since 7.1.0)

Used to attach the service to a VPC with a Custom Security Group

Important: This hook MUST be set after declaring every function of the service. If a function is declared after this hook, it won't be attached to the VPC.

| Option | Type | Description | Attributes | Default value | |--------|------|-------------|------------|---------------| | vpcId | string | The ID of the VPC, for example vpc-11111111. If this is not set, VPC will not be attached. | | | | subnetIds | string[] | The IDs of the Subnets, for example subnet-111111111. If this is not set or is empty, VPC will not be attached. | | |

It will automatically create a Security Group in the given VPC and attach it to every lambda function. The logical name of the SG will be ServiceSecurityGroup. It can be overriden using Serverless resource overrides.

['janis.functionsVpc', {
	vpcId: 'vpc-11111111',
	subnetIds: [
		'subnet-111111111',
		'subnet-222222222'
	]
}]

VPC Configuration

(since 8.0.0)

If the env vars LAMBDA_SECURITY_GROUP_ID and LAMBDA_SUBNET_IDS are set, the global VPC configuration for all functions added in the service will be added in provider.

See more VPC Configuration

process.env.LAMBDA_SECURITY_GROUP_ID = 'sg-abcdef0001';
process.env.LAMBDA_SUBNET_IDS = 'subnet-111111111,subnet-222222222';

Function URL

This plugin is used to create Lambda functions with customized domains. The domain structure follows the format ${customSubdomain}.${hostedZone}/{customPath}.

Important:

This hook links existing Lambda functions with custom domains. It means referenced Functions must be defined before this hook.
The hostedZone name is obtained from ${self:custom.customDomain.lambdaUrlDomainName}. If it is not defined, the value of ${self:custom.customDomain.domainName} will be used instead.

| Option | Type | Description | |--------|------|-------------| | subdomainName | string | Subdomain to prepend to Service domain name (defined as a custom property for each service). | | | acmCertificate | string | AWS's ACM Certificate Id valid for defined subdomain.| | | functions | Array{} | Array of objects with path definitions for the subdomain. * The first referenced function will be set as the default for requests with no path. | | | functions.0.functionName | string | Name of the function being referenced. * In order to be valid, referenced Functions must be defined as Lambdas Url. | | functions.0.path | string | Relative path associated with the function. * Use '' to redirect all requests with that specific path and any additional subpaths to that specific function* |

It will automatically create (or update) a Cloudfront Distribution and a Route 53 Record Set.

[
	"janis.functionUrl",
	{
		"subdomainName": "subSubdomain.subdomain",
		"acmCertificate": "${param:acmCertificateId}",
		"functions": [
			{
				"functionName": "CustomUrlLambda",
				"path": "/customUrl/*"
			},
			{
				"functionName": "CustomUrlLambda2",
				"path": "/customUrl2/"
			}
		]
	}
]

Expected URLs to access CustomUrlLambda: https://subSubdomain.subdomain.{HostedZoneName}/customUrl. https://subSubdomain.subdomain.{HostedZoneName}/customUrl/subpath

Expected URL to access CustomUrlLambda2: https://subSubdomain.subdomain.{HostedZoneName}/customUrl2

:new: Hook Builders Helpers

This kind of Helpers aren't hooks, this helpers builds hooks (normally many of them) that together make available some kind of resource.

This helpers exist to create some kind of standard and re-utilize another hooks

SQS Helper

This helpers must be used to create SQS resources and consumers with minimal data to a full customization.

Require Helpers

Unlike to normal Hooks, they must be explicitly required from the package.

const { SQSHelper } = require('sls-helper-plugin-janis');  // eslint-disable-line

Permissions

To use SQS resources, AWS permissions must be added, in order to make it easier, you can get them from the Helper using SQSHelper.sqsPermissions getter.

Build Hook

To use the hook Builder of:

SQS Queue
Delay Queue (optional). Since 9.7.0
DLQ Queue
Main Consumer
Delay Consumer (optional). Since 9.7.0
DLQ Consumer (optional)
Env Vars for SQS Urls

You can use SQSHelper.buildHooks(configs) method. This will create an array of Hooks with the proper data.

Parameters

configs: Object
- name: REQUIRED | String | The name of SQS, it will be used for every resource. It must be not empty and camelCase to avoid issues creating the resources names.
- mainQueueProperties: OPTIONAL Object | If it is not passed, it will use default data.
- consumerProperties: OPTIONAL | Object | If it is not passed, it will use default data.
- delayConsumerProperties: OPTIONAL | Object | If it is not passed, it will use default data when delayQueueProperties received.
- delayQueueProperties: OPTIONAL Object | If it is not passed, wont be created.
- dlqQueueProperties: OPTIONAL Object | If it is not passed, it will use default data.
- dlqConsumerProperties: OPTIONAL | Object | By default the DLQ consumer won't be created, you must pass values to create it.
- sourceSnsTopic: OPTIONAL | Object | Array | The configuration of one or more SNS Topics to which the queue will be subscribed to. (See SNSHelper to know how to create an SNS Topic)

Only with a name can create everything except for the Delay hooks (queue and consumer) and DLQ Consumer function

Consumer Properties: All consumerProperties, delayConsumerProperties and dlqConsumerProperties fields can be customized with the following properties:

timeout: default: 15 | Change the Function timeout (in seconds).
handler: default: src/sqs-consumer/[name in lowerCase]-consumer.handler | Change the location of the file.
description: default: [name] SQS Queue Consumer | Change the function description.
batchSize: default: 1 (only for main consumer) | Change the SQS consumer batch Size.
maximumBatchingWindow: default: 10 (only for main consumer) | Change the SQS consumer maximum batching window.
prefixPath: String: To add optional prefix path after src/sqs-consumer. e.g. src/sqs-consumer/[prefixPath]/[name in lowerCase]-consumer.handler

Some other properties

functionProperties: Object | To add other properties to the function (the same one in function hook).
rawProperties: Object | To add rawProperties to the function for example changed a DependsOn.
eventProperties: Object | To add extra Properties to the sqs event configuration, for example functionResponseType

Delay Consumer and DLQ Consumer properties

useMainHandler: boolean | To use the main consumer and not creating other function.

Queue Properties: All mainQueueProperties, delayQueueProperties and dlqQueueProperties fields can be customized with the following properties:

maxReceiveCount: default: 5 (only for MainQueue and DelayQueue) | Change the max receive count properties before sent the message to DelayQueue or DLQ.
receiveMessageWaitTimeSeconds: default: 20 (MainQueue and DelayQueue) or 5 (DLQ).
visibilityTimeout: default: 60 (MainQueue and DelayQueue) or 20 (DLQ).
messageRetentionPeriod: default: 864000 (only for DLQ).
delaySeconds: default: 300 (only for DelayQueue).
addTags: object array: To add Tags for queues. The AWS tag format is [{ Key: 'myTag', Value: 'theTagValue' }].
generateEnvVars: boolean | If set to true, the environment variables with the SQS url will be generated. The default will be true only for SQS queues.

FIFO properties (since 9.6.0)

fifoQueue: boolean | If set to true, creates a FIFO queue.
contentBasedDeduplication: boolean | Specifies whether to enable content-based deduplication.
fifoThroughputLimit: string | Valid values are perQueue and perMessageGroupId.
deduplicationScope: string | Valid values are queue and messageGroup.

Source SNS Topic The sourceSnsTopic parameter has the following structure:

name REQUIRED The name of the SNS Topic
filterPolicy OPTIONAL An object defining a SNS Subscription Policy to apply. The policy will be applied to the messages attributes scope, not to the event payload.

For cross-account topics (ie, topics pubished in another AWS Accounts / Janis Services), you must add the following properties:

scope: string With the fixed value of remote
serviceCode: string With the service code of the remote service that will publish the topic

Returns: array of Hooks

Consumer Files

If handler's location don't change (uses default values), the files must be located in

src/sqs-consumer/[name-in-kebab-case]-consumer.js for main queue consumer
src/sqs-consumer/[name-in-kebab-case]-delay-consumer.js for delay consumer
src/sqs-consumer/[name-in-kebab-case]-dlq-consumer.js for dlq consumer

If prefixPath received the location will be

src/sqs-consumer/[prefixPath]/[name-in-kebab-case]-consumer.js for main queue consumer
src/sqs-consumer/[prefixPath]/[name-in-kebab-case]-delay-consumer.js for delay consumer
src/sqs-consumer/[prefixPath]/[name-in-kebab-case]-dlq-consumer.js for dlq consumer

SQS URL Env Vars

Environment Variables will be created for SQS URL if the property generateEnvVars of each queue is set as true (for main queues, generateEnvVars defaults to true):

[NAME_IN_SNAKE_CASE]_SQS_QUEUE_URL for main queue
[NAME_IN_SNAKE_CASE]_DELAY_QUEUE_URL for delay queue (when delayQueueProperties received)
[NAME_IN_SNAKE_CASE]_DLQ_SQS_QUEUE_URL for dlq

FIFO queues uses the same Environment Variables as Standard queues.

Disable Global env vars

As service grows, the environment variable size quota is reached and breaks service deployments. To avoid it, global env vars can be disabled, and Queue URL env vars can be set in a per-function basis.

To do so, you can use SQSHelper.shouldSetGlobalEnvVars(false) method (by default, global env vars are enabled).

Once disabled, you MUST set the variables to each Lambda function that needs them using SQSHelper.getEnvVar(queueName), for example:

const { helper } = require('sls-helper'); // eslint-disable-line
const { SQSHelper } = require('sls-helper-plugin-janis');  // eslint-disable-line

// ...

SQSHelper.shouldSetGlobalEnvVars(false);

module.exports = helper({
	hooks: [
		// other hooks

		// Permissions must be applied once
		SQSHelper.sqsPermissions

		// must spread it
		...SQSHelper.buildHooks({ name: 'SessionEnded' }),

		['function', {
			functionName: 'EndSession',
			handler: 'src/lambda/Session/End.handler',
			rawProperties: {
				environment: {
					...SQSHelper.getEnvVar('SessionEnded')
				}
			}
		}],

		[['janis.api',
			{
				path: '/session/{id}/end',
				method: 'post',
				cors: true,
				functionRawProps: {
					environment: {
						...SQSHelper.getEnvVar('SessionEnded')
					}
				}
			}
		]]
	]
});

Quick hook example

const { helper } = require('sls-helper'); // eslint-disable-line
const { SQSHelper } = require('sls-helper-plugin-janis');  // eslint-disable-line

// ...

module.exports = helper({
	hooks: [
		// other hooks

		// Permissions must be applied once
		SQSHelper.sqsPermissions

		// must spread it
		...SQSHelper.buildHooks({ name: 'SessionEnded' })
	]
});

/*

Creates the following Hooks
// For permissions

	['iamStatement', {
		action: [
			'sqs:SendMessage',
			'sqs:DeleteMessage',
			'sqs:ReceiveMessage',
			'sqs:GetQueueAttributes'
		],
		// eslint-disable-next-line no-template-curly-in-string
		resource: 'arn:aws:sqs:${aws:region}:${aws:accountId}:*'
	}]

// For Env Vars

	['envVars', {
		SESSION_ENDED_SQS_QUEUE_URL: 'https://sqs.${aws:region}.amazonaws.com/${aws:accountId}/${self:custom.serviceName}SessionEndedQueue',
		SESSION_ENDED_DLQ_QUEUE_URL: 'https://sqs.${aws:region}.amazonaws.com/${aws:accountId}/${self:custom.serviceName}SessionEndedDLQ'
	}]

// For SQS Consumer

	['function', {
		functionName: 'SessionEndedQueueConsumer',
		handler: 'src/sqs-consumer/session-ended-consumer.handler',
		description: 'SessionEnded SQS Queue Consumer',
		timeout: 15,
		rawProperties: {
			dependsOn: ['SessionEndedQueue']
		},
		events: [
			{
				sqs: {
					arn: 'arn:aws:sqs:${aws:region}:${aws:accountId}:${self:custom.serviceName}SessionEndedQueue',
					batchSize: 1,
					maximumBatchingWindow: 10
				}
			}
		]
	}]

// For SQS Resources

	['resource', {
		name: 'SessionEndedQueue',
		resource: {
			Type: 'AWS::SQS::Queue',
			Properties: {
				QueueName: '${self:custom.serviceName}SessionEndedQueue',
				ReceiveMessageWaitTimeSeconds: 20,
				VisibilityTimeout: 60,
				// eslint-disable-next-line max-len
				RedrivePolicy: '{"maxReceiveCount": 5, "deadLetterTargetArn": "arn:aws:sqs:${aws:region}:${aws:accountId}:${self:custom.serviceName}SessionEndedDLQ"}'
			},
			DependsOn: ['SessionEndedDLQ']
		}
	}]

	['resource', {
		name: 'SessionEndedDLQ',
		resource: {
			Type: 'AWS::SQS::Queue',
			Properties: {
				QueueName: '${self:custom.serviceName}SessionEndedDLQ',
				ReceiveMessageWaitTimeSeconds: 5,
				VisibilityTimeout: 20,
				MessageRetentionPeriod: 864000
			}
		}
	}]
*/

With DLQ Consumer example


const { helper } = require('sls-helper'); // eslint-disable-line
const { SQSHelper } = require('sls-helper-plugin-janis');  // eslint-disable-line

// ...

module.exports = helper({
	hooks: [
		// other hooks

		SQSHelper.sqsPermissions

		// must be spread
		...SQSHelper.buildHooks({
			name: 'SessionEnded',
			dlqConsumerProperties: {
				timeout: 30,
				batchSize: 10,
				maximumBatchingWindow: 100
			}
		})
	]
});

/*

Creates the following Hooks

// For permissions

	['iamStatement', {
		action: [
			'sqs:SendMessage',
			'sqs:DeleteMessage',
			'sqs:ReceiveMessage',
			'sqs:GetQueueAttributes'
		],
		// eslint-disable-next-line no-template-curly-in-string
		resource: 'arn:aws:sqs:${aws:region}:${aws:accountId}:*'
	}]

// For Env Vars

	['envVars', {
		SESSION_ENDED_SQS_QUEUE_URL: 'https://sqs.${aws:region}.amazonaws.com/${aws:accountId}/${self:custom.serviceName}SessionEndedQueue',
		SESSION_ENDED_DLQ_QUEUE_URL: 'https://sqs.${aws:region}.amazonaws.com/${aws:accountId}/${self:custom.serviceName}SessionEndedDLQ'
	}]

// For SQS Consumers

	['function', {
		functionName: 'SessionEndedQueueConsumer',
		handler: 'src/sqs-consumer/session-ended-consumer.handler',
		description: 'SessionEnded SQS Queue Consumer',
		timeout: 15,
		rawProperties: {
			dependsOn: ['SessionEndedQueue']
		},
		events: [
			{
				sqs: {
					arn: 'arn:aws:sqs:${aws:region}:${aws:accountId}:${self:custom.serviceName}SessionEndedQueue',
					batchSize: 1,
					maximumBatchingWindow: 10
				}
			}
		]
	}]

	['function', {
		functionName: 'SessionEndedDLQQueueConsumer',
		handler: 'src/sqs-consumer/session-ended-dlq-consumer.handler',
		description: 'SessionEndedDLQ SQS Queue Consumer',
		timeout: 30,
		rawProperties: {
			dependsOn: ['SessionEndedDLQ']
		},
		events: [
			{
				sqs: {
					arn: 'arn:aws:sqs:${aws:region}:${aws:accountId}:${self:custom.serviceName}SessionEndedDLQ',
					batchSize: 10,
					maximumBatchingWindow: 100
				}
			}
		]
	}]

// For SQS Resources

	['resource', {
		name: 'SessionEndedQueue',
		resource: {
			Type: 'AWS::SQS::Queue',
			Properties: {
				QueueName: '${self:custom.serviceName}SessionEndedQueue',
				ReceiveMessageWaitTimeSeconds: 20,
				VisibilityTimeout: 60,
				// eslint-disable-next-line max-len
				RedrivePolicy: '{"maxReceiveCount": 5, "deadLetterTargetArn": "arn:aws:sqs:${aws:region}:${aws:accountId}:${self:custom.serviceName}SessionEndedDLQ"}'
			},
			DependsOn: ['SessionEndedDLQ']
		}
	}]

	['resource', {
		name: 'SessionEndedDLQ',
		resource: {
			Type: 'AWS::SQS::Queue',
			Properties: {
				QueueName: '${self:custom.serviceName}SessionEndedDLQ',
				ReceiveMessageWaitTimeSeconds: 5,
				VisibilityTimeout: 20,
				MessageRetentionPeriod: 864000
			}
		}
	}]
*/

Delay Queue using main consumer example


const { helper } = require('sls-helper'); // eslint-disable-line
const { SQSHelper } = require('sls-helper-plugin-janis');  // eslint-disable-line

// ...

module.exports = helper({
	hooks: [
		// other hooks

		SQSHelper.sqsPermissions

		// must be spread
		...SQSHelper.buildHooks({
			name: 'ProcessStock',
			consumerProperties: {
				batchSize: 100,
				maximumBatchingWindow: 60,
				eventProperties: { maximumConcurrency: 5 }
			}
			delayQueueProperties: {
				// this delay the process
				visibilityTimeout: 600
			},
			delayConsumerProperties: {
				// same process as main consumer
				useMainHandler: true,
				batchSize: 50,
				maximumBatchingWindow: 30,
				eventProperties: { maximumConcurrency: 1 }
			}
		})
	]
});

/*

Creates the following Hooks

// For permissions

	['iamStatement', {
		action: [
			'sqs:SendMessage',
			'sqs:DeleteMessage',
			'sqs:ReceiveMessage',
			'sqs:GetQueueAttributes'
		],
		// eslint-disable-next-line no-template-curly-in-string
		resource: 'arn:aws:sqs:${aws:region}:${aws:accountId}:*'
	}]

// For Env Vars

	['envVars', {
		PROCESS_STOCK_SQS_QUEUE_URL: 'https://sqs.${aws:region}.amazonaws.com/${aws:accountId}/${self:custom.serviceName}ProcessStockQueue',
		PROCESS_STOCK_DLQ_QUEUE_URL: 'https://sqs.${aws:region}.amazonaws.com/${aws:accountId}/${self:custom.serviceName}ProcessStockDLQ',
		PROCESS_STOCK_DELAY_QUEUE_URL: 'https://sqs.${aws:region}.amazonaws.com/${aws:accountId}/${self:custom.serviceName}ProcessStockDelayQueue'
	}]

// For SQS Consumers

	['function', {
		functionName: 'ProcessStockQueueConsumer',
		handler: 'src/sqs-consumer/process-stock-consumer.handler',
		description: 'ProcessStock SQS Queue Consumer',
		timeout: 15,
		rawProperties: {
			dependsOn: ['ProcessStockQueue']
		},
		events: [
			{
				sqs: {
					arn: 'arn:aws:sqs:${aws:region}:${aws:accountId}:${self:custom.serviceName}ProcessStockQueue',
					batchSize: 100,
					maximumBatchingWindow: 60,
					maximumConcurrency: 5
				}
			}, {
				sqs: {
					arn: 'arn:aws:sqs:${aws:region}:${aws:accountId}:${self:custom.serviceName}ProcessStockDelayQueue',
					batchSize: 50,
					maximumBatchingWindow: 30,
					maximumConcurrency: 1
				}
			}
		]
	}]

// For SQS Resources

	['resource', {
		name: 'ProcessStockQueue',
		resource: {
			Type: 'AWS::SQS::Queue',
			Properties: {
				QueueName: '${self:custom.serviceName}ProcessStockQueue',
				ReceiveMessageWaitTimeSeconds: 20,
				VisibilityTimeout: 60,
				// eslint-disable-next-line max-len
				RedrivePolicy: '{"maxReceiveCount": 5, "deadLetterTargetArn": "arn:aws:sqs:${aws:region}:${aws:accountId}:${self:custom.serviceName}ProcessStockDelayQueue"}'
			},
			DependsOn: ['ProcessStockDelayQueue']
		}
	}],

	['resource', {
		name: 'ProcessStockDelayQueue',
		resource: {
			Type: 'AWS::SQS::Queue',
			Properties: {
				QueueName: '${self:custom.serviceName}ProcessStockDelayQueue',
				ReceiveMessageWaitTimeSeconds: 20,
				VisibilityTimeout: 600,
				DelaySeconds: 300,
				// eslint-disable-next-line max-len
				RedrivePolicy: '{"maxReceiveCount": 5, "deadLetterTargetArn": "arn:aws:sqs:${aws:region}:${aws:accountId}:${self:custom.serviceName}ProcessStockDLQ"}'
			},
			DependsOn: ['ProcessStockDLQ']
		}
	}],

	['resource', {
		name: 'ProcessStockDLQ',
		resource: {
			Type: 'AWS::SQS::Queue',
			Properties: {
				QueueName: '${self:custom.serviceName}ProcessStockDLQ',
				ReceiveMessageWaitTimeSeconds: 5,
				VisibilityTimeout: 20,
				MessageRetentionPeriod: 864000
			}
		}
	}]
*/

SNS Helper

This helpers must be used to create SNS resources and subscribers with minimal data to a full customization.

Require Helpers

Unlike to normal Hooks, they must be explicitly required from the package.

const { SNSHelper } = require('sls-helper-plugin-janis');

Permissions

SNS Permissions are automatically created when creating a topic, you don't need to do nothing else :sparkles:

Build Hook

To create a new SNS Topic, you just have to call the SNS.buildHooks(config: SNSConfig) method with the proper configuration object.

Types

You can see SNSConfig and their properties in the types definition

Only with a topic name you are ready to go

SNS ARN Env Vars

Environment Variables can be generated using the SNSHelper.getEnvVar(topicName) method, that will return the following env var:

[TOPIC_NAME_IN_UPPERCASE_SNAKE_CASE]_SNS_TOPIC_ARN for the topic ARN

For example, for a topic with the name userCreated, the USER_CREATED_SNS_TOPIC_ARN env var will be returned.

You MUST add it to the lambda function that uses it.

SQS Connection

See SQSHelper (sourceSnsTopic property) to know how to link a topic to an SQS Queue.

Quick hook example

const { helper } = require('sls-helper'); // eslint-disable-line
const { SNSHelper } = require('sls-helper-plugin-janis');  // eslint-disable-line

module.exports = helper({
	hooks: [
		// other hooks

		// must spread it
		...SNSHelper.buildHooks({
			topic: {
				name: 'userCreated'
			}
		}),

		['function', {
			functionName: 'CreateUser',
			handler: 'src/lambda/User/Create.handler',
			rawProperties: {
				environment: {
					...SNSHelper.getEnvVar('userCreated')
				}
			}
		}],
	]
});

Full example

// serverless.js

'use strict';

const { helper } = require('sls-helper'); // eslint-disable-line

// Only for SQS
const { SQSHelper } = require('sls-helper-plugin-janis');  // eslint-disable-line

module.exports = helper({
	hooks: [

		['janis.base', {
			serviceCode: 'my-service',
			servicePort: 5000,
			apiSecrets: {
				beta: 'foo',
				qa: 'bar',
				prod: 'baz'
			}
		}],

		'janis.templates',

		['janis.authorizers', {
			accountId: '012345678910'
		}],

		'janis.cors',

		['janis.api', {
			path: '/hello-world',
			authorizer: 'NoClientAuthorizer',
			cors: true
		}],

		['janis.apiList', {
			entityName: 'product',
			authorizer: 'FullAuthorizer',
			cors: true
		}],

		['janis.apiGet', {
			entityName: 'product',
			authorizer: 'FullAuthorizer',
			cors: true
		}]

		['janis.apiPost', {
			entityName: 'product',
			authorizer: 'FullAuthorizer',
			cors: true
		}],

		['janis.apiPut', {
			entityName: 'product',
			authorizer: 'FullAuthorizer',
			cors: true
		}],

		['janis.apiList', {
			entityName: 'otherEntity',
			authorizer: 'FullAuthorizer',
			cors: {
				origins: ['*'], // Open to every origin
				allowCredentials: false
			}
		}],

		['janis.eventListener', {
			serviceName: 'catalog',
			entityName: 'product',
			eventName: 'created',
			mustHaveClient: true
		}],

		['janis.stateMachine', {
			name: 'StateMachineName',
			definition: {
				Comment: 'State Machine Comment',
				StartAt: 'WaitForCall',
				States: {
					WaitForCall: {
						Type: 'Wait',
						SecondsPath: '$.body.wait',
						Next: 'Finish'
					}
				}
			}
		}],

		['janis.functionsVpc', {
			vpcId: 'vpc-11111111',
			subnetIds: [
				'subnet-111111111',
				'subnet-222222222'
			]
		}],

		['janis.functionUrl', {
			subdomainName: 'subSubdomain.subdomain',
			acmCertificate: '${param:acmCertificateId}',
			functions: [
				{
					functionName: 'CustomUrlLambda',
					path: '/customUrl/*'
				}
			]
		}],

		...SNSHelper.buildHooks({
			topic: {
				name: 'productUpdated'
			}
		}),

		SQSHelper.sqsPermissions,

		...SQSHelper.buildHooks({
			name: 'ProductToUpdate',
			// Link previously created SNS Topic to the main queue
			sourceSnsTopic: {
				name: 'productUpdated',
				filterPolicy: {
					'platform': ['fullcommerce']
				}
			}
		})
	]
}, {});

Published

Vulnerabilities

Links

Maintainers

Keywords

Readme

Serverless Helper Plugin JANIS

Helpers

base

package.include and package.includeOnly

package.exclude and package.excludeOnly

package.plugins and package.pluginsOnly

Trace Lambda Layer

templates

authorizers

cors

CORS Default headers:

api

apiList, apiGet, apiPost and apiPut

eventListener

dbConfig

stateMachine

functionsVpc

VPC Configuration

Function URL

:new: Hook Builders Helpers

SQS Helper

Require Helpers

Permissions

Build Hook

Consumer Files

SQS URL Env Vars

Quick hook example

With DLQ Consumer example

Delay Queue using main consumer example

SNS Helper

Require Helpers

Permissions

Build Hook

SNS ARN Env Vars

SQS Connection

Quick hook example

Full example