import { Inject, Injectable } from '@nestjs/common';
import { Cron, CronExpression } from '@nestjs/schedule';
import { CommandBus, EventBus, QueryBus } from '@nestjs/cqrs';

import { UserService } from '@energyweb/origin-backend';
import {
    ApproveCertificationRequestCommand,
    GetAllCertificationRequestsQuery,
    RevokeCertificationRequestCommand
} from '@energyweb/issuer-api';
import { IssuanceStatus } from '@energyweb/issuer-irec-api-wrapper';
import { IREC_SERVICE, IrecService } from '@energyweb/origin-organization-irec-api';

import { CertificationRequestStatusChangedEvent } from '../events';

@Injectable()
export class CheckCertificationRequestStateTask {
    constructor(
        private readonly commandBus: CommandBus,
        @Inject(IREC_SERVICE)
        private readonly irecService: IrecService,
        private readonly eventBus: EventBus,
        private readonly queryBus: QueryBus,
        private readonly userService: UserService
    ) {}

    @Cron(CronExpression.EVERY_MINUTE)
    async handleCron() {
        const certificationRequests = await this.queryBus.execute(
            new GetAllCertificationRequestsQuery({ approved: false })
        );

        for (const certificateRequest of certificationRequests) {
            const user = await this.userService.findOne(certificateRequest.userId);
            const irecIssue = await this.irecService.getIssueRequest(
                user.organization.id,
                certificateRequest.irecIssueId
            );

            if (!irecIssue) {
                return;
            }

            if (irecIssue.status === IssuanceStatus.Approved) {
                await this.commandBus.execute(
                    new ApproveCertificationRequestCommand(certificateRequest.id)
                );
                this.eventBus.publish(
                    new CertificationRequestStatusChangedEvent(
                        certificateRequest,
                        IssuanceStatus.Approved
                    )
                );
            }
            if (irecIssue.status === IssuanceStatus.Rejected) {
                await this.commandBus.execute(
                    new RevokeCertificationRequestCommand(certificateRequest.id)
                );
            }
        }
    }
}