yujunjun/strapi
1
0
Fork 0
mirror of https://github.com/strapi/strapi.git synced 2025-12-27 23:24:03 +00:00
Code Issues Packages Projects Releases Wiki Activity

feat: persistStagesJoinTables

Browse Source
This commit is contained in:
Marc-Roig 2023-04-19 14:23:38 +02:00
parent d3056d63c4
commit bf3fb202e0
1 changed files with 22 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

31
packages/core/admin/ee/server/services/review-workflows/review-workflows.js
View File

@ -72,12 +72,7 @@ function enableReviewWorkflow({ strapi }) {
const firstStage = defaultWorkflow.stages[0];
const stagesService = getService('stages', { strapi });
const up = async (contentTypeUID) => {
// Persist the stage join table
const { attributes, tableName } = strapi.db.metadata.get(contentTypeUID);
const joinTableName = attributes[ENTITY_STAGE_ATTRIBUTE].joinTable.name;
await persistTable(joinTableName, [tableName]);
const updateEntitiesStage = async (contentTypeUID) => {
// Update CT entities stage
return stagesService.updateEntitiesStage(contentTypeUID, {
fromStageId: null,
@ -85,16 +80,34 @@ function enableReviewWorkflow({ strapi }) {
});
};
await removePersistedTablesWithSuffix('_strapi_review_workflows_stage_links');
return pipe([
getContentTypeUIDsWithActivatedReviewWorkflows,
// Iterate over UIDs to extend the content-type
(contentTypesUIDs) => mapAsync(contentTypesUIDs, up),
(contentTypesUIDs) => mapAsync(contentTypesUIDs, updateEntitiesStage),
])(contentTypes);
};
}
function persistStagesJoinTables({ strapi }) {
return async ({ contentTypes }) => {
const getStageTableToPersist = (contentTypeUID) => {
// Persist the stage join table
const { attributes, tableName } = strapi.db.metadata.get(contentTypeUID);
const joinTableName = attributes[ENTITY_STAGE_ATTRIBUTE].joinTable.name;
return { name: joinTableName, dependsOn: { name: tableName } };
};
const joinTablesToPersist = pipe([
getContentTypeUIDsWithActivatedReviewWorkflows,
(contentTypesUIDs) => contentTypesUIDs.map(getStageTableToPersist),
])(contentTypes);
// TODO: Instead of removing all the tables, we should only remove the ones that are not in the joinTablesToPersist
await removePersistedTablesWithSuffix('_strapi_review_workflows_stage_links');
await persistTables(joinTablesToPersist);
};
}
module.exports = ({ strapi }) => {
const workflowsService = getService('workflows', { strapi });
const stagesService = getService('stages', { strapi });