| 505 | } |
| 506 | |
| 507 | normalizeRequestResponse(response) { |
| 508 | if (!response || typeof response !== "object") { |
| 509 | return { correlationId: null, results: [] }; |
| 510 | } |
| 511 | const correlationId = |
| 512 | typeof response.correlationId === "string" && response.correlationId.trim().length > 0 |
| 513 | ? response.correlationId.trim() |
| 514 | : null; |
| 515 | const results = Array.isArray(response.results) ? response.results : []; |
| 516 | return { correlationId, results }; |
| 517 | } |
| 518 | |
| 519 | async on(eventType, callback) { |
| 520 | if (typeof callback !== "function") { |