<?php

use App\Models\AbstractQueue;
use App\Models\BitrixQueue;
use Illuminate\Database\Migrations\Migration;

return new class extends Migration {

    public function up()
    {
        BitrixQueue::query()
            ->where('status', AbstractQueue::STATUS_ERROR)
            ->where('error', 'Undefined array key ""')
            ->each(function ($row) {
                $data = json_decode($row->data, true, 512, JSON_THROW_ON_ERROR);
                unset($data['region']);
                $row->data = json_encode($data, JSON_THROW_ON_ERROR);
                $row->status = 0;
                $row->save();
            });
    }

    public function down()
    {
        // Nothing
    }

};