Миграции MongoDB стали простыми

# Добавление нового поля во все документы
class AddTimestampsToProducts < Exodus::Migration
  def up
    products.find({}).each do |product|
      product['created_at'] = Time.now
      product['updated_at'] = Time.now
      products.save(product)
    end
  end

  def down
    products.update({}, {'$unset' => {'created_at' => 1, 'updated_at' => 1}})
  end
end

# Миграция с трансформацией данных
class NormalizeUserData < Exodus::Migration
  def up
    users.find({}).each do |user|
      # Нормализация телефонов
      if user['phone']
        user['phone'] = normalize_phone(user['phone'])
      end

      # Миграция старой структуры адресов
      if user['address_string']
        user['address'] = parse_address(user['address_string'])
        user.delete('address_string')
      end

      users.save(user)
    end
  end

  private

  def normalize_phone(phone)
    phone.gsub(/[^0-9+]/, '')
  end

  def parse_address(address_str)
    # Парсинг адреса в структурированный объект
    parts = address_str.split(', ')
    {
      'street' => parts[0],
      'city' => parts[1],
      'country' => parts[2]
    }
  end
end

# Откат миграции с сохранением данных
class MigrateOrderStatus < Exodus::Migration
  def up
    orders.find({status: 'completed'}).each do |order|
      order['status'] = 'delivered'
      order['legacy_status'] = 'completed'  # Сохраняем старое значение
      orders.save(order)
    end
  end

  def down
    orders.find({legacy_status: 'completed'}).each do |order|
      order['status'] = order['legacy_status']
      order.delete('legacy_status')
      orders.save(order)
    end
  end
end

# Откат миграции
# rake exodus:rollback