ambiser
/
strapi-plugin-config-sync
mirror of https://github.com/boazpoolman/strapi-plugin-config-sync
9
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fix: import issues

pull/70/head
Salman 2022-09-12 20:27:26 +05:30
parent 2260b84f49
commit eefbed50d9
1 changed files with 10 additions and 30 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

40
server/config/type.js
View File

@ -49,20 +49,6 @@ const ConfigType = class ConfigType {
}); });
if (existingConfig && configContent === null) { // Config exists in DB but no configfile content --> delete config from DB if (existingConfig && configContent === null) { // Config exists in DB but no configfile content --> delete config from DB
await Promise.all(this.relations.map(async ({ queryString, parentName }) => {
const relations = await noLimit(strapi.query(queryString), {
where: {
[parentName]: existingConfig.id,
},
});
await Promise.all(relations.map(async (relation) => {
await strapi.query(queryString).delete({
where: { id: relation.id },
});
}));
}));
await queryAPI.delete({ await queryAPI.delete({
where: { id: existingConfig.id }, where: { id: existingConfig.id },
}); });
@ -104,32 +90,26 @@ const ConfigType = class ConfigType {
this.jsonFields.map((field) => query[field] = JSON.stringify(configContent[field])); this.jsonFields.map((field) => query[field] = JSON.stringify(configContent[field]));
// Update entity. // Update entity.
// TODO: See if this is redundaunt now?
this.relations.map(({ relationName }) => delete query[relationName]); this.relations.map(({ relationName }) => delete query[relationName]);
const entity = await queryAPI.update({ where: combinedUidWhereFilter, data: query });
// Delete/create relations. // Delete/create relations.
await Promise.all(this.relations.map(async ({ queryString, relationName, parentName, relationSortFields }) => { const relationRows = await Promise.all(this.relations.map(async ({ queryString, relationName, parentName, relationSortFields }) => {
const relationQueryApi = strapi.query(queryString); const relationQueryApi = strapi.query(queryString);
existingConfig = sanitizeConfig(existingConfig, relationName, relationSortFields);
configContent = sanitizeConfig(configContent, relationName, relationSortFields); configContent = sanitizeConfig(configContent, relationName, relationSortFields);
const configToAdd = difference(configContent[relationName], existingConfig[relationName], relationSortFields); return relationQueryApi.findMany({
const existingRows = await relationQueryApi.findMany({
where: { where: {
$and: relationSortFields.map((field) => ({ [field]: { $in: configToAdd.map(c => c[field] ) } })) $and: relationSortFields.map((field) => ({ [field]: { $in: configContent[relationName].map(c => c[field] ) } }))
} }
}) })
await queryAPI.update({
where: combinedUidWhereFilter,
data: {
...configContent,
[relationName]: existingRows.map(r => r.id)
}
});
})); }));
const data = this.relations.reduce((acc, { relationName }, index) => {
acc[relationName] = relationRows[index].map(r => r.id)
return acc
}, { ...query })
await queryAPI.update({ where: combinedUidWhereFilter, data });
} }
} }