chore: temp support for wip streamlined result

lib/resolvers/crud/create.js

@@ -13,7 +13,21 @@ module.exports = async ({ req, res }, service, entity, selection) => {
   const entries = entriesStructureToEntityStructure(service, entity, astToEntries(input))
   query.entries(entries)
 
-  const result = await service.dispatch(new GraphQLRequest({ req, res, query }))
+  const cdsReq = new GraphQLRequest({ req, res, query })
+  let result = await service.dispatch(cdsReq)
+  if (typeof result === 'object' && 'affectedRows' in result) {
+    let only_keys = true
+    const entity_keys = Object.keys(entity.keys ?? {})
+    for (let i = 0; i < result.data.length; i++) {
+      const data_keys = Object.keys(result.data[i])
+      if (!data_keys.every(k => entity_keys.includes(k))) {
+        only_keys = false
+        break
+      }
+    }
+    if (only_keys) result = cdsReq.data
+    else result = result.data
+  }
 
   return formatResult(entity, selection, result, false)
 }

lib/resolvers/crud/delete.js

@@ -14,6 +14,7 @@ module.exports = async ({ req, res }, service, entity, selection) => {
   let result
   try {
     result = await service.dispatch(new GraphQLRequest({ req, res, query }))
+    if (typeof result === 'object' && 'affectedRows' in result) result = result.affectedRows
   } catch (e) {
     if (e.code === 404) result = 0
     else throw e

lib/resolvers/crud/update.js

@@ -30,7 +30,10 @@ module.exports = async ({ req, res }, service, entity, selection) => {
     resultBeforeUpdate = await tx.dispatch(new GraphQLRequest({ req, res, query: queryBeforeUpdate }))
     if (resultBeforeUpdate.length === 0) return {}
 
-    return await tx.dispatch(new GraphQLRequest({ req, res, query }))
+    const cdsReq = new GraphQLRequest({ req, res, query })
+    let result = await service.dispatch(cdsReq)
+    if (typeof result === 'object' && 'affectedRows' in result) result = result.data ?? cdsReq.data
+    return result
   })
 
   let mergedResults = result