//create a  list of sns topics from input (cloud formation outputs)
//for each topic - run "aws sns list-subscriptions-by-topic --topic-arn <topicArn>"
//  for each subscription with "Protocol": "sqs" - run "aws sns set-subscription-attributes --attribute-name RawMessageDelivery --attribute-value true --subscription-arn <subscriptionArn>"
var AWS = require('aws-sdk');
var sns = new AWS.SNS({
  apiVersion: '2010-03-31',
  accessKeyId: '<accessKeyId>',
  secretAccessKey: '<secretAccessKey>',
  region: "us-east-1"
});
var async = require('async');

if (process.argv.length < 3) {
  console.log('at least 1 param is needed');
  process.exit(1);
}
var outputs = require(process.argv[2]);
const keys = [
    "ProcessAcceptedSns",
    "ProcessDoneSns"
];

async.each(keys, function(key, cb){
  if (outputs[key]) {
    var params = {
      TopicArn: outputs[key]
    };
    sns.listSubscriptionsByTopic(params, function(err, data) {
      if (err) {
        console.error(err); // an error occurred
        cb(err);
      }
      else {
        if (data && data.Subscriptions && data.Subscriptions.length) {
          async.each(data.Subscriptions, function(subscription, cb){
            if (subscription && subscription.SubscriptionArn && subscription.Protocol === "sqs") {
              var params = {
                AttributeName: 'RawMessageDelivery', /* required */
                SubscriptionArn: subscription.SubscriptionArn, /* required */
                AttributeValue: 'true'
              };
              sns.setSubscriptionAttributes(params, function(err, data) {
                if (err) {
                  console.error('failed to change subscription ' + subscription.SubscriptionArn, err); // an error occurred
                  cb(err);
                }
                else {
                  console.log('subscription ' + subscription.SubscriptionArn , data);
                  cb();
                }
              });
            }
            else {
              cb();
            }
          }, function (err){
            cb(err);
          });
        }
      }
    });
  }
  else {
    cb();
  }
}, function(err){
  if (err) {
    console.error(err);
    process.exit(1);
  }
  else {
    process.exit();
  }
})