import { map, update, property } from 'lodash/fp';
import { async } from '@strapi/utils';
import { getService } from '../utils/index.mjs';
import { validateWorkflowCreate, validateWorkflowUpdate } from '../validation/review-workflows.mjs';
import { WORKFLOW_POPULATE, WORKFLOW_MODEL_UID } from '../constants/workflows.mjs';

/**
 *
 * @param { Core.Strapi } strapi - Strapi instance
 * @param userAbility
 * @return { PermissionChecker }
 */ function getWorkflowsPermissionChecker({ strapi: strapi1 }, userAbility) {
    return strapi1.plugin('content-manager').service('permission-checker').create({
        userAbility,
        model: WORKFLOW_MODEL_UID
    });
}
/**
 * Transforms workflow to an admin UI format.
 * Some attributes (like permissions) are presented in a different format in the admin UI.
 * @param {Workflow} workflow
 */ function formatWorkflowToAdmin(workflow) {
    if (!workflow) return;
    if (!workflow.stages) return workflow;
    // Transform permissions roles to be the id string instead of an object
    const transformPermissions = map(update('role', property('id')));
    const transformStages = map(update('permissions', transformPermissions));
    return update('stages', transformStages, workflow);
}
var workflows = {
    /**
   * Create a new workflow
   * @param {import('koa').BaseContext} ctx - koa context
   */ async create (ctx) {
        const { body, query } = ctx.request;
        const { sanitizeCreateInput, sanitizeOutput, sanitizedQuery } = getWorkflowsPermissionChecker({
            strapi
        }, ctx.state.userAbility);
        const { populate } = await sanitizedQuery.create(query);
        const workflowBody = await validateWorkflowCreate(body.data);
        const workflowService = getService('workflows');
        const createdWorkflow = await workflowService.create({
            data: await sanitizeCreateInput(workflowBody),
            populate
        }).then(formatWorkflowToAdmin);
        ctx.created({
            data: await sanitizeOutput(createdWorkflow)
        });
    },
    /**
   * Update a workflow
   * @param {import('koa').BaseContext} ctx - koa context
   */ async update (ctx) {
        const { id } = ctx.params;
        const { body, query } = ctx.request;
        const workflowService = getService('workflows');
        const { sanitizeUpdateInput, sanitizeOutput, sanitizedQuery } = getWorkflowsPermissionChecker({
            strapi
        }, ctx.state.userAbility);
        const { populate } = await sanitizedQuery.update(query);
        const workflowBody = await validateWorkflowUpdate(body.data);
        // Find if workflow exists
        const workflow = await workflowService.findById(id, {
            populate: WORKFLOW_POPULATE
        });
        if (!workflow) {
            return ctx.notFound();
        }
        // Sanitize input data
        const getPermittedFieldToUpdate = sanitizeUpdateInput(workflow);
        const dataToUpdate = await getPermittedFieldToUpdate(workflowBody);
        // Update workflow
        const updatedWorkflow = await workflowService.update(workflow, {
            data: dataToUpdate,
            populate
        }).then(formatWorkflowToAdmin);
        // Send sanitized response
        ctx.body = {
            data: await sanitizeOutput(updatedWorkflow)
        };
    },
    /**
   * Delete a workflow
   * @param {import('koa').BaseContext} ctx - koa context
   */ async delete (ctx) {
        const { id } = ctx.params;
        const { query } = ctx.request;
        const workflowService = getService('workflows');
        const { sanitizeOutput, sanitizedQuery } = getWorkflowsPermissionChecker({
            strapi
        }, ctx.state.userAbility);
        const { populate } = await sanitizedQuery.delete(query);
        const workflow = await workflowService.findById(id, {
            populate: WORKFLOW_POPULATE
        });
        if (!workflow) {
            return ctx.notFound("Workflow doesn't exist");
        }
        const deletedWorkflow = await workflowService.delete(workflow, {
            populate
        }).then(formatWorkflowToAdmin);
        ctx.body = {
            data: await sanitizeOutput(deletedWorkflow)
        };
    },
    /**
   * List all workflows
   * @param {import('koa').BaseContext} ctx - koa context
   */ async find (ctx) {
        const { query } = ctx.request;
        const workflowService = getService('workflows');
        const { sanitizeOutput, sanitizedQuery } = getWorkflowsPermissionChecker({
            strapi
        }, ctx.state.userAbility);
        const { populate, filters, sort } = await sanitizedQuery.read(query);
        const [workflows, workflowCount] = await Promise.all([
            workflowService.find({
                populate,
                filters,
                sort
            }).then(map(formatWorkflowToAdmin)),
            workflowService.count()
        ]);
        ctx.body = {
            data: await async.map(workflows, sanitizeOutput),
            meta: {
                workflowCount
            }
        };
    }
};

export { workflows as default };
//# sourceMappingURL=workflows.mjs.map