text: 'use strict';
  
  module.exports = {
    up: async (queryInterface, Sequelize) => {
      const transaction = await queryInterface.sequelize.transaction();
      try {
        await queryInterface.addColumn("member_topic", 'subscription_arn', {
          type: Sequelize.STRING(255),
          after: 'topic_id'
        }, { transaction })
        await transaction.commit();
      } catch (err) {
        await transaction.rollback();
        throw err;
      }
    },
  
    down: async (queryInterface, Sequelize) => {
      const transaction = await queryInterface.sequelize.transaction();
      try {
        await queryInterface.removeColumn("member_topic", 'subscription_arn', { transaction });
        await transaction.commit();
      } catch (err) {
        await transaction.rollback();
        throw err;
      }
    }
  };
  