1. /**
  2. * Validates a JSON payload against a schema with retry logic.
  3. * @param {object} payload The JSON payload to validate.
  4. * @param {object} schema The JSON schema to validate against.
  5. * @param {number} maxRetries The maximum number of retry attempts.
  6. * @returns {Promise<boolean>} A promise that resolves to true if the payload is valid,
  7. * or false if validation fails after all retries.
  8. * @throws {Error} If payload or schema is not an object or maxRetries is not a number.
  9. */
  10. async function validateJsonPayload(payload, schema, maxRetries = 3) {
  12. if (typeof payload !== 'object' || payload === null) {
  13. throw new Error("Payload must be an object.");
  14. }
  16. if (typeof schema !== 'object' || schema === null) {
  17. throw new Error("Schema must be an object.");
  18. }
  20. if (typeof maxRetries !== 'number' || maxRetries <= 0 || !Number.isInteger(maxRetries)) {
  21. throw new Error("maxRetries must be a positive integer.");
  22. }
  24. let retryCount = 0;
  26. while (retryCount < maxRetries) {
  27. try {
  28. // Validate the payload against the schema
  29. if (!isJsonValid(payload, schema)) {
  30. retryCount++;
  31. console.warn(`Validation failed (attempt ${retryCount}/${maxRetries}).`);
  32. continue; // Retry
  33. }
  34. return true; // Validation successful
  35. } catch (error) {
  36. retryCount++;
  37. console.warn(`Validation failed (attempt ${retryCount}/${maxRetries}): ${error.message}`);
  38. }
  39. }
  41. console.error("Validation failed after multiple retries.");
  42. return false; // Validation failed after all retries
  43. }
  45. /**
  46. * Checks if a JSON payload is valid against a given schema.
  47. * @param {object} payload The JSON payload.
  48. * @param {object} schema The JSON schema.
  49. * @returns {boolean} True if the payload is valid, false otherwise.
  50. */
  51. function isJsonValid(payload, schema) {
  52. try {
  53. const Ajv = require('ajv'); // Import Ajv (install: npm install ajv)
  54. const ajv = new Ajv();
  56. const validate = ajv.compile(schema);
  57. const valid = validate(payload);
  59. if (!valid) {
  60. throw new Error(`JSON validation failed: ${validate.errors.map(e => e.message).join(', ')}`);
  61. }
  63. return true;
  64. } catch (error) {
  65. throw new Error(`Error during JSON validation: ${error.message}`);
  66. }
  67. }
  70. module.exports = validateJsonPayload;

Add your comment