sns topics updater

const AWS = require('aws-sdk');
const Promise = require('bluebird');

AWS.config.setPromisesDependency(Promise);

AWS.config.update({
  region: 'eu-west-1',
  credentials: {
    accessKeyId: 'sas',
    secretAccessKey: 'sas'
  }
});

const appArn = 'arn';
const sns = new AWS.SNS();

function processEndpoints(endpoints) {
  const failedEndpoints = endpoints.filter(({ Attributes }) => Attributes.Enabled === 'false');

  return Promise.each(failedEndpoints, ({ EndpointArn, Attributes }) => {
    console.log(`processing ${EndpointArn} arn`, Object.assign(Attributes, { Enabled: 'true' }));

    return sns
      .setEndpointAttributes({
        EndpointArn,
        Attributes: Object.assign(Attributes, { Enabled: 'true' })
      })
      .promise();
  });
}

async function main() {
  let res = await sns
    .listEndpointsByPlatformApplication({
      PlatformApplicationArn: appArn
    })
    .promise();

  await processEndpoints(res.Endpoints);

  while (res.NextToken) {
    res = await sns
      .listEndpointsByPlatformApplication({
        PlatformApplicationArn: appArn,
        NextToken: res.NextToken
      })
      .promise();

    await processEndpoints(res.Endpoints);
  }

  console.log('the endpoints was succesfully updated');
}

main().catch(console.error);