import { ChildProcess, spawn } from 'child_process'
import { Redis } from 'ioredis'
import { FlowProducer, Queue } from 'bullmq'

const connectionOpts = {
    host: '127.0.0.1',
    port: 6379,
    enableOfflineQueue: false,
}

let redisProcess: ChildProcess
async function wait(ms: number) { return new Promise(r => setTimeout(r, ms)) }

function startRedis() {
    console.log('--- Starting Redis Server ---')
    redisProcess = spawn('redis-server', [], { stdio: 'ignore' })
}

async function runRepro() {
    startRedis()
    await wait(500)
    const setupConn = new Redis(connectionOpts)
    await wait(500)
    console.log('Making Redis READONLY')
    await setupConn.replicaof(connectionOpts.host, connectionOpts.port)
    await setupConn.quit()

    const queueName = 'test-queue'

    const flowProducer = new FlowProducer({ connection: connectionOpts })
    const queue = new Queue(queueName, { connection: connectionOpts })

    await flowProducer.waitUntilReady()
    await queue.waitUntilReady()

    console.log('Adding job with Queue...')
    try {
        const job = await queue.add('test-job', { foo: 'bar' })

        console.error('Job added with Queue unexpectedly', job)
    } catch (e) {
        console.log('Got expected error while adding job with Queue')
    }

    console.log('Adding jobs with FlowProducer...')
    try {
        const jobNode = await flowProducer.add({
            name: 'test-parent',
            queueName,
            children: [{ name: 'test-child', queueName }]
        })

        console.error('Job added with FlowProducer unexpectedly:', jobNode.job.id)

        const verifyJobNode = await flowProducer.getFlow({ id: jobNode.job.id!, queueName })
        console.error('.add() did not throw but flow does not exist:', verifyJobNode)
    } catch (e) {
        console.log('Got expected error while adding jobs with FlowProducer', e)
    }

    if (redisProcess) redisProcess.kill()
    process.exit()
}

runRepro().catch(console.error)