Polymorphic reducer types & accessor generation support added

languages/c/Types.mjs

@@ -167,6 +167,23 @@ const deepMergeAll = (module, name, schema, schemas, options) => {
   return union
 }
 
+const getPolymorphicReducerParamSchema = (method) => {
+  let reducedParamSchema = {
+    name: `${method.name}Params`,
+    schema: {
+      type: "array",
+      items: {
+        title: `${method.name}Param`,
+        type: "object",
+        properties: {}
+      }
+    },
+    required: true
+  }
+  method.params.forEach(p => reducedParamSchema.schema.items.properties[p.name] = p)
+  return reducedParamSchema
+}
+
 function getMethodSignature(method, module, { destination, isInterface = false }) {
   const extraParam = '${method.result.type}* ${method.result.name}'
 
@@ -312,12 +329,12 @@ function getSchemaTypeInfo(module = {}, json = {}, name = '', schemas = {}, pref
   return structure
 }
 
-function getSchemaShape(json, module, { name = '', prefix = '', level = 0, title, summary, descriptions = true, destination = '', section = '', enums = true } = {}) {
+function getSchemaShape(json, module, { name = '', prefix = '', type = '', level = 0, title, summary, descriptions = true, destination = '', section = '', enums = true } = {}) {
 
-  let shape = getSchemaShapeInfo(json, module, module['x-schemas'], { name, prefix, merged: false, level, title, summary, descriptions, destination, section, enums })
+  let shape = getSchemaShapeInfo(json, module, module['x-schemas'], { name, prefix, type, merged: false, level, title, summary, descriptions, destination, section, enums })
     return shape
 }
-function getSchemaShapeInfo(json, module, schemas = {}, { name = '', prefix = '', merged = false, level = 0, title, summary, descriptions = true, destination = '', section = '', enums = true } = {}) {
+function getSchemaShapeInfo(json, module, schemas = {}, { name = '', prefix = '', type = '', merged = false, level = 0, title, summary, descriptions = true, destination = '', section = '', enums = true } = {}) {
   let shape = ''
 
   if (destination && section) {
@@ -326,6 +343,14 @@ function getSchemaShapeInfo(json, module, schemas = {}, { name = '', prefix = ''
     json = JSON.parse(JSON.stringify(json))
 
     name = json.title || name
+
+    if (type === 'reducer') {
+      let recuderParam = getPolymorphicReducerParamSchema(json)
+      name = recuderParam.name
+      json = recuderParam.schema
+      type = ''
+    }
+
     if (json['$ref']) {
       if (json['$ref'][0] === '#') {
         //Ref points to local schema
@@ -492,7 +517,7 @@ function getSchemaShapeInfo(json, module, schemas = {}, { name = '', prefix = ''
 
         if (info.type && info.type.length > 0) {
           let type = getArrayElementSchema(json, module, schemas, info.name)
-          let arrayName = capitalize(info.name) + capitalize(type.type)
+          let arrayName = capitalize(name) + capitalize(type.type)
           let objName = getTypeName(info.namespace, arrayName, prefix)
           let tName = objName + 'Array'
           let moduleName = info.namespace

src/macrofier/engine.mjs

@@ -29,7 +29,7 @@ import isString from 'crocks/core/isString.js'
 import predicates from 'crocks/predicates/index.js'
 const { isObject, isArray, propEq, pathSatisfies, propSatisfies } = predicates
 
-import { isRPCOnlyMethod, isProviderInterfaceMethod, getProviderInterface, getPayloadFromEvent, providerHasNoParameters, isTemporalSetMethod, hasMethodAttributes, getMethodAttributes, isEventMethodWithContext, getSemanticVersion, getSetterFor, getProvidedCapabilities, isPolymorphicPullMethod, hasPublicAPIs } from '../shared/modules.mjs'
+import { isRPCOnlyMethod, isProviderInterfaceMethod, getProviderInterface, getPayloadFromEvent, providerHasNoParameters, isTemporalSetMethod, hasMethodAttributes, getMethodAttributes, isEventMethodWithContext, getSemanticVersion, getSetterFor, getProvidedCapabilities, isPolymorphicPullMethod, isPolymorphicReducer, hasPublicAPIs } from '../shared/modules.mjs'
 import isEmpty from 'crocks/core/isEmpty.js'
 import { getLinkedSchemaPaths, getSchemaConstraints, isSchema, localizeDependencies, isDefinitionReferencedBySchema } from '../shared/json-schema.mjs'
 
@@ -646,12 +646,11 @@ function generateSchemas(json, templates, options) {
 
   const schemas = (options.section.includes('methods') ? (hasMethodsSchema(json) ? json.methods : '') : (json.definitions || (json.components && json.components.schemas) || {}))
 
-  const generate = (name, schema, uri, { prefix = '' } = {}) => {
+  const generate = (name, schema, uri, { prefix = '', type = '' } = {}) => {
     // these are internal schemas used by the firebolt-openrpc tooling, and not meant to be used in code/doc generation
     if (['ListenResponse', 'ProviderRequest', 'ProviderResponse', 'FederatedResponse', 'FederatedRequest'].includes(name)) {
       return
     }    
-
     let content = getTemplate('/schemas/default', templates)
 
     if (!schema.examples || schema.examples.length === 0) {
@@ -667,7 +666,7 @@ function generateSchemas(json, templates, options) {
     else {
       content = content.replace(/\$\{if\.description\}(.*?)\{end\.if\.description\}/gms, '$1')
     }
-    const schemaShape = types.getSchemaShape(schema, json, { name, prefix, destination: state.destination, section: options.section })
+    const schemaShape = types.getSchemaShape(schema, json, { name, prefix, type, destination: state.destination, section: options.section })
 
     content = content
         .replace(/\$\{schema.title\}/, (schema.title || name))
@@ -712,13 +711,18 @@ function generateSchemas(json, templates, options) {
     }
     else if (schema.tags) {
       if (!isDeprecatedMethod(schema)) {
-        schema.params.forEach(param => {
-          if (param.schema && (param.schema.type === 'object')) {
-            list.push([param.name, param.schema, '', { prefix : schema.name}])
+        if (isPolymorphicReducer(schema)) {
+          list.push([schema.name, schema, '', { type : 'reducer' }])
+        }
+        else {
+          schema.params.forEach(param => {
+            if (param.schema && (param.schema.type === 'object')) {
+              list.push([param.name, param.schema, '', { prefix : schema.name }])
+            }
+          })
+          if (schema.result.schema && (schema.result.schema.type === 'object')) {
+            list.push([schema.result.name, schema.result.schema, '', { prefix : schema.name }])
           }
-        })
-        if (schema.result.schema && (schema.result.schema.type === 'object')) {
-          list.push([schema.result.name, schema.result.schema, '', { prefix : schema.name}])
         }
       }
     }