local luatest = require('luatest')
local helpers = require('test.luatest_helpers')
local cluster = require('test.luatest_helpers.cluster')
local g = luatest.group('gh-6033-box-promote-demote')

g.before_each(function(g)
    g.cluster = cluster:new({})

    g.box_cfg = {
        election_mode = 'off';
        replication = {
            helpers.instance_uri('server_', 1);
            helpers.instance_uri('server_', 2);
        };
    }

    g.server_1 = g.cluster:build_and_add_server(
        {alias = 'server_1', box_cfg = g.box_cfg})
    g.server_2 = g.cluster:build_and_add_server(
        {alias = 'server_2', box_cfg = g.box_cfg})
    g.cluster:start()
end)

g.after_each(function(g)
    g.cluster:stop()
    g.cluster.servers = nil
end)

g.test_interfering_promote_in_wal = function(g)
    local wal_write_count = g.server_1:exec(function()
        box.error.injection.set('ERRINJ_WAL_DELAY', true)
        return box.error.injection.get('ERRINJ_WAL_WRITE_COUNT')
    end)

    g.server_2:exec(function()
        box.ctl.promote()
        box.error.injection.set('ERRINJ_WAL_DELAY', true)
    end)
    g.server_1:wait_wal_write_count(wal_write_count + 1)

    local ok, err = g.server_1:exec(function()
        local f = require('fiber').new(box.ctl.promote); f:set_joinable(true)
        box.error.injection.set('ERRINJ_WAL_DELAY', false)
        return f:join()
    end)

    print(string.format("Server %d thinks that limbo is owned by %d",
        g.server_1:exec(function()
            return box.info.id, box.info.synchro.queue.owner
    end)))

    print(string.format("Server %d thinks that limbo is owned by %d",
        g.server_2:exec(function()
            return box.info.id, box.info.synchro.queue.owner
    end)))

    g.server_2:exec(function()
        box.error.injection.set('ERRINJ_WAL_DELAY', false)
    end)

    luatest.assert(
        not ok and err.code == box.error.INTERFERING_PROMOTE,
        'interfering promote not handled')
end