'use strict';

module.exports = {
  async up(queryInterface, Sequelize) {
    // Add raw_payload column to drone_detections table
    await queryInterface.addColumn('drone_detections', 'raw_payload', {
      type: Sequelize.JSON,
      allowNull: true,
      comment: 'Complete raw payload received from detector (for debugging)'
    });

    // Add raw_payload column to heartbeats table
    await queryInterface.addColumn('heartbeats', 'raw_payload', {
      type: Sequelize.JSON,
      allowNull: true,
      comment: 'Complete raw payload received from detector (for debugging)'
    });

    console.log('✅ Added raw_payload fields to drone_detections and heartbeats tables');
  },

  async down(queryInterface, Sequelize) {
    // Remove raw_payload column from drone_detections table
    await queryInterface.removeColumn('drone_detections', 'raw_payload');

    // Remove raw_payload column from heartbeats table
    await queryInterface.removeColumn('heartbeats', 'raw_payload');

    console.log('✅ Removed raw_payload fields from drone_detections and heartbeats tables');
  }
};