/** @type {typeof import('adonisjs-queue/src/Job')} */
const Job = use('Job')
 
/** @type {typeof import('@adonisjs/mail/src/Mail')} */
const Mail = use('Mail')
 
class SendEmail extends Job {
    
    get queue(){
        return 'low'
    }
    
    constructor(emailAddress, emailFrom, emailSubject, emailBody) {
        super(arguments)
 
        this.timeOut = 100; // seconds
        this.retryCount = 0;
        this.retryUntil = 200; // seconds
        this.delayUntil = Date.parse('2038-01-19T03:14:08.000Z') // optional, omit this line if not required
    }
 
    async handle(link, done) {
        //....
        console.log(`Job [${this.constructor.name}] - handler called: status=running; id=${this.id} `)
    
        await link.reportProgress(10)
 
        let _data = link.data // arguments passed into the constructor
        let error = null
        let result = null
 
        try{
            result = await Mail.send(_data.emailBody, {gender:'F', fullname:"Aisha Salihu"}, (message) => {
                message.to(_data.emailAddress) 
                message.from(_data.emailFrom) 
                message.subject(_data.emailSubject)
            })
            await link.reportProgress(50)
        }catch(err){
            error = err
            result = undefined
            await link.reportProgress(50)
        }finally{
            await link.reportProgress(100)
        }
        
        return new Promise((resolve, reject) => {
            error === null ? resolve(result) : reject(error)
        });
    }
 
    progress(progress) {
 
        console.log(`Job [${this.constructor.name}] - progress:${progress}%: status=running; id=${this.id} `)
    }
 
    failed(error) {
    
        console.log(`Job [${this.constructor.name}] - status:failed; id=${this.id} `, error.message)
        
        this.detach() // remove the job from the queue (when the job fails after all retries)
    }
    
    retrying(error){
    
        console.log(`Job [${this.constructor.name}] - status:retrying; id=${this.id} `, error.message)
    }
    
    succeeded(result){
    
        console.log(`Job [${this.constructor.name}] - status:succeeded; id=${this.id} `, result)
    }
}
 
module.exports = SendEmail
 

 
'use strict'
 
/** @type {typeof import('@adonisjs/framework/src/Event')} */
const Event = use('Event')
 
/** @type {typeof import('adonisjs-queue/src/Queue')} */
const Queue = use('Queue')
 
const SendEmail = use('App/Jobs/SendEmail')
 
Event.on('user_registered', async ( _email ) => {
    // dispatch to the "high" priority queue
 
    await Queue.select('high').andDispatch(new SendEmail(
        _email,
        'support@example.com',
        'YOU ARE WELCOME',
        'emails.template_1' // AdonisJS view template file: "resources/views/emails/template_1.edge"
    ));
    
    // implicitly calls select('high')
    await Queue.dispatch(new SendEmail(
    		_email,
        'support@example.com',
        'NEXT STEPS',
        'emails.template_2' // AdonisJS view template file: "resources/views/emails/template_2.edge"
    ));
})
 

 
/** @type {typeof import('@adonisjs/framework/src/Route/Manager')} */
const Route = use('Route')
 
Route.post('user/register/:type', ({ request, params: { type }, respopnse }) => {
    const body = request.post()
 
    Event.fire('user_registered', 'queensaisha04@gmail.com') // Invoke the 'SendEmail' Job (to send an email) via the Event Bus
 
    if (request.format() === 'json') {
  		return response.status(200).json({
          	status:'success'
        })
    }else{
        return response.send('success')
    }
})

 
'use strict'
 
const SendEmail = use('App/Jobs/SendEmail')
 
class WorksController {
 
    async sendEmail({ request, queue, session }){
    
        let tenant_id = session.get('tenant_id')
        
        let { email } = request.only([
            'email'
        ])
        
        await queue.dispatch(new SendEmail( // dispatch to the "low" priority queue
            email,
            'support@example.com',
            'YOU ARE WELCOME',
            'emails.template' // AdonisJS view template file in "resources/views"
        ))
    }
}
 
module.exports = WorksController