yujunjun/strapi
1
0
Fork 0
mirror of https://github.com/strapi/strapi.git synced 2025-09-25 08:19:07 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix naming

Browse Source
This commit is contained in:
Convly 2022-12-12 16:24:48 +01:00
parent 34153ec9cb
commit b6903cd77b
1 changed files with 11 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
packages/core/data-transfer/lib/providers/shared/strapi/entity.ts
View File

@ -26,39 +26,36 @@ const createEntityQuery = (strapi: Strapi.Strapi) => {
return assign(entityComponents, dataWithoutComponents); return assign(entityComponents, dataWithoutComponents);
}, },
create: async <T>(uid: string, data: T) => {
return data;
},
get: async <T extends object>(uid: string, entity: T) => { get: async <T extends object>(uid: string, entity: T) => {
return componentsService.getComponents(uid, entity); return componentsService.getComponents(uid, entity);
}, },
delete<T extends object>(uid: string, components: T) { delete<T extends object>(uid: string, componentsToDelete: T) {
return componentsService.deleteComponents(uid, components, { loadComponents: false }); return componentsService.deleteComponents(uid, componentsToDelete, { loadComponents: false });
}, },
}; };
const query = (uid: string) => { const query = (uid: string) => {
const create = async <T extends { data: U }, U extends object>(query: T) => { const create = async <T extends { data: U }, U extends object>(params: T) => {
const dataWithComponents = await components.assignToEntity(uid, query.data); const dataWithComponents = await components.assignToEntity(uid, params.data);
const sanitizedData = omitInvalidCreationAttributes(dataWithComponents); const sanitizedData = omitInvalidCreationAttributes(dataWithComponents);
return strapi.db.query(uid).create({ ...query, data: sanitizedData }); return strapi.db.query(uid).create({ ...params, data: sanitizedData });
}; };
const createMany = async <T extends { data: U[] }, U extends object>(query: T) => { const createMany = async <T extends { data: U[] }, U extends object>(params: T) => {
return ( return (
Promise.resolve(query.data) Promise.resolve(params.data)
// Create components for each entity // Create components for each entity
.then(map((data) => components.assignToEntity(uid, data))) .then(map((data) => components.assignToEntity(uid, data)))
// Remove unwanted attributes // Remove unwanted attributes
.then(map(omitInvalidCreationAttributes)) .then(map(omitInvalidCreationAttributes))
// Execute a strapi db createMany query with all the entities + their created components // Execute a strapi db createMany query with all the entities + their created components
.then((data) => strapi.db.query(uid).createMany({ ...query, data })) .then((data) => strapi.db.query(uid).createMany({ ...params, data }))
); );
}; };
const deleteMany = async <T extends object>(query?: T) => { const deleteMany = async <T extends object>(params?: T) => {
const entitiesToDelete = await strapi.db.query(uid).findMany(query ?? {}); const entitiesToDelete = await strapi.db.query(uid).findMany(params ?? {});
if (!entitiesToDelete.length) { if (!entitiesToDelete.length) {
return null; return null;
@ -68,7 +65,7 @@ const createEntityQuery = (strapi: Strapi.Strapi) => {
entitiesToDelete.map((entityToDelete) => components.get(uid, entityToDelete)) entitiesToDelete.map((entityToDelete) => components.get(uid, entityToDelete))
); );
const deletedEntities = await strapi.db.query(uid).deleteMany(query); const deletedEntities = await strapi.db.query(uid).deleteMany(params);
await Promise.all(componentsToDelete.map((compos) => components.delete(uid, compos))); await Promise.all(componentsToDelete.map((compos) => components.delete(uid, compos)));
return deletedEntities; return deletedEntities;