index.js

'use strict';

const Joi = require('joi');
const Hoek = require('@hapi/hoek');
const SNS = require('./lib/sns');
const handlers = require('./handlers');

const validOptions = Joi.array().items(Joi.object({
	topic: Joi.object({
		arn: Joi.string().required(),
		attributes: Joi.object().optional().description('Automatically sets topic attributes on onPostStart'),
		subscribe: Joi.object({
			endpoint: Joi.string().required(),
			protocol: Joi.string().valid('HTTP', 'HTTPS').required(),
			attributes: Joi.object().optional().description('Set subscription attributes, only used if the plugin handles the subscription confirmation and subscription does not exist')
		}).optional().description('Automatically subscribe if subscription does not exit on onPostStart')
	}).optional(),
	skipPayloadValidation: Joi.boolean().default(false).optional().description('Skip Signature validation on SNS message'),
	aws: Joi.object().optional().description('AWS config used for SNS'),
	route: Joi.object().optional().description('Overrides for the default route configuration'),
	handlers: Joi.object({
		subscriptionconfirmation: Joi.func().optional().description('If omitted the plugin will handle the subscription confirmation'),
		notification: Joi.func().required()
	}).required().description('Request handler functions for different kind of sns messages')
})).single();

function register(server, opts) {
	const value = Joi.attempt(opts, validOptions);

	const snsInstances = (server.plugins.hookido && server.plugins.hookido.snsInstances) || [];
	value.forEach((config) => init(config));
	server.expose('snsInstances', snsInstances);
	return;

	function init(config) {
		const sns = new SNS(config.aws);
		snsInstances.push(sns);
		const subscribe = Hoek.reach(config, 'topic.subscribe');

		function requestSubscription() {
			return sns
				.subscribe(config.topic.arn, subscribe.protocol, subscribe.endpoint)
				.then(() => server.log(['hookido', 'subscribe'], `Subscription request sent for ${config.topic.arn}`));
		}

		if (subscribe) {

			server.ext('onPostStart', () => {
				return sns
					.findSubscriptionArn(config.topic.arn, subscribe.protocol, subscribe.endpoint)
					.then(() => server.log(['hookido', 'subscribe'], `Subscription already exists for ${config.topic.arn}`))
					.catch({code: 'NOT_FOUND'}, requestSubscription)
					.catch({code: 'PENDING'}, requestSubscription)
					.catch((err) => server.log(['hookido', 'subscribe', 'error'], err));
			});

		}

		const topicAttributes = Hoek.reach(config, 'topic.attributes');
		if (topicAttributes) {
			server.ext('onPostStart', () => {
				return sns
					.setTopicAttributes(config.topic.arn, topicAttributes)
					.then(() => server.log(['hookido', 'setTopicAttributes'], `topicAttributes was updated for ${config.topic.arn}`))
					.catch((err) => server.log(['hookido', 'setTopicAttributes', 'error'], err));
			});
		}

		server.route(Hoek.applyToDefaults({
			method: 'POST',
			path: '/hookido',
			config: {
				auth: false,
				description: 'SNS webhook endpoint',
				handler: handlers.hook(sns, config)
			}
		}, config.route || {}));
	}
}

module.exports = {
	name: 'hookido',
	register,
	multiple: true
};