const cds = require('@sap/cds/lib')
const cwd = process.cwd(); process.chdir (__dirname) //> only for internal CI/CD@SAP
const {expect} = cds.test
const _model = '@capire/reviews'


describe('Messaging', ()=>{

    after(()=> process.chdir(cwd))

    it ('should bootstrap sqlite in-memory db', async()=>{
        const db = await cds.deploy (_model) .to ('sqlite::memory:')
        expect (db.model) .not.undefined
    })

    let srv
    it ('should serve ReviewsService', async()=>{
        srv = await cds.serve('ReviewsService') .from (_model)
        expect (srv.name) .to.match (/ReviewsService/)
    })

    let N=0, received=[], M=0
    it ('should add messaging event handlers', ()=>{
        srv.on('reviewed', (msg,next)=> { received.push(msg); return next() })
    })

    it ('should add more messaging event handlers', ()=>{
        srv.on('reviewed', (_,next)=> { ++M; return next() })
    })

    it ('should add review', async ()=>{
        const review = { subject: "201", title: "Captivating", rating: ++N }
        const response = await srv.create ('Reviews') .entries (review)
        expect (response) .to.containSubset (review)
    })

    it ('should add more reviews', ()=> Promise.all ([
        // REVISIT: mass operation should trigger one message per entry
        // srv.create('Reviews').entries(
        //     { ID: 111 + (++N),  subject: "201", title: "Captivating", rating: N },
        //     { ID: 111 + (++N),  subject: "201", title: "Captivating", rating: N },
        //     { ID: 111 + (++N),  subject: "201", title: "Captivating", rating: N },
        //     { ID: 111 + (++N),  subject: "201", title: "Captivating", rating: N },
        // ),
        srv.create ('Reviews') .entries (
            { ID: 111 + (++N),  subject: "201", title: "Captivating", rating: N }
        ),
        srv.create ('Reviews') .entries (
            { ID: 111 + (++N),  subject: "201", title: "Captivating", rating: N }
        ),
        srv.create ('Reviews') .entries (
            { ID: 111 + (++N),  subject: "201", title: "Captivating", rating: N }
        ),
        srv.create ('Reviews') .entries (
            { ID: 111 + (++N),  subject: "201", title: "Captivating", rating: N }
        ),
    ]))

    it ('should have received all messages', async()=> {
        await new Promise((done)=>setImmediate(done))
        expect(M).equals(N)
        expect(received.length).equals(N)
        expect(received.map(m=>m.data)).to.deep.equal([
            { subject: '201', rating: 1 },
            { subject: '201', rating: 1.5 },
            { subject: '201', rating: 2 },
            { subject: '201', rating: 2.5 },
            { subject: '201', rating: 3 },
        ])
    })
})