Springwolf ui can't mapped oneOf message. Error parsing AsyncAPI message of channel.

[FanatTokyoGhoul]

Describe the bug
When i generate oneOf message schema for springwolf-ui i get exception - "Error parsing AsyncAPI message of channel queue: Schema com.example.request.Request1 not found".

Dependencies and versions used

• springwolf-sqs version 1.9.0
• springwolf-ui version 1.9.0
• kotlin version 2.0.21
• spring version 3.3.5 and dependency manager version 1.1.5

Code Examples

Spring SqsListener

I use only AsyncListener. Sqs listener i disable in application.yml. This example for my sqs listener.

@Component
class QueueListener(
    private val service: Service
) {

    @SqsListener(
        value = ["\${amazon.sqs.queue}"],
    )
    @AsyncListener(
        operation = AsyncOperation(
            headers = AsyncOperation.Headers(
                schemaName = "Request id header",
                values = [AsyncOperation.Headers.Header(
                    name = "request-id",
                    description = "Generate from sqs sender"
                )]
            ),
            channelName = "queue",
            description = "some description",
            message = AsyncMessage(
                messageId = "com.example.request.BaseRequest"
            )
        )
    )
    @SqsAsyncOperationBinding(queues = [SqsAsyncQueueBinding(name = "\${amazon.sqs.queue}")])
    fun onMessage(request: LabelDetectRequest) {

        when (request) {
            is ReqestExample1-> service.mapRequest1(request)
            is ReqestExample2 -> service.mapRequest2(request)
        }
    }
}

Dto class examples

enum class RequestEnum{
    REQUEST_1, REQUEST_2
}


@JsonTypeInfo(
    use = JsonTypeInfo.Id.NAME,
    include = JsonTypeInfo.As.EXISTING_PROPERTY,
    property = "type"
)
@JsonSubTypes(
    JsonSubTypes.Type(
        value = Request1::class,
        name = "REQUEST_1"
    ),
    JsonSubTypes.Type(
        value = Request2::class,
        name = "REQUEST_2"
    )
)
@Schema(
    description = "Base class for request",
    discriminatorProperty = "type",
    oneOf = [Request1::class, Request2::class]
)
sealed class Request(

    @field:Schema(description = "Enum for detected label type", example = "REQUEST_1")
    open val type: RequestEnum = RequestEnum.REQUEST_1
)

@Schema(
    description = "Class for request 1"
)
data class Request1(

    @Schema(description = "Job id from rekognition", example = "00000000-0000-0000-0000-000000000000")
    val jobId: String,

    @Schema(description = "UUID of project", example = "00000000-0000-0000-0000-000000000000")
    val objectId: String,

    @Schema(hidden = true)
    override val type: RequestEnum= RequestEnum.REQUEST_1
) : Request(type)

data class Request2(

    @Schema(description = "UUID of project", example = "00000000-0000-0000-0000-000000000000")
    val objectId: String,

    @Schema(description = "List labels from rekognition")
    val moderationLabels: List<RequestLabel>,

    @Schema(hidden = true)
    override val type: RequestEnum= RequestEnum.REQUEST_2
) : Request(type)

@Schema(description = "Class for label description from rekognition")
data class RequestLabel(

    @JsonProperty("Name")
    @Schema(description = "Label name", example = "Human")
    val name: String?,

    @JsonProperty("Confidence")
    @Schema(description = "Percentage of the chance that the label is in the project", example = "99.99")
    val confidence: Float?
)

When i send request GET /springwolf/docs i get response -

"com.example.Request": {
        "discriminator": "type",
        "title": "Request",
        "type": "object",
        "properties": {
          "type": {
            "type": "string",
            "description": "some description",
            "enum": [
              "REQUEST_1",
              "REQUEST_2"
            ],
            "examples": [
              "REQUEST_2"
            ]
          }
        },
        "description": "Base class for request",
        "examples": [
          {
            "jobId": "00000000-0000-0000-0000-000000000000",
            "objectId": "00000000-0000-0000-0000-000000000000",
            "type": "REQUEST_1"
          }
        ],
        "required": [
          "type"
        ],
        "oneOf": [
          {
            "$ref": "#/components/schemas/com.example.request.LabelDetectVideoRequest"
          },
          {
            "$ref": "#/components/schemas/com.example.request.LabelDetectImageRequest"
          }
        ]
      }

When i use springwolf-ui i see this exception

I debugging js code your springwolf-ui and found this code

springwolf-core/springwolf-ui/src/app/service/asyncapi/asyncapi-mapper.service.ts

Lines 290 to 306 in 123fe16

	private mapPayload(
	payloadName: string,
	schema: { $ref: string } | ServerAsyncApiSchema
	): Message["payload"] {
	if ("$ref" in schema) {
	const payloadName = this.resolveRefId(schema.$ref);
	return {
	ts_type: "ref",
	name: payloadName,
	title: this.resolveTitleFromName(payloadName),
	anchorUrl: AsyncApiMapperService.BASE_URL + payloadName,
	};
	}
	return this.mapSchemaObj(payloadName, schema, {});
	}

In this code method mapSchemaObj use parameter schemas how {} and in this method has this code

springwolf-core/springwolf-ui/src/app/service/asyncapi/asyncapi-mapper.service.ts

Lines 443 to 445 in 123fe16

	if (schema.oneOf !== undefined && schema.oneOf.length > 0) {
	this.addPropertiesToSchema(schema.oneOf[0], properties, schemas);
	}

In method addPropertiesToSchema this property use for get schemas for payload message

springwolf-core/springwolf-ui/src/app/service/asyncapi/asyncapi-mapper.service.ts

Lines 497 to 509 in 123fe16

	private addPropertiesToSchema(
	schema: ServerAsyncApiSchemaOrRef,
	properties: { [key: string]: any },
	schemas: ServerComponents["schemas"]
	) {
	let actualSchema = this.resolveSchema(schema, schemas);
	if ("properties" in actualSchema && actualSchema.properties !== undefined) {
	Object.entries(actualSchema.properties).forEach(([key, value]) => {
	properties[key] = this.mapSchema(key, value, schemas);
	});
	}
	}

This method throw exception.

springwolf-core/springwolf-ui/src/app/service/asyncapi/asyncapi-mapper.service.ts

Lines 511 to 527 in 123fe16

	private resolveSchema(
	schema: ServerAsyncApiSchemaOrRef,
	schemas: ServerComponents["schemas"]
	): ServerAsyncApiSchema {
	let actualSchema = schema;
	while ("$ref" in actualSchema) {
	const refId = this.resolveRefId(actualSchema.$ref);
	const refSchema = schemas[refId];
	if (refSchema !== undefined) {
	actualSchema = refSchema;
	} else {
	throw new Error("Schema " + refId + " not found");
	}
	}
	return actualSchema;
	}

Сode try get schema from {} object which was delivered

springwolf-core/springwolf-ui/src/app/service/asyncapi/asyncapi-mapper.service.ts

Line 305 in 123fe16

return this.mapSchemaObj(payloadName, schema, {});

Maybe I'm doing something wrong, but it looks like a bug.

[github-actions]

Welcome to Springwolf. Thanks a lot for reporting your first issue. Please check out our contributors guide and feel free to join us on discord.

[sam0r040]

Hi @FanatTokyoGhoul, thanks a lot for the detailed report. Any chance that you could provide the full specification so that we can reproduce the error with the specification only? You can also provide a MR that reproduces the error if thats easier for you.